Modifier and Type	Class and Description
private static class	DefaultByteBufferPool.DefaultPooledBuffer
private static class	DefaultByteBufferPool.LeakDetector
private static class	DefaultByteBufferPool.ThreadLocalCache
private class	DefaultByteBufferPool.ThreadLocalData

Modifier and Type	Field and Description
private final DefaultByteBufferPool	arrayBackedPool
private final int	bufferSize
private volatile boolean	closed
private int	count
private volatile int	currentQueueLength
private static final AtomicIntegerFieldUpdater<DefaultByteBufferPool>	currentQueueLengthUpdater
private final boolean	direct
private final int	leakDectionPercent
private final int	maximumPoolSize
private final ConcurrentLinkedQueue<ByteBuffer>	queue
private volatile int	reclaimedThreadLocals
private static final AtomicIntegerFieldUpdater<DefaultByteBufferPool>	reclaimedThreadLocalsUpdater
private final DefaultByteBufferPool.ThreadLocalCache	threadLocalCache
private final int	threadLocalCacheSize
private final List<WeakReference<DefaultByteBufferPool.ThreadLocalData>>	threadLocalDataList

Access	Constructor and Description
public	DefaultByteBufferPool(boolean If this implementation should use direct buffers direct, int The buffer size to use bufferSize)
public	DefaultByteBufferPool(boolean If this implementation should use direct buffers direct, int The buffer size to use bufferSize, int The maximum pool size, in number of buffers, it does not include buffers in thread local caches maximumPoolSize, int The maximum number of buffers that can be stored in a thread local cache threadLocalCacheSize, int leakDecetionPercent)
public	DefaultByteBufferPool(boolean If this implementation should use direct buffers direct, int The buffer size to use bufferSize, int The maximum pool size, in number of buffers, it does not include buffers in thread local caches maximumPoolSize, int The maximum number of buffers that can be stored in a thread local cache threadLocalCacheSize)

Method Summary

Modifier and Type	Method and Description
public PooledByteBuffer	allocate() Implements io.undertow.connector.ByteBufferPool.allocate.
private void	cleanupThreadLocalData()
public void	close() Implements io.undertow.connector.ByteBufferPool.close. Closes this stream and releases any system resources associated with it.
protected void	finalize() Overrides java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object.
private void	freeInternal(ByteBuffer buffer)
public ByteBufferPool	getArrayBackedPool() Implements io.undertow.connector.ByteBufferPool.getArrayBackedPool. If this byte buffer pool corresponds to an array backed pool then this will return itself.
public int	getBufferSize() Implements io.undertow.connector.ByteBufferPool.getBufferSize.
public boolean	isDirect() Implements io.undertow.connector.ByteBufferPool.isDirect.
private void	queueIfUnderMax(ByteBuffer buffer)

Inherited from java.lang.Object:: clone equals getClass hashCode notify notifyAll toString wait wait wait

Field Detail

arrayBackedPool	back to summary
private final DefaultByteBufferPool arrayBackedPool

bufferSize	back to summary
private final int bufferSize

closed	back to summary
private volatile boolean closed

count	back to summary
private int count

currentQueueLength	back to summary
private volatile int currentQueueLength Annotations @SuppressWarnings:unused, FieldCanBeLocal

currentQueueLengthUpdater	back to summary
private static final AtomicIntegerFieldUpdater<DefaultByteBufferPool> currentQueueLengthUpdater

direct	back to summary
private final boolean direct

leakDectionPercent	back to summary
private final int leakDectionPercent

maximumPoolSize	back to summary
private final int maximumPoolSize

queue	back to summary
private final ConcurrentLinkedQueue<ByteBuffer> queue

reclaimedThreadLocals	back to summary
private volatile int reclaimedThreadLocals Annotations @SuppressWarnings:unused, FieldCanBeLocal

reclaimedThreadLocalsUpdater	back to summary
private static final AtomicIntegerFieldUpdater<DefaultByteBufferPool> reclaimedThreadLocalsUpdater

threadLocalCache	back to summary
private final DefaultByteBufferPool.ThreadLocalCache threadLocalCache

threadLocalCacheSize	back to summary
private final int threadLocalCacheSize

threadLocalDataList	back to summary
private final List<WeakReference<DefaultByteBufferPool.ThreadLocalData>> threadLocalDataList

Constructor Detail

DefaultByteBufferPool	back to summary
public DefaultByteBufferPool(boolean direct, int bufferSize) Parameters direct:boolean If this implementation should use direct buffers bufferSize:int The buffer size to use

DefaultByteBufferPool	back to summary
public DefaultByteBufferPool(boolean direct, int bufferSize, int maximumPoolSize, int threadLocalCacheSize, int leakDecetionPercent) Parameters direct:boolean If this implementation should use direct buffers bufferSize:int The buffer size to use maximumPoolSize:int The maximum pool size, in number of buffers, it does not include buffers in thread local caches threadLocalCacheSize:int The maximum number of buffers that can be stored in a thread local cache

