| Package | Description |
|---|---|
| com.orientechnologies.orient.server.distributed | |
| com.orientechnologies.orient.server.distributed.impl |
| Modifier and Type | Method and Description |
|---|---|
ODistributedResponse |
ODistributedDatabase.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
ODistributedResponse |
ODistributedServerManager.sendRequest(String iDatabaseName,
Collection<String> iClusterNames,
Collection<String> iTargetNodeNames,
ORemoteTask iTask,
long messageId,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback)
Sends a distributed request against multiple servers.
|
ODistributedResponse |
ODistributedResponse.setExecutorNodeName(String executorNodeName) |
ODistributedResponse |
ODistributedResponse.setPayload(Object payload) |
| Modifier and Type | Method and Description |
|---|---|
long |
ODistributedMessageService.dispatchResponseToThread(ODistributedResponse response) |
void |
ORemoteServerController.sendResponse(ODistributedResponse response,
String node) |
void |
ORemoteServerChannel.sendResponse(ODistributedResponse response,
String node) |
| Modifier and Type | Method and Description |
|---|---|
protected List<ODistributedResponse> |
ODistributedResponseManager.getConflictResponses()
Returns all the responses in conflict.
|
protected List<ODistributedResponse> |
ODistributedResponseManager.getReceivedResponses()
Returns the received response objects.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ODistributedResponseManager.collectResponse(ODistributedResponse response)
Not synchronized, it's called when a message arrives
|
long |
ODistributedMessageServiceImpl.dispatchResponseToThread(ODistributedResponse response)
Not synchronized, it's called when a message arrives
|
ODistributedResponse |
ODistributedResponseManager.merge(ODistributedResponse merged) |
protected boolean |
ODistributedTransactionManager.processCommitResult(String localNodeName,
OTransaction iTx,
OTxTask txTask,
Set<String> involvedClusters,
Iterable<ORecordOperation> tmpEntries,
Collection<String> nodes,
int autoRetryDelay,
ODistributedRequestId reqId,
ODistributedResponse dResponse,
boolean isLastRetry) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
ODistributedResponseManager.checkNoWinnerCase(List<ODistributedResponse> bestResponsesGroup) |
protected boolean |
ODistributedResponseManager.fixNodesInConflict(List<ODistributedResponse> bestResponsesGroup,
int conflicts) |
Copyright © 2009–2016 Orient Technologies. All rights reserved.