Modifier and Type	Class and Description
private static class	PoolThreadCache.FreeOnFinalize
private abstract static class	PoolThreadCache.MemoryRegionCache<T>
private static class	PoolThreadCache.NormalMemoryRegionCache<T> Cache used for buffers which are backed by NORMAL size.
private static class	PoolThreadCache.SubPageMemoryRegionCache<T> Cache used for buffers which are backed by TINY or SMALL size.

Access	Constructor and Description
pack-priv	PoolThreadCache(PoolArena<byte[]> heapArena, PoolArena<ByteBuffer> directArena, int smallCacheSize, int normalCacheSize, int maxCachedBufferCapacity, int freeSweepAllocationThreshold, boolean useFinalizer)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	add(PoolArena<?> area, PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity, PoolArena.SizeClass sizeClass) Add `PoolChunk` and `handle` to the cache if there is enough room.
private boolean	allocate(PoolThreadCache.MemoryRegionCache<?> cache, PooledByteBuf<T> buf, int reqCapacity)
pack-priv boolean	allocateNormal(PoolArena<?> area, PooledByteBuf<?> buf, int reqCapacity, int sizeIdx) Try to allocate a normal buffer out of the cache.
pack-priv boolean	allocateSmall(PoolArena<?> area, PooledByteBuf<?> buf, int reqCapacity, int sizeIdx) Try to allocate a small buffer out of the cache.
private PoolThreadCache.MemoryRegionCache<?>	cache(PoolArena<?> area, int sizeIdx, PoolArena.SizeClass sizeClass)
private static <T> PoolThreadCache.MemoryRegionCache<T>	cache(PoolThreadCache.MemoryRegionCache<T>[] cache, int sizeIdx)
private PoolThreadCache.MemoryRegionCache<?>	cacheForNormal(PoolArena<?> area, int sizeIdx)
private PoolThreadCache.MemoryRegionCache<?>	cacheForSmall(PoolArena<?> area, int sizeIdx)
private static void	checkCacheMayLeak(PoolThreadCache.MemoryRegionCache<?>[] caches, String type)
private static <T> PoolThreadCache.MemoryRegionCache<T>[]	createNormalCaches(int cacheSize, int maxCachedBufferCapacity, PoolArena<T> area)
private static <T> PoolThreadCache.MemoryRegionCache<T>[]	createSubPageCaches(int cacheSize, int numCaches)
pack-priv void	free(boolean finalizer) Should be called if the Thread that uses this cache is about to exist to release resources out of the cache
private static int	free(PoolThreadCache.MemoryRegionCache<?>[] caches, boolean finalizer)
private static int	free(PoolThreadCache.MemoryRegionCache<?> cache, boolean finalizer)
pack-priv static int	log2(int val)
pack-priv void	trim()
private static void	trim(PoolThreadCache.MemoryRegionCache<?>[] caches)
private static void	trim(PoolThreadCache.MemoryRegionCache<?> cache)

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

Field Detail

allocations	back to summary
private int allocations

directArena	back to summary
pack-priv final PoolArena<ByteBuffer> directArena

freed	back to summary
private final AtomicBoolean freed

freeOnFinalize	back to summary
private final PoolThreadCache.FreeOnFinalize freeOnFinalize Annotations @SuppressWarnings:unused

freeSweepAllocationThreshold	back to summary
private final int freeSweepAllocationThreshold

heapArena	back to summary
pack-priv final PoolArena<byte[]> heapArena

INTEGER_SIZE_MINUS_ONE	back to summary
private static final int INTEGER_SIZE_MINUS_ONE

logger	back to summary
private static final InternalLogger logger

normalDirectCaches	back to summary
private final PoolThreadCache.MemoryRegionCache<ByteBuffer>[] normalDirectCaches

normalHeapCaches	back to summary
private final PoolThreadCache.MemoryRegionCache<byte[]>[] normalHeapCaches

smallSubPageDirectCaches	back to summary
private final PoolThreadCache.MemoryRegionCache<ByteBuffer>[] smallSubPageDirectCaches

smallSubPageHeapCaches	back to summary
private final PoolThreadCache.MemoryRegionCache<byte[]>[] smallSubPageHeapCaches

PoolThreadCache	back to summary
pack-priv PoolThreadCache(PoolArena<byte[]> heapArena, PoolArena<ByteBuffer> directArena, int smallCacheSize, int normalCacheSize, int maxCachedBufferCapacity, int freeSweepAllocationThreshold, boolean useFinalizer)

