|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AppSocketReceiver | |
---|---|
rice.p2p.commonapi | |
rice.p2p.commonapi.appsocket | |
rice.p2p.multiring | |
rice.p2p.past.gc | |
rice.pastry | |
rice.pastry.client | |
rice.pastry.direct | |
rice.pastry.socket |
Uses of AppSocketReceiver in rice.p2p.commonapi |
---|
Methods in rice.p2p.commonapi with parameters of type AppSocketReceiver | |
---|---|
void |
Endpoint.accept(AppSocketReceiver receiver)
Set's the acceptor for this application. |
void |
Endpoint.connect(NodeHandle handle,
AppSocketReceiver receiver,
int timeout)
Opens a connection to this application on a remote node. |
Uses of AppSocketReceiver in rice.p2p.commonapi.appsocket |
---|
Methods in rice.p2p.commonapi.appsocket with parameters of type AppSocketReceiver | |
---|---|
void |
AppSocket.register(boolean wantToRead,
boolean wantToWrite,
int timeout,
AppSocketReceiver receiver)
Must be called every time a Read/Write occurs to continue operation. |
Uses of AppSocketReceiver in rice.p2p.multiring |
---|
Methods in rice.p2p.multiring with parameters of type AppSocketReceiver | |
---|---|
void |
MultiringEndpoint.accept(AppSocketReceiver receiver)
|
void |
MultiringEndpoint.connect(NodeHandle handle,
AppSocketReceiver receiver,
int timeout)
Passthrough to sub endpoint. |
Uses of AppSocketReceiver in rice.p2p.past.gc |
---|
Methods in rice.p2p.past.gc with parameters of type AppSocketReceiver | |
---|---|
void |
GCEndpoint.accept(AppSocketReceiver receiver)
|
void |
GCEndpoint.connect(NodeHandle handle,
AppSocketReceiver receiver,
int timeout)
Passthrough to the sub endpoint. |
Uses of AppSocketReceiver in rice.pastry |
---|
Methods in rice.pastry with parameters of type AppSocketReceiver | |
---|---|
abstract void |
PastryNode.connect(NodeHandle handle,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
Called by PastryAppl to ask the transport layer to open a Socket to its counterpart on another node. |
Uses of AppSocketReceiver in rice.pastry.client |
---|
Fields in rice.pastry.client declared as AppSocketReceiver | |
---|---|
protected AppSocketReceiver |
PastryAppl.receiver
holds the receiverSocket |
Methods in rice.pastry.client with parameters of type AppSocketReceiver | |
---|---|
void |
PastryAppl.accept(AppSocketReceiver receiver)
Sets an AppSocketReceiver to be called when the next socket arrives. |
void |
PastryAppl.connect(NodeHandle handle,
AppSocketReceiver receiver,
int timeout)
Called to open an ApplicationLevelSocket |
Uses of AppSocketReceiver in rice.pastry.direct |
---|
Methods in rice.pastry.direct with parameters of type AppSocketReceiver | |
---|---|
void |
DirectPastryNode.connect(NodeHandle remoteNode,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
|
Uses of AppSocketReceiver in rice.pastry.socket |
---|
Fields in rice.pastry.socket declared as AppSocketReceiver | |
---|---|
protected AppSocketReceiver |
SocketAppSocket.reader
|
protected AppSocketReceiver |
SocketAppSocket.receiver
|
protected AppSocketReceiver |
SocketAppSocket.writer
|
Methods in rice.pastry.socket with parameters of type AppSocketReceiver | |
---|---|
void |
SocketSourceRouteManager.connect(EpochInetSocketAddress address,
int appAddress,
AppSocketReceiver receiver,
int timeout)
Method which sends a message across the wire. |
void |
SocketSourceRouteManager.AddressManager.connect(int appAddress,
AppSocketReceiver receiver,
int timeout)
Method which opens an app socket to this address |
void |
SocketSourceRouteManager.AddressManager.SourceRouteManager.connect(int appId,
AppSocketReceiver receiver,
int timeout)
Method which opens a socket along this route |
void |
SocketPastryNode.connect(NodeHandle handle,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
|
void |
SocketCollectionManager.connect(SourceRoute path,
int appId,
AppSocketReceiver receiver,
int timeout)
Method which sends a message across the wire. |
protected void |
SocketCollectionManager.openAppSocket(SourceRoute path,
int appId,
AppSocketReceiver connector,
int timeout)
Method which opens a socket to a given remote node handle, and updates the bookkeeping to keep track of this socket |
void |
SocketAppSocket.register(boolean wantToRead,
boolean wantToWrite,
int timeout,
AppSocketReceiver receiver)
|
Constructors in rice.pastry.socket with parameters of type AppSocketReceiver | |
---|---|
PendingAppSocket(int appAddress,
AppSocketReceiver receiver)
|
|
SocketAppSocket(SocketCollectionManager manager,
SourceRoute path,
int appId,
AppSocketReceiver receiver,
int timeout)
Constructor which creates an outgoing connection to the given node handle using the provided address as a source route intermediate node. |
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |