Class PoolArena<T>

java.lang.Object

io.netty.buffer.PoolArena<T>

All Implemented Interfaces:

PoolArenaMetric, SizeClassesMetric

Direct Known Subclasses:

PoolArena.DirectArena, PoolArena.HeapArena

abstract class PoolArena<T>
extends Object
implements PoolArenaMetric

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	PoolArena.DirectArena
(package private) static final class	PoolArena.HeapArena
(package private) static enum	PoolArena.SizeClass

Field Summary

Fields

Modifier and Type	Field	Description
private final LongCounter	activeBytesHuge
private final LongCounter	allocationsHuge
private long	allocationsNormal
private final LongCounter	allocationsSmall
private final List<PoolChunkListMetric>	chunkListMetrics
private final LongCounter	deallocationsHuge
private long	deallocationsNormal
private long	deallocationsSmall
private static final boolean	HAS_UNSAFE
private final ReentrantLock	lock
(package private) final AtomicInteger	numThreadCaches
(package private) final PooledByteBufAllocator	parent
private final PoolChunkList<T>	q000
private final PoolChunkList<T>	q025
private final PoolChunkList<T>	q050
private final PoolChunkList<T>	q075
private final PoolChunkList<T>	q100
private final PoolChunkList<T>	qInit
(package private) final SizeClasses	sizeClass
(package private) final PoolSubpage<T>[]	smallSubpagePools

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PoolArena(PooledByteBufAllocator parent, SizeClasses sizeClass)

Method Summary

Modifier and Type	Method	Description
(package private) PooledByteBuf<T>	allocate(PoolThreadCache cache, int reqCapacity, int maxCapacity)
private void	allocate(PoolThreadCache cache, PooledByteBuf<T> buf, int reqCapacity)
private void	allocateHuge(PooledByteBuf<T> buf, int reqCapacity)
private void	allocateNormal(PooledByteBuf<T> buf, int reqCapacity, int sizeIdx, PoolThreadCache threadCache)
private static void	appendPoolSubPages(StringBuilder buf, PoolSubpage<?>[] subpages)
List<PoolChunkListMetric>	chunkLists()	Returns an unmodifiable List which holds PoolChunkListMetrics.
protected abstract void	destroyChunk(PoolChunk<T> chunk)
private void	destroyPoolChunkLists(PoolChunkList<T>... chunkLists)
private static void	destroyPoolSubPages(PoolSubpage<?>[] pages)
protected final void	finalize()
(package private) void	free(PoolChunk<T> chunk, ByteBuffer nioBuffer, long handle, int normCapacity, PoolThreadCache cache)
(package private) void	freeChunk(PoolChunk<T> chunk, long handle, int normCapacity, PoolArena.SizeClass sizeClass, ByteBuffer nioBuffer, boolean finalizer)
private void	incSmallAllocation()
(package private) abstract boolean	isDirect()
(package private) void	lock()
protected abstract void	memoryCopy(T src, int srcOffset, PooledByteBuf<T> dst, int length)
protected abstract PooledByteBuf<T>	newByteBuf(int maxCapacity)
protected abstract PoolChunk<T>	newChunk(int pageSize, int maxPageIdx, int pageShifts, int chunkSize)
private PoolSubpage<T>[]	newSubpagePoolArray(int size)
private PoolSubpage<T>	newSubpagePoolHead(int index)
protected abstract PoolChunk<T>	newUnpooledChunk(int capacity)
int	normalizeSize(int size)	Normalizes usable size that would result from allocating an object with the specified size and alignment.
long	numActiveAllocations()	Return the number of currently active allocations.
long	numActiveBytes()	Return the number of active bytes that are currently allocated by the arena.
long	numActiveHugeAllocations()	Return the number of currently active huge allocations.
long	numActiveNormalAllocations()	Return the number of currently active normal allocations.
long	numActiveSmallAllocations()	Return the number of currently active small allocations.
long	numActiveTinyAllocations()	Return the number of currently active tiny allocations.
long	numAllocations()	Return the number of allocations done via the arena.
int	numChunkLists()	Returns the number of chunk lists for the arena.
long	numDeallocations()	Return the number of deallocations done via the arena.
long	numHugeAllocations()	Return the number of huge allocations done via the arena.
long	numHugeDeallocations()	Return the number of huge deallocations done via the arena.
long	numNormalAllocations()	Return the number of normal allocations done via the arena.
long	numNormalDeallocations()	Return the number of normal deallocations done via the arena.
long	numPinnedBytes()	Return an estimate of the number of bytes that are currently pinned to buffer instances, by the arena.
long	numSmallAllocations()	Return the number of small allocations done via the arena.
long	numSmallDeallocations()	Return the number of small deallocations done via the arena.
int	numSmallSubpages()	Returns the number of small sub-pages for the arena.
int	numThreadCaches()	Returns the number of thread caches backed by this arena.
long	numTinyAllocations()	Return the number of tiny allocations done via the arena.
long	numTinyDeallocations()	Return the number of tiny deallocations done via the arena.
int	numTinySubpages()	Returns the number of tiny sub-pages for the arena.
long	pageIdx2size(int pageIdx)	Computes size from lookup table according to pageIdx.
long	pageIdx2sizeCompute(int pageIdx)	Computes size according to pageIdx.
int	pages2pageIdx(int pages)	Normalizes request size up to the nearest pageSize class.
int	pages2pageIdxFloor(int pages)	Normalizes request size down to the nearest pageSize class.
(package private) void	reallocate(PooledByteBuf<T> buf, int newCapacity)
int	size2SizeIdx(int size)	Normalizes request size up to the nearest size class.
private static PoolArena.SizeClass	sizeClass(long handle)
int	sizeIdx2size(int sizeIdx)	Computes size from lookup table according to sizeIdx.
int	sizeIdx2sizeCompute(int sizeIdx)	Computes size according to sizeIdx.
List<PoolSubpageMetric>	smallSubpages()	Returns an unmodifiable List which holds PoolSubpageMetrics for small sub-pages.
private static List<PoolSubpageMetric>	subPageMetricList(PoolSubpage<?>[] pages)
private void	tcacheAllocateNormal(PoolThreadCache cache, PooledByteBuf<T> buf, int reqCapacity, int sizeIdx)
private void	tcacheAllocateSmall(PoolThreadCache cache, PooledByteBuf<T> buf, int reqCapacity, int sizeIdx)
List<PoolSubpageMetric>	tinySubpages()	Returns an unmodifiable List which holds PoolSubpageMetrics for tiny sub-pages.
String	toString()
(package private) void	unlock()

