| Package | Description |
|---|---|
| com.orientechnologies.orient.server.distributed | |
| com.orientechnologies.orient.server.distributed.impl |
| Modifier and Type | Class and Description |
|---|---|
class |
ODistributedResponseManagerImpl
Asynchronous response manager.
|
| Modifier and Type | Method and Description |
|---|---|
ODistributedResponseManager |
ODistributedResponse.getDistributedResponseManager() |
ODistributedResponseManager |
ODistributedMessageService.getResponseManager(ODistributedRequestId reqId) |
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedMessageService.registerRequest(long id,
ODistributedResponseManager currentResponseMgr) |
void |
ODistributedResponse.setDistributedResponseManager(ODistributedResponseManager distributedResponseManager) |
| Constructor and Description |
|---|
ODistributedResponse(ODistributedResponseManager msg,
ODistributedRequestId iRequestId,
String executorNodeName,
String senderNodeName,
Object payload) |
| Modifier and Type | Class and Description |
|---|---|
class |
ONewDistributedResponseManager |
| Modifier and Type | Method and Description |
|---|---|
ODistributedResponseManager |
ODistributedMessageServiceImpl.getResponseManager(ODistributedRequestId reqId) |
ODistributedResponseManager |
ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest,
Collection<String> iNodes,
ORemoteTask task,
Set<String> nodesConcurToTheQuorum,
int availableNodes,
int expectedResponses,
int quorum,
boolean groupByResponse,
boolean waitLocalNode) |
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedMessageServiceImpl.registerRequest(long id,
ODistributedResponseManager currentResponseMgr) |
protected ODistributedResponse |
ODistributedDatabaseImpl.waitForResponse(ODistributedRequest iRequest,
ODistributedResponseManager currentResponseMgr) |
Copyright © 2009–2025 OrientDB. All rights reserved.