Method Detail

add back to summary

add	back to summary
pack-priv boolean add(PoolArena<?> area, PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity, PoolArena.SizeClass sizeClass) Add `PoolChunk` and `handle` to the cache if there is enough room. Returns `true` if it fit into the cache `false` otherwise. Annotations @SuppressWarnings:unchecked, rawtypes

pack-priv boolean add(PoolArena<?> area, PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity, PoolArena.SizeClass sizeClass)

Add PoolChunk and handle to the cache if there is enough room. Returns true if it fit into the cache false otherwise.

Annotations

@SuppressWarnings:unchecked, rawtypes

allocate	back to summary
private boolean allocate(PoolThreadCache.MemoryRegionCache<?> cache, PooledByteBuf<T> buf, int reqCapacity) Annotations @SuppressWarnings:unchecked, rawtypes

allocateNormal	back to summary
pack-priv boolean allocateNormal(PoolArena<?> area, PooledByteBuf<?> buf, int reqCapacity, int sizeIdx) Try to allocate a normal buffer out of the cache. Returns `true` if successful `false` otherwise

allocateSmall	back to summary
pack-priv boolean allocateSmall(PoolArena<?> area, PooledByteBuf<?> buf, int reqCapacity, int sizeIdx) Try to allocate a small buffer out of the cache. Returns `true` if successful `false` otherwise

cache	back to summary
private PoolThreadCache.MemoryRegionCache<?> cache(PoolArena<?> area, int sizeIdx, PoolArena.SizeClass sizeClass)

cache	back to summary
private static <T> PoolThreadCache.MemoryRegionCache<T> cache(PoolThreadCache.MemoryRegionCache<T>[] cache, int sizeIdx)

cacheForNormal	back to summary
private PoolThreadCache.MemoryRegionCache<?> cacheForNormal(PoolArena<?> area, int sizeIdx)

cacheForSmall	back to summary
private PoolThreadCache.MemoryRegionCache<?> cacheForSmall(PoolArena<?> area, int sizeIdx)

checkCacheMayLeak	back to summary
private static void checkCacheMayLeak(PoolThreadCache.MemoryRegionCache<?>[] caches, String type)

createNormalCaches	back to summary
private static <T> PoolThreadCache.MemoryRegionCache<T>[] createNormalCaches(int cacheSize, int maxCachedBufferCapacity, PoolArena<T> area) Annotations @SuppressWarnings:unchecked

createSubPageCaches	back to summary
private static <T> PoolThreadCache.MemoryRegionCache<T>[] createSubPageCaches(int cacheSize, int numCaches)

free	back to summary
pack-priv void free(boolean finalizer) Should be called if the Thread that uses this cache is about to exist to release resources out of the cache

free	back to summary
private static int free(PoolThreadCache.MemoryRegionCache<?>[] caches, boolean finalizer)

free	back to summary
private static int free(PoolThreadCache.MemoryRegionCache<?> cache, boolean finalizer)

log2	back to summary
pack-priv static int log2(int val)

trim	back to summary
pack-priv void trim()

trim	back to summary
private static void trim(PoolThreadCache.MemoryRegionCache<?>[] caches)

trim	back to summary
private static void trim(PoolThreadCache.MemoryRegionCache<?> cache)

io.netty.buffer back to summary

private final Class PoolThreadCache.FreeOnFinalize

Class Inheritance

extends Object

java.lang.Object
io.netty.buffer.PoolThreadCache.FreeOnFinalize

Field Summary

Modifier and Type	Field and Description
private final PoolThreadCache	cache

Constructor Summary

Access	Constructor and Description
private	FreeOnFinalize(PoolThreadCache cache)

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

cache	back to summary
private final PoolThreadCache cache

Constructor Detail

FreeOnFinalize	back to summary
private FreeOnFinalize(PoolThreadCache cache)

Method Detail

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 @SuppressWarnings:FinalizeDeclaration, deprecation @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

@SuppressWarnings:FinalizeDeclaration, deprecation
@Override

Exceptions

Throwable:: the Exception raised by this method

io.netty.buffer back to summary

private abstract Class PoolThreadCache.MemoryRegionCache<T>

Class Inheritance

extends Object

java.lang.Object
io.netty.buffer.PoolThreadCache.MemoryRegionCache

