com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd

Class RntbdClientChannelPool

java.lang.Object

io.netty.channel.pool.SimpleChannelPool

com.microsoft.azure.cosmosdb.internal.directconnectivity.rntbd.RntbdClientChannelPool

All Implemented Interfaces:

io.netty.channel.pool.ChannelPool, Closeable, AutoCloseable

public final class RntbdClientChannelPool
extends io.netty.channel.pool.SimpleChannelPool

ChannelPool implementation that enforces a maximum number of concurrent direct TCP Cosmos connections

Method Summary

Modifier and Type	Method and Description
io.netty.util.concurrent.Future<io.netty.channel.Channel>	acquire(io.netty.util.concurrent.Promise<io.netty.channel.Channel> promise)
int	channelsAcquired()
int	channelsAvailable()
void	close()
boolean	isClosed()
int	maxChannels()
int	maxRequestsPerChannel()
protected boolean	offerChannel(io.netty.channel.Channel channel) Offer a Channel back to the internal storage
protected io.netty.channel.Channel	pollChannel() Poll a Channel out of internal storage to reuse it
io.netty.util.concurrent.Future<Void>	release(io.netty.channel.Channel channel, io.netty.util.concurrent.Promise<Void> promise)
SocketAddress	remoteAddress()
int	requestQueueLength()
String	toString()
long	usedDirectMemory()
long	usedHeapMemory()

Methods inherited from class io.netty.channel.pool.SimpleChannelPool

acquire, bootstrap, closeAsync, connectChannel, handler, healthChecker, release, releaseHealthCheck

Methods inherited from class java.lang.Object

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

Method Detail

channelsAcquired

public int channelsAcquired()

channelsAvailable

public int channelsAvailable()

maxChannels

public int maxChannels()

maxRequestsPerChannel

public int maxRequestsPerChannel()

remoteAddress

public SocketAddress remoteAddress()

requestQueueLength

public int requestQueueLength()

usedDirectMemory

public long usedDirectMemory()

usedHeapMemory

public long usedHeapMemory()

isClosed

public boolean isClosed()

acquire

public io.netty.util.concurrent.Future<io.netty.channel.Channel> acquire(io.netty.util.concurrent.Promise<io.netty.channel.Channel> promise)

Specified by:

acquire in interface io.netty.channel.pool.ChannelPool

Overrides:

acquire in class io.netty.channel.pool.SimpleChannelPool

close

public void close()

Specified by:

close in interface io.netty.channel.pool.ChannelPool

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class io.netty.channel.pool.SimpleChannelPool

release

public io.netty.util.concurrent.Future<Void> release(io.netty.channel.Channel channel,
                                                     io.netty.util.concurrent.Promise<Void> promise)

Specified by:

release in interface io.netty.channel.pool.ChannelPool

Overrides:

release in class io.netty.channel.pool.SimpleChannelPool

toString

public String toString()

Overrides:

toString in class Object

offerChannel

protected boolean offerChannel(io.netty.channel.Channel channel)

Offer a Channel back to the internal storage

Maintainers: Implementations of this method must be thread-safe.

Overrides:

offerChannel in class io.netty.channel.pool.SimpleChannelPool

Parameters:

channel - the Channel to return to internal storage

Returns:

true, if the Channel could be added to internal storage; otherwise false

pollChannel

protected io.netty.channel.Channel pollChannel()

Poll a Channel out of internal storage to reuse it

Maintainers: Implementations of this method must be thread-safe and this type ensures thread safety by calling this method serially on a single-threaded EventExecutor. As a result this method need not (and should not) be synchronized.

Overrides:

pollChannel in class io.netty.channel.pool.SimpleChannelPool

Returns:

a value of null, if no Channel is ready to be reused

See Also:

acquire(Promise)