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.ChunkControllerFactory	chunkControllerFactory
private final Queue<AdaptivePoolingAllocator.Chunk>	chunkReuseQueue
private boolean	freed
private final StampedLock	magazineExpandLock
private AdaptivePoolingAllocator.Magazine[]	magazines
private final AdaptivePoolingAllocator.Magazine	threadLocalMagazine

Constructor Summary

Constructors

Constructor	Description
MagazineGroup(AdaptivePoolingAllocator allocator, AdaptivePoolingAllocator.ChunkAllocator chunkAllocator, AdaptivePoolingAllocator.ChunkControllerFactory chunkControllerFactory, 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()
(package private) boolean	offerToQueue(AdaptivePoolingAllocator.Chunk buffer)
private boolean	tryExpandMagazines(int currentLength)

Methods inherited from class 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

chunkControllerFactory

private final AdaptivePoolingAllocator.ChunkControllerFactory chunkControllerFactory

chunkReuseQueue

private final Queue<AdaptivePoolingAllocator.Chunk> chunkReuseQueue

magazineExpandLock

private final StampedLock magazineExpandLock

threadLocalMagazine

private final AdaptivePoolingAllocator.Magazine threadLocalMagazine

magazines

private volatile AdaptivePoolingAllocator.Magazine[] magazines

freed

private volatile boolean freed

Constructor Details

MagazineGroup

MagazineGroup(AdaptivePoolingAllocator allocator,
 AdaptivePoolingAllocator.ChunkAllocator chunkAllocator,
 AdaptivePoolingAllocator.ChunkControllerFactory chunkControllerFactory,
 boolean isThreadLocal)

Method Details

allocate

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

tryExpandMagazines

private boolean tryExpandMagazines(int currentLength)

offerToQueue

boolean offerToQueue(AdaptivePoolingAllocator.Chunk buffer)

free

private void free()

freeChunkReuseQueue

private void freeChunkReuseQueue()