Known Direct Subclasses

io.netty.buffer.PoolThreadCache.SubPageMemoryRegionCache, io.netty.buffer.PoolThreadCache.NormalMemoryRegionCache

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	PoolThreadCache.MemoryRegionCache.Entry<T>

Field Summary

Modifier and Type	Field and Description
private int	allocations
private final Queue<PoolThreadCache.MemoryRegionCache.Entry<T>>	queue
private static final ObjectPool<PoolThreadCache.MemoryRegionCache.Entry<T>>	RECYCLER
private final int	size
private final PoolArena.SizeClass	sizeClass

Constructor Summary

Access	Constructor and Description
pack-priv	MemoryRegionCache(int size, PoolArena.SizeClass sizeClass)

Method Summary

Modifier and Type	Method and Description
public final boolean	add(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity) Add to cache if not already full.
public final boolean	allocate(PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache) Allocate something out of the cache if possible and remove the entry from the cache.
public final int	free(boolean finalizer) Clear out this cache and free up all previous cached `PoolChunk`s and `handle`s.
private int	free(int max, boolean finalizer)
private void	freeEntry(PoolThreadCache.MemoryRegionCache.Entry<T> entry, boolean finalizer)
protected abstract void	initBuf(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache) Init the `PooledByteBuf` using the provided chunk and handle with the capacity restrictions.
private static PoolThreadCache.MemoryRegionCache.Entry<T>	newEntry(PoolChunk<?> chunk, ByteBuffer nioBuffer, long handle, int normCapacity)
public final void	trim() Free up cached `PoolChunk`s if not allocated frequently enough.

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

Field Detail

allocations	back to summary
private int allocations

queue	back to summary
private final Queue<PoolThreadCache.MemoryRegionCache.Entry<T>> queue

RECYCLER	back to summary
private static final ObjectPool<PoolThreadCache.MemoryRegionCache.Entry<T>> RECYCLER Annotations @SuppressWarnings:rawtypes

size	back to summary
private final int size

sizeClass	back to summary
private final PoolArena.SizeClass sizeClass

Constructor Detail

MemoryRegionCache	back to summary
pack-priv MemoryRegionCache(int size, PoolArena.SizeClass sizeClass)

Method Detail

add

back to summary

public final boolean add(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity)

Add to cache if not already full.

Annotations

@SuppressWarnings:unchecked

allocate	back to summary
public final boolean allocate(PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache) Allocate something out of the cache if possible and remove the entry from the cache.

free	back to summary
public final int free(boolean finalizer) Clear out this cache and free up all previous cached `PoolChunk`s and `handle`s.

free	back to summary
private int free(int max, boolean finalizer)

freeEntry	back to summary
private void freeEntry(PoolThreadCache.MemoryRegionCache.Entry<T> entry, boolean finalizer) Annotations @SuppressWarnings:unchecked, rawtypes

initBuf	back to summary
protected abstract void initBuf(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache) Init the `PooledByteBuf` using the provided chunk and handle with the capacity restrictions.

newEntry	back to summary
private static PoolThreadCache.MemoryRegionCache.Entry<T> newEntry(PoolChunk<?> chunk, ByteBuffer nioBuffer, long handle, int normCapacity) Annotations @SuppressWarnings:rawtypes

trim	back to summary
public final void trim() Free up cached `PoolChunk`s if not allocated frequently enough.

io.netty.buffer back to summary

pack-priv final Class PoolThreadCache.MemoryRegionCache.Entry<T>

Class Inheritance

extends Object

java.lang.Object
io.netty.buffer.PoolThreadCache.MemoryRegionCache.Entry

Field Summary

Modifier and Type	Field and Description
pack-priv PoolChunk<T>	chunk
pack-priv long	handle
pack-priv ByteBuffer	nioBuffer
pack-priv int	normCapacity
pack-priv final Recycler.EnhancedHandle<PoolThreadCache.MemoryRegionCache.Entry<?>>	recyclerHandle

Constructor Summary

Access	Constructor and Description
pack-priv	Entry(ObjectPool.Handle<PoolThreadCache.MemoryRegionCache.Entry<?>> recyclerHandle)

Method Summary

Modifier and Type	Method and Description
pack-priv void	recycle()
pack-priv void	unguardedRecycle()

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

Field Detail

chunk	back to summary
pack-priv PoolChunk<T> chunk

