Class AbstractByteBufferPool

java.lang.Object

org.eclipse.jetty.io.AbstractByteBufferPool

All Implemented Interfaces:

ByteBufferPool

Direct Known Subclasses:

ArrayByteBufferPool, MappedByteBufferPool

@ManagedObject
abstract class AbstractByteBufferPool
extends Object
implements ByteBufferPool

Nested Class Summary

Nested classes/interfaces inherited from interface ByteBufferPool

ByteBufferPool.Bucket, ByteBufferPool.Lease

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicLong	_directMemory
private final int	_factor
private final AtomicLong	_heapMemory
private final long	_maxDirectMemory
private final long	_maxHeapMemory
private final int	_maxQueueLength

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractByteBufferPool(int factor, int maxQueueLength, long maxHeapMemory, long maxDirectMemory)	Creates a new ByteBufferPool with the given configuration.

Method Summary

Modifier and Type	Method	Description
void	clear()
protected void	decrementMemory(ByteBuffer buffer)	Deprecated.
protected int	getCapacityFactor()
long	getDirectMemory()
long	getHeapMemory()
long	getMaxDirectMemory()
long	getMaxHeapMemory()
protected int	getMaxQueueLength()
long	getMemory(boolean direct)
protected void	incrementMemory(ByteBuffer buffer)	Deprecated.
protected void	releaseExcessMemory(boolean direct, Consumer<Boolean> clearFn)
(package private) IntConsumer	updateMemory(boolean direct)
private void	updateMemory(ByteBuffer buffer, boolean addOrSub)

Methods inherited from class Object

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

Methods inherited from interface ByteBufferPool

acquire, newByteBuffer, release, remove

Field Details

_factor

private final int _factor

_maxQueueLength

private final int _maxQueueLength

_maxHeapMemory

private final long _maxHeapMemory

_maxDirectMemory

private final long _maxDirectMemory

_heapMemory

private final AtomicLong _heapMemory

_directMemory

private final AtomicLong _directMemory

Constructor Details

AbstractByteBufferPool

protected AbstractByteBufferPool(int factor,
 int maxQueueLength,
 long maxHeapMemory,
 long maxDirectMemory)

Creates a new ByteBufferPool with the given configuration.

Parameters:

factor - the capacity factor

maxQueueLength - the maximum ByteBuffer queue length

maxHeapMemory - the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic.

maxDirectMemory - the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic.

Method Details

getCapacityFactor

protected int getCapacityFactor()

getMaxQueueLength

protected int getMaxQueueLength()

decrementMemory

@Deprecated
protected void decrementMemory(ByteBuffer buffer)

Deprecated.

incrementMemory

@Deprecated
protected void incrementMemory(ByteBuffer buffer)

Deprecated.

updateMemory

private void updateMemory(ByteBuffer buffer,
 boolean addOrSub)

releaseExcessMemory

protected void releaseExcessMemory(boolean direct,
 Consumer<Boolean> clearFn)

getDirectMemory

@ManagedAttribute("The bytes retained by direct ByteBuffers")
public long getDirectMemory()

getHeapMemory

@ManagedAttribute("The bytes retained by heap ByteBuffers")
public long getHeapMemory()

getMaxDirectMemory

@ManagedAttribute("The max num of bytes that can be retained from direct ByteBuffers")
public long getMaxDirectMemory()

getMaxHeapMemory

@ManagedAttribute("The max num of bytes that can be retained from heap ByteBuffers")
public long getMaxHeapMemory()

getMemory

public long getMemory(boolean direct)

updateMemory

IntConsumer updateMemory(boolean direct)

clear

@ManagedOperation(value="Clears this ByteBufferPool",
                  impact="ACTION")
public void clear()