Package io.netty.buffer

Class AdaptivePoolingAllocator.MagazineGroup

java.lang.Object

io.netty.buffer.AdaptivePoolingAllocator.MagazineGroup

Enclosing class:

AdaptivePoolingAllocator

private static final class AdaptivePoolingAllocator.MagazineGroup
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final AdaptivePoolingAllocator	allocator
private final AdaptivePoolingAllocator.ChunkAllocator	chunkAllocator
private final AdaptivePoolingAllocator.ChunkCache	chunkCache
private final AdaptivePoolingAllocator.ChunkManagementStrategy	chunkManagementStrategy
private boolean	freed
private final StampedLock	magazineExpandLock
private AdaptivePoolingAllocator.Magazine[]	magazines
private Thread	ownerThread
private final AdaptivePoolingAllocator.Magazine	threadLocalMagazine

Constructor Summary

Constructors

Constructor	Description
MagazineGroup(AdaptivePoolingAllocator allocator, AdaptivePoolingAllocator.ChunkAllocator chunkAllocator, AdaptivePoolingAllocator.ChunkManagementStrategy chunkManagementStrategy, boolean isThreadLocal)

Method Summary

Modifier and Type	Method	Description
AdaptivePoolingAllocator.AdaptiveByteBuf	allocate(int size, int maxCapacity, Thread currentThread, AdaptivePoolingAllocator.AdaptiveByteBuf buf)
private void	free()
private void	freeChunkReuseQueue(Thread ownerThread)
(package private) boolean	offerChunk(AdaptivePoolingAllocator.Chunk chunk)
(package private) AdaptivePoolingAllocator.Chunk	pollChunk(int size)
private boolean	tryExpandMagazines(int currentLength)

Methods inherited from class java.lang.Object

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

Field Details

allocator

private final AdaptivePoolingAllocator allocator

chunkAllocator

private final AdaptivePoolingAllocator.ChunkAllocator chunkAllocator

chunkManagementStrategy

private final AdaptivePoolingAllocator.ChunkManagementStrategy chunkManagementStrategy

chunkCache

private final AdaptivePoolingAllocator.ChunkCache chunkCache

magazineExpandLock

private final StampedLock magazineExpandLock

threadLocalMagazine

private final AdaptivePoolingAllocator.Magazine threadLocalMagazine

ownerThread

private Thread ownerThread

magazines

private volatile AdaptivePoolingAllocator.Magazine[] magazines

freed

private volatile boolean freed

Constructor Details

MagazineGroup

MagazineGroup(AdaptivePoolingAllocator allocator,
 AdaptivePoolingAllocator.ChunkAllocator chunkAllocator,
 AdaptivePoolingAllocator.ChunkManagementStrategy chunkManagementStrategy,
 boolean isThreadLocal)

Method Details

allocate

public AdaptivePoolingAllocator.AdaptiveByteBuf allocate(int size,
 int maxCapacity,
 Thread currentThread,
 AdaptivePoolingAllocator.AdaptiveByteBuf buf)

tryExpandMagazines

private boolean tryExpandMagazines(int currentLength)

pollChunk

AdaptivePoolingAllocator.Chunk pollChunk(int size)

offerChunk

boolean offerChunk(AdaptivePoolingAllocator.Chunk chunk)

free

private void free()

freeChunkReuseQueue

private void freeChunkReuseQueue(Thread ownerThread)