handle	back to summary
pack-priv long handle

nioBuffer	back to summary
pack-priv ByteBuffer nioBuffer

normCapacity	back to summary
pack-priv int normCapacity

recyclerHandle	back to summary
pack-priv final Recycler.EnhancedHandle<PoolThreadCache.MemoryRegionCache.Entry<?>> recyclerHandle

Constructor Detail

Entry	back to summary
pack-priv Entry(ObjectPool.Handle<PoolThreadCache.MemoryRegionCache.Entry<?>> recyclerHandle)

Method Detail

recycle	back to summary
pack-priv void recycle()

unguardedRecycle	back to summary
pack-priv void unguardedRecycle()

io.netty.buffer back to summary

private final Class PoolThreadCache.NormalMemoryRegionCache<T>

Class Inheritance

extends PoolThreadCache.MemoryRegionCache<T>

java.lang.Object
io.netty.buffer.PoolThreadCache.MemoryRegionCache
io.netty.buffer.PoolThreadCache.NormalMemoryRegionCache

Cache used for buffers which are backed by NORMAL size.

Constructor Summary

Access	Constructor and Description
pack-priv	NormalMemoryRegionCache(int size)

Method Summary

Modifier and Type	Method and Description
protected void	initBuf(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache) Implements abstract io.netty.buffer.PoolThreadCache.MemoryRegionCache.initBuf. Init the `PooledByteBuf` using the provided chunk and handle with the capacity restrictions.

Inherited from io.netty.buffer.PoolThreadCache.MemoryRegionCache:: add allocate free trim

Constructor Detail

NormalMemoryRegionCache	back to summary
pack-priv NormalMemoryRegionCache(int size)

Method Detail

initBuf back to summary

protected void initBuf(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache)

Implements abstract io.netty.buffer.PoolThreadCache.MemoryRegionCache.initBuf.

Doc from io.netty.buffer.PoolThreadCache.MemoryRegionCache.initBuf.

Init the PooledByteBuf using the provided chunk and handle with the capacity restrictions.

Annotations

@Override

io.netty.buffer back to summary

private final Class PoolThreadCache.SubPageMemoryRegionCache<T>

Class Inheritance

extends PoolThreadCache.MemoryRegionCache<T>

java.lang.Object
io.netty.buffer.PoolThreadCache.MemoryRegionCache
io.netty.buffer.PoolThreadCache.SubPageMemoryRegionCache

Cache used for buffers which are backed by TINY or SMALL size.

Constructor Summary

Access	Constructor and Description
pack-priv	SubPageMemoryRegionCache(int size)

Method Summary

Modifier and Type	Method and Description
protected void	initBuf(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache) Implements abstract io.netty.buffer.PoolThreadCache.MemoryRegionCache.initBuf. Init the `PooledByteBuf` using the provided chunk and handle with the capacity restrictions.

Inherited from io.netty.buffer.PoolThreadCache.MemoryRegionCache:: add allocate free trim

Constructor Detail

SubPageMemoryRegionCache	back to summary
pack-priv SubPageMemoryRegionCache(int size)

Method Detail

initBuf back to summary

protected void initBuf(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, PooledByteBuf<T> buf, int reqCapacity, PoolThreadCache threadCache)

Implements abstract io.netty.buffer.PoolThreadCache.MemoryRegionCache.initBuf.

Doc from io.netty.buffer.PoolThreadCache.MemoryRegionCache.initBuf.

Init the PooledByteBuf using the provided chunk and handle with the capacity restrictions.

Annotations

@Override

Modifier and Type	Field and Description
private int	allocations
pack-priv final PoolArena<ByteBuffer>	directArena
private final AtomicBoolean	freed
private final PoolThreadCache.FreeOnFinalize	freeOnFinalize
private final int	freeSweepAllocationThreshold
pack-priv final PoolArena<byte[]>	heapArena
private static final int	INTEGER_SIZE_MINUS_ONE
private static final InternalLogger	logger
private final PoolThreadCache.MemoryRegionCache<ByteBuffer>[]	normalDirectCaches
private final PoolThreadCache.MemoryRegionCache<byte[]>[]	normalHeapCaches
private final PoolThreadCache.MemoryRegionCache<ByteBuffer>[]	smallSubPageDirectCaches
private final PoolThreadCache.MemoryRegionCache<byte[]>[]	smallSubPageHeapCaches