Modifier and Type | Method and Description |
---|---|
byte[][] |
BFTMapBatchServer.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[] |
BFTMapServer.appExecuteOrdered(byte[] command,
MessageContext msgCtx) |
byte[] |
BFTMapBatchServer.executeUnordered(byte[] command,
MessageContext msgCtx) |
byte[] |
BFTMapServer.executeUnordered(byte[] command,
MessageContext msgCtx) |
Modifier and Type | Method and Description |
---|---|
byte[][] |
CounterServer.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[] |
CounterServer.executeUnordered(byte[] command,
MessageContext msgCtx) |
Modifier and Type | Method and Description |
---|---|
byte[][] |
BFTListImpl.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[] |
BFTListImpl.executeUnordered(byte[] command,
MessageContext msgCtx) |
Modifier and Type | Method and Description |
---|---|
byte[][] |
LatencyServer.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[][] |
ThroughputLatencyServer.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[] |
LatencyServer.execute(byte[] command,
MessageContext msgCtx) |
byte[] |
ThroughputLatencyServer.execute(byte[] command,
MessageContext msgCtx) |
byte[] |
LatencyServer.executeUnordered(byte[] command,
MessageContext msgCtx) |
byte[] |
ThroughputLatencyServer.executeUnordered(byte[] command,
MessageContext msgCtx) |
Modifier and Type | Method and Description |
---|---|
byte[][] |
RandomServer.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[] |
RandomServer.executeOrdered(byte[] command,
MessageContext msgCtx) |
byte[] |
RandomServer.executeUnordered(byte[] command,
MessageContext msgCtx)
Just return the current value of the counter.
|
Modifier and Type | Method and Description |
---|---|
byte[][] |
YCSBServer.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtx) |
byte[] |
YCSBServer.executeUnordered(byte[] theCommand,
MessageContext theContext) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceReplica.receiveReadonlyMessage(TOMMessage message,
MessageContext msgCtx)
This message delivers a readonly message, i.e., a message that was not
ordered to the replica and gather the reply to forward to the client
|
Modifier and Type | Method and Description |
---|---|
byte[][] |
BatchExecutable.executeBatch(byte[][] command,
MessageContext[] msgCtx)
Execute a batch of requests.
|
byte[] |
SingleExecutable.executeOrdered(byte[] command,
MessageContext msgCtx)
Method called to execute a request totally ordered.
|
byte[] |
FIFOExecutable.executeOrderedFIFO(byte[] command,
MessageContext msgCtx,
int clientId,
int operationId) |
byte[] |
Executable.executeUnordered(byte[] command,
MessageContext msgCtx)
Method called to execute a request totally ordered.
|
byte[] |
FIFOExecutable.executeUnorderedFIFO(byte[] command,
MessageContext msgCtx,
int clientId,
int operationId) |
void |
Replier.manageReply(TOMMessage request,
MessageContext msgCtx) |
Modifier and Type | Field and Description |
---|---|
MessageContext[] |
CommandsInfo.msgCtx |
Modifier and Type | Method and Description |
---|---|
abstract byte[][] |
DefaultRecoverable.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
abstract byte[] |
DefaultSingleRecoverable.appExecuteOrdered(byte[] command,
MessageContext msgCtx) |
byte[][] |
DefaultRecoverable.executeBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[] |
DefaultSingleRecoverable.executeOrdered(byte[] command,
MessageContext msgCtx) |
void |
DefaultReplier.manageReply(TOMMessage request,
MessageContext msgCtx) |
Constructor and Description |
---|
CommandsInfo(byte[][] commands,
MessageContext[] msgCtx,
int round,
int leader) |
Modifier and Type | Method and Description |
---|---|
void |
DurableStateLog.addMessageBatch(byte[][] commands,
MessageContext[] msgCtx,
int round,
int leader,
int consensusId)
Adds a message batch to the log.
|
abstract byte[][] |
DurabilityCoordinator.appExecuteBatch(byte[][] commands,
MessageContext[] msgCtxs) |
byte[][] |
DurabilityCoordinator.executeBatch(byte[][] commands,
MessageContext[] msgCtx) |