org.mpisws.p2p.transport.peerreview.replay.playback
Class ReplayVerifier<Identifier>

java.lang.Object
  org.mpisws.p2p.transport.peerreview.replay.playback.ReplayVerifier<Identifier>

All Implemented Interfaces:

PeerReviewConstants, Verifier<Identifier>, StatusConstants, TransportLayer<Identifier,java.nio.ByteBuffer>, Destructable

Direct Known Subclasses:

ReplayLayer

public abstract class ReplayVerifier<Identifier>
extends java.lang.Object
implements Verifier<Identifier>, PeerReviewConstants

Field Summary

protected HashProvider	hashProv
protected SecureHistory	history
protected Identifier	localHandle
protected Logger	logger
protected Serializer<Identifier>	serializer

Fields inherited from interface org.mpisws.p2p.transport.peerreview.PeerReviewConstants

AUTH_CACHE_INTERVAL, CERT_MISSING, CHAL_AUDIT, CHAL_SEND, DEFAULT_AUDIT_INTERVAL_MILLIS, DEFAULT_AUTH_PUSH_INTERVAL_MILLIS, DEFAULT_CHECKPOINT_INTERVAL_MILLIS, DEFAULT_LOG_DOWNLOAD_TIMEOUT, DEFAULT_TIME_TOLERANCE_MILLIS, EVT_ACK, EVT_CHECKPOINT, EVT_CHOOSE_Q, EVT_CHOOSE_RAND, EVT_INIT, EVT_MAX_RESERVED, EVT_MAX_SOCKET_EVT, EVT_MIN_SOCKET_EVT, EVT_RECV, EVT_SEND, EVT_SENDSIGN, EVT_SIGN, EVT_SOCKET_CAN_READ, EVT_SOCKET_CAN_RW, EVT_SOCKET_CAN_WRITE, EVT_SOCKET_CLOSE, EVT_SOCKET_CLOSED, EVT_SOCKET_EXCEPTION, EVT_SOCKET_OPEN_INCOMING, EVT_SOCKET_OPEN_OUTGOING, EVT_SOCKET_OPENED_OUTGOING, EVT_SOCKET_READ, EVT_SOCKET_SHUTDOWN_OUTPUT, EVT_SOCKET_WRITE, EVT_VRF, EX_TYPE_ClosedChannel, EX_TYPE_IO, EX_TYPE_Unknown, FLAG_FULL_MESSAGES_ALL, FLAG_FULL_MESSAGES_SENDER, FLAG_INCLUDE_CHECKPOINT, INVALID, INVESTIGATION_INTERVAL_MILLIS, MAINTENANCE_INTERVAL_MILLIS, MAX_ACTIVE_AUDITS, MAX_ACTIVE_INVESTIGATIONS, MAX_ENTRIES_BETWEEN_CHECKPOINTS, MAX_STATUS_INFO, MAX_WITNESSED_NODES, MSG_ACCUSATION, MSG_ACK, MSG_AUTHPUSH, MSG_AUTHREQ, MSG_AUTHRESP, MSG_CHALLENGE, MSG_RESPONSE, MSG_USERDATA, MSG_USERDGRAM, NO_CERTIFICATE, PROGRESS_INTERVAL_MILLIS, PROOF_INCONSISTENT, PROOF_NONCONFORMANT, RESP_AUDIT, RESP_SEND, SIGNATURE_BAD, SIGNATURE_OK, STATE_SEND_AUDIT, STATE_WAIT_FOR_LOG, TI_AUTH_PUSH, TI_CHECKPOINT, TI_MAINTENANCE, TI_MAKE_PROGRESS, TI_MAX_RESERVED, TI_START_AUDITS, TI_STATUS_INFO, VALID

Fields inherited from interface org.mpisws.p2p.transport.peerreview.StatusConstants

STATUS_EXPOSED, STATUS_SUSPECTED, STATUS_TRUSTED

Constructor Summary

ReplayVerifier(Serializer<Identifier> serializer, HashProvider hashProv, SecureHistory history, Identifier localHandle, short signatureSizeBytes, short hashSizeBytes, int firstEntryToReplay, Logger logger)

Method Summary

void	close(int socketId)
protected java.io.IOException	deserializeException(InputBuffer nextEvent)
protected void	fetchNextEvent() Fetch the next log entry, or set the EOF flag
void	generatedSocketException(int socketId, java.io.IOException ioe)
IndexEntry	getNextEvent()
long	getNextEventTime()
protected abstract void	incomingSocket(Identifier from, int socketId) Callback when a socket comes in from a remote node.
boolean	isSuccess()
boolean	makeProgress() This is called by the Audit protocol to make another replay step; it returns true if further calls are necessary, and false if the replay has finished.
int	openSocket(Identifier target) Return the new socketId
int	readSocket(int socketId, java.nio.ByteBuffer dst) Return the bytes read.
protected abstract void	receive(Identifier from, java.nio.ByteBuffer msg) Callback when a message has arrived.
void	registerEvent(EventCallback callback, short... eventType) This binds specific event types to one of the handlers
void	registerEvent(EventCallback callback, short eventType)
protected void	send(Identifier target, java.nio.ByteBuffer message, int relevantLen) Called by the state machine when it wants to send a message
void	setApplication(PeerReviewCallback app)
void	shutdownOutput(int socketId)
protected abstract void	socketException(int socketId, java.io.IOException ioe)
protected abstract void	socketIO(int socketId, boolean canRead, boolean canWrite) Callback when a socket is ready to read/write.
protected abstract void	socketOpened(int socketId)
boolean	verifiedOK()
int	writeSocket(int socketId, java.nio.ByteBuffer src) Return the bytes written.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mpisws.p2p.transport.peerreview.replay.Verifier

getEnvironment

Methods inherited from interface org.mpisws.p2p.transport.TransportLayer

acceptMessages, acceptSockets, getLocalIdentifier, openSocket, sendMessage, setCallback, setErrorHandler

Methods inherited from interface rice.Destructable

destroy

Field Detail

localHandle

protected Identifier localHandle

history

protected SecureHistory history

logger

protected Logger logger

serializer

protected Serializer<Identifier> serializer

hashProv

protected HashProvider hashProv

Constructor Detail

ReplayVerifier

public ReplayVerifier(Serializer<Identifier> serializer,
                      HashProvider hashProv,
                      SecureHistory history,
                      Identifier localHandle,
                      short signatureSizeBytes,
                      short hashSizeBytes,
                      int firstEntryToReplay,
                      Logger logger)
               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

verifiedOK

public boolean verifiedOK()

Specified by:

verifiedOK in interface Verifier<Identifier>

getNextEvent

public IndexEntry getNextEvent()

receive

protected abstract void receive(Identifier from,
                                java.nio.ByteBuffer msg)
                         throws java.io.IOException

Callback when a message has arrived.

Parameters:

from -

msg -

Throws:

java.io.IOException

incomingSocket

protected abstract void incomingSocket(Identifier from,
                                       int socketId)
                                throws java.io.IOException

Callback when a socket comes in from a remote node.

Parameters:

from -

socketId -

Throws:

java.io.IOException

socketIO

protected abstract void socketIO(int socketId,
                                 boolean canRead,
                                 boolean canWrite)
                          throws java.io.IOException

Callback when a socket is ready to read/write. Note that the simulated node should have already registered for this event, even though it is not logged. If the node is not registred for the event, it is an error.

Parameters:

socketId -

canRead -

canWrite -

Throws:

java.io.IOException

socketOpened

protected abstract void socketOpened(int socketId)
                              throws java.io.IOException

Throws:

java.io.IOException

socketException

protected abstract void socketException(int socketId,
                                        java.io.IOException ioe)
                                 throws java.io.IOException

Throws:

java.io.IOException

setApplication

public void setApplication(PeerReviewCallback app)

Specified by:

setApplication in interface Verifier<Identifier>

fetchNextEvent

protected void fetchNextEvent()

Fetch the next log entry, or set the EOF flag

send

protected void send(Identifier target,
                    java.nio.ByteBuffer message,
                    int relevantLen)
             throws java.io.IOException

Called by the state machine when it wants to send a message

Throws:

java.io.IOException

openSocket

public int openSocket(Identifier target)
               throws java.io.IOException

Return the new socketId

Parameters:

i -

Returns:

the new socketId, Integer.MIN_VALUE for an error

Throws:

java.io.IOException

readSocket

public int readSocket(int socketId,
                      java.nio.ByteBuffer dst)
               throws java.io.IOException

Return the bytes read.

Parameters:

socketId -

Returns:

number of bytes read

Throws:

java.io.IOException

generatedSocketException

public void generatedSocketException(int socketId,
                                     java.io.IOException ioe)

writeSocket

public int writeSocket(int socketId,
                       java.nio.ByteBuffer src)
                throws java.io.IOException

Return the bytes written.

Parameters:

socketId -

Returns:

number of bytes written

Throws:

java.io.IOException

close

public void close(int socketId)

shutdownOutput

public void shutdownOutput(int socketId)

registerEvent

public void registerEvent(EventCallback callback,
                          short... eventType)

This binds specific event types to one of the handlers

registerEvent

public void registerEvent(EventCallback callback,
                          short eventType)

makeProgress

public boolean makeProgress()

This is called by the Audit protocol to make another replay step; it returns true if further calls are necessary, and false if the replay has finished. The idea is that we can stop calling this if there is more important work to do, e.g. handle foreground requests

Specified by:

makeProgress in interface Verifier<Identifier>

getNextEventTime

public long getNextEventTime()

Specified by:

getNextEventTime in interface Verifier<Identifier>

isSuccess

public boolean isSuccess()

Specified by:

isSuccess in interface Verifier<Identifier>

deserializeException

protected java.io.IOException deserializeException(InputBuffer nextEvent)
                                            throws java.io.IOException

Throws:

java.io.IOException