Methods inherited from class Object

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

Field Details

HAS_UNSAFE

private static final boolean HAS_UNSAFE

parent

final PooledByteBufAllocator parent

smallSubpagePools

final PoolSubpage<T>[] smallSubpagePools

q050

private final PoolChunkList<T> q050

q025

private final PoolChunkList<T> q025

q000

private final PoolChunkList<T> q000

qInit

private final PoolChunkList<T> qInit

q075

private final PoolChunkList<T> q075

q100

private final PoolChunkList<T> q100

chunkListMetrics

private final List<PoolChunkListMetric> chunkListMetrics

allocationsNormal

private long allocationsNormal

allocationsSmall

private final LongCounter allocationsSmall

allocationsHuge

private final LongCounter allocationsHuge

activeBytesHuge

private final LongCounter activeBytesHuge

deallocationsSmall

private long deallocationsSmall

deallocationsNormal

private long deallocationsNormal

deallocationsHuge

private final LongCounter deallocationsHuge

numThreadCaches

final AtomicInteger numThreadCaches

lock

private final ReentrantLock lock

sizeClass

final SizeClasses sizeClass

Constructor Details

PoolArena

protected PoolArena(PooledByteBufAllocator parent,
 SizeClasses sizeClass)

Method Details

newSubpagePoolHead

private PoolSubpage<T> newSubpagePoolHead(int index)

newSubpagePoolArray

private PoolSubpage<T>[] newSubpagePoolArray(int size)

isDirect

abstract boolean isDirect()

allocate

PooledByteBuf<T> allocate(PoolThreadCache cache,
 int reqCapacity,
 int maxCapacity)

allocate

private void allocate(PoolThreadCache cache,
 PooledByteBuf<T> buf,
 int reqCapacity)

tcacheAllocateSmall

private void tcacheAllocateSmall(PoolThreadCache cache,
 PooledByteBuf<T> buf,
 int reqCapacity,
 int sizeIdx)

tcacheAllocateNormal

private void tcacheAllocateNormal(PoolThreadCache cache,
 PooledByteBuf<T> buf,
 int reqCapacity,
 int sizeIdx)

allocateNormal

private void allocateNormal(PooledByteBuf<T> buf,
 int reqCapacity,
 int sizeIdx,
 PoolThreadCache threadCache)

incSmallAllocation

private void incSmallAllocation()

allocateHuge

private void allocateHuge(PooledByteBuf<T> buf,
 int reqCapacity)

free

void free(PoolChunk<T> chunk,
 ByteBuffer nioBuffer,
 long handle,
 int normCapacity,
 PoolThreadCache cache)

