org.apache.ignite.tensorflow.cluster.util

Class ClusterPortManager

java.lang.Object

org.apache.ignite.tensorflow.cluster.util.ClusterPortManager

public class ClusterPortManager
extends Object

Cluster port manager that allows to reliably acquirePort(UUID) and releasePort(UUID, int) on the cluster nodes.

Constructor Summary

Constructors

Constructor and Description
ClusterPortManager(Ignite ignite, String poolName, int from, int cnt) Constructs a new instance of cluster port manager.

Method Summary

Modifier and Type	Method and Description
int	acquirePort(UUID nodeId) Acquires free port on the specified node.
void	destroy() Destroys port manager and related caches.
void	releasePort(UUID nodeId, int port) Releases acquired port on the specified node.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterPortManager

public ClusterPortManager(Ignite ignite,
                          String poolName,
                          int from,
                          int cnt)

Constructs a new instance of cluster port manager.

Parameters:

poolName - Port pool name.

from - Port range from point.

cnt - Port range size.

Method Detail

acquirePort

public int acquirePort(UUID nodeId)

Acquires free port on the specified node.

Parameters:

nodeId - Node identifier.

Returns:

Port to be acquired.

releasePort

public void releasePort(UUID nodeId,
                        int port)

Releases acquired port on the specified node.

Parameters:

nodeId - Node identifier.

port - Acquired port to be free.

destroy

public void destroy()

Destroys port manager and related caches.