Class AdaptivePoolingAllocator.HistogramChunkController

java.lang.Object

io.netty.buffer.AdaptivePoolingAllocator.HistogramChunkController

All Implemented Interfaces:

AdaptivePoolingAllocator.ChunkController, AdaptivePoolingAllocator.ChunkReleasePredicate

Enclosing class:

AdaptivePoolingAllocator

private static final class AdaptivePoolingAllocator.HistogramChunkController
extends Object
implements AdaptivePoolingAllocator.ChunkController, AdaptivePoolingAllocator.ChunkReleasePredicate

Field Summary

Fields

Modifier and Type	Field	Description
private final AdaptivePoolingAllocator.ChunkRegistry	chunkRegistry
private int	datumCount
private int	datumTarget
private final AdaptivePoolingAllocator.MagazineGroup	group
private boolean	hasHadRotation
private short[]	histo
private static final int	HISTO_BUCKET_COUNT
private static final int[]	HISTO_BUCKETS
private int	histoIndex
private final short[][]	histos
private static final int	INIT_DATUM_TARGET
private int	localPrefChunkSize
private int	localUpperBufSize
private static final int	MAX_DATUM_TARGET
private static final int	MIN_DATUM_TARGET
private final boolean	shareable
private int	sharedPrefChunkSize
private final int[]	sums

Constructor Summary

Constructors

Modifier	Constructor	Description
private	HistogramChunkController(AdaptivePoolingAllocator.MagazineGroup group, boolean shareable)

Method Summary

Modifier and Type	Method	Description
private static int	binarySearchInsertionPoint(int index)
(package private) static int	bucketToSize(int sizeBucket)
int	computeBufferCapacity(int requestedSize, int maxCapacity, boolean isReallocation)	Compute the "fast max capacity" value for the buffer.
void	initializeSharedStateIn(AdaptivePoolingAllocator.ChunkController chunkController)	Initialize the given chunk factory with shared statistics state (if any) from this factory.
AdaptivePoolingAllocator.Chunk	newChunkAllocation(int promptingSize, AdaptivePoolingAllocator.Magazine magazine)	Allocate a new AdaptivePoolingAllocator.Chunk for the given AdaptivePoolingAllocator.Magazine.
(package private) int	preferredChunkSize()	Get the preferred chunk size, based on statistics from the recorded allocation sizes.
private void	recordAllocationSize(int bufferSizeToRecord)
private void	rotateHistograms()
boolean	shouldReleaseChunk(int chunkSize)
(package private) static int	sizeToBucket(int size)

Methods inherited from class Object

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

Field Details

MIN_DATUM_TARGET

private static final int MIN_DATUM_TARGET

See Also:

• Constant Field Values

MAX_DATUM_TARGET

private static final int MAX_DATUM_TARGET

See Also:

• Constant Field Values

INIT_DATUM_TARGET

private static final int INIT_DATUM_TARGET

See Also:

• Constant Field Values

HISTO_BUCKET_COUNT

private static final int HISTO_BUCKET_COUNT

See Also:

• Constant Field Values

HISTO_BUCKETS

private static final int[] HISTO_BUCKETS

group

private final AdaptivePoolingAllocator.MagazineGroup group

shareable

private final boolean shareable

histos

private final short[][] histos

chunkRegistry

private final AdaptivePoolingAllocator.ChunkRegistry chunkRegistry

histo

private short[] histo

sums

private final int[] sums

histoIndex

private int histoIndex

datumCount

private int datumCount

datumTarget

private int datumTarget

hasHadRotation

private boolean hasHadRotation

sharedPrefChunkSize

private volatile int sharedPrefChunkSize

localPrefChunkSize

private volatile int localPrefChunkSize

localUpperBufSize

private volatile int localUpperBufSize

Constructor Details

HistogramChunkController

private HistogramChunkController(AdaptivePoolingAllocator.MagazineGroup group,
 boolean shareable)

Method Details

computeBufferCapacity

public int computeBufferCapacity(int requestedSize,
 int maxCapacity,
 boolean isReallocation)

Description copied from interface: AdaptivePoolingAllocator.ChunkController

Compute the "fast max capacity" value for the buffer.

Specified by:

computeBufferCapacity in interface AdaptivePoolingAllocator.ChunkController

recordAllocationSize

private void recordAllocationSize(int bufferSizeToRecord)

sizeToBucket

static int sizeToBucket(int size)

binarySearchInsertionPoint

private static int binarySearchInsertionPoint(int index)

bucketToSize

static int bucketToSize(int sizeBucket)

rotateHistograms

private void rotateHistograms()

preferredChunkSize

int preferredChunkSize()

Get the preferred chunk size, based on statistics from the recorded allocation sizes.

This method must be thread-safe.

Returns:

The currently preferred chunk allocation size.

initializeSharedStateIn

public void initializeSharedStateIn(AdaptivePoolingAllocator.ChunkController chunkController)

Description copied from interface: AdaptivePoolingAllocator.ChunkController

Initialize the given chunk factory with shared statistics state (if any) from this factory.

Specified by:

initializeSharedStateIn in interface AdaptivePoolingAllocator.ChunkController

newChunkAllocation

public AdaptivePoolingAllocator.Chunk newChunkAllocation(int promptingSize,
 AdaptivePoolingAllocator.Magazine magazine)

Description copied from interface: AdaptivePoolingAllocator.ChunkController

Allocate a new AdaptivePoolingAllocator.Chunk for the given AdaptivePoolingAllocator.Magazine.

Specified by:

newChunkAllocation in interface AdaptivePoolingAllocator.ChunkController

shouldReleaseChunk

public boolean shouldReleaseChunk(int chunkSize)

Specified by:

shouldReleaseChunk in interface AdaptivePoolingAllocator.ChunkReleasePredicate