com.mongodb

Class PooledConnectionProvider

java.lang.Object

com.mongodb.PooledConnectionProvider

class PooledConnectionProvider
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	PooledConnectionProvider.ConnectionItemFactory

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	closed
private java.lang.String	clusterId
private ConnectionFactory	connectionFactory
private ConnectionPoolListener	connectionPoolListener
private java.util.concurrent.atomic.AtomicInteger	generation
private boolean	hasWorked
private static java.util.logging.Logger	LOGGER
private java.lang.Runnable	maintenanceTask
private ConcurrentPool<Connection>	pool
private ServerAddress	serverAddress
private ConnectionPoolSettings	settings
private java.util.concurrent.ExecutorService	sizeMaintenanceTimer
private java.util.concurrent.atomic.AtomicInteger	waitQueueSize

Constructor Summary

Constructors

Constructor and Description
PooledConnectionProvider(java.lang.String clusterId, ServerAddress serverAddress, ConnectionFactory connectionFactory, ConnectionPoolSettings settings, ConnectionPoolListener connectionPoolListener)

Method Summary

Modifier and Type	Method and Description
void	close()
private java.lang.Runnable	createMaintenanceTask()
private java.util.concurrent.ExecutorService	createTimer()
void	doMaintenance() Synchronously prune idle connections and ensure the minimum pool size.
private boolean	expired(long startTime, long curTime, long maxTime)
private boolean	fromPreviousGeneration(Connection connection)
Connection	get()
Connection	get(long timeout, java.util.concurrent.TimeUnit timeUnit)
boolean	hasWorked()
void	invalidate()
private boolean	pastMaxIdleTime(Connection connection)
private boolean	pastMaxLifeTime(Connection connection)
void	release(Connection connection)
private boolean	shouldEnsureMinSize()
private boolean	shouldPrune()
private boolean	shouldPrune(Connection connection)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final java.util.logging.Logger LOGGER

pool

private final ConcurrentPool<Connection> pool

settings

private final ConnectionPoolSettings settings

waitQueueSize

private final java.util.concurrent.atomic.AtomicInteger waitQueueSize

generation

private final java.util.concurrent.atomic.AtomicInteger generation

sizeMaintenanceTimer

private final java.util.concurrent.ExecutorService sizeMaintenanceTimer

clusterId

private final java.lang.String clusterId

serverAddress

private final ServerAddress serverAddress

maintenanceTask

private final java.lang.Runnable maintenanceTask

connectionPoolListener

private final ConnectionPoolListener connectionPoolListener

connectionFactory

private final ConnectionFactory connectionFactory

closed

private volatile boolean closed

hasWorked

private volatile boolean hasWorked

Constructor Detail

PooledConnectionProvider

public PooledConnectionProvider(java.lang.String clusterId,
                                ServerAddress serverAddress,
                                ConnectionFactory connectionFactory,
                                ConnectionPoolSettings settings,
                                ConnectionPoolListener connectionPoolListener)

Method Detail

get

public Connection get()

get

public Connection get(long timeout,
                      java.util.concurrent.TimeUnit timeUnit)

release

public void release(Connection connection)

hasWorked

public boolean hasWorked()

close

public void close()

doMaintenance

public void doMaintenance()

Synchronously prune idle connections and ensure the minimum pool size.

createMaintenanceTask

private java.lang.Runnable createMaintenanceTask()

createTimer

private java.util.concurrent.ExecutorService createTimer()

shouldEnsureMinSize

private boolean shouldEnsureMinSize()

shouldPrune

private boolean shouldPrune()

shouldPrune

private boolean shouldPrune(Connection connection)

pastMaxIdleTime

private boolean pastMaxIdleTime(Connection connection)

pastMaxLifeTime

private boolean pastMaxLifeTime(Connection connection)

fromPreviousGeneration

private boolean fromPreviousGeneration(Connection connection)

expired

private boolean expired(long startTime,
                        long curTime,
                        long maxTime)

invalidate

public void invalidate()