org.quickserver.net.client.pool

Class BlockingClientPool

java.lang.Object

org.quickserver.net.client.pool.BlockingClientPool

public class BlockingClientPool
extends java.lang.Object

A generic Socket Pool implementation using BlockingClient of QuickServer Client API

Author:

Akshathkumar Shetty

Constructor Summary

Constructors

Constructor and Description
BlockingClientPool(java.lang.String name, PoolableBlockingClient poolableBlockingClient)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkAllNodes()
void	close()
PooledBlockingClient	getBlockingClient()
PooledBlockingClient	getBlockingClient(ClientInfo clientInfo)
HostMonitoringService	getHostMonitoringService()
int	getIdlePoolSize()
int	getLogPoolStatsTimeInMinute()
int	getMaxPoolSize()
int	getMinPoolSize()
java.lang.String	getName()
PooledBlockingClient[]	getOneBlockingClientForAllActiveHosts()
PoolableBlockingClient	getPoolableBlockingClient()
int	getPoolSize(SocketBasedHost host)
java.lang.String	getStats()
java.lang.String	getStats(SocketBasedHost host)
void	init()
boolean	isDebug()
void	returnBlockingClient(PooledBlockingClient pooledBlockingClient)
void	sendNoOp()
void	setDebug(boolean aDebug)
void	setIdlePoolSize(int idlePoolSize)
void	setLogPoolStatsTimeInMinute(int logPoolStatsTimeInMinute)
void	setMaxPoolSize(int maxPoolSize)
void	setMinPoolSize(int minPoolSize)
void	setName(java.lang.String name)
void	setPoolableBlockingClient(PoolableBlockingClient poolableBlockingClient)
static void	test()
java.lang.String	toStirng()

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingClientPool

public BlockingClientPool(java.lang.String name,
                  PoolableBlockingClient poolableBlockingClient)

Method Detail

isDebug

public boolean isDebug()

setDebug

public void setDebug(boolean aDebug)

test

public static void test()

init

public void init()

getBlockingClient

public PooledBlockingClient getBlockingClient()

checkAllNodes

public void checkAllNodes()

getPoolSize

public int getPoolSize(SocketBasedHost host)

Parameters:

host -

Returns:

-1 if read lock failed!

getOneBlockingClientForAllActiveHosts

public PooledBlockingClient[] getOneBlockingClientForAllActiveHosts()

getBlockingClient

public PooledBlockingClient getBlockingClient(ClientInfo clientInfo)

returnBlockingClient

public void returnBlockingClient(PooledBlockingClient pooledBlockingClient)

getStats

public java.lang.String getStats()

getStats

public java.lang.String getStats(SocketBasedHost host)
                          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

close

public void close()

sendNoOp

public void sendNoOp()

getPoolableBlockingClient

public PoolableBlockingClient getPoolableBlockingClient()

setPoolableBlockingClient

public void setPoolableBlockingClient(PoolableBlockingClient poolableBlockingClient)

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getMinPoolSize

public int getMinPoolSize()

setMinPoolSize

public void setMinPoolSize(int minPoolSize)

getMaxPoolSize

public int getMaxPoolSize()

setMaxPoolSize

public void setMaxPoolSize(int maxPoolSize)

getIdlePoolSize

public int getIdlePoolSize()

setIdlePoolSize

public void setIdlePoolSize(int idlePoolSize)

getHostMonitoringService

public HostMonitoringService getHostMonitoringService()

getLogPoolStatsTimeInMinute

public int getLogPoolStatsTimeInMinute()

setLogPoolStatsTimeInMinute

public void setLogPoolStatsTimeInMinute(int logPoolStatsTimeInMinute)

toStirng

public java.lang.String toStirng()