DefaultByteBufferPool

back to summary

public DefaultByteBufferPool(boolean direct, int bufferSize, int maximumPoolSize, int threadLocalCacheSize, int leakDecetionPercent)

Parameters

direct:boolean: If this implementation should use direct buffers
bufferSize:int: The buffer size to use
maximumPoolSize:int: The maximum pool size, in number of buffers, it does not include buffers in thread local caches
threadLocalCacheSize:int: The maximum number of buffers that can be stored in a thread local cache

DefaultByteBufferPool	back to summary
public DefaultByteBufferPool(boolean direct, int bufferSize, int maximumPoolSize, int threadLocalCacheSize) Parameters direct:boolean If this implementation should use direct buffers bufferSize:int The buffer size to use maximumPoolSize:int The maximum pool size, in number of buffers, it does not include buffers in thread local caches threadLocalCacheSize:int The maximum number of buffers that can be stored in a thread local cache

DefaultByteBufferPool

back to summary

public DefaultByteBufferPool(boolean direct, int bufferSize, int maximumPoolSize, int threadLocalCacheSize)

Parameters

direct:boolean: If this implementation should use direct buffers
bufferSize:int: The buffer size to use
maximumPoolSize:int: The maximum pool size, in number of buffers, it does not include buffers in thread local caches
threadLocalCacheSize:int: The maximum number of buffers that can be stored in a thread local cache

Method Detail

allocate	back to summary
public PooledByteBuffer allocate() Implements io.undertow.connector.ByteBufferPool.allocate. Annotations @Override

allocate

back to summary

public PooledByteBuffer allocate()

Implements io.undertow.connector.ByteBufferPool.allocate.

Annotations

@Override

cleanupThreadLocalData	back to summary
private void cleanupThreadLocalData()

close back to summary

close	back to summary
public void close() Implements io.undertow.connector.ByteBufferPool.close. Doc from java.io.Closeable.close. Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. As noted in `AutoCloseable#close()`, cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the `Closeable` as closed, prior to throwing the `IOException`. Annotations @Override

public void close()

Implements io.undertow.connector.ByteBufferPool.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations

@Override

finalize back to summary

finalize	back to summary
protected void finalize() throws Throwable Overrides java.lang.Object.finalize. Doc from java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. A subclass overrides the `finalize` method to dispose of system resources or to perform other cleanup. When running in a Java virtual machine in which finalization has been disabled or removed, the garbage collector will never call `finalize()`. In a Java virtual machine in which finalization is enabled, the garbage collector might call `finalize` only after an indefinite delay. The general contract of `finalize` is that it is invoked if and when the Java virtual machine has determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, except as a result of an action taken by the finalization of some other object or class which is ready to be finalized. The `finalize` method may take any action, including making this object available again to other threads; the usual purpose of `finalize`, however, is to perform cleanup actions before the object is irrevocably discarded. For example, the finalize method for an object that represents an input/output connection might perform explicit I/O transactions to break the connection before the object is permanently discarded. The `finalize` method of class `Object` performs no special action; it simply returns normally. Subclasses of `Object` may override this definition. The Java programming language does not guarantee which thread will invoke the `finalize` method for any given object. It is guaranteed, however, that the thread that invokes finalize will not be holding any user-visible synchronization locks when finalize is invoked. If an uncaught exception is thrown by the finalize method, the exception is ignored and finalization of that object terminates. After the `finalize` method has been invoked for an object, no further action is taken until the Java virtual machine has again determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, including possible actions by other objects or classes which are ready to be finalized, at which point the object may be discarded. The `finalize` method is never invoked more than once by a Java virtual machine for any given object. Any exception thrown by the `finalize` method causes the finalization of this object to be halted, but is otherwise ignored. Annotations @Override Exceptions Throwable: the `Exception` raised by this method

protected void finalize() throws Throwable

Overrides java.lang.Object.finalize.

Doc from java.lang.Object.finalize.

Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. A subclass overrides the finalize method to dispose of system resources or to perform other cleanup.

When running in a Java virtual machine in which finalization has been disabled or removed, the garbage collector will never call finalize(). In a Java virtual machine in which finalization is enabled, the garbage collector might call finalize only after an indefinite delay.

The general contract of finalize is that it is invoked if and when the Java virtual machine has determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, except as a result of an action taken by the finalization of some other object or class which is ready to be finalized. The finalize method may take any action, including making this object available again to other threads; the usual purpose of finalize, however, is to perform cleanup actions before the object is irrevocably discarded. For example, the finalize method for an object that represents an input/output connection might perform explicit I/O transactions to break the connection before the object is permanently discarded.

