Uses of Class
com.orientechnologies.orient.server.distributed.ODistributedRequest
Packages that use ODistributedRequest
Package
Description
-
Uses of ODistributedRequest in com.orientechnologies.agent.ha
Methods in com.orientechnologies.agent.ha with parameters of type ODistributedRequestModifier and TypeMethodDescriptionOEnterpriseDistributedStrategy.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 ODistributedRequestModifier and TypeMethodDescriptionvoidODistributedServerManager.executeOnLocalNodeFromRemote(ODistributedRequest request) ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes) default voidODistributedServerManager.messageProcessEnd(ODistributedRequest iRequest, Object responsePayload) default voidODistributedServerManager.messageProcessStart(ODistributedRequest message) default voidODistributedServerManager.messageReceived(ODistributedRequest request) ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode) default voidODistributedLifecycleListener.onMessageProcessEnd(ODistributedRequest iRequest, Object responsePayload) default voidODistributedLifecycleListener.onMessageProcessStart(ODistributedRequest message) default voidODistributedLifecycleListener.onMessageReceived(ODistributedRequest request) voidODistributedDatabase.processRequest(ODistributedRequest request, boolean waitForAcceptingRequests) voidORemoteServerChannel.sendRequest(ODistributedRequest request) voidORemoteServerController.sendRequest(ODistributedRequest req) Constructors in com.orientechnologies.orient.server.distributed with parameters of type ODistributedRequestModifierConstructorDescriptionODistributedResponseManagerImpl(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 ODistributedRequestModifier and TypeMethodDescriptionprotected voidODistributedPlugin.checkForServerOnline(ODistributedRequest iRequest) voidODistributedPlugin.executeOnLocalNodeFromRemote(ODistributedRequest request) ODefaultDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes) voidODistributedPlugin.messageProcessEnd(ODistributedRequest iRequest, Object responsePayload) voidODistributedPlugin.messageProcessStart(ODistributedRequest message) voidODistributedPlugin.messageReceived(ODistributedRequest request) voidODistributedDatabaseImpl.processRequest(ODistributedRequest request, boolean waitForAcceptingRequests) Distributed requests against the available workers by using one queue per worker.ODistributedPlugin.send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult) ODistributedPlugin.send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, ODistributedResponseManagerFactory responseManagerFactory) protected ODistributedResponseODistributedPlugin.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 ODistributedRequestModifier and TypeMethodDescriptionvoidOTransactionPhase1Task.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 ODistributedRequestModifier and TypeMethodDescriptiondefault voidORemoteTask.received(ODistributedRequest request, ODistributedDatabase distributedDatabase)