|
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 | |||||||||