Uses of Interface
org.mpisws.p2p.transport.P2PSocket

Packages that use P2PSocket

org.mpisws.p2p.transport
org.mpisws.p2p.transport.bandwidthmeasure
org.mpisws.p2p.transport.commonapi
org.mpisws.p2p.transport.direct
org.mpisws.p2p.transport.limitsockets
org.mpisws.p2p.transport.liveness
org.mpisws.p2p.transport.multiaddress
org.mpisws.p2p.transport.nat
org.mpisws.p2p.transport.networkinfo
org.mpisws.p2p.transport.peerreview
org.mpisws.p2p.transport.peerreview.replay
org.mpisws.p2p.transport.peerreview.replay.record
org.mpisws.p2p.transport.priority
org.mpisws.p2p.transport.rc4
org.mpisws.p2p.transport.rendezvous
org.mpisws.p2p.transport.simpleidentity
org.mpisws.p2p.transport.sourceroute
org.mpisws.p2p.transport.sourceroute.manager
org.mpisws.p2p.transport.ssl
org.mpisws.p2p.transport.table
org.mpisws.p2p.transport.util
org.mpisws.p2p.transport.wire
org.mpisws.p2p.transport.wire.magicnumber
rice.pastry
rice.pastry.peerreview
rice.pastry.transport
rice.tutorial.transportlayer

Uses of P2PSocket in org.mpisws.p2p.transport

Methods in org.mpisws.p2p.transport with parameters of type P2PSocket

void	TransportLayerCallback.incomingSocket(P2PSocket<Identifier> s) Notification of a new socket.
void	P2PSocketReceiver.receiveException(P2PSocket<Identifier> socket, java.lang.Exception ioe) Called when there is an error
void	SocketCallback.receiveResult(SocketRequestHandle<Identifier> cancellable, P2PSocket<Identifier> sock)
void	P2PSocketReceiver.receiveSelectResult(P2PSocket<Identifier> socket, boolean canRead, boolean canWrite) Called when a socket is available for read/write

Uses of P2PSocket in org.mpisws.p2p.transport.bandwidthmeasure

Methods in org.mpisws.p2p.transport.bandwidthmeasure with parameters of type P2PSocket

void	BandwidthMeasuringTransportLayer.incomingSocket(P2PSocket<Identifier> s)

Uses of P2PSocket in org.mpisws.p2p.transport.commonapi

Methods in org.mpisws.p2p.transport.commonapi with parameters of type P2PSocket

void	CommonAPITransportLayerImpl.incomingSocket(P2PSocket<Identifier> s)

Uses of P2PSocket in org.mpisws.p2p.transport.direct

Methods in org.mpisws.p2p.transport.direct with parameters of type P2PSocket

void	DirectTransportLayer.finishReceiveSocket(P2PSocket<Identifier> acceptorEndpoint)

Uses of P2PSocket in org.mpisws.p2p.transport.limitsockets

Methods in org.mpisws.p2p.transport.limitsockets with parameters of type P2PSocket

protected org.mpisws.p2p.transport.limitsockets.LimitSocketsTransportLayer.LSSocket	LimitSocketsTransportLayer.getLSSock(P2PSocket<Identifier> sock)
void	LimitSocketsTransportLayer.incomingSocket(P2PSocket<Identifier> s)

Uses of P2PSocket in org.mpisws.p2p.transport.liveness

Methods in org.mpisws.p2p.transport.liveness that return P2PSocket

P2PSocket<Identifier>	AggressiveLivenessTransportLayerImpl.getLSocket(P2PSocket<Identifier> s, LivenessTransportLayerImpl.EntityManager manager)
P2PSocket<Identifier>	LivenessTransportLayerImpl.getLSocket(P2PSocket<Identifier> s, LivenessTransportLayerImpl.EntityManager manager)

Methods in org.mpisws.p2p.transport.liveness with parameters of type P2PSocket

P2PSocket<Identifier>	AggressiveLivenessTransportLayerImpl.getLSocket(P2PSocket<Identifier> s, LivenessTransportLayerImpl.EntityManager manager)
P2PSocket<Identifier>	LivenessTransportLayerImpl.getLSocket(P2PSocket<Identifier> s, LivenessTransportLayerImpl.EntityManager manager)
void	LivenessTransportLayerImpl.incomingSocket(P2PSocket<Identifier> s)

Uses of P2PSocket in org.mpisws.p2p.transport.multiaddress

Methods in org.mpisws.p2p.transport.multiaddress with parameters of type P2PSocket

void	MultiInetAddressTransportLayerImpl.incomingSocket(P2PSocket<java.net.InetSocketAddress> s)

Uses of P2PSocket in org.mpisws.p2p.transport.nat

Methods in org.mpisws.p2p.transport.nat with parameters of type P2PSocket

void	FirewallTLImpl.incomingSocket(P2PSocket<Identifier> s) Only allow outgoing sockets.

Uses of P2PSocket in org.mpisws.p2p.transport.networkinfo

Methods in org.mpisws.p2p.transport.networkinfo with parameters of type P2PSocket

void	NetworkInfoTransportLayer.handleIdRequest(P2PSocket<java.net.InetSocketAddress> socket)
void	NetworkInfoTransportLayer.handleIpRequest(P2PSocket<java.net.InetSocketAddress> socket)
void	NetworkInfoTransportLayer.handleNodesRequest(P2PSocket<java.net.InetSocketAddress> socket)
void	NetworkInfoTransportLayer.handleProbeRequest(P2PSocket<java.net.InetSocketAddress> socket)
void	NetworkInfoTransportLayer.handleProbeResponse(P2PSocket<java.net.InetSocketAddress> socket)
void	NetworkInfoTransportLayer.incomingSocket(P2PSocket<java.net.InetSocketAddress> s)

Uses of P2PSocket in org.mpisws.p2p.transport.peerreview

Methods in org.mpisws.p2p.transport.peerreview with parameters of type P2PSocket

void	PeerReviewImpl.incomingSocket(P2PSocket<Handle> s)

Uses of P2PSocket in org.mpisws.p2p.transport.peerreview.replay

Classes in org.mpisws.p2p.transport.peerreview.replay that implement P2PSocket

class

ReplaySocket<Identifier extends RawSerializable>

Uses of P2PSocket in org.mpisws.p2p.transport.peerreview.replay.record

Classes in org.mpisws.p2p.transport.peerreview.replay.record that implement P2PSocket

class

RecordSocket<Identifier>

Methods in org.mpisws.p2p.transport.peerreview.replay.record with parameters of type P2PSocket

void	RecordLayer.incomingSocket(P2PSocket<Identifier> s)

Constructors in org.mpisws.p2p.transport.peerreview.replay.record with parameters of type P2PSocket

RecordSocket(Identifier identifier, P2PSocket<Identifier> socket, Logger logger, java.util.Map<java.lang.String,java.lang.Object> options, int socketId, java.nio.ByteBuffer sib, RecordLayer<Identifier> recordLayer)

Uses of P2PSocket in org.mpisws.p2p.transport.priority

Methods in org.mpisws.p2p.transport.priority with parameters of type P2PSocket

void	PriorityTransportLayerImpl.incomingSocket(P2PSocket<Identifier> s) We have to read the first byte and see if this is a passthrough (the layer higher than us asked to open it) socket or a primary (our layer tried to open it) socket.

Uses of P2PSocket in org.mpisws.p2p.transport.rc4

Classes in org.mpisws.p2p.transport.rc4 that implement P2PSocket

class

EncryptedSocket<Identifier>

Methods in org.mpisws.p2p.transport.rc4 with parameters of type P2PSocket

void	RC4TransportLayer.incomingSocket(P2PSocket<Identifier> s)
void	EncryptedSocket.receiveSelectResult(P2PSocket<Identifier> socket, boolean canRead, boolean canWrite)

Constructors in org.mpisws.p2p.transport.rc4 with parameters of type P2PSocket

