This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.Network.NetworkService.NsConnection< T > Class Template Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Public Member Functions | List of all members
Org.Apache.REEF.Network.NetworkService.NsConnection< T > Class Template Reference

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

Detailed Description

Represents a connection between two hosts using the NetworkService.

Constructor & Destructor Documentation

Org.Apache.REEF.Network.NetworkService.NsConnection< T >.NsConnection ( IIdentifier  sourceId,
IIdentifier  destId,
INameClient  nameClient,
IRemoteManager< NsMessage< T >>  remoteManager,
Dictionary< IIdentifier, IConnection< T >>  connectionMap 
)
inline

Creates a new NsConnection between two hosts.

Parameters
sourceIdThe identifier of the sender
destIdThe identifier of the receiver
nameClientThe NameClient used for naming lookup
remoteManagerThe remote manager used for network communication
connectionMapA cache of opened connections. Will remove itself from the cache when the NsConnection is disposed.

Member Function Documentation

Closes the connection

Opens the connection to the remote host.

Implements Org.Apache.REEF.Network.NetworkService.IConnection< T >.

void Org.Apache.REEF.Network.NetworkService.NsConnection< T >.Write ( message)
inline

Writes the object to the remote host.

Parameters
messageThe message to send

Implements Org.Apache.REEF.Network.NetworkService.IConnection< T >.


The documentation for this class was generated from the following file: