Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T > Class Template Reference

Manages incoming and outgoing messages between remote hosts. More...

Inherits Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

Public Member Functions
IObserver< T >	GetRemoteObserver (RemoteEventEndPoint< T > remoteEndpoint)
	Returns an IObserver used to send messages to the remote host at the specified IPEndpoint. More...
IObserver< T >	GetRemoteObserver (IPEndPoint remoteEndpoint)
	Returns an IObserver used to send messages to the remote host at the specified IPEndpoint. More...
IRemoteObserver< T >	GetUnmanagedRemoteObserver (RemoteEventEndPoint< T > remoteEndpoint)
IRemoteObserver< T >	GetUnmanagedObserver (IPEndPoint remoteEndpoint)
IDisposable	RegisterObserver (RemoteEventEndPoint< T > remoteEndpoint, IObserver< T > observer)
	Registers an IObserver used to handle incoming messages from the remote host at the specified IPEndPoint. More...
IDisposable	RegisterObserver (IPEndPoint remoteEndpoint, IObserver< T > observer)
	Registers an IObserver used to handle incoming messages from the remote host at the specified IPEndPoint. More...
IDisposable	RegisterObserver (IObserver< IRemoteMessage< T >> observer)
	Registers an IObserver used to handle incoming messages from the remote host at the specified IPEndPoint. More...
void	Dispose ()
	Release all resources for the DefaultRemoteManager. More...

Properties
IRemoteIdentifier	Identifier [get]
	Gets the RemoteIdentifier for the DefaultRemoteManager More...
IPEndPoint	LocalEndpoint [get]
	Gets the local IPEndPoint for the DefaultRemoteManager More...
Properties inherited from Org.Apache.REEF.Wake.Remote.IRemoteManager< T >
IRemoteIdentifier	Identifier [get]
IPEndPoint	LocalEndpoint [get]

Detailed Description

Manages incoming and outgoing messages between remote hosts.

Member Function Documentation

void Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.Dispose ( )

inline

Release all resources for the DefaultRemoteManager.

IObserver<T> Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.GetRemoteObserver ( RemoteEventEndPoint< T >  remoteEndpoint )

inline

Returns an IObserver used to send messages to the remote host at the specified IPEndpoint.

Parameters

remoteEndpoint

The IPEndpoint of the remote host

Returns

An IObserver used to send messages to the remote host

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

IObserver<T> Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.GetRemoteObserver ( IPEndPoint  remoteEndpoint )

inline

Returns an IObserver used to send messages to the remote host at the specified IPEndpoint.

Parameters

remoteEndpoint

The IPEndpoint of the remote host

Returns

An IObserver used to send messages to the remote host

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

IRemoteObserver<T> Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.GetUnmanagedObserver ( IPEndPoint  remoteEndpoint )

inline

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

IRemoteObserver<T> Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.GetUnmanagedRemoteObserver ( RemoteEventEndPoint< T >  remoteEndpoint )

inline

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

IDisposable Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.RegisterObserver ( RemoteEventEndPoint< T >  remoteEndpoint, IObserver< T >  observer  )

inline

Registers an IObserver used to handle incoming messages from the remote host at the specified IPEndPoint.

The IDisposable that is returned can be used to unregister the IObserver.

Parameters

remoteEndpoint	The IPEndPoint of the remote host
observer	The IObserver to handle incoming messages

Returns

An IDisposable used to unregister the observer with

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

IDisposable Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.RegisterObserver ( IPEndPoint  remoteEndpoint, IObserver< T >  observer  )

inline

Registers an IObserver used to handle incoming messages from the remote host at the specified IPEndPoint.

The IDisposable that is returned can be used to unregister the IObserver.

Parameters

remoteEndpoint	The IPEndPoint of the remote host
observer	The IObserver to handle incoming messages

Returns

An IDisposable used to unregister the observer with

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

IDisposable Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.RegisterObserver ( IObserver< IRemoteMessage< T >>  observer )

inline

Registers an IObserver used to handle incoming messages from the remote host at the specified IPEndPoint.

The IDisposable that is returned can be used to unregister the IObserver.

Parameters

observer

The IObserver to handle incoming messages

Returns

An IDisposable used to unregister the observer with

Implements Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.

Property Documentation

IRemoteIdentifier Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.Identifier

get

Gets the RemoteIdentifier for the DefaultRemoteManager

IPEndPoint Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >.LocalEndpoint

get

Gets the local IPEndPoint for the DefaultRemoteManager

---

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

• lang/cs/Org.Apache.REEF.Wake/Remote/Impl/DefaultRemoteManager.cs