Class AdaptivePoolingAllocator.Chunk

java.lang.Object

io.netty.buffer.AdaptivePoolingAllocator.Chunk

All Implemented Interfaces:

ReferenceCounted

Direct Known Subclasses:

AdaptivePoolingAllocator.BuddyChunk, AdaptivePoolingAllocator.SizeClassedChunk

Enclosing class:

AdaptivePoolingAllocator

private static class AdaptivePoolingAllocator.Chunk
extends Object
implements ReferenceCounted

Field Summary

Fields

Modifier and Type	Field	Description
private static final AtomicIntegerFieldUpdater<AdaptivePoolingAllocator.Chunk>	AIF_UPDATER
protected int	allocatedBytes
private final AdaptivePoolingAllocator	allocator
private final int	capacity
protected final AbstractByteBuf	delegate
protected AdaptivePoolingAllocator.Magazine	magazine
private int	refCnt
private static final long	REFCNT_FIELD_OFFSET
private static final ReferenceCountUpdater<AdaptivePoolingAllocator.Chunk>	updater

Constructor Summary

Constructors

Constructor	Description
Chunk()
Chunk(AbstractByteBuf delegate, AdaptivePoolingAllocator.Magazine magazine)

Method Summary

Modifier and Type	Method	Description
(package private) void	attachToMagazine(AdaptivePoolingAllocator.Magazine magazine)
int	capacity()
(package private) AdaptivePoolingAllocator.Magazine	currentMagazine()
protected void	deallocate()
(package private) void	detachFromMagazine()
boolean	hasUnprocessedFreelistEntries()
(package private) void	markToDeallocate()
void	processFreelistEntries()
boolean	readInitInto(AdaptivePoolingAllocator.AdaptiveByteBuf buf, int size, int startingCapacity, int maxCapacity)
int	refCnt()	Returns the reference count of this object.
boolean	release()	Decreases the reference count by 1 and deallocates this object if the reference count reaches at 0.
boolean	release(int decrement)	Decreases the reference count by the specified decrement and deallocates this object if the reference count reaches at 0.
(package private) void	releaseFromMagazine()	Called when a magazine is done using this chunk, probably because it was emptied.
(package private) void	releaseSegment(int ignoredSegmentId, int size)	Called when a ByteBuf is done using its allocation in this chunk.
int	remainingCapacity()
AdaptivePoolingAllocator.Chunk	retain()	Increases the reference count by 1.
AdaptivePoolingAllocator.Chunk	retain(int increment)	Increases the reference count by the specified increment.
AdaptivePoolingAllocator.Chunk	touch()	Records the current access location of this object for debugging purposes.
AdaptivePoolingAllocator.Chunk	touch(Object hint)	Records the current access location of this object with an additional arbitrary information for debugging purposes.

Methods inherited from class Object

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

Field Details

REFCNT_FIELD_OFFSET

private static final long REFCNT_FIELD_OFFSET

AIF_UPDATER

private static final AtomicIntegerFieldUpdater<AdaptivePoolingAllocator.Chunk> AIF_UPDATER

delegate

protected final AbstractByteBuf delegate

magazine

protected AdaptivePoolingAllocator.Magazine magazine

allocator

private final AdaptivePoolingAllocator allocator

capacity

private final int capacity

allocatedBytes

protected int allocatedBytes

updater

private static final ReferenceCountUpdater<AdaptivePoolingAllocator.Chunk> updater

refCnt

private volatile int refCnt

Constructor Details

Chunk

Chunk()

Chunk

Chunk(AbstractByteBuf delegate,
 AdaptivePoolingAllocator.Magazine magazine)

Method Details

currentMagazine

AdaptivePoolingAllocator.Magazine currentMagazine()

detachFromMagazine

void detachFromMagazine()

attachToMagazine

void attachToMagazine(AdaptivePoolingAllocator.Magazine magazine)

touch

public AdaptivePoolingAllocator.Chunk touch(Object hint)

Description copied from interface: ReferenceCounted

Records the current access location of this object with an additional arbitrary information for debugging purposes. If this object is determined to be leaked, the information recorded by this operation will be provided to you via ResourceLeakDetector.

Specified by:

touch in interface ReferenceCounted

refCnt

public int refCnt()

Description copied from interface: ReferenceCounted

Returns the reference count of this object. If 0, it means this object has been deallocated.

Specified by:

refCnt in interface ReferenceCounted

retain

public AdaptivePoolingAllocator.Chunk retain()

Description copied from interface: ReferenceCounted

Increases the reference count by 1.

Specified by:

retain in interface ReferenceCounted

retain

public AdaptivePoolingAllocator.Chunk retain(int increment)

Description copied from interface: ReferenceCounted

Increases the reference count by the specified increment.

Specified by:

retain in interface ReferenceCounted

touch

public AdaptivePoolingAllocator.Chunk touch()

Description copied from interface: ReferenceCounted

Records the current access location of this object for debugging purposes. If this object is determined to be leaked, the information recorded by this operation will be provided to you via ResourceLeakDetector. This method is a shortcut to touch(null).

Specified by:

touch in interface ReferenceCounted

release

public boolean release()

Description copied from interface: ReferenceCounted

Decreases the reference count by 1 and deallocates this object if the reference count reaches at 0.

Specified by:

release in interface ReferenceCounted

Returns:

true if and only if the reference count became 0 and this object has been deallocated

release

public boolean release(int decrement)

Description copied from interface: ReferenceCounted

Decreases the reference count by the specified decrement and deallocates this object if the reference count reaches at 0.

Specified by:

release in interface ReferenceCounted

Returns:

true if and only if the reference count became 0 and this object has been deallocated

releaseFromMagazine

void releaseFromMagazine()

Called when a magazine is done using this chunk, probably because it was emptied.

releaseSegment

void releaseSegment(int ignoredSegmentId,
 int size)

Called when a ByteBuf is done using its allocation in this chunk.

markToDeallocate

void markToDeallocate()

deallocate

protected void deallocate()

readInitInto

public boolean readInitInto(AdaptivePoolingAllocator.AdaptiveByteBuf buf,
 int size,
 int startingCapacity,
 int maxCapacity)

remainingCapacity

public int remainingCapacity()

hasUnprocessedFreelistEntries

public boolean hasUnprocessedFreelistEntries()

processFreelistEntries

public void processFreelistEntries()

capacity

public int capacity()