org.mpisws.p2p.transport.peerreview.message
Class OutgoingUserDataMessage<Handle extends RawSerializable>

java.lang.Object
  org.mpisws.p2p.transport.peerreview.message.UserDataMessage<Handle>
      org.mpisws.p2p.transport.peerreview.message.OutgoingUserDataMessage<Handle>

All Implemented Interfaces:

MessageRequestHandle<Handle,java.nio.ByteBuffer>, Evidence, PeerReviewMessage, PeerReviewConstants, StatusConstants, Cancellable, RawSerializable

public class OutgoingUserDataMessage<Handle extends RawSerializable>
extends UserDataMessage<Handle>
implements MessageRequestHandle<Handle,java.nio.ByteBuffer>

Field Summary

Fields inherited from class org.mpisws.p2p.transport.peerreview.message.UserDataMessage

TYPE

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

OutgoingUserDataMessage(long topSeq, Handle senderHandle, byte[] topMinusOne, byte[] sig, java.nio.ByteBuffer message, int relevantlen, java.util.Map<java.lang.String,java.lang.Object> options, PeerInfo<Handle> pi, MessageCallback<Handle,java.nio.ByteBuffer> deliverAckToMe)

Method Summary

boolean	cancel()
Handle	getIdentifier()
java.nio.ByteBuffer	getMessage()
java.util.Map<java.lang.String,java.lang.Object>	getOptions()
void	sendComplete()
void	sendFailed(java.io.IOException ioe)

Methods inherited from class org.mpisws.p2p.transport.peerreview.message.UserDataMessage

build, getEvidenceType, getHTopMinusOne, getInnerHash, getInnerHash, getInnerHash, getPayload, getPayloadLen, getReceiveEvent, getRelevantCode, getRelevantLen, getSenderHandle, getSignature, getTopSeq, getType, serialize, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

OutgoingUserDataMessage

public OutgoingUserDataMessage(long topSeq,
                               Handle senderHandle,
                               byte[] topMinusOne,
                               byte[] sig,
                               java.nio.ByteBuffer message,
                               int relevantlen,
                               java.util.Map<java.lang.String,java.lang.Object> options,
                               PeerInfo<Handle> pi,
                               MessageCallback<Handle,java.nio.ByteBuffer> deliverAckToMe)

Method Detail

getIdentifier

public Handle getIdentifier()

Specified by:

getIdentifier in interface MessageRequestHandle<Handle extends RawSerializable,java.nio.ByteBuffer>

getMessage

public java.nio.ByteBuffer getMessage()

Specified by:

getMessage in interface MessageRequestHandle<Handle extends RawSerializable,java.nio.ByteBuffer>

getOptions

public java.util.Map<java.lang.String,java.lang.Object> getOptions()

Specified by:

getOptions in interface MessageRequestHandle<Handle extends RawSerializable,java.nio.ByteBuffer>

cancel

public boolean cancel()

Specified by:

cancel in interface Cancellable

Returns:

true if it was cancelled, false if it was already complete, or cancelled.

sendComplete

public void sendComplete()

sendFailed

public void sendFailed(java.io.IOException ioe)