Uses of Class
com.orientechnologies.orient.server.distributed.ODistributedRequest
Packages that use ODistributedRequest
Package
Description
-
Uses of ODistributedRequest in com.orientechnologies.orient.distributed.db
Methods in com.orientechnologies.orient.distributed.db with parameters of type ODistributedRequestModifier and TypeMethodDescriptionprotected voidOrientDBDistributed.checkForServerOnline(ODistributedRequest iRequest) voidOrientDBDistributed.executeDistributedRequest(ODistributedRequest req) OrientDBDistributed.send2Nodes(ODistributedRequest iRequest, Collection<ONodeId> iNodes, Object localResult) OrientDBDistributed.send2Nodes(ODistributedRequest request, Collection<ONodeId> nodes, Object localResult, ODistributedResponseManagerFactory responseManagerFactory) protected ODistributedResponseOrientDBDistributed.waitForResponse(ODistributedRequest iRequest, ODistributedResponseManager currentResponseMgr) -
Uses of ODistributedRequest in com.orientechnologies.orient.server.distributed
Methods in com.orientechnologies.orient.server.distributed with parameters of type ODistributedRequestModifier and TypeMethodDescriptionODistributedStrategy.getNodesConcurInQuorum(OrientDBInternal ctx, String databaseName, ODistributedRequest request, Collection<ONodeId> iNodes) ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<ONodeId> iNodes, ORemoteTask task, Set<ONodeId> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode) 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(OrientDBDistributed ctx, ODistributedRequest iRequest, Collection<ONodeId> expectedResponses, Set<ONodeId> 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 TypeMethodDescriptionstatic voidODistributedDatabaseImpl.executeNoDb(ODistributedRequest request, OrientDBDistributed ctx) ODefaultDistributedStrategy.getNodesConcurInQuorum(OrientDBInternal ctxi, String databaseName, ODistributedRequest request, Collection<ONodeId> iNodes) voidODistributedDatabaseImpl.processRequest(ODistributedRequest request, boolean waitForAcceptingRequests) Distributed requests against the available workers by using one queue per worker. -
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)