EncryptedSocket(Identifier identifier, P2PSocket<Identifier> socket, Logger logger, ErrorHandler<Identifier> handler, java.util.Map<java.lang.String,java.lang.Object> options, javax.crypto.Cipher encryptCipher, javax.crypto.Cipher decryptCipher, int writeBufferSize)

Uses of P2PSocket in org.mpisws.p2p.transport.rendezvous

Methods in org.mpisws.p2p.transport.rendezvous that return P2PSocket

P2PSocket<Identifier>

RendezvousTransportLayerImpl.removeConnectSocket(HighIdentifier requestor, HighIdentifier target, int uid)

Methods in org.mpisws.p2p.transport.rendezvous with parameters of type P2PSocket

protected void	RendezvousTransportLayerImpl.createForwarder(P2PSocket<Identifier> a, P2PSocket<Identifier> b, HighIdentifier connector, HighIdentifier acceptor, int uid)
protected void	RendezvousTransportLayerImpl.createForwarder(P2PSocket<Identifier> a, P2PSocket<Identifier> b, HighIdentifier connector, HighIdentifier acceptor, int uid)
void	RendezvousTransportLayerImpl.incomingSocket(P2PSocket<Identifier> s)
void	RendezvousTransportLayerImpl.putConnectSocket(HighIdentifier requestor, HighIdentifier target, int uid, P2PSocket<Identifier> socket) This map stores the connect socket until the corresponding accept socket arrives
protected void	RendezvousTransportLayerImpl.readAcceptHeader(P2PSocket<Identifier> acceptorSocket)
protected void	RendezvousTransportLayerImpl.readConnectHeader(P2PSocket<Identifier> socket)

Uses of P2PSocket in org.mpisws.p2p.transport.simpleidentity

Methods in org.mpisws.p2p.transport.simpleidentity with parameters of type P2PSocket

void	SimpleIdentityTransportLayer.incomingSocket(P2PSocket<Identifier> s)

Uses of P2PSocket in org.mpisws.p2p.transport.sourceroute

Methods in org.mpisws.p2p.transport.sourceroute with parameters of type P2PSocket

void	SourceRouteTransportLayerImpl.incomingSocket(P2PSocket<Identifier> socka)
protected void	SourceRouteTransportLayerImpl.incomingSocketHelper(P2PSocket<Identifier> socket, SourceRoute<Identifier> sr) To override this behavior if needed.
protected void	SourceRouteTransportLayerImpl.openSocketHelper(SocketCallback<SourceRoute<Identifier>> deliverSocketToMe, SocketRequestHandleImpl<SourceRoute<Identifier>> handle, P2PSocket<Identifier> socket, SourceRoute<Identifier> i)
void	SourceRouteTap.receivedBytes(java.nio.ByteBuffer m, SourceRoute path, P2PSocket a, P2PSocket b) We are the intermediate node for some bytes from Socket a to Socket b
void	SourceRouteTap.receivedBytes(java.nio.ByteBuffer m, SourceRoute path, P2PSocket a, P2PSocket b) We are the intermediate node for some bytes from Socket a to Socket b
void	SourceRouteTap.socketClosed(SourceRoute path, P2PSocket a, P2PSocket b)
void	SourceRouteTap.socketClosed(SourceRoute path, P2PSocket a, P2PSocket b)
void	SourceRouteTap.socketOpened(SourceRoute path, P2PSocket a, P2PSocket b)
void	SourceRouteTap.socketOpened(SourceRoute path, P2PSocket a, P2PSocket b)

Constructors in org.mpisws.p2p.transport.sourceroute with parameters of type P2PSocket

Forwarder(SourceRoute<Identifier> sr, P2PSocket<Identifier> socka, P2PSocket<Identifier> sockb, Logger logger)

Forwarder(SourceRoute<Identifier> sr, P2PSocket<Identifier> socka, P2PSocket<Identifier> sockb, Logger logger)

Uses of P2PSocket in org.mpisws.p2p.transport.sourceroute.manager

Classes in org.mpisws.p2p.transport.sourceroute.manager that implement P2PSocket

class

SourceRouteManagerP2PSocket<Identifier>

Methods in org.mpisws.p2p.transport.sourceroute.manager with parameters of type P2PSocket

