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

Packages that use ODistributedRequest

Package	Description
com.orientechnologies.agent.ha
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.agent.ha

Methods in com.orientechnologies.agent.ha with parameters of type ODistributedRequest

Modifier and Type	Method	Description
Set<String>	OEnterpriseDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes)	Returns only the subset of servers that are part of the local dc.

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

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

Modifier and Type	Method	Description
void	ODistributedServerManager.executeOnLocalNodeFromRemote(ODistributedRequest request)
Set<String>	ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes)
default void	ODistributedServerManager.messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
default void	ODistributedServerManager.messageProcessStart(ODistributedRequest message)
default void	ODistributedServerManager.messageReceived(ODistributedRequest request)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
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)
void	ORemoteServerChannel.sendRequest(ODistributedRequest request)
void	ORemoteServerController.sendRequest(ODistributedRequest req)

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

Modifier	Constructor	Description
	ODistributedResponseManagerImpl(ODistributedServerManager iManager, ODistributedRequest iRequest, Collection<String> expectedResponses, Set<String> iNodesConcurInQuorum, int iQuorum, boolean iWaitForLocalNode, long iSynchTimeout, boolean iGroupResponsesByResult)

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

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

Modifier and Type	Method	Description
protected void	ODistributedPlugin.checkForServerOnline(ODistributedRequest iRequest)
void	ODistributedPlugin.executeOnLocalNodeFromRemote(ODistributedRequest request)
Set<String>	ODefaultDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes)
void	ODistributedPlugin.messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
void	ODistributedPlugin.messageProcessStart(ODistributedRequest message)
void	ODistributedPlugin.messageReceived(ODistributedRequest request)
void	ODistributedDatabaseImpl.processRequest(ODistributedRequest request, boolean waitForAcceptingRequests)	Distributed requests against the available workers by using one queue per worker.
ODistributedResponse	ODistributedPlugin.send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult)
ODistributedResponse	ODistributedPlugin.send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
protected ODistributedResponse	ODistributedPlugin.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	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	Description
default void	ORemoteTask.received(ODistributedRequest request, ODistributedDatabase distributedDatabase)