The finalize method of class Object performs no special action; it simply returns normally. Subclasses of Object may override this definition.

The Java programming language does not guarantee which thread will invoke the finalize method for any given object. It is guaranteed, however, that the thread that invokes finalize will not be holding any user-visible synchronization locks when finalize is invoked. If an uncaught exception is thrown by the finalize method, the exception is ignored and finalization of that object terminates.

After the finalize method has been invoked for an object, no further action is taken until the Java virtual machine has again determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, including possible actions by other objects or classes which are ready to be finalized, at which point the object may be discarded.

The finalize method is never invoked more than once by a Java virtual machine for any given object.

Any exception thrown by the finalize method causes the finalization of this object to be halted, but is otherwise ignored.

Annotations

@Override

Exceptions

Throwable:: the Exception raised by this method

freeInternal	back to summary
private void freeInternal(ByteBuffer buffer)

getArrayBackedPool	back to summary
public ByteBufferPool getArrayBackedPool() Implements io.undertow.connector.ByteBufferPool.getArrayBackedPool. Doc from io.undertow.connector.ByteBufferPool.getArrayBackedPool. If this byte buffer pool corresponds to an array backed pool then this will return itself. Otherwise it will return an array backed pool that contains buffers of the same size. Returns:ByteBufferPool An array backed pool of the same size Annotations @Override

getArrayBackedPool

back to summary

public ByteBufferPool getArrayBackedPool()

Implements io.undertow.connector.ByteBufferPool.getArrayBackedPool.

Doc from io.undertow.connector.ByteBufferPool.getArrayBackedPool.

If this byte buffer pool corresponds to an array backed pool then this will return itself. Otherwise it will return an array backed pool that contains buffers of the same size.

Returns:ByteBufferPool

An array backed pool of the same size

Annotations

@Override

getBufferSize	back to summary
public int getBufferSize() Implements io.undertow.connector.ByteBufferPool.getBufferSize. Annotations @Override

getBufferSize

back to summary

public int getBufferSize()

Implements io.undertow.connector.ByteBufferPool.getBufferSize.

Annotations

@Override

isDirect	back to summary
public boolean isDirect() Implements io.undertow.connector.ByteBufferPool.isDirect. Annotations @Override

isDirect

back to summary

public boolean isDirect()

Implements io.undertow.connector.ByteBufferPool.isDirect.

Annotations

@Override

queueIfUnderMax	back to summary
private void queueIfUnderMax(ByteBuffer buffer)

io.undertow.server back to summary

private Class DefaultByteBufferPool.DefaultPooledBuffer

Class Inheritance

extends Object
implements PooledByteBuffer

java.lang.Object
io.undertow.server.DefaultByteBufferPool.DefaultPooledBuffer

All Implemented Interfaces

io.undertow.connector.PooledByteBuffer, java.io.Closeable, java.lang.AutoCloseable

Field Summary

Modifier and Type	Field and Description
private ByteBuffer	buffer
private final DefaultByteBufferPool.LeakDetector	leakDetector
private final DefaultByteBufferPool	pool
private volatile int	referenceCount
private static final AtomicIntegerFieldUpdater<DefaultByteBufferPool.DefaultPooledBuffer>	referenceCountUpdater

Constructor Summary

Access	Constructor and Description
pack-priv	DefaultPooledBuffer(DefaultByteBufferPool pool, ByteBuffer buffer, boolean detectLeaks)

Method Summary

Modifier and Type	Method and Description
public void	close() Implements io.undertow.connector.PooledByteBuffer.close. Closes this resource, relinquishing any underlying resources.
public ByteBuffer	getBuffer() Implements io.undertow.connector.PooledByteBuffer.getBuffer.
public boolean	isOpen() Implements io.undertow.connector.PooledByteBuffer.isOpen.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

buffer	back to summary
private ByteBuffer buffer

leakDetector	back to summary
private final DefaultByteBufferPool.LeakDetector leakDetector

pool	back to summary
private final DefaultByteBufferPool pool

referenceCount	back to summary
private volatile int referenceCount

referenceCountUpdater	back to summary
private static final AtomicIntegerFieldUpdater<DefaultByteBufferPool.DefaultPooledBuffer> referenceCountUpdater

Constructor Detail

DefaultPooledBuffer	back to summary
pack-priv DefaultPooledBuffer(DefaultByteBufferPool pool, ByteBuffer buffer, boolean detectLeaks)

Method Detail

close back to summary

close	back to summary
public void close() Implements io.undertow.connector.PooledByteBuffer.close. Doc from java.lang.AutoCloseable.close. Closes this resource, relinquishing any underlying resources. This method is invoked automatically on objects managed by the `try`-with-resources statement. Annotations @Override

public void close()

Implements io.undertow.connector.PooledByteBuffer.close.