void	SourceRouteManagerImpl.incomingSocket(P2PSocket<SourceRoute<Identifier>> s)

Constructors in org.mpisws.p2p.transport.sourceroute.manager with parameters of type P2PSocket

SourceRouteManagerP2PSocket(P2PSocket<SourceRoute<Identifier>> socket, Logger logger, ErrorHandler<Identifier> errorHandler, Environment env)

Uses of P2PSocket in org.mpisws.p2p.transport.ssl

Classes in org.mpisws.p2p.transport.ssl that implement P2PSocket

class

SSLSocketManager<Identifier>

Fields in org.mpisws.p2p.transport.ssl declared as P2PSocket

protected P2PSocket<Identifier>

SSLSocketManager.socket

Methods in org.mpisws.p2p.transport.ssl with parameters of type P2PSocket

protected SSLSocketManager<Identifier>	SSLTransportLayerImpl.getSocketManager(SSLTransportLayerImpl<Identifier,?> sslTL, P2PSocket<Identifier> s, Continuation<SSLSocketManager<Identifier>,java.lang.Exception> c, boolean server, boolean useClientAuth)
void	SSLTransportLayerImpl.incomingSocket(P2PSocket<Identifier> s) TODO: support resuming
void	SSLSocketManager.receiveException(P2PSocket<Identifier> socket, java.lang.Exception ioe)
void	SSLSocketManager.receiveSelectResult(P2PSocket<Identifier> socket, boolean canRead, boolean canWrite)

Constructors in org.mpisws.p2p.transport.ssl with parameters of type P2PSocket

SSLSocketManager(SSLTransportLayerImpl<Identifier,?> sslTL, P2PSocket<Identifier> s, Continuation<SSLSocketManager<Identifier>,java.lang.Exception> c, boolean server, boolean useClientAuth)
Called on incoming side

Uses of P2PSocket in org.mpisws.p2p.transport.table

Methods in org.mpisws.p2p.transport.table with parameters of type P2PSocket

void	TableTransprotLayerImpl.handleValueRequest(P2PSocket<Identifier> sock)
void	TableTransprotLayerImpl.incomingSocket(P2PSocket<Identifier> sock)

Uses of P2PSocket in org.mpisws.p2p.transport.util

Classes in org.mpisws.p2p.transport.util that implement P2PSocket

class

SocketWrapperSocket<Identifier,SubIdentifier> Just maps a socket from one form into another.

Fields in org.mpisws.p2p.transport.util declared as P2PSocket

protected P2PSocket<SubIdentifier>

SocketWrapperSocket.socket

Methods in org.mpisws.p2p.transport.util with parameters of type P2PSocket

void	DefaultCallback.incomingSocket(P2PSocket s)
void	BufferReader.receiveException(P2PSocket<Identifier> socket, java.lang.Exception ioe)
void	BufferWriter.receiveException(P2PSocket<Identifier> socket, java.lang.Exception ioe)
void	SocketWrapperSocket.receiveException(P2PSocket<SubIdentifier> socket, java.lang.Exception e)
void	BufferReader.receiveSelectResult(P2PSocket<Identifier> socket, boolean canRead, boolean canWrite)
void	BufferWriter.receiveSelectResult(P2PSocket<Identifier> socket, boolean canRead, boolean canWrite)
void	SocketWrapperSocket.receiveSelectResult(P2PSocket<SubIdentifier> socket, boolean canRead, boolean canWrite)

Constructors in org.mpisws.p2p.transport.util with parameters of type P2PSocket

BufferReader(P2PSocket<Identifier> socket, Continuation<java.nio.ByteBuffer,java.lang.Exception> continuation)
Constructor for variable/unknown sized BB, it reads the size off the stream

BufferReader(P2PSocket<Identifier> socket, Continuation<java.nio.ByteBuffer,java.lang.Exception> continuation, int size)
Constructor for fixed size BB

BufferReaderWriter(P2PSocket<Identifier> sock, java.nio.ByteBuffer writeMe, boolean writeSize, Continuation<java.nio.ByteBuffer,java.lang.Exception> c)

BufferReaderWriter(P2PSocket<Identifier> sock, java.nio.ByteBuffer writeMe, boolean writeSize, Continuation<java.nio.ByteBuffer,java.lang.Exception> c, int readSize)

BufferWriter(java.nio.ByteBuffer writeMe, P2PSocket<Identifier> socket, Continuation<P2PSocket<Identifier>,java.lang.Exception> continuation)

BufferWriter(java.nio.ByteBuffer writeMe, P2PSocket<Identifier> socket, Continuation<P2PSocket<Identifier>,java.lang.Exception> continuation, boolean includeSizeHeader)

SocketInputBuffer(P2PSocket socket)

SocketInputBuffer(P2PSocket socket, int size)

SocketWrapperSocket(Identifier identifier, P2PSocket<SubIdentifier> socket, Logger logger, ErrorHandler<Identifier> errorHandler, java.util.Map<java.lang.String,java.lang.Object> options)

Constructor parameters in org.mpisws.p2p.transport.util with type arguments of type P2PSocket

BufferWriter(java.nio.ByteBuffer writeMe, P2PSocket<Identifier> socket, Continuation<P2PSocket<Identifier>,java.lang.Exception> continuation)

BufferWriter(java.nio.ByteBuffer writeMe, P2PSocket<Identifier> socket, Continuation<P2PSocket<Identifier>,java.lang.Exception> continuation, boolean includeSizeHeader)

Uses of P2PSocket in org.mpisws.p2p.transport.wire

Classes in org.mpisws.p2p.transport.wire that implement P2PSocket

class

SocketManager

Methods in org.mpisws.p2p.transport.wire with parameters of type P2PSocket

protected void

WireTransportLayerImpl.incomingSocket(P2PSocket<java.net.InetSocketAddress> sm)

Uses of P2PSocket in org.mpisws.p2p.transport.wire.magicnumber

Methods in org.mpisws.p2p.transport.wire.magicnumber with parameters of type P2PSocket

void	MagicNumberTransportLayer.incomingSocket(P2PSocket<Identifier> s)
void	MagicNumberTransportLayer.VerifyHeaderReceiver.receiveException(P2PSocket<Identifier> socket, java.lang.Exception ioe)
void	MagicNumberTransportLayer.VerifyHeaderReceiver.receiveSelectResult(P2PSocket<Identifier> socket, boolean canRead, boolean canWrite)

Constructors in org.mpisws.p2p.transport.wire.magicnumber with parameters of type P2PSocket

MagicNumberTransportLayer.VerifyHeaderReceiver(P2PSocket<Identifier> s)

Uses of P2PSocket in rice.pastry

Methods in rice.pastry with parameters of type P2PSocket

void	PastryNode.incomingSocket(P2PSocket<NodeHandle> s)

Uses of P2PSocket in rice.pastry.peerreview

Methods in rice.pastry.peerreview with parameters of type P2PSocket

void	PeerReviewCallbackImpl.incomingSocket(P2PSocket<TransportLayerNodeHandle<MultiInetSocketAddress>> s)

Uses of P2PSocket in rice.pastry.transport

Methods in rice.pastry.transport with parameters of type P2PSocket

void	AppSocketReceiverWrapper.receiveException(P2PSocket<Identifier> s, java.lang.Exception ioe)
void	SocketAdapter.receiveException(P2PSocket<Identifier> s, java.lang.Exception e)
void	AppSocketReceiverWrapper.receiveSelectResult(P2PSocket<Identifier> s, boolean canRead, boolean canWrite)
void	SocketAdapter.receiveSelectResult(P2PSocket<Identifier> s, boolean canRead, boolean canWrite)

Constructors in rice.pastry.transport with parameters of type P2PSocket

SocketAdapter(P2PSocket<Identifier> socket, Environment env)

Uses of P2PSocket in rice.tutorial.transportlayer

Methods in rice.tutorial.transportlayer with parameters of type P2PSocket

void	BandwidthLimitingTransportLayer.incomingSocket(P2PSocket<Identifier> s)