|
Rice Pastry API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mpisws.p2p.transport.peerreview.replay.VerifierImpl<Handle,Identifier>
public class VerifierImpl<Handle,Identifier>
Field Summary | |
---|---|
protected Serializer<Handle> |
handleSerializer
|
protected SecureHistory |
history
|
protected Serializer<Identifier> |
idSerializer
|
protected Handle |
localHandle
|
protected Logger |
logger
|
protected IdentityTransport<Handle,Identifier> |
transport
|
Constructor Summary | |
---|---|
VerifierImpl(RandomSource prng,
Serializer<Handle> handleSerializer,
Serializer<Identifier> idSerializer,
IdentityTransport<Handle,Identifier> transport,
SecureHistory history,
Handle localHandle,
int firstEntryToReplay,
java.lang.Object extInfo,
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)
|
java.lang.Object |
getExtInfo()
|
IndexEntry |
getNextEvent()
|
long |
getNextEventTime()
|
protected void |
incomingSocket(Handle from,
int socketId)
|
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(Handle target)
Return the new socketId |
SocketRequestHandle<Handle> |
openSocket(Handle i,
SocketCallback<Handle> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
int |
readSocket(int socketId,
java.nio.ByteBuffer dst)
Return the bytes read. |
void |
registerEvent(EventCallback callback,
short... eventType)
This binds specific event types to one of the handlers |
void |
registerEvent(EventCallback callback,
short eventType)
|
MessageRequestHandle<Handle,java.nio.ByteBuffer> |
sendMessage(Handle target,
java.nio.ByteBuffer message,
MessageCallback<Handle,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
Called by the state machine when it wants to send a message |
void |
setApplication(PeerReviewCallback<Handle,Identifier> app)
|
void |
shutdownOutput(int socketId)
|
protected void |
socketException(int socketId,
java.io.IOException ioe)
|
protected void |
socketIO(int socketId,
boolean canRead,
boolean canWrite)
|
protected 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 |
Field Detail |
---|
protected Handle localHandle
protected SecureHistory history
protected Logger logger
protected Serializer<Handle> handleSerializer
protected Serializer<Identifier> idSerializer
protected IdentityTransport<Handle,Identifier> transport
Constructor Detail |
---|
public VerifierImpl(RandomSource prng, Serializer<Handle> handleSerializer, Serializer<Identifier> idSerializer, IdentityTransport<Handle,Identifier> transport, SecureHistory history, Handle localHandle, int firstEntryToReplay, java.lang.Object extInfo, Logger logger) throws java.io.IOException
java.io.IOException
Method Detail |
---|
public java.lang.Object getExtInfo()
protected void fetchNextEvent()
public boolean verifiedOK()
verifiedOK
in interface Verifier<Handle,Identifier>
public IndexEntry getNextEvent()
public void setApplication(PeerReviewCallback<Handle,Identifier> app)
setApplication
in interface Verifier<Handle,Identifier>
public void registerEvent(EventCallback callback, short... eventType)
public void registerEvent(EventCallback callback, short eventType)
public boolean makeProgress()
makeProgress
in interface Verifier<Handle,Identifier>
public MessageRequestHandle<Handle,java.nio.ByteBuffer> sendMessage(Handle target, java.nio.ByteBuffer message, MessageCallback<Handle,java.nio.ByteBuffer> deliverAckToMe, java.util.Map<java.lang.String,java.lang.Object> options)
public long getNextEventTime()
public boolean isSuccess()
protected java.io.IOException deserializeException(InputBuffer nextEvent) throws java.io.IOException
java.io.IOException
public SocketRequestHandle<Handle> openSocket(Handle i, SocketCallback<Handle> deliverSocketToMe, java.util.Map<java.lang.String,java.lang.Object> options)
protected void socketIO(int socketId, boolean canRead, boolean canWrite) throws java.io.IOException
java.io.IOException
protected void incomingSocket(Handle from, int socketId) throws java.io.IOException
java.io.IOException
protected void socketOpened(int socketId) throws java.io.IOException
java.io.IOException
protected void socketException(int socketId, java.io.IOException ioe) throws java.io.IOException
java.io.IOException
public int openSocket(Handle target) throws java.io.IOException
i
-
java.io.IOException
public int readSocket(int socketId, java.nio.ByteBuffer dst) throws java.io.IOException
socketId
-
java.io.IOException
public void generatedSocketException(int socketId, java.io.IOException ioe)
public int writeSocket(int socketId, java.nio.ByteBuffer src) throws java.io.IOException
socketId
-
java.io.IOException
public void close(int socketId)
public void shutdownOutput(int socketId)
|
Rice Pastry API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |