Uses of Class
com.orientechnologies.orient.server.distributed.ODistributedRequest

Packages that use ODistributedRequest

Package	Description
com.orientechnologies.orient.server.distributed
com.orientechnologies.orient.server.distributed.impl
com.orientechnologies.orient.server.distributed.impl.task
com.orientechnologies.orient.server.distributed.task

Uses of ODistributedRequest in com.orientechnologies.orient.server.distributed

Methods in com.orientechnologies.orient.server.distributed that return ODistributedRequest

Modifier and Type	Method and Description
ODistributedRequest	ODistributedResponseManager.getRequest()
ODistributedRequest	ODistributedRequest.setDatabaseName(String databaseName)
ODistributedRequest	ODistributedRequest.setTask(ORemoteTask payload)

Methods in com.orientechnologies.orient.server.distributed with parameters of type ODistributedRequest

Modifier and Type	Method and Description
Set<String>	ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes, String databaseName, Object localResult)
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, OCallable<Void,ODistributedResponseManager> endCallback)
void	ORemoteServerController.sendRequest(ODistributedRequest req)
void	ORemoteServerChannel.sendRequest(ODistributedRequest request)

Constructors in com.orientechnologies.orient.server.distributed with parameters of type ODistributedRequest

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, OCallable<Void,ODistributedResponseManager> endCallback)

Uses of ODistributedRequest in com.orientechnologies.orient.server.distributed.impl

Fields in com.orientechnologies.orient.server.distributed.impl with type parameters of type ODistributedRequest

Modifier and Type	Field and Description
protected ArrayBlockingQueue<ODistributedRequest>	ODistributedWorker.localQueue

Methods in com.orientechnologies.orient.server.distributed.impl that return ODistributedRequest

Modifier and Type	Method and Description
ODistributedRequest	ODistributedWorker.getProcessing()
protected ODistributedRequest	ODistributedWorker.nextMessage()
protected ODistributedRequest	ODistributedWorker.readRequest()

Methods in com.orientechnologies.orient.server.distributed.impl with parameters of type ODistributedRequest

Modifier and Type	Method and Description
protected void	ODistributedDatabaseImpl.checkForServerOnline(ODistributedRequest iRequest)
Set<String>	ODefaultDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes, String databaseName, Object localResult)
protected void	ODistributedWorker.handleError(ODistributedRequest iRequest, Object responsePayload)
protected void	ODistributedWorker.onMessage(ODistributedRequest iRequest) Executes the remote call on the local node and send back the result
protected void	ODistributedDatabaseImpl.processRequest(int partitionKey, ODistributedRequest request)
void	ODistributedWorker.processRequest(ODistributedRequest request)
void	ODistributedDatabaseImpl.processRequest(ODistributedRequest request) Distributed requests against the available workers by using one queue per worker.
ODistributedResponse	ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
protected ODistributedResponse	ODistributedDatabaseImpl.waitForResponse(ODistributedRequest iRequest, ODistributedResponseManager currentResponseMgr)

Uses of ODistributedRequest in com.orientechnologies.orient.server.distributed.impl.task

Methods in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ODistributedRequest

Modifier and Type	Method and Description
ORemoteTask	OResurrectRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OUpdateRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OAbstract2pcTask.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	OCreateRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNode, ODistributedServerManager dManager)
ORemoteTask	ORepairClusterTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	ORepairRecordsTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)

Uses of ODistributedRequest in com.orientechnologies.orient.server.distributed.task

Methods in com.orientechnologies.orient.server.distributed.task with parameters of type ODistributedRequest

Modifier and Type	Method and Description
ORemoteTask	OAbstractReplicatedTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)