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