org.apache.reef.io.network.impl

Class NetworkService<T>

java.lang.Object

org.apache.reef.io.network.impl.NetworkService<T>

All Implemented Interfaces:

AutoCloseable, ConnectionFactory<T>, Stage

public final class NetworkService<T>
extends Object
implements Stage, ConnectionFactory<T>

Network service for Task

Constructor Summary

Constructors

Constructor and Description
NetworkService(IdentifierFactory factory, int nsPort, String nameServerAddr, int nameServerPort, Codec<T> codec, TransportFactory tpFactory, EventHandler<Message<T>> recvHandler, EventHandler<Exception> exHandler)
NetworkService(IdentifierFactory factory, int nsPort, String nameServerAddr, int nameServerPort, int retryCount, int retryTimeout, Codec<T> codec, TransportFactory tpFactory, EventHandler<Message<T>> recvHandler, EventHandler<Exception> exHandler)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Codec<T>	getCodec()
IdentifierFactory	getIdentifierFactory()
Identifier	getMyId()
Naming	getNameClient()
Transport	getTransport()
Connection<T>	newConnection(Identifier destId) Creates a new connection
void	registerId(Identifier id)
void	unregisterId(Identifier id)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NetworkService

public NetworkService(IdentifierFactory factory,
              int nsPort,
              String nameServerAddr,
              int nameServerPort,
              Codec<T> codec,
              TransportFactory tpFactory,
              EventHandler<Message<T>> recvHandler,
              EventHandler<Exception> exHandler)

NetworkService

@Inject
public NetworkService(IdentifierFactory factory,
                     int nsPort,
                     String nameServerAddr,
                     int nameServerPort,
                     int retryCount,
                     int retryTimeout,
                     Codec<T> codec,
                     TransportFactory tpFactory,
                     EventHandler<Message<T>> recvHandler,
                     EventHandler<Exception> exHandler)

Method Detail

registerId

public void registerId(Identifier id)

unregisterId

public void unregisterId(Identifier id)

getMyId

public Identifier getMyId()

getTransport

public Transport getTransport()

getCodec

public Codec<T> getCodec()

getNameClient

public Naming getNameClient()

getIdentifierFactory

public IdentifierFactory getIdentifierFactory()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

newConnection

public Connection<T> newConnection(Identifier destId)

Description copied from interface: ConnectionFactory

Creates a new connection

Specified by:

newConnection in interface ConnectionFactory<T>

Parameters:

destId - a destination identifier

Returns:

a connection