Rice Pastry API

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

java.lang.Object
  extended by org.mpisws.p2p.transport.peerreview.message.PeerReviewMessage
      extended by org.mpisws.p2p.transport.peerreview.message.UserDataMessage<Handle>
          extended by org.mpisws.p2p.transport.peerreview.message.OutgoingUserDataMessage<Handle>
All Implemented Interfaces:
MessageRequestHandle<Handle,java.nio.ByteBuffer>, Evidence, PeerReviewConstants, 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
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, 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, STATUS_EXPOSED, STATUS_SUSPECTED, STATUS_TRUSTED, TI_AUTH_PUSH, TI_CHECKPOINT, TI_MAINTENANCE, TI_MAX_RESERVED, TI_STATUS_INFO
 
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, getHTopMinusOne, getInnerHash, getPayload, getPayloadLen, getReceiveEvent, getRelevantLen, getSenderHandle, getSignature, getTopSeq, getType, serialize, setType, toString
 
Methods inherited from class org.mpisws.p2p.transport.peerreview.message.PeerReviewMessage
serialize
 
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>
Overrides:
getOptions in class UserDataMessage<Handle extends RawSerializable>

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)

Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.