org.infinispan.client.hotrod.impl.transport.tcp

Class TcpTransportFactory

java.lang.Object

org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory

All Implemented Interfaces:

TransportFactory

@ThreadSafe
public class TcpTransportFactory
extends Object
implements TransportFactory

Since:

4.1

Author:

Mircea.Markus@jboss.com

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TcpTransportFactory.ClusterSwitchStatus

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_CLUSTER_NAME

Constructor Summary

Constructors

Constructor and Description
TcpTransportFactory()

Method Summary

Modifier and Type	Method and Description
boolean	checkServersAlive(Collection<SocketAddress> servers)
AtomicInteger	createTopologyId(byte[] cacheName)
void	destroy()
Transport	getAddressTransport(SocketAddress server)
RequestBalancingStrategy	getBalancer(byte[] cacheName) Note that the returned RequestBalancingStrategy may not be thread-safe.
CacheTopologyInfo	getCacheTopologyInfo(byte[] cacheName)
org.apache.commons.pool.impl.GenericKeyedObjectPool<SocketAddress,TcpTransport>	getConnectionPool()
int	getConnectTimeout()
ConsistentHash	getConsistentHash(byte[] cacheName) Note that the returned ConsistentHash may not be thread-safe.
ConsistentHashFactory	getConsistentHashFactory()
String	getCurrentClusterName()
Marshaller	getMarshaller()
int	getMaxRetries()
Collection<SocketAddress>	getServers()
SocketAddress	getSocketAddress(Object key, byte[] cacheName)
int	getSoTimeout()
SSLContext	getSSLContext()
int	getTopologyAge()
int	getTopologyId(byte[] cacheName)
Transport	getTransport(Object key, Set<SocketAddress> failedServers, byte[] cacheName)
Transport	getTransport(Set<SocketAddress> failedServers, byte[] cacheName)
void	invalidateTransport(SocketAddress serverAddress, Transport transport)
boolean	isTcpKeepAlive()
boolean	isTcpNoDelay()
void	releaseTransport(Transport transport)
void	reset(byte[] cacheName)
void	start(Codec codec, Configuration configuration, AtomicInteger defaultCacheTopologyId, ClientListenerNotifier listenerNotifier)
boolean	switchToCluster(String clusterName)
TcpTransportFactory.ClusterSwitchStatus	trySwitchCluster(String failedClusterName, byte[] cacheName)
void	updateHashFunction(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, short hashFunctionVersion, int hashSpace, byte[] cacheName, AtomicInteger topologyId)
void	updateHashFunction(SocketAddress[][] segmentOwners, int numSegments, short hashFunctionVersion, byte[] cacheName, AtomicInteger topologyId)
void	updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CLUSTER_NAME

public static final String DEFAULT_CLUSTER_NAME

See Also:

Constant Field Values

Constructor Detail

TcpTransportFactory

public TcpTransportFactory()

Method Detail

start

public void start(Codec codec,
                  Configuration configuration,
                  AtomicInteger defaultCacheTopologyId,
                  ClientListenerNotifier listenerNotifier)

Specified by:

start in interface TransportFactory

destroy

public void destroy()

Specified by:

destroy in interface TransportFactory

getCacheTopologyInfo

public CacheTopologyInfo getCacheTopologyInfo(byte[] cacheName)

Specified by:

getCacheTopologyInfo in interface TransportFactory

updateHashFunction

public void updateHashFunction(Map<SocketAddress,Set<Integer>> servers2Hash,
                               int numKeyOwners,
                               short hashFunctionVersion,
                               int hashSpace,
                               byte[] cacheName,
                               AtomicInteger topologyId)

Specified by:

updateHashFunction in interface TransportFactory

updateHashFunction

public void updateHashFunction(SocketAddress[][] segmentOwners,
                               int numSegments,
                               short hashFunctionVersion,
                               byte[] cacheName,
                               AtomicInteger topologyId)

Specified by:

updateHashFunction in interface TransportFactory

getTransport

public Transport getTransport(Set<SocketAddress> failedServers,
                              byte[] cacheName)

Specified by:

getTransport in interface TransportFactory

getAddressTransport

public Transport getAddressTransport(SocketAddress server)

Specified by:

getAddressTransport in interface TransportFactory

getSocketAddress

public SocketAddress getSocketAddress(Object key,
                                      byte[] cacheName)

Specified by:

getSocketAddress in interface TransportFactory

getTransport

public Transport getTransport(Object key,
                              Set<SocketAddress> failedServers,
                              byte[] cacheName)

Specified by:

getTransport in interface TransportFactory

releaseTransport

public void releaseTransport(Transport transport)

Specified by:

releaseTransport in interface TransportFactory

invalidateTransport

public void invalidateTransport(SocketAddress serverAddress,
                                Transport transport)

Specified by:

invalidateTransport in interface TransportFactory

updateServers

public void updateServers(Collection<SocketAddress> newServers,
                          byte[] cacheName,
                          boolean quiet)

Specified by:

updateServers in interface TransportFactory

getServers

public Collection<SocketAddress> getServers()

getConsistentHash

public ConsistentHash getConsistentHash(byte[] cacheName)

Note that the returned ConsistentHash may not be thread-safe.

Specified by:

getConsistentHash in interface TransportFactory

getConsistentHashFactory

public ConsistentHashFactory getConsistentHashFactory()

Specified by:

getConsistentHashFactory in interface TransportFactory

isTcpNoDelay

public boolean isTcpNoDelay()

Specified by:

isTcpNoDelay in interface TransportFactory

isTcpKeepAlive

public boolean isTcpKeepAlive()

Specified by:

isTcpKeepAlive in interface TransportFactory

getMaxRetries

public int getMaxRetries()

Specified by:

getMaxRetries in interface TransportFactory

getSoTimeout

public int getSoTimeout()

Specified by:

getSoTimeout in interface TransportFactory

getConnectTimeout

public int getConnectTimeout()

Specified by:

getConnectTimeout in interface TransportFactory

getSSLContext

public SSLContext getSSLContext()

Specified by:

getSSLContext in interface TransportFactory

reset

public void reset(byte[] cacheName)

Specified by:

reset in interface TransportFactory

createTopologyId

public AtomicInteger createTopologyId(byte[] cacheName)

Specified by:

createTopologyId in interface TransportFactory

getTopologyId

public int getTopologyId(byte[] cacheName)

Specified by:

getTopologyId in interface TransportFactory

trySwitchCluster

public TcpTransportFactory.ClusterSwitchStatus trySwitchCluster(String failedClusterName,
                                                                byte[] cacheName)

Specified by:

trySwitchCluster in interface TransportFactory

checkServersAlive

public boolean checkServersAlive(Collection<SocketAddress> servers)

getMarshaller

public Marshaller getMarshaller()

Specified by:

getMarshaller in interface TransportFactory

switchToCluster

public boolean switchToCluster(String clusterName)

Specified by:

switchToCluster in interface TransportFactory

getCurrentClusterName

public String getCurrentClusterName()

Specified by:

getCurrentClusterName in interface TransportFactory

getTopologyAge

public int getTopologyAge()

Specified by:

getTopologyAge in interface TransportFactory

getBalancer

public RequestBalancingStrategy getBalancer(byte[] cacheName)

Note that the returned RequestBalancingStrategy may not be thread-safe.

getConnectionPool

public org.apache.commons.pool.impl.GenericKeyedObjectPool<SocketAddress,TcpTransport> getConnectionPool()