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
com.orientechnologies.orient.server.hazelcast

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	ODistributedResponseManagerImpl.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
void	ODistributedServerManager.executeOnLocalNodeFromRemote(ODistributedRequest request)
Set<String>	ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes, String databaseName, Object localResult)
default void	ODistributedServerManager.messagePartitionCalculate(ODistributedRequest request, Set<Integer> involvedWorkerQueues)
default void	ODistributedServerManager.messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
default void	ODistributedServerManager.messageProcessStart(ODistributedRequest message)
default void	ODistributedServerManager.messageReceived(ODistributedRequest request)
default void	ODistributedLifecycleListener.onMessagePartitionCalculated(ODistributedRequest request, Set<Integer> involvedWorkerQueues)
default void	ODistributedLifecycleListener.onMessageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
default void	ODistributedLifecycleListener.onMessageProcessStart(ODistributedRequest message)
default void	ODistributedLifecycleListener.onMessageReceived(ODistributedRequest request)
void	ODistributedDatabase.processRequest(ODistributedRequest request, boolean waitForAcceptingRequests)
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
ODistributedResponseManagerImpl(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()
ODistributedRequest	ONewDistributedResponseManager.getRequest()
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)
void	ODistributedAbstractPlugin.executeOnLocalNodeFromRemote(ODistributedRequest request)
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)
ODistributedResponseManager	ODistributedDatabaseImpl.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
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)
boolean	ODistributedWorker.processRequest(ODistributedRequest request)
void	ODistributedDatabaseImpl.processRequest(ODistributedRequest request, boolean waitForAcceptingRequests) 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)
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, ODistributedResponseManagerFactory responseManagerFactory)
static boolean	ODistributedWorker.sendResponseBack(Object current, ODistributedServerManager manager, ODistributedRequest iRequest, Object responsePayload)
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
void	OTransactionPhase1Task.received(ODistributedRequest request, ODistributedDatabase distributedDatabase)

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)
default void	ORemoteTask.received(ODistributedRequest request, ODistributedDatabase distributedDatabase)

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

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

Modifier and Type	Method and Description
void	OHazelcastPlugin.messagePartitionCalculate(ODistributedRequest request, Set<Integer> involvedWorkerQueues)
void	OHazelcastPlugin.messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
void	OHazelcastPlugin.messageProcessStart(ODistributedRequest message)
void	OHazelcastPlugin.messageReceived(ODistributedRequest request)