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)

Method Summary

Modifier and Type	Method	Description
void	clear()
protected void	decrementMemory(ByteBuffer buffer)
protected int	getCapacityFactor()
long	getDirectMemory()
long	getHeapMemory()
protected int	getMaxQueueLength()
long	getMemory(boolean direct)
protected void	incrementMemory(ByteBuffer buffer)
protected void	releaseExcessMemory(boolean direct, Consumer<Boolean> clearFn)
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

_heapMemory

private final AtomicLong _heapMemory

_maxDirectMemory

private final long _maxDirectMemory

_directMemory

private final AtomicLong _directMemory

Constructor Details

AbstractByteBufferPool

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

Method Details

getCapacityFactor

protected int getCapacityFactor()

getMaxQueueLength

protected int getMaxQueueLength()

decrementMemory

protected void decrementMemory(ByteBuffer buffer)

incrementMemory

protected void incrementMemory(ByteBuffer buffer)

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()

getMemory

public long getMemory(boolean direct)

clear

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