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 java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private AdaptivePoolingAllocator	allocator
private AdaptivePoolingAllocator.ChunkAllocator	chunkAllocator
private AdaptivePoolingAllocator.ChunkCache	chunkCache
private AdaptivePoolingAllocator.ChunkManagementStrategy	chunkManagementStrategy
private boolean	freed
private java.util.concurrent.locks.StampedLock	magazineExpandLock
private AdaptivePoolingAllocator.Magazine[]	magazines
private java.lang.Thread	ownerThread
private 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, java.lang.Thread currentThread, AdaptivePoolingAllocator.AdaptiveByteBuf buf)
private void	free()
private void	freeChunkReuseQueue(java.lang.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 Detail

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 java.util.concurrent.locks.StampedLock magazineExpandLock

threadLocalMagazine

private final AdaptivePoolingAllocator.Magazine threadLocalMagazine

ownerThread

private java.lang.Thread ownerThread

magazines

private volatile AdaptivePoolingAllocator.Magazine[] magazines

freed

private volatile boolean freed

Constructor Detail

MagazineGroup

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

Method Detail

allocate

public AdaptivePoolingAllocator.AdaptiveByteBuf allocate(int size,
                                                         int maxCapacity,
                                                         java.lang.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(java.lang.Thread ownerThread)