Class PoolThreadCache.MemoryRegionCache<T>

java.lang.Object

io.netty.buffer.PoolThreadCache.MemoryRegionCache<T>

Direct Known Subclasses:

PoolThreadCache.NormalMemoryRegionCache, PoolThreadCache.SubPageMemoryRegionCache

Enclosing class:

PoolThreadCache

private abstract static class PoolThreadCache.MemoryRegionCache<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	PoolThreadCache.MemoryRegionCache.Entry<T>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MemoryRegionCache(int size, PoolArena.SizeClass sizeClass)

Method Summary

Modifier and Type	Method	Description
final boolean	add(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity)	Add to cache if not already full.
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.
final int	free(boolean finalizer)	Clear out this cache and free up all previous cached PoolChunks and handles.
private int	free(int max, boolean finalizer)
private void	freeEntry(PoolThreadCache.MemoryRegionCache.Entry 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	newEntry(PoolChunk<?> chunk, ByteBuffer nioBuffer, long handle, int normCapacity)
final void	trim()	Free up cached PoolChunks if not allocated frequently enough.

Methods inherited from class Object

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

Field Details

size

private final int size

queue

private final Queue<PoolThreadCache.MemoryRegionCache.Entry<T>> queue

sizeClass

private final PoolArena.SizeClass sizeClass

allocations

private int allocations

RECYCLER

private static final ObjectPool<PoolThreadCache.MemoryRegionCache.Entry> RECYCLER

Constructor Details

MemoryRegionCache

MemoryRegionCache(int size,
 PoolArena.SizeClass sizeClass)

Method Details

initBuf

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.

add

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

Add to cache if not already full.

allocate

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

public final int free(boolean finalizer)

Clear out this cache and free up all previous cached PoolChunks and handles.

free

private int free(int max,
 boolean finalizer)

trim

public final void trim()

Free up cached PoolChunks if not allocated frequently enough.

freeEntry

private void freeEntry(PoolThreadCache.MemoryRegionCache.Entry entry,
 boolean finalizer)

newEntry

private static PoolThreadCache.MemoryRegionCache.Entry newEntry(PoolChunk<?> chunk,
 ByteBuffer nioBuffer,
 long handle,
 int normCapacity)