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

Access	Constructor and Description
pack-priv	PoolThreadCache(PoolArena arena, int smallCacheSize, int normalCacheSize, int maxCachedBufferCapacity, int freeSweepAllocationThreshold)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	add(PoolArena area, PoolChunk chunk, long handle, int normCapacity, PoolArena.SizeClass sizeClass) Add `PoolChunk` and `handle` to the cache if there is enough room.
private UntetheredMemory	allocate(PoolThreadCache.MemoryRegionCache cache, int size)
pack-priv UntetheredMemory	allocateNormal(PoolArena area, int size, int sizeIdx) Try to allocate a normal buffer out of the cache.
pack-priv UntetheredMemory	allocateSmall(int size, 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 PoolThreadCache.MemoryRegionCache	cache(PoolThreadCache.MemoryRegionCache[] cache, int sizeIdx)
private PoolThreadCache.MemoryRegionCache	cacheForNormal(PoolArena area, int sizeIdx)
private PoolThreadCache.MemoryRegionCache	cacheForSmall(int sizeIdx)
private static PoolThreadCache.MemoryRegionCache[]	createNormalCaches(int cacheSize, int maxCachedBufferCapacity, PoolArena area)
private static PoolThreadCache.MemoryRegionCache[]	createSubPageCaches(int cacheSize, int numCaches)
pack-priv void	free() 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)
private static int	free(PoolThreadCache.MemoryRegionCache cache)
pack-priv PoolArena	getArena()
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

arena	back to summary
private final PoolArena arena

arenaReferenceCounter	back to summary
pack-priv final AtomicInteger arenaReferenceCounter

freeSweepAllocationThreshold	back to summary
private final int freeSweepAllocationThreshold

INTEGER_SIZE_MINUS_ONE	back to summary
private static final int INTEGER_SIZE_MINUS_ONE

logger	back to summary
private static final InternalLogger logger

normalCaches	back to summary
private final PoolThreadCache.MemoryRegionCache[] normalCaches

smallSubPageCaches	back to summary
private final PoolThreadCache.MemoryRegionCache[] smallSubPageCaches

PoolThreadCache	back to summary
pack-priv PoolThreadCache(PoolArena arena, int smallCacheSize, int normalCacheSize, int maxCachedBufferCapacity, int freeSweepAllocationThreshold)

Method Detail

add	back to summary
pack-priv boolean add(PoolArena area, PoolChunk chunk, 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.

allocate	back to summary
private UntetheredMemory allocate(PoolThreadCache.MemoryRegionCache cache, int size)

allocateNormal	back to summary
pack-priv UntetheredMemory allocateNormal(PoolArena area, int size, int sizeIdx) Try to allocate a normal buffer out of the cache. Returns `true` if successful `false` otherwise

allocateSmall	back to summary
pack-priv UntetheredMemory allocateSmall(int size, 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 PoolThreadCache.MemoryRegionCache cache(PoolThreadCache.MemoryRegionCache[] cache, int sizeIdx)

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

cacheForSmall	back to summary
private PoolThreadCache.MemoryRegionCache cacheForSmall(int sizeIdx)

createNormalCaches	back to summary
private static PoolThreadCache.MemoryRegionCache[] createNormalCaches(int cacheSize, int maxCachedBufferCapacity, PoolArena area)

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

free	back to summary
pack-priv void free() 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)

free	back to summary
private static int free(PoolThreadCache.MemoryRegionCache cache)

getArena	back to summary
pack-priv PoolArena getArena()

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.netty5.buffer.pool back to summary

private abstract Class PoolThreadCache.MemoryRegionCache

Class Inheritance

extends Object

java.lang.Object
io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache

Known Direct Subclasses

io.netty5.buffer.pool.PoolThreadCache.SubPageMemoryRegionCache, io.netty5.buffer.pool.PoolThreadCache.NormalMemoryRegionCache

Nested and Inner Type Summary

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

Field Summary

Modifier and Type	Field and Description
private int	allocations
private final Queue<PoolThreadCache.MemoryRegionCache.Entry>	queue
private static final ObjectPool<PoolThreadCache.MemoryRegionCache.Entry>	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 chunk, long handle, int normCapacity) Add to cache if not already full.
public final UntetheredMemory	allocate(int size, PoolThreadCache threadCache) Allocate something out of the cache if possible and remove the entry from the cache.
protected abstract UntetheredMemory	allocBuf(PoolChunk chunk, long handle, int size, PoolThreadCache threadCache) Allocate a new `UntetheredMemory` using the provided chunk and handle with the capacity restrictions.
public final int	free() Clear out this cache and free up all previous cached `PoolChunk`s and `handle`s.
private int	free(int max)
private void	freeEntry(PoolThreadCache.MemoryRegionCache.Entry entry)
private static PoolThreadCache.MemoryRegionCache.Entry	newEntry(PoolChunk chunk, 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> queue

RECYCLER	back to summary
private static final ObjectPool<PoolThreadCache.MemoryRegionCache.Entry> RECYCLER

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 chunk, long handle, int normCapacity) Add to cache if not already full.

allocate	back to summary
public final UntetheredMemory allocate(int size, PoolThreadCache threadCache) Allocate something out of the cache if possible and remove the entry from the cache.

allocBuf	back to summary
protected abstract UntetheredMemory allocBuf(PoolChunk chunk, long handle, int size, PoolThreadCache threadCache) Allocate a new `UntetheredMemory` using the provided chunk and handle with the capacity restrictions.

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

free	back to summary
private int free(int max)

freeEntry	back to summary
private void freeEntry(PoolThreadCache.MemoryRegionCache.Entry entry)

newEntry	back to summary
private static PoolThreadCache.MemoryRegionCache.Entry newEntry(PoolChunk chunk, long handle, int normCapacity)

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

io.netty5.buffer.pool back to summary

pack-priv final Class PoolThreadCache.MemoryRegionCache.Entry

Class Inheritance

extends Object

java.lang.Object
io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.Entry

Field Summary

Modifier and Type	Field and Description
pack-priv PoolChunk	chunk
pack-priv long	handle
pack-priv int	normCapacity
pack-priv final ObjectPool.Handle<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()

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 chunk

handle	back to summary
pack-priv long handle

normCapacity	back to summary
pack-priv int normCapacity

recyclerHandle	back to summary
pack-priv final ObjectPool.Handle<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()

io.netty5.buffer.pool back to summary

private final Class PoolThreadCache.NormalMemoryRegionCache

Class Inheritance

extends MemoryRegionCache

java.lang.Object
io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache
io.netty5.buffer.pool.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 UntetheredMemory	allocBuf(PoolChunk chunk, long handle, int size, PoolThreadCache threadCache) Implements abstract io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.allocBuf. Allocate a new `UntetheredMemory` using the provided chunk and handle with the capacity restrictions.

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

Constructor Detail

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

Method Detail

allocBuf back to summary

protected UntetheredMemory allocBuf(PoolChunk chunk, long handle, int size, PoolThreadCache threadCache)

Implements abstract io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.allocBuf.

Doc from io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.allocBuf.

Allocate a new UntetheredMemory using the provided chunk and handle with the capacity restrictions.

Annotations

@Override

io.netty5.buffer.pool back to summary

private final Class PoolThreadCache.SubPageMemoryRegionCache

Class Inheritance

extends MemoryRegionCache

java.lang.Object
io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache
io.netty5.buffer.pool.PoolThreadCache.SubPageMemoryRegionCache

Cache used for buffers which are backed by SMALL size.

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
protected UntetheredMemory	allocBuf(PoolChunk chunk, long handle, int size, PoolThreadCache threadCache) Implements abstract io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.allocBuf. Allocate a new `UntetheredMemory` using the provided chunk and handle with the capacity restrictions.

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

Constructor Detail

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

Method Detail

allocBuf back to summary

protected UntetheredMemory allocBuf(PoolChunk chunk, long handle, int size, PoolThreadCache threadCache)

Implements abstract io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.allocBuf.

Doc from io.netty5.buffer.pool.PoolThreadCache.MemoryRegionCache.allocBuf.

Allocate a new UntetheredMemory using the provided chunk and handle with the capacity restrictions.

Annotations

@Override

Modifier and Type	Field and Description
private int	allocations
private final PoolArena	arena
pack-priv final AtomicInteger	arenaReferenceCounter
private final int	freeSweepAllocationThreshold
private static final int	INTEGER_SIZE_MINUS_ONE
private static final InternalLogger	logger
private final PoolThreadCache.MemoryRegionCache[]	normalCaches
private final PoolThreadCache.MemoryRegionCache[]	smallSubPageCaches