com.mongodb.internal.connection

Class PowerOfTwoBufferPool

java.lang.Object

com.mongodb.internal.connection.PowerOfTwoBufferPool

All Implemented Interfaces:

BufferProvider

public class PowerOfTwoBufferPool
extends java.lang.Object
implements BufferProvider

Power-of-two buffer pool implementation.

This class should not be considered a part of the public API.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	PowerOfTwoBufferPool.PooledByteBufNIO

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.lang.Integer,ConcurrentPool<java.nio.ByteBuffer>>	powerOfTwoToPoolMap

Constructor Summary

Constructors

Constructor and Description
PowerOfTwoBufferPool() Construct an instance with a highest power of two of 24.
PowerOfTwoBufferPool(int highestPowerOfTwo) Construct an instance.

Method Summary

Modifier and Type	Method and Description
private java.nio.ByteBuffer	createNew(int size)
ByteBuf	getBuffer(int size) Gets a buffer with the givens capacity.
(package private) static int	log2(int powerOfTwo)
private void	release(java.nio.ByteBuffer buffer)
(package private) static int	roundUpToNextHighestPowerOfTwo(int size)

Methods inherited from class java.lang.Object

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

Field Detail

powerOfTwoToPoolMap

private final java.util.Map<java.lang.Integer,ConcurrentPool<java.nio.ByteBuffer>> powerOfTwoToPoolMap

Constructor Detail

PowerOfTwoBufferPool

public PowerOfTwoBufferPool()

Construct an instance with a highest power of two of 24.

PowerOfTwoBufferPool

public PowerOfTwoBufferPool(int highestPowerOfTwo)

Construct an instance.

Parameters:

highestPowerOfTwo - the highest power of two buffer size that will be pooled

Method Detail

getBuffer

public ByteBuf getBuffer(int size)

Description copied from interface: BufferProvider

Gets a buffer with the givens capacity.

Specified by:

getBuffer in interface BufferProvider

Parameters:

size - the size required for the buffer

Returns:

a ByteBuf with the given size, which is now owned by the caller and must be released.

createNew

private java.nio.ByteBuffer createNew(int size)

release

private void release(java.nio.ByteBuffer buffer)

log2

static int log2(int powerOfTwo)

roundUpToNextHighestPowerOfTwo

static int roundUpToNextHighestPowerOfTwo(int size)