Doc from java.lang.AutoCloseable.close.

Closes this resource, relinquishing any underlying resources. This method is invoked automatically on objects managed by the try-with-resources statement.

Annotations

@Override

getBuffer	back to summary
public ByteBuffer getBuffer() Implements io.undertow.connector.PooledByteBuffer.getBuffer. Annotations @Override

getBuffer

back to summary

public ByteBuffer getBuffer()

Implements io.undertow.connector.PooledByteBuffer.getBuffer.

Annotations

@Override

isOpen	back to summary
public boolean isOpen() Implements io.undertow.connector.PooledByteBuffer.isOpen. Annotations @Override

isOpen

back to summary

public boolean isOpen()

Implements io.undertow.connector.PooledByteBuffer.isOpen.

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

io.undertow.server back to summary

private Class DefaultByteBufferPool.LeakDetector

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.DefaultByteBufferPool.LeakDetector

Field Summary

Modifier and Type	Field and Description
private final Throwable	allocationPoint
pack-priv volatile boolean	closed

Constructor Summary

Access	Constructor and Description
private	LeakDetector()

Method Summary

Modifier and Type	Method and Description
protected void	finalize() Overrides java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object.

Inherited from java.lang.Object:: clone equals getClass hashCode notify notifyAll toString wait wait wait

Field Detail

allocationPoint	back to summary
private final Throwable allocationPoint

closed	back to summary
pack-priv volatile boolean closed

Constructor Detail

LeakDetector	back to summary
private LeakDetector()

Method Detail

finalize back to summary

protected void finalize() throws Throwable

Overrides java.lang.Object.finalize.

Doc from java.lang.Object.finalize.

The finalize method of class Object performs no special action; it simply returns normally. Subclasses of Object may override this definition.

The finalize method is never invoked more than once by a Java virtual machine for any given object.

Any exception thrown by the finalize method causes the finalization of this object to be halted, but is otherwise ignored.

Annotations

@Override

Exceptions

Throwable:: the Exception raised by this method

io.undertow.server back to summary

private Class DefaultByteBufferPool.ThreadLocalCache

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.DefaultByteBufferPool.ThreadLocalCache

Field Summary

Modifier and Type	Field and Description
pack-priv Map<Thread, DefaultByteBufferPool.ThreadLocalData>	localsByThread

Constructor Summary

Access	Constructor and Description
private	ThreadLocalCache()

Method Summary

Modifier and Type	Method and Description
pack-priv DefaultByteBufferPool.ThreadLocalData	get()
pack-priv void	remove(DefaultByteBufferPool.ThreadLocalData threadLocalData)
pack-priv void	set(DefaultByteBufferPool.ThreadLocalData threadLocalData)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

localsByThread	back to summary
pack-priv Map<Thread, DefaultByteBufferPool.ThreadLocalData> localsByThread

Constructor Detail

ThreadLocalCache	back to summary
private ThreadLocalCache()

Method Detail

get	back to summary
pack-priv DefaultByteBufferPool.ThreadLocalData get()

remove	back to summary
pack-priv void remove(DefaultByteBufferPool.ThreadLocalData threadLocalData)

set	back to summary
pack-priv void set(DefaultByteBufferPool.ThreadLocalData threadLocalData)

io.undertow.server back to summary

private Class DefaultByteBufferPool.ThreadLocalData

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.DefaultByteBufferPool.ThreadLocalData

Field Summary

Modifier and Type	Field and Description
pack-priv int	allocationDepth
pack-priv ArrayDeque<ByteBuffer>	buffers

Constructor Summary

Access	Constructor and Description
private	ThreadLocalData()

Method Summary

Modifier and Type	Method and Description
protected void	finalize() Overrides java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object.

Inherited from java.lang.Object:: clone equals getClass hashCode notify notifyAll toString wait wait wait

Field Detail

allocationDepth	back to summary
pack-priv int allocationDepth

buffers	back to summary
pack-priv ArrayDeque<ByteBuffer> buffers

Constructor Detail

ThreadLocalData	back to summary
private ThreadLocalData()

Method Detail

finalize back to summary

protected void finalize() throws Throwable

Overrides java.lang.Object.finalize.

Doc from java.lang.Object.finalize.

The finalize method of class Object performs no special action; it simply returns normally. Subclasses of Object may override this definition.

The finalize method is never invoked more than once by a Java virtual machine for any given object.

Any exception thrown by the finalize method causes the finalization of this object to be halted, but is otherwise ignored.

Annotations

@Override

Exceptions

Throwable:: the Exception raised by this method

public Class DefaultByteBufferPool

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class DefaultByteBufferPool.DefaultPooledBuffer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class DefaultByteBufferPool.LeakDetector

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class DefaultByteBufferPool.ThreadLocalCache

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class DefaultByteBufferPool.ThreadLocalData

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail