Modifier and Type | Method and Description |
---|---|
TOMMessage |
RequestList.get(byte[] serializedMessage) |
TOMMessage |
RequestList.getById(int id) |
TOMMessage |
RequestList.getBySequence(int sequence) |
TOMMessage |
ClientsManager.getPending(int reqId)
Get some reqId that is pending.
|
TOMMessage |
ClientData.getReply(int reqSequence) |
TOMMessage |
RequestList.remove(byte[] serializedMessage) |
TOMMessage |
RequestList.removeById(int id) |
Modifier and Type | Method and Description |
---|---|
void |
RequestList.addLast(TOMMessage msg) |
boolean |
ClientData.removeOrderedRequest(TOMMessage request) |
boolean |
ClientData.removeRequest(TOMMessage request) |
boolean |
ClientsManager.requestReceived(TOMMessage request,
boolean fromClient) |
boolean |
ClientsManager.requestReceived(TOMMessage request,
boolean fromClient,
ServerCommunicationSystem cs)
Notifies the ClientsManager that a new request from a client arrived.
|
void |
ClientsManager.requestsOrdered(TOMMessage[] requests)
Notifies the ClientsManager that these requests were already executed.
|
Modifier and Type | Method and Description |
---|---|
void |
ReplyListener.replyReceived(RequestContext context,
TOMMessage reply) |
void |
ReplyReceiver.replyReceived(TOMMessage reply)
This is the method invoked by the client side comunication system, and where the
code to handle the reply is to be written
|
void |
RequestReceiver.requestReceived(TOMMessage msg)
This is the method invoked by the CommunicationSystemServerSide, to
deliver a client request.
|
void |
CommunicationSystemClientSide.send(boolean sign,
int[] targets,
TOMMessage sm) |
void |
CommunicationSystemServerSide.send(int[] targets,
TOMMessage sm,
boolean serializeClassHeaders) |
void |
CommunicationSystemClientSide.sign(TOMMessage sm) |
Modifier and Type | Method and Description |
---|---|
void |
NettyClientServerCommunicationSystemClientSide.channelRead0(io.netty.channel.ChannelHandlerContext context,
TOMMessage sm) |
protected void |
NettyClientServerCommunicationSystemServerSide.channelRead0(io.netty.channel.ChannelHandlerContext arg0,
TOMMessage sm) |
protected void |
NettyTOMMessageEncoder.encode(io.netty.channel.ChannelHandlerContext context,
TOMMessage sm,
io.netty.buffer.ByteBuf buffer) |
void |
NettyClientServerCommunicationSystemClientSide.send(boolean sign,
int[] targets,
TOMMessage sm) |
void |
NettyClientServerCommunicationSystemServerSide.send(int[] targets,
TOMMessage sm,
boolean serializeClassHeaders) |
void |
NettyClientServerCommunicationSystemClientSide.sign(TOMMessage sm) |
Modifier and Type | Field and Description |
---|---|
TOMMessage[] |
Round.deserializedPropValue |
TOMMessage |
Consensus.firstMessageProposed |
Modifier and Type | Method and Description |
---|---|
TOMMessage[] |
Consensus.getDeserializedDecision() |
Modifier and Type | Method and Description |
---|---|
TOMMessage[] |
ServerViewController.clearUpdates() |
Modifier and Type | Method and Description |
---|---|
void |
ServerViewController.enqueueUpdate(TOMMessage up) |
Modifier and Type | Method and Description |
---|---|
TOMMessage |
MessageContext.getFirstInBatch() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceReplica.receiveMessages(int[] consId,
int regency,
TOMMessage[][] requests) |
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
|
void |
AsynchServiceProxy.replyReceived(TOMMessage reply) |
void |
ServiceProxy.replyReceived(TOMMessage reply)
This is the method invoked by the client side communication system.
|
void |
TOMSender.TOMulticast(TOMMessage sm)
Multicast a TOMMessage to the group of replicas
|
Constructor and Description |
---|
MessageContext(long timestamp,
byte[] nonces,
int regency,
int consensusId,
int sender,
TOMMessage firstInBatch) |
Modifier and Type | Method and Description |
---|---|
TOMMessage[] |
TOMLayer.checkProposedValue(byte[] proposedValue,
boolean addToClientManager)
Verify if the value being proposed for a round is valid.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DeliveryThread.deliverUnordered(TOMMessage request,
int regency) |
void |
TOMLayer.forwardRequestToLeader(TOMMessage request) |
void |
TOMLayer.requestReceived(TOMMessage msg)
This method is invoked by the communication system to deliver a request.
|
void |
ReplyManager.send(TOMMessage msg) |
Modifier and Type | Method and Description |
---|---|
void |
TOMLayer.triggerTimeout(java.util.List<TOMMessage> requestList)
This method is called when there is a timeout and the request has already been forwarded to the leader
|
Modifier and Type | Field and Description |
---|---|
TOMMessage |
TOMMessage.reply |
Modifier and Type | Method and Description |
---|---|
static TOMMessage |
TOMMessage.bytesToMessage(byte[] b) |
Modifier and Type | Method and Description |
---|---|
static byte[] |
TOMMessage.messageToBytes(TOMMessage m) |
Modifier and Type | Method and Description |
---|---|
TOMMessage |
ForwardedMessage.getRequest() |
Modifier and Type | Method and Description |
---|---|
void |
RequestsTimer.unwatch(TOMMessage request)
Cancels a timer for a given request
|
void |
RequestsTimer.watch(TOMMessage request)
Creates a timer for the given request
|
Constructor and Description |
---|
ForwardedMessage(int senderId,
TOMMessage request) |
Modifier and Type | Method and Description |
---|---|
java.util.List<TOMMessage> |
LCManager.getCurrentRequestTimedOut()
Get the timed out messages in this replica
|
Modifier and Type | Method and Description |
---|---|
void |
LCManager.setCurrentRequestTimedOut(java.util.List<TOMMessage> currentRequestTimedOut)
This is meant to keep track of timed out messages in this replica
|
Modifier and Type | Method and Description |
---|---|
void |
Replier.manageReply(TOMMessage request,
MessageContext msgCtx) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultReplier.manageReply(TOMMessage request,
MessageContext msgCtx) |
Modifier and Type | Field and Description |
---|---|
TOMMessage |
DebugInfo.msg |
Modifier and Type | Method and Description |
---|---|
TOMMessage[] |
BatchReader.deserialiseRequests(ServerViewController controller) |
TOMMessage |
Extractor.extractResponse(TOMMessage[] replies,
int sameContent,
int lastReceived) |
Modifier and Type | Method and Description |
---|---|
TOMMessage |
Extractor.extractResponse(TOMMessage[] replies,
int sameContent,
int lastReceived) |
Modifier and Type | Method and Description |
---|---|
byte[] |
BatchBuilder.makeBatch(java.util.Collection<TOMMessage> msgs,
int numNounces,
long timestamp,
ServerViewController controller) |
Constructor and Description |
---|
DebugInfo(int eid,
int round,
int leader,
TOMMessage msg) |