org.mpisws.p2p.transport.peerreview.challenge
Class ChallengeResponseProtocolImpl<Handle extends RawSerializable,Identifier extends RawSerializable>
java.lang.Object
org.mpisws.p2p.transport.peerreview.challenge.ChallengeResponseProtocolImpl<Handle,Identifier>
- All Implemented Interfaces:
- ChallengeResponseProtocol<Handle,Identifier>, PeerReviewConstants
public class ChallengeResponseProtocolImpl<Handle extends RawSerializable,Identifier extends RawSerializable>
- extends java.lang.Object
- implements PeerReviewConstants, ChallengeResponseProtocol<Handle,Identifier>
Fields inherited from interface org.mpisws.p2p.transport.peerreview.PeerReviewConstants |
CHAL_AUDIT, CHAL_SEND, DEFAULT_AUTH_PUSH_INTERVAL_MICROS, DEFAULT_CHECKPOINT_INTERVAL_MICROS, DEFAULT_TIME_TOLERANCE_MICROS, EVT_ACK, EVT_CHECKPOINT, EVT_INIT, 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, EX_TYPE_ClosedChannel, EX_TYPE_IO, EX_TYPE_Unknown, FLAG_FULL_MESSAGES_ALL, FLAG_FULL_MESSAGES_SENDER, FLAG_INCLUDE_CHECKPOINT, MAINTENANCE_INTERVAL_MICROS, MAX_STATUS_INFO, MSG_ACCUSATION, MSG_ACK, MSG_AUTHPUSH, MSG_AUTHREQ, MSG_AUTHRESP, MSG_CHALLENGE, MSG_RESPONSE, MSG_USERDATA, MSG_USERDGRAM, PROOF_INCONSISTENT, PROOF_NONCONFORMANT, RESP_AUDIT, RESP_SEND, STATUS_EXPOSED, STATUS_SUSPECTED, STATUS_TRUSTED, TI_AUTH_PUSH, TI_CHECKPOINT, TI_MAINTENANCE, TI_MAX_RESERVED, TI_STATUS_INFO |
Constructor Summary |
ChallengeResponseProtocolImpl(PeerReviewImpl<Handle,Identifier> peerReviewImpl,
IdentityTransport<Handle,Identifier> transport,
PeerInfoStore<Handle,Identifier> infoStore,
SecureHistory history,
AuthenticatorStore<Identifier> authOutStore,
AuditProtocol<Identifier> auditProtocol,
CommitmentProtocol<Handle,Identifier> commitmentProtocol)
|
Method Summary |
void |
challengeSuspectedNode(Handle target)
Looks up the first unanswered challenge to a SUSPECTED node, and sends it to that node |
protected void |
copyAndEnqueueTail(Handle source,
Evidence evidence,
boolean isAccusation,
Identifier subject,
Identifier originator,
long evidenceSeq,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected void |
deliver(PacketInfo<Handle,Identifier> pi)
|
void |
handleChallenge(Handle source,
ChallengeMessage<Identifier> challenge,
java.util.Map<java.lang.String,java.lang.Object> options)
Called when another node sends us a challenge. |
void |
handleIncomingMessage(Handle source,
UserDataMessage<Handle> message,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected void |
handleResponse(ResponseMessage<Identifier> message,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
handleStatement(Handle source,
PeerReviewMessage m,
java.util.Map<java.lang.String,java.lang.Object> options)
Handle an incoming RESPONSE or ACCUSATION from another node |
void |
notifyStatusChange(Identifier id,
int newStatus)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected Logger logger
ChallengeResponseProtocolImpl
public ChallengeResponseProtocolImpl(PeerReviewImpl<Handle,Identifier> peerReviewImpl,
IdentityTransport<Handle,Identifier> transport,
PeerInfoStore<Handle,Identifier> infoStore,
SecureHistory history,
AuthenticatorStore<Identifier> authOutStore,
AuditProtocol<Identifier> auditProtocol,
CommitmentProtocol<Handle,Identifier> commitmentProtocol)
copyAndEnqueueTail
protected void copyAndEnqueueTail(Handle source,
Evidence evidence,
boolean isAccusation,
Identifier subject,
Identifier originator,
long evidenceSeq,
java.util.Map<java.lang.String,java.lang.Object> options)
deliver
protected void deliver(PacketInfo<Handle,Identifier> pi)
notifyStatusChange
public void notifyStatusChange(Identifier id,
int newStatus)
handleChallenge
public void handleChallenge(Handle source,
ChallengeMessage<Identifier> challenge,
java.util.Map<java.lang.String,java.lang.Object> options)
throws java.io.IOException
- Called when another node sends us a challenge. If the challenge is valid, we respond.
- Specified by:
handleChallenge
in interface ChallengeResponseProtocol<Handle extends RawSerializable,Identifier extends RawSerializable>
- Throws:
java.io.IOException
handleResponse
protected void handleResponse(ResponseMessage<Identifier> message,
java.util.Map<java.lang.String,java.lang.Object> options)
challengeSuspectedNode
public void challengeSuspectedNode(Handle target)
- Looks up the first unanswered challenge to a SUSPECTED node, and sends it to that node
- Specified by:
challengeSuspectedNode
in interface ChallengeResponseProtocol<Handle extends RawSerializable,Identifier extends RawSerializable>
handleIncomingMessage
public void handleIncomingMessage(Handle source,
UserDataMessage<Handle> message,
java.util.Map<java.lang.String,java.lang.Object> options)
throws java.io.IOException
- Specified by:
handleIncomingMessage
in interface ChallengeResponseProtocol<Handle extends RawSerializable,Identifier extends RawSerializable>
- Throws:
java.io.IOException
handleStatement
public void handleStatement(Handle source,
PeerReviewMessage m,
java.util.Map<java.lang.String,java.lang.Object> options)
- Handle an incoming RESPONSE or ACCUSATION from another node
- Specified by:
handleStatement
in interface ChallengeResponseProtocol<Handle extends RawSerializable,Identifier extends RawSerializable>
Copyright © 2001-2005 - Rice Pastry.