|
Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Represents a connection between two hosts using the NetworkService. More...
Inherits Org.Apache.REEF.Network.NetworkService.IConnection< T >.
Public Member Functions | |
| NsConnection (IIdentifier sourceId, IIdentifier destId, INameClient nameClient, IRemoteManager< NsMessage< T >> remoteManager, Dictionary< IIdentifier, IConnection< T >> connectionMap) | |
| Creates a new NsConnection between two hosts. More... | |
| void | Open () |
| Opens the connection to the remote host. More... | |
| void | Write (T message) |
| Writes the object to the remote host. More... | |
| void | Dispose () |
| Closes the connection More... | |
Represents a connection between two hosts using the NetworkService.
|
inline |
Creates a new NsConnection between two hosts.
| sourceId | The identifier of the sender |
| destId | The identifier of the receiver |
| nameClient | The NameClient used for naming lookup |
| remoteManager | The remote manager used for network communication |
| connectionMap | A cache of opened connections. Will remove itself from the cache when the NsConnection is disposed. |
|
inline |
Closes the connection
|
inline |
Opens the connection to the remote host.
Implements Org.Apache.REEF.Network.NetworkService.IConnection< T >.
|
inline |
Writes the object to the remote host.
| message | The message to send |
Implements Org.Apache.REEF.Network.NetworkService.IConnection< T >.
1.8.11