Package org.asynchttpclient.netty.channel

Class CombinedConnectionSemaphore

java.lang.Object

org.asynchttpclient.netty.channel.PerHostConnectionSemaphore

org.asynchttpclient.netty.channel.CombinedConnectionSemaphore

All Implemented Interfaces:

ConnectionSemaphore

public class CombinedConnectionSemaphore
extends PerHostConnectionSemaphore

A combined ConnectionSemaphore with two limits - a global limit and a per-host limit

Field Summary

Fields

Modifier and Type	Field	Description
protected MaxConnectionSemaphore	globalMaxConnectionSemaphore

Fields inherited from class org.asynchttpclient.netty.channel.PerHostConnectionSemaphore

acquireTimeout, freeChannelsPerHost, maxConnectionsPerHost, tooManyConnectionsPerHost

Method Summary

Modifier and Type	Method	Description
void	acquireChannelLock(Object partitionKey)
void	acquireChannelLock(Object partitionKey, boolean nonBlocking)	Acquires a connection permit for partitionKey, optionally without blocking.
protected long	acquireGlobal(Object partitionKey)
protected long	acquireGlobalTimed(Object partitionKey)
void	releaseChannelLock(Object partitionKey)
protected void	releaseGlobal(Object partitionKey)

Methods inherited from class org.asynchttpclient.netty.channel.PerHostConnectionSemaphore

getFreeConnectionsForHost

Methods inherited from class java.lang.Object

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

Field Detail

globalMaxConnectionSemaphore

protected final MaxConnectionSemaphore globalMaxConnectionSemaphore

Method Detail

acquireChannelLock

public void acquireChannelLock(Object partitionKey)
                        throws IOException

Specified by:

acquireChannelLock in interface ConnectionSemaphore

Overrides:

acquireChannelLock in class PerHostConnectionSemaphore

Throws:

IOException

acquireChannelLock

public void acquireChannelLock(Object partitionKey,
                               boolean nonBlocking)
                        throws IOException

Description copied from interface: ConnectionSemaphore

Acquires a connection permit for partitionKey, optionally without blocking.

When nonBlocking is true a permit must be taken without waiting — the too-many-connections exception is thrown immediately if none is free. This is used when the caller runs on a Netty event-loop thread (a redirect / 401 / 407 / retry replay re-enters the send path on the event loop), where waiting for the configured acquire timeout would freeze the loop and stall every other connection it serves. When false this behaves exactly like ConnectionSemaphore.acquireChannelLock(Object).

The default implementation ignores the hint and delegates to the blocking ConnectionSemaphore.acquireChannelLock(Object), preserving the behaviour of custom implementations; the built-in limiters override it to honour nonBlocking.

Specified by:

acquireChannelLock in interface ConnectionSemaphore

Overrides:

acquireChannelLock in class PerHostConnectionSemaphore

Parameters:

partitionKey - the per-host partition key the permit is scoped to

nonBlocking - true to fail fast instead of waiting for a permit

Throws:

IOException - if no permit could be acquired

releaseGlobal

protected void releaseGlobal(Object partitionKey)

acquireGlobal

protected long acquireGlobal(Object partitionKey)
                      throws IOException

Throws:

IOException

acquireGlobalTimed

protected long acquireGlobalTimed(Object partitionKey)
                           throws IOException

Throws:

IOException

releaseChannelLock

public void releaseChannelLock(Object partitionKey)

Specified by:

releaseChannelLock in interface ConnectionSemaphore

Overrides:

releaseChannelLock in class PerHostConnectionSemaphore