| Modifier and Type | Method and Description |
|---|---|
ODistributedRequest |
ODistributedRequest.setDatabaseName(String databaseName) |
ODistributedRequest |
ODistributedRequest.setExecutionMode(ODistributedRequest.EXECUTION_MODE executionMode) |
ODistributedRequest |
ODistributedRequest.setTask(ORemoteTask payload) |
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedDatabase.processRequest(ODistributedRequest request) |
ODistributedResponse |
ODistributedDatabase.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
void |
ORemoteServerController.sendRequest(ODistributedRequest req,
String node) |
void |
ORemoteServerChannel.sendRequest(ODistributedRequest req,
String node) |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayBlockingQueue<ODistributedRequest> |
ODistributedWorker.localQueue |
| Modifier and Type | Method and Description |
|---|---|
protected ODistributedRequest |
ODistributedWorker.nextMessage() |
protected ODistributedRequest |
ODistributedWorker.readRequest() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ODistributedDatabaseImpl.checkForServerOnline(ODistributedRequest iRequest) |
protected void |
ODistributedWorker.onMessage(ODistributedRequest iRequest)
Execute the remote call on the local node and send back the result
|
void |
ODistributedWorker.processRequest(ODistributedRequest request) |
void |
ODistributedDatabaseImpl.processRequest(ODistributedRequest request)
Distributed requests against the available workers.
|
ODistributedResponse |
ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
protected ODistributedResponse |
ODistributedDatabaseImpl.waitForResponse(ODistributedRequest iRequest,
ODistributedResponseManager currentResponseMgr) |
| Constructor and Description |
|---|
ODistributedResponseManager(ODistributedServerManager iManager,
ODistributedRequest iRequest,
Collection<String> expectedResponses,
Set<String> iNodesConcurInQuorum,
int iTotalExpectedResponses,
int iQuorum,
boolean iWaitForLocalNode,
long iSynchTimeout,
long iTotalTimeout,
boolean iGroupResponsesByResult) |
| Modifier and Type | Method and Description |
|---|---|
ORemoteTask |
OUpdateRecordTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
ORemoteTask |
OTxTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
ORemoteTask |
ODeleteRecordTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
ORemoteTask |
OResurrectRecordTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
ORemoteTask |
OCreateRecordTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNode,
ODistributedServerManager dManager) |
| Modifier and Type | Method and Description |
|---|---|
ORemoteTask |
OAbstractReplicatedTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
Copyright © 2009–2016 Orient Technologies. All rights reserved.