Package io.netty.buffer

Class PoolArena<T>

java.lang.Object

io.netty.buffer.SizeClasses

io.netty.buffer.PoolArena<T>

All Implemented Interfaces:

PoolArenaMetric, SizeClassesMetric

Direct Known Subclasses:

PoolArena.DirectArena, PoolArena.HeapArena

abstract class PoolArena<T>
extends SizeClasses
implements PoolArenaMetric

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private LongCounter	activeBytesHuge
private LongCounter	allocationsHuge
private long	allocationsNormal
private LongCounter	allocationsSmall
private java.util.List<PoolChunkListMetric>	chunkListMetrics
private LongCounter	deallocationsHuge
private long	deallocationsNormal
private long	deallocationsSmall
(package private) int	directMemoryCacheAlignment
(package private) int	directMemoryCacheAlignmentMask
(package private) static boolean	HAS_UNSAFE
(package private) int	numSmallSubpagePools
(package private) java.util.concurrent.atomic.AtomicInteger	numThreadCaches
(package private) PooledByteBufAllocator	parent
private PoolChunkList<T>	q000
private PoolChunkList<T>	q025
private PoolChunkList<T>	q050
private PoolChunkList<T>	q075
private PoolChunkList<T>	q100
private PoolChunkList<T>	qInit
private PoolSubpage<T>[]	smallSubpagePools

Fields inherited from class io.netty.buffer.SizeClasses

chunkSize, LOG2_QUANTUM, nPSizes, nSizes, nSubpages, pageShifts, pageSize, smallMaxSizeIdx

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PoolArena(PooledByteBufAllocator parent, int pageSize, int pageShifts, int chunkSize, int cacheAlignment)

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(java.lang.StringBuilder buf, PoolSubpage<?>[] subpages)
java.util.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 void	finalize()
(package private) PoolSubpage<T>	findSubpagePoolHead(int sizeIdx)
(package private) void	free(PoolChunk<T> chunk, java.nio.ByteBuffer nioBuffer, long handle, int normCapacity, PoolThreadCache cache)
(package private) void	freeChunk(PoolChunk<T> chunk, long handle, int normCapacity, PoolArena.SizeClass sizeClass, java.nio.ByteBuffer nioBuffer, boolean finalizer)
private void	incSmallAllocation()
(package private) abstract boolean	isDirect()
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()
protected abstract PoolChunk<T>	newUnpooledChunk(int capacity)
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	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.
(package private) void	reallocate(PooledByteBuf<T> buf, int newCapacity, boolean freeOldMemory)
private PoolArena.SizeClass	sizeClass(long handle)
java.util.List<PoolSubpageMetric>	smallSubpages()	Returns an unmodifiable List which holds PoolSubpageMetrics for small sub-pages.
private static java.util.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)
java.util.List<PoolSubpageMetric>	tinySubpages()	Returns an unmodifiable List which holds PoolSubpageMetrics for tiny sub-pages.
java.lang.String	toString()

Methods inherited from class io.netty.buffer.SizeClasses

normalizeSize, pageIdx2size, pageIdx2sizeCompute, pages2pageIdx, pages2pageIdxFloor, size2SizeIdx, sizeIdx2size, sizeIdx2sizeCompute

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.buffer.SizeClassesMetric

normalizeSize, pageIdx2size, pageIdx2sizeCompute, pages2pageIdx, pages2pageIdxFloor, size2SizeIdx, sizeIdx2size, sizeIdx2sizeCompute

Field Detail

HAS_UNSAFE

static final boolean HAS_UNSAFE

parent

final PooledByteBufAllocator parent

numSmallSubpagePools

final int numSmallSubpagePools

directMemoryCacheAlignment

final int directMemoryCacheAlignment

directMemoryCacheAlignmentMask

final int directMemoryCacheAlignmentMask

smallSubpagePools

private 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 java.util.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 java.util.concurrent.atomic.AtomicInteger numThreadCaches

Constructor Detail

PoolArena

protected PoolArena(PooledByteBufAllocator parent,
                    int pageSize,
                    int pageShifts,
                    int chunkSize,
                    int cacheAlignment)

Method Detail

newSubpagePoolHead

private PoolSubpage<T> newSubpagePoolHead()

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,
          java.nio.ByteBuffer nioBuffer,
          long handle,
          int normCapacity,
          PoolThreadCache cache)

sizeClass

private PoolArena.SizeClass sizeClass(long handle)

freeChunk

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

findSubpagePoolHead

PoolSubpage<T> findSubpagePoolHead(int sizeIdx)

reallocate

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

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 java.util.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 java.util.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 java.util.List<PoolChunkListMetric> chunkLists()

Description copied from interface: PoolArenaMetric

Returns an unmodifiable List which holds PoolChunkListMetrics.

Specified by:

chunkLists in interface PoolArenaMetric

subPageMetricList

private static java.util.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

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

appendPoolSubPages

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

finalize

protected final void finalize()
                       throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

destroyPoolSubPages

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

destroyPoolChunkLists

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