sizeClass

private static PoolArena.SizeClass sizeClass(long handle)

freeChunk

void freeChunk(PoolChunk<T> chunk,
 long handle,
 int normCapacity,
 PoolArena.SizeClass sizeClass,
 ByteBuffer nioBuffer,
 boolean finalizer)

reallocate

void reallocate(PooledByteBuf<T> buf,
 int newCapacity)

numThreadCaches

public int numThreadCaches()

Description copied from interface: PoolArenaMetric

Returns the number of thread caches backed by this arena.

Specified by:

numThreadCaches in interface PoolArenaMetric

numTinySubpages

public int numTinySubpages()

Description copied from interface: PoolArenaMetric

Returns the number of tiny sub-pages for the arena.

Specified by:

numTinySubpages in interface PoolArenaMetric

numSmallSubpages

public int numSmallSubpages()

Description copied from interface: PoolArenaMetric

Returns the number of small sub-pages for the arena.

Specified by:

numSmallSubpages in interface PoolArenaMetric

numChunkLists

public int numChunkLists()

Description copied from interface: PoolArenaMetric

Returns the number of chunk lists for the arena.

Specified by:

numChunkLists in interface PoolArenaMetric

tinySubpages

public List<PoolSubpageMetric> tinySubpages()

Description copied from interface: PoolArenaMetric

Returns an unmodifiable List which holds PoolSubpageMetrics for tiny sub-pages.

Specified by:

tinySubpages in interface PoolArenaMetric

smallSubpages

public List<PoolSubpageMetric> smallSubpages()

Description copied from interface: PoolArenaMetric

Returns an unmodifiable List which holds PoolSubpageMetrics for small sub-pages.

Specified by:

smallSubpages in interface PoolArenaMetric

chunkLists

public List<PoolChunkListMetric> chunkLists()

Description copied from interface: PoolArenaMetric

Returns an unmodifiable List which holds PoolChunkListMetrics.

Specified by:

chunkLists in interface PoolArenaMetric

subPageMetricList

private static List<PoolSubpageMetric> subPageMetricList(PoolSubpage<?>[] pages)

numAllocations

public long numAllocations()

Description copied from interface: PoolArenaMetric

Return the number of allocations done via the arena. This includes all sizes.

Specified by:

numAllocations in interface PoolArenaMetric

numTinyAllocations

public long numTinyAllocations()

Description copied from interface: PoolArenaMetric

Return the number of tiny allocations done via the arena.

Specified by:

numTinyAllocations in interface PoolArenaMetric

numSmallAllocations

public long numSmallAllocations()

Description copied from interface: PoolArenaMetric

Return the number of small allocations done via the arena.

Specified by:

numSmallAllocations in interface PoolArenaMetric

numNormalAllocations

public long numNormalAllocations()

Description copied from interface: PoolArenaMetric

Return the number of normal allocations done via the arena.

Specified by:

numNormalAllocations in interface PoolArenaMetric

numDeallocations

public long numDeallocations()

Description copied from interface: PoolArenaMetric

Return the number of deallocations done via the arena. This includes all sizes.

Specified by:

numDeallocations in interface PoolArenaMetric

numTinyDeallocations

public long numTinyDeallocations()

Description copied from interface: PoolArenaMetric

Return the number of tiny deallocations done via the arena.

Specified by:

numTinyDeallocations in interface PoolArenaMetric

numSmallDeallocations

public long numSmallDeallocations()

Description copied from interface: PoolArenaMetric

Return the number of small deallocations done via the arena.

Specified by:

numSmallDeallocations in interface PoolArenaMetric

numNormalDeallocations

public long numNormalDeallocations()

Description copied from interface: PoolArenaMetric

Return the number of normal deallocations done via the arena.

Specified by:

numNormalDeallocations in interface PoolArenaMetric

numHugeAllocations

public long numHugeAllocations()

Description copied from interface: PoolArenaMetric

Return the number of huge allocations done via the arena.

Specified by:

numHugeAllocations in interface PoolArenaMetric

numHugeDeallocations

public long numHugeDeallocations()

Description copied from interface: PoolArenaMetric

Return the number of huge deallocations done via the arena.

Specified by:

numHugeDeallocations in interface PoolArenaMetric

numActiveAllocations

public long numActiveAllocations()

Description copied from interface: PoolArenaMetric

Return the number of currently active allocations.

Specified by:

numActiveAllocations in interface PoolArenaMetric

numActiveTinyAllocations

public long numActiveTinyAllocations()

Description copied from interface: PoolArenaMetric

