Class AdaptivePoolingAllocator.Magazine

java.lang.Object

io.netty.buffer.AdaptivePoolingAllocator.Magazine

Enclosing class:

AdaptivePoolingAllocator

private static final class AdaptivePoolingAllocator.Magazine
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	AdaptivePoolingAllocator.Magazine.AdaptiveRecycler

Field Summary

Fields

Modifier and Type	Field	Description
private final java.util.concurrent.locks.StampedLock	allocationLock
private final AdaptivePoolingAllocator.ChunkController	chunkController
private AdaptivePoolingAllocator.Chunk	current
private static final AdaptivePoolingAllocator.Magazine.AdaptiveRecycler	EVENT_LOOP_LOCAL_BUFFER_POOL
private final AdaptivePoolingAllocator.MagazineGroup	group
private static final AdaptivePoolingAllocator.Chunk	MAGAZINE_FREED
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AdaptivePoolingAllocator.Magazine, AdaptivePoolingAllocator.Chunk>	NEXT_IN_LINE
private AdaptivePoolingAllocator.Chunk	nextInLine
private final AdaptivePoolingAllocator.Magazine.AdaptiveRecycler	recycler

Constructor Summary

Constructors

Constructor	Description
Magazine(AdaptivePoolingAllocator.MagazineGroup group, boolean shareable, AdaptivePoolingAllocator.ChunkController chunkController)

Method Summary

Modifier and Type	Method	Description
private boolean	allocate(int size, int maxCapacity, AdaptivePoolingAllocator.AdaptiveByteBuf buf, boolean reallocate)
private boolean	allocateWithoutLock(int size, int maxCapacity, AdaptivePoolingAllocator.AdaptiveByteBuf buf)
(package private) void	free()
AdaptivePoolingAllocator.AdaptiveByteBuf	newBuffer()
(package private) boolean	offerToQueue(AdaptivePoolingAllocator.Chunk chunk)
private void	restoreMagazineFreed()
private void	transferToNextInLineOrRelease(AdaptivePoolingAllocator.Chunk chunk)
boolean	tryAllocate(int size, int maxCapacity, AdaptivePoolingAllocator.AdaptiveByteBuf buf, boolean reallocate)

Methods inherited from class java.lang.Object

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

Field Details

NEXT_IN_LINE

private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AdaptivePoolingAllocator.Magazine, AdaptivePoolingAllocator.Chunk> NEXT_IN_LINE

MAGAZINE_FREED

private static final AdaptivePoolingAllocator.Chunk MAGAZINE_FREED

EVENT_LOOP_LOCAL_BUFFER_POOL

private static final AdaptivePoolingAllocator.Magazine.AdaptiveRecycler EVENT_LOOP_LOCAL_BUFFER_POOL

current

private AdaptivePoolingAllocator.Chunk current

nextInLine

private volatile AdaptivePoolingAllocator.Chunk nextInLine

group

private final AdaptivePoolingAllocator.MagazineGroup group

chunkController

private final AdaptivePoolingAllocator.ChunkController chunkController

allocationLock

private final java.util.concurrent.locks.StampedLock allocationLock

recycler

private final AdaptivePoolingAllocator.Magazine.AdaptiveRecycler recycler

Constructor Details

Magazine

Magazine(AdaptivePoolingAllocator.MagazineGroup group,
 boolean shareable,
 AdaptivePoolingAllocator.ChunkController chunkController)

Method Details

tryAllocate

public boolean tryAllocate(int size,
 int maxCapacity,
 AdaptivePoolingAllocator.AdaptiveByteBuf buf,
 boolean reallocate)

allocateWithoutLock

private boolean allocateWithoutLock(int size,
 int maxCapacity,
 AdaptivePoolingAllocator.AdaptiveByteBuf buf)

allocate

private boolean allocate(int size,
 int maxCapacity,
 AdaptivePoolingAllocator.AdaptiveByteBuf buf,
 boolean reallocate)

restoreMagazineFreed

private void restoreMagazineFreed()

transferToNextInLineOrRelease

private void transferToNextInLineOrRelease(AdaptivePoolingAllocator.Chunk chunk)

free

void free()

newBuffer

public AdaptivePoolingAllocator.AdaptiveByteBuf newBuffer()

offerToQueue

boolean offerToQueue(AdaptivePoolingAllocator.Chunk chunk)