org.apache.reef.io.network.naming

Class NameServerImpl

java.lang.Object

org.apache.reef.io.network.naming.NameServerImpl

All Implemented Interfaces:

AutoCloseable, NameServer, Stage

public class NameServerImpl
extends Object
implements NameServer

Naming server implementation

Constructor Summary

Constructors

Constructor and Description
NameServerImpl(int port, IdentifierFactory factory) Deprecated. inject the NameServer instead of new it up Constructs a name server
NameServerImpl(int port, IdentifierFactory factory, ReefEventStateManager reefEventStateManager) Constructs a name server

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes resources
int	getPort() Gets port
InetSocketAddress	lookup(Identifier id) Finds an address for an identifier locally
List<NameAssignment>	lookup(Iterable<Identifier> identifiers) Finds addresses for identifiers locally
void	register(Identifier id, InetSocketAddress addr) Registers an (identifier, address) mapping locally
void	unregister(Identifier id) Unregisters an identifier locally

Methods inherited from class java.lang.Object

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

Constructor Detail

NameServerImpl

@Deprecated
public NameServerImpl(int port,
                         IdentifierFactory factory)

Deprecated. inject the NameServer instead of new it up Constructs a name server

Parameters:

port - a listening port number

factory - an identifier factory

NameServerImpl

@Inject
public NameServerImpl(int port,
                     IdentifierFactory factory,
                     ReefEventStateManager reefEventStateManager)

Constructs a name server

Parameters:

port - a listening port number

factory - an identifier factory

reefEventStateManager - the event state manager used to register name server info

Method Detail

getPort

public int getPort()

Gets port

Specified by:

getPort in interface NameServer

Returns:

close

public void close()
           throws Exception

Closes resources

Specified by:

close in interface AutoCloseable

Throws:

Exception

register

public void register(Identifier id,
            InetSocketAddress addr)

Registers an (identifier, address) mapping locally

Specified by:

register in interface NameServer

Parameters:

id - an identifier

addr - an Internet socket address

unregister

public void unregister(Identifier id)

Unregisters an identifier locally

Specified by:

unregister in interface NameServer

Parameters:

id - an identifier

lookup

public InetSocketAddress lookup(Identifier id)

Finds an address for an identifier locally

Specified by:

lookup in interface NameServer

Parameters:

id - an identifier

Returns:

an Internet socket address

lookup

public List<NameAssignment> lookup(Iterable<Identifier> identifiers)

Finds addresses for identifiers locally

Specified by:

lookup in interface NameServer

Parameters:

identifiers - an iterable of identifiers

Returns:

a list of name assignments