Return the number of currently active tiny allocations.

Specified by:

numActiveTinyAllocations in interface PoolArenaMetric

numActiveSmallAllocations

public long numActiveSmallAllocations()

Description copied from interface: PoolArenaMetric

Return the number of currently active small allocations.

Specified by:

numActiveSmallAllocations in interface PoolArenaMetric

numActiveNormalAllocations

public long numActiveNormalAllocations()

Description copied from interface: PoolArenaMetric

Return the number of currently active normal allocations.

Specified by:

numActiveNormalAllocations in interface PoolArenaMetric

numActiveHugeAllocations

public long numActiveHugeAllocations()

Description copied from interface: PoolArenaMetric

Return the number of currently active huge allocations.

Specified by:

numActiveHugeAllocations in interface PoolArenaMetric

numActiveBytes

public long numActiveBytes()

Description copied from interface: PoolArenaMetric

Return the number of active bytes that are currently allocated by the arena.

Specified by:

numActiveBytes in interface PoolArenaMetric

numPinnedBytes

public long numPinnedBytes()

Return an estimate of the number of bytes that are currently pinned to buffer instances, by the arena. The pinned memory is not accessible for use by any other allocation, until the buffers using have all been released.

newChunk

protected abstract PoolChunk<T> newChunk(int pageSize,
 int maxPageIdx,
 int pageShifts,
 int chunkSize)

newUnpooledChunk

protected abstract PoolChunk<T> newUnpooledChunk(int capacity)

newByteBuf

protected abstract PooledByteBuf<T> newByteBuf(int maxCapacity)

memoryCopy

protected abstract void memoryCopy(T src,
 int srcOffset,
 PooledByteBuf<T> dst,
 int length)

destroyChunk

protected abstract void destroyChunk(PoolChunk<T> chunk)

toString

public String toString()

Overrides:

toString in class Object

appendPoolSubPages

private static void appendPoolSubPages(StringBuilder buf,
 PoolSubpage<?>[] subpages)

finalize

protected final void finalize()
                       throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

destroyPoolSubPages

private static void destroyPoolSubPages(PoolSubpage<?>[] pages)

destroyPoolChunkLists

private void destroyPoolChunkLists(PoolChunkList<T>... chunkLists)

lock

void lock()

unlock

void unlock()

sizeIdx2size

public int sizeIdx2size(int sizeIdx)

Description copied from interface: SizeClassesMetric

Computes size from lookup table according to sizeIdx.

Specified by:

sizeIdx2size in interface SizeClassesMetric

Returns:

size

sizeIdx2sizeCompute

public int sizeIdx2sizeCompute(int sizeIdx)

Description copied from interface: SizeClassesMetric

Computes size according to sizeIdx.

Specified by:

sizeIdx2sizeCompute in interface SizeClassesMetric

Returns:

size

pageIdx2size

public long pageIdx2size(int pageIdx)

Description copied from interface: SizeClassesMetric

Computes size from lookup table according to pageIdx.

Specified by:

pageIdx2size in interface SizeClassesMetric

Returns:

size which is multiples of pageSize.

pageIdx2sizeCompute

public long pageIdx2sizeCompute(int pageIdx)

Description copied from interface: SizeClassesMetric

Computes size according to pageIdx.

Specified by:

pageIdx2sizeCompute in interface SizeClassesMetric

Returns:

size which is multiples of pageSize

size2SizeIdx

public int size2SizeIdx(int size)

Description copied from interface: SizeClassesMetric

Normalizes request size up to the nearest size class.

Specified by:

size2SizeIdx in interface SizeClassesMetric

Parameters:

size - request size

Returns:

sizeIdx of the size class

pages2pageIdx

public int pages2pageIdx(int pages)

Description copied from interface: SizeClassesMetric

Normalizes request size up to the nearest pageSize class.

Specified by:

pages2pageIdx in interface SizeClassesMetric

Parameters:

pages - multiples of pageSizes

Returns:

pageIdx of the pageSize class

pages2pageIdxFloor

public int pages2pageIdxFloor(int pages)

Description copied from interface: SizeClassesMetric

Normalizes request size down to the nearest pageSize class.

Specified by:

pages2pageIdxFloor in interface SizeClassesMetric

Parameters:

pages - multiples of pageSizes

Returns:

pageIdx of the pageSize class

normalizeSize

public int normalizeSize(int size)

Description copied from interface: SizeClassesMetric

Normalizes usable size that would result from allocating an object with the specified size and alignment.

Specified by:

normalizeSize in interface SizeClassesMetric

Parameters:

size - request size

Returns:

normalized size