Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Represents an open connection between remote hosts More...
Inherits Org.Apache.REEF.Wake.Remote.ILink< T >.
Public Member Functions | |
Link (IPEndPoint remoteEndpoint, ICodec< T > codec, ITcpClientConnectionFactory tcpClientFactory) | |
Constructs a Link object. More... | |
Link (TcpClient client, ICodec< T > codec) | |
Constructs a Link object. More... | |
void | Write (T value) |
Writes the message to the remote host More... | |
async Task | WriteAsync (T value, CancellationToken token) |
Writes the value to this link asynchronously More... | |
T | Read () |
Reads the value from the link synchronously More... | |
async Task< T > | ReadAsync (CancellationToken token) |
Reads the value from the link asynchronously More... | |
void | Dispose () |
Close the client connection More... | |
virtual void | Dispose (bool disposing) |
Subclasses of Links should overwrite this to handle disposing of the link More... | |
override bool | Equals (object obj) |
Overrides Equals. More... | |
override int | GetHashCode () |
Gets the hash code for the Link object. More... | |
Properties | |
IPEndPoint | LocalEndpoint [get] |
Returns the local socket address More... | |
IPEndPoint | RemoteEndpoint [get] |
Returns the remote socket address More... | |
TcpClient | Client [get] |
Gets the underlying TcpClient More... | |
Properties inherited from Org.Apache.REEF.Wake.Remote.ILink< T > | |
IPEndPoint | LocalEndpoint [get] |
Returns the local socket address More... | |
IPEndPoint | RemoteEndpoint [get] |
Returns the remote socket address More... | |
Represents an open connection between remote hosts
|
inline |
Constructs a Link object.
Connects to the specified remote endpoint.
remoteEndpoint | The remote endpoint to connect to |
codec | The codec for serializing messages |
tcpClientFactory | TcpClient factory |
|
inline |
Constructs a Link object.
Uses the already connected TcpClient.
client | The already connected client |
codec | The encoder and decoder |
|
inline |
Close the client connection
|
inlinevirtual |
Subclasses of Links should overwrite this to handle disposing of the link
disposing | To dispose or not |
|
inline |
|
inline |
Gets the hash code for the Link object.
|
inline |
Reads the value from the link synchronously
Implements Org.Apache.REEF.Wake.Remote.ILink< T >.
|
inline |
Reads the value from the link asynchronously
token | The cancellation token |
Implements Org.Apache.REEF.Wake.Remote.ILink< T >.
|
inline |
Writes the message to the remote host
value | The data to write |
Implements Org.Apache.REEF.Wake.Remote.ILink< T >.
|
inline |
Writes the value to this link asynchronously
value | The data to write |
token | The cancellation token |
Implements Org.Apache.REEF.Wake.Remote.ILink< T >.
|
get |
Gets the underlying TcpClient
|
get |
Returns the local socket address
|
get |
Returns the remote socket address