Modifier and Type	Class and Description
private static class	ArrayByteBufferPool.Buffer
public static class	ArrayByteBufferPool.Quadratic A variant of the `ArrayByteBufferPool` that uses buckets of buffers that increase in size by a power of 2 (eg 1k, 2k, 4k, 8k, etc.).
private static class	ArrayByteBufferPool.RetainedBucket
public static class	ArrayByteBufferPool.Tracking A variant of `ArrayByteBufferPool` that tracks buffer acquires/releases, useful to identify buffer leaks.

Modifier and Type	Field and Description
private final IntUnaryOperator	_bucketIndexFor
private final AtomicLong	_currentDirectMemory
private final AtomicLong	_currentHeapMemory
private final ArrayByteBufferPool.RetainedBucket[]	_direct
private final ArrayByteBufferPool.RetainedBucket[]	_indirect
private final int	_maxCapacity
private final long	_maxDirectMemory
private final long	_maxHeapMemory
private final int	_minCapacity
pack-priv static final int	DEFAULT_FACTOR
pack-priv static final int	DEFAULT_MAX_CAPACITY_BY_FACTOR
private static final Logger	LOG

Constructor Summary

Access	Constructor and Description
public	ArrayByteBufferPool() Creates a new ArrayByteBufferPool with a default configuration.
public	ArrayByteBufferPool(int the minimum ByteBuffer capacity minCapacity, int the capacity factor factor, int the maximum ByteBuffer capacity maxCapacity) Creates a new ArrayByteBufferPool with the given configuration.
public	ArrayByteBufferPool(int the minimum ByteBuffer capacity minCapacity, int the capacity factor factor, int the maximum ByteBuffer capacity maxCapacity, int the maximum number of ByteBuffers for each bucket maxBucketSize) Creates a new ArrayByteBufferPool with the given configuration.
public	ArrayByteBufferPool(int the minimum ByteBuffer capacity minCapacity, int the capacity factor factor, int the maximum ByteBuffer capacity maxCapacity, int the maximum number of ByteBuffers for each bucket maxBucketSize, long the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic maxHeapMemory, long the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic maxDirectMemory) Creates a new ArrayByteBufferPool with the given configuration.
protected	ArrayByteBufferPool(int the minimum ByteBuffer capacity minCapacity, int the capacity factor factor, int the maximum ByteBuffer capacity maxCapacity, int the maximum number of ByteBuffers for each bucket maxBucketSize, long the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic maxHeapMemory, long the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic maxDirectMemory, IntUnaryOperator a `IntUnaryOperator` that takes a capacity and returns a bucket index bucketIndexFor, IntUnaryOperator a `IntUnaryOperator` that takes a bucket index and returns a capacity bucketCapacity) Creates a new ArrayByteBufferPool with the given configuration.

Method Summary

Modifier and Type	Method and Description
public RetainableByteBuffer	acquire(int The size of the buffer. The returned buffer will have at least this capacity. size, boolean true if a direct memory buffer is needed, false otherwise. direct) Implements org.eclipse.jetty.io.ByteBufferPool.acquire. Acquires a `RetainableByteBuffer` from this pool.
protected ByteBuffer	allocate(int capacity)
protected ByteBuffer	allocateDirect(int capacity)
private ArrayByteBufferPool.RetainedBucket	bucketFor(int capacity, boolean direct)
public void	clear() Implements org.eclipse.jetty.io.ByteBufferPool.clear. Removes all `non-retained` pooled instances from this pool.
private void	clearArray(ArrayByteBufferPool.RetainedBucket[] poolArray, AtomicLong memoryCounter)
public void	dump(Appendable The appendable to dump to out, String The indent to apply after any new lines. indent) Implements org.eclipse.jetty.util.component.Dumpable.dump. Dump this object (and children) into an Appendable using the provided indent after any new lines.
private void	evict(boolean true to search in the direct buffers buckets, false to search in the heap buffers buckets. direct, long the amount of bytes to evict. At least this much will be removed from the buckets. excess) This eviction mechanism searches for the RetainableByteBuffers that were released the longest time ago.
private Pool.Entry<RetainableByteBuffer>	findOldestEntry(long now, Pool<RetainableByteBuffer> bucket)
private long	getAvailableByteBufferCount(boolean direct)
public long	getAvailableDirectByteBufferCount()
public long	getAvailableDirectMemory()
public long	getAvailableHeapByteBufferCount()
public long	getAvailableHeapMemory()
private long	getAvailableMemory(boolean direct)
private long	getByteBufferCount(boolean direct)
public long	getDirectByteBufferCount()
public long	getDirectMemory()
public long	getHeapByteBufferCount()
public long	getHeapMemory()
public int	getMaxCapacity()
private long	getMemory(boolean direct)
public int	getMinCapacity()
private long	maxMemory(long maxMemory)
private RetainableByteBuffer	newRetainableByteBuffer(int capacity, boolean direct, Consumer<RetainableByteBuffer> releaser)
public Pool<RetainableByteBuffer>	poolFor(int capacity, boolean direct)
private void	releaseExcessMemory(boolean direct)
protected void	removed(RetainableByteBuffer retainedBuffer)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

_bucketIndexFor	back to summary
private final IntUnaryOperator _bucketIndexFor

_currentDirectMemory	back to summary
private final AtomicLong _currentDirectMemory

_currentHeapMemory	back to summary
private final AtomicLong _currentHeapMemory

_direct	back to summary
private final ArrayByteBufferPool.RetainedBucket[] _direct

_indirect	back to summary
private final ArrayByteBufferPool.RetainedBucket[] _indirect

_maxCapacity	back to summary
private final int _maxCapacity

_maxDirectMemory	back to summary
private final long _maxDirectMemory

_maxHeapMemory	back to summary
private final long _maxHeapMemory

_minCapacity	back to summary
private final int _minCapacity

DEFAULT_FACTOR	back to summary
pack-priv static final int DEFAULT_FACTOR

DEFAULT_MAX_CAPACITY_BY_FACTOR	back to summary
pack-priv static final int DEFAULT_MAX_CAPACITY_BY_FACTOR

LOG	back to summary
private static final Logger LOG

Constructor Detail

ArrayByteBufferPool	back to summary
public ArrayByteBufferPool() Creates a new ArrayByteBufferPool with a default configuration. Both `maxHeapMemory` and `maxDirectMemory` default to 0 to use default heuristic.

ArrayByteBufferPool back to summary

ArrayByteBufferPool	back to summary
public ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity) Creates a new ArrayByteBufferPool with the given configuration. Both `maxHeapMemory` and `maxDirectMemory` default to 0 to use default heuristic. Parameters minCapacity:int the minimum ByteBuffer capacity factor:int the capacity factor maxCapacity:int the maximum ByteBuffer capacity

public ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity)

Creates a new ArrayByteBufferPool with the given configuration. Both maxHeapMemory and maxDirectMemory default to 0 to use default heuristic.

Parameters

minCapacity:int: the minimum ByteBuffer capacity
factor:int: the capacity factor
maxCapacity:int: the maximum ByteBuffer capacity

ArrayByteBufferPool back to summary

ArrayByteBufferPool	back to summary
public ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity, int maxBucketSize) Creates a new ArrayByteBufferPool with the given configuration. Both `maxHeapMemory` and `maxDirectMemory` default to 0 to use default heuristic. Parameters minCapacity:int the minimum ByteBuffer capacity factor:int the capacity factor maxCapacity:int the maximum ByteBuffer capacity maxBucketSize:int the maximum number of ByteBuffers for each bucket

public ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity, int maxBucketSize)

Creates a new ArrayByteBufferPool with the given configuration. Both maxHeapMemory and maxDirectMemory default to 0 to use default heuristic.

Parameters

minCapacity:int: the minimum ByteBuffer capacity
factor:int: the capacity factor
maxCapacity:int: the maximum ByteBuffer capacity
maxBucketSize:int: the maximum number of ByteBuffers for each bucket

ArrayByteBufferPool	back to summary
public ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory) Creates a new ArrayByteBufferPool with the given configuration. Parameters minCapacity:int the minimum ByteBuffer capacity factor:int the capacity factor maxCapacity:int the maximum ByteBuffer capacity maxBucketSize:int the maximum number of ByteBuffers for each bucket maxHeapMemory:long the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic maxDirectMemory:long the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic

ArrayByteBufferPool

back to summary

public ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory)

Creates a new ArrayByteBufferPool with the given configuration.

Parameters

minCapacity:int: the minimum ByteBuffer capacity
factor:int: the capacity factor
maxCapacity:int: the maximum ByteBuffer capacity
maxBucketSize:int: the maximum number of ByteBuffers for each bucket
maxHeapMemory:long: the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic
maxDirectMemory:long: the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic

ArrayByteBufferPool back to summary

ArrayByteBufferPool	back to summary
protected ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory, IntUnaryOperator bucketIndexFor, IntUnaryOperator bucketCapacity) Creates a new ArrayByteBufferPool with the given configuration. Parameters minCapacity:int the minimum ByteBuffer capacity factor:int the capacity factor maxCapacity:int the maximum ByteBuffer capacity maxBucketSize:int the maximum number of ByteBuffers for each bucket maxHeapMemory:long the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic maxDirectMemory:long the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic bucketIndexFor:IntUnaryOperator a `IntUnaryOperator` that takes a capacity and returns a bucket index bucketCapacity:IntUnaryOperator a `IntUnaryOperator` that takes a bucket index and returns a capacity

protected ArrayByteBufferPool(int minCapacity, int factor, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory, IntUnaryOperator bucketIndexFor, IntUnaryOperator bucketCapacity)

Creates a new ArrayByteBufferPool with the given configuration.

Parameters

minCapacity:int: the minimum ByteBuffer capacity
factor:int: the capacity factor
maxCapacity:int: the maximum ByteBuffer capacity
maxBucketSize:int: the maximum number of ByteBuffers for each bucket
maxHeapMemory:long: the max heap memory in bytes, -1 for unlimited memory or 0 to use default heuristic
maxDirectMemory:long: the max direct memory in bytes, -1 for unlimited memory or 0 to use default heuristic
bucketIndexFor:IntUnaryOperator: a IntUnaryOperator that takes a capacity and returns a bucket index
bucketCapacity:IntUnaryOperator: a IntUnaryOperator that takes a bucket index and returns a capacity

Method Detail

acquire back to summary

acquire	back to summary
public RetainableByteBuffer acquire(int size, boolean direct) Implements org.eclipse.jetty.io.ByteBufferPool.acquire. Doc from org.eclipse.jetty.io.ByteBufferPool.acquire. Acquires a `RetainableByteBuffer` from this pool. Parameters size:int The size of the buffer. The returned buffer will have at least this capacity. direct:boolean true if a direct memory buffer is needed, false otherwise. Returns:RetainableByteBuffer a `RetainableByteBuffer` with position and limit set to 0. Annotations @Override

public RetainableByteBuffer acquire(int size, boolean direct)

Implements org.eclipse.jetty.io.ByteBufferPool.acquire.

Doc from org.eclipse.jetty.io.ByteBufferPool.acquire.

Acquires a RetainableByteBuffer from this pool.

Parameters

size:int: The size of the buffer. The returned buffer will have at least this capacity.
direct:boolean: true if a direct memory buffer is needed, false otherwise.

Returns:RetainableByteBuffer

a RetainableByteBuffer with position and limit set to 0.

Annotations

@Override

allocate	back to summary
protected ByteBuffer allocate(int capacity)

allocateDirect	back to summary
protected ByteBuffer allocateDirect(int capacity)

bucketFor	back to summary
private ArrayByteBufferPool.RetainedBucket bucketFor(int capacity, boolean direct)

clear back to summary

clear	back to summary
public void clear() Implements org.eclipse.jetty.io.ByteBufferPool.clear. Doc from org.eclipse.jetty.io.ByteBufferPool.clear. Removes all `non-retained` pooled instances from this pool. Annotations @ManagedOperation:Clears this ByteBufferPool impact:ACTION

public void clear()

Implements org.eclipse.jetty.io.ByteBufferPool.clear.

Doc from org.eclipse.jetty.io.ByteBufferPool.clear.

Removes all non-retained pooled instances from this pool.

Annotations

@ManagedOperation:Clears this ByteBufferPool
impact:ACTION

clearArray	back to summary
private void clearArray(ArrayByteBufferPool.RetainedBucket[] poolArray, AtomicLong memoryCounter)

dump	back to summary
public void dump(Appendable out, String indent) throws IOException Implements org.eclipse.jetty.util.component.Dumpable.dump. Doc from org.eclipse.jetty.util.component.Dumpable.dump. Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped. Parameters out:Appendable The appendable to dump to indent:String The indent to apply after any new lines. Annotations @Override Exceptions IOException: if unable to write to Appendable

dump

back to summary

public void dump(Appendable out, String indent) throws IOException

Implements org.eclipse.jetty.util.component.Dumpable.dump.

Doc from org.eclipse.jetty.util.component.Dumpable.dump.

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Parameters

out:Appendable: The appendable to dump to
indent:String: The indent to apply after any new lines.

Annotations

@Override

Exceptions

IOException:: if unable to write to Appendable

evict	back to summary
private void evict(boolean direct, long excess) This eviction mechanism searches for the RetainableByteBuffers that were released the longest time ago. Parameters direct:boolean true to search in the direct buffers buckets, false to search in the heap buffers buckets. excess:long the amount of bytes to evict. At least this much will be removed from the buckets.

evict

back to summary

private void evict(boolean direct, long excess)

This eviction mechanism searches for the RetainableByteBuffers that were released the longest time ago.

Parameters

direct:boolean: true to search in the direct buffers buckets, false to search in the heap buffers buckets.
excess:long: the amount of bytes to evict. At least this much will be removed from the buckets.

findOldestEntry	back to summary
private Pool.Entry<RetainableByteBuffer> findOldestEntry(long now, Pool<RetainableByteBuffer> bucket)

getAvailableByteBufferCount	back to summary
private long getAvailableByteBufferCount(boolean direct)

getAvailableDirectByteBufferCount	back to summary
public long getAvailableDirectByteBufferCount() Annotations @ManagedAttribute:The number of pooled direct ByteBuffers that are available

getAvailableDirectMemory	back to summary
public long getAvailableDirectMemory() Annotations @ManagedAttribute:The available bytes retained by direct ByteBuffers

getAvailableHeapByteBufferCount	back to summary
public long getAvailableHeapByteBufferCount() Annotations @ManagedAttribute:The number of pooled heap ByteBuffers that are available

getAvailableHeapMemory	back to summary
public long getAvailableHeapMemory() Annotations @ManagedAttribute:The available bytes retained by heap ByteBuffers

getAvailableMemory	back to summary
private long getAvailableMemory(boolean direct)

getByteBufferCount	back to summary
private long getByteBufferCount(boolean direct)

getDirectByteBufferCount	back to summary
public long getDirectByteBufferCount() Annotations @ManagedAttribute:The number of pooled direct ByteBuffers

getDirectMemory	back to summary
public long getDirectMemory() Annotations @ManagedAttribute:The bytes retained by direct ByteBuffers

getHeapByteBufferCount	back to summary
public long getHeapByteBufferCount() Annotations @ManagedAttribute:The number of pooled heap ByteBuffers

getHeapMemory	back to summary
public long getHeapMemory() Annotations @ManagedAttribute:The bytes retained by heap ByteBuffers

getMaxCapacity	back to summary
public int getMaxCapacity() Annotations @ManagedAttribute:The maximum pooled buffer capacity

getMemory	back to summary
private long getMemory(boolean direct)

getMinCapacity	back to summary
public int getMinCapacity() Annotations @ManagedAttribute:The minimum pooled buffer capacity

maxMemory	back to summary
private long maxMemory(long maxMemory)

newRetainableByteBuffer	back to summary
private RetainableByteBuffer newRetainableByteBuffer(int capacity, boolean direct, Consumer<RetainableByteBuffer> releaser)

poolFor	back to summary
public Pool<RetainableByteBuffer> poolFor(int capacity, boolean direct)

releaseExcessMemory	back to summary
private void releaseExcessMemory(boolean direct)

removed	back to summary
protected void removed(RetainableByteBuffer retainedBuffer)

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

org.eclipse.jetty.io back to summary

private Class ArrayByteBufferPool.Buffer

Class Inheritance

extends AbstractRetainableByteBuffer

java.lang.Object
org.eclipse.jetty.io.AbstractRetainableByteBuffer
org.eclipse.jetty.io.ArrayByteBufferPool.Buffer

Field Summary

Modifier and Type	Field and Description
private final AtomicLong	lastNanoTime
private final Consumer<RetainableByteBuffer>	releaser

Constructor Summary

Access	Constructor and Description
private	Buffer(ByteBuffer buffer, Consumer<RetainableByteBuffer> releaser)

Method Summary

Modifier and Type	Method and Description
public long	getLastNanoTime()
public boolean	release() Overrides org.eclipse.jetty.io.AbstractRetainableByteBuffer.release. Overrides default org.eclipse.jetty.io.Retainable.release. Releases this resource, potentially decrementing a reference count (if any).

Inherited from org.eclipse.jetty.io.AbstractRetainableByteBuffer:: acquire canRetain getByteBuffer isRetained retain toString

Field Detail

lastNanoTime	back to summary
private final AtomicLong lastNanoTime

releaser	back to summary
private final Consumer<RetainableByteBuffer> releaser

Constructor Detail

Buffer	back to summary
private Buffer(ByteBuffer buffer, Consumer<RetainableByteBuffer> releaser)

Method Detail

getLastNanoTime	back to summary
public long getLastNanoTime()

release back to summary

public boolean release()

Overrides org.eclipse.jetty.io.AbstractRetainableByteBuffer.release.

Overrides default org.eclipse.jetty.io.Retainable.release.

Doc from org.eclipse.jetty.io.Retainable.release.

Releases this resource, potentially decrementing a reference count (if any).

Returns:boolean

true when the reference count goes to zero or if there was no reference count, false otherwise.

Annotations

@Override

org.eclipse.jetty.io back to summary

public Class ArrayByteBufferPool.Quadratic

Class Inheritance

extends ArrayByteBufferPool

java.lang.Object
org.eclipse.jetty.io.ArrayByteBufferPool
org.eclipse.jetty.io.ArrayByteBufferPool.Quadratic

A variant of the ArrayByteBufferPool that uses buckets of buffers that increase in size by a power of 2 (eg 1k, 2k, 4k, 8k, etc.).

Field Summary

Inherited from org.eclipse.jetty.io.ArrayByteBufferPool:: DEFAULT_FACTOR DEFAULT_MAX_CAPACITY_BY_FACTOR

Constructor Summary

Access	Constructor and Description
public	Quadratic()
public	Quadratic(int minCapacity, int maxCapacity, int maxBucketSize)
public	Quadratic(int minCapacity, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory)

Method Summary

Inherited from org.eclipse.jetty.io.ArrayByteBufferPool:: acquire allocate allocateDirect clear dump getAvailableDirectByteBufferCount getAvailableDirectMemory getAvailableHeapByteBufferCount getAvailableHeapMemory getDirectByteBufferCount getDirectMemory getHeapByteBufferCount getHeapMemory getMaxCapacity getMinCapacity poolFor removed toString

Constructor Detail

Quadratic	back to summary
public Quadratic()

Quadratic	back to summary
public Quadratic(int minCapacity, int maxCapacity, int maxBucketSize)

Quadratic	back to summary
public Quadratic(int minCapacity, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory)

org.eclipse.jetty.io back to summary

private Class ArrayByteBufferPool.RetainedBucket

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.io.ArrayByteBufferPool.RetainedBucket

Field Summary

Modifier and Type	Field and Description
private final int	_capacity
private final Pool<RetainableByteBuffer>	_pool

Constructor Summary

Access	Constructor and Description
private	RetainedBucket(int capacity, int poolSize)

Method Summary

Modifier and Type	Method and Description
private Pool<RetainableByteBuffer>	getPool()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

_capacity	back to summary
private final int _capacity

_pool	back to summary
private final Pool<RetainableByteBuffer> _pool

Constructor Detail

RetainedBucket	back to summary
private RetainedBucket(int capacity, int poolSize)

Method Detail

getPool	back to summary
private Pool<RetainableByteBuffer> getPool()

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

org.eclipse.jetty.io back to summary

public Class ArrayByteBufferPool.Tracking

Class Inheritance

extends ArrayByteBufferPool

java.lang.Object
org.eclipse.jetty.io.ArrayByteBufferPool
org.eclipse.jetty.io.ArrayByteBufferPool.Tracking

A variant of ArrayByteBufferPool that tracks buffer acquires/releases, useful to identify buffer leaks.

Use getLeaks() when the system is idle to get the Buffers that have been leaked, which contain the stack trace information of where the buffer was acquired.

Nested and Inner Type Summary

Modifier and Type	Class and Description
public class	ArrayByteBufferPool.Tracking.Buffer

Field Summary

Modifier and Type	Field and Description
private final Set<ArrayByteBufferPool.Tracking.Buffer>	buffers
private static final Logger	LOG Hides org.eclipse.jetty.io.ArrayByteBufferPool.LOG.

Inherited from org.eclipse.jetty.io.ArrayByteBufferPool:: DEFAULT_FACTOR DEFAULT_MAX_CAPACITY_BY_FACTOR

Constructor Summary

Access	Constructor and Description
public	Tracking()
public	Tracking(int minCapacity, int maxCapacity, int maxBucketSize)
public	Tracking(int minCapacity, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory)

Method Summary

Modifier and Type	Method and Description
public RetainableByteBuffer	acquire(int The size of the buffer. The returned buffer will have at least this capacity. size, boolean true if a direct memory buffer is needed, false otherwise. direct) Overrides org.eclipse.jetty.io.ArrayByteBufferPool.acquire. Implements org.eclipse.jetty.io.ByteBufferPool.acquire. Acquires a `RetainableByteBuffer` from this pool.
public String	dumpLeaks()
public Set<ArrayByteBufferPool.Tracking.Buffer>	getLeaks()

Inherited from org.eclipse.jetty.io.ArrayByteBufferPool:: allocate allocateDirect clear dump getAvailableDirectByteBufferCount getAvailableDirectMemory getAvailableHeapByteBufferCount getAvailableHeapMemory getDirectByteBufferCount getDirectMemory getHeapByteBufferCount getHeapMemory getMaxCapacity getMinCapacity poolFor removed toString

Field Detail

buffers	back to summary
private final Set<ArrayByteBufferPool.Tracking.Buffer> buffers

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.io.ArrayByteBufferPool.LOG.

Constructor Detail

Tracking	back to summary
public Tracking()

Tracking	back to summary
public Tracking(int minCapacity, int maxCapacity, int maxBucketSize)

Tracking	back to summary
public Tracking(int minCapacity, int maxCapacity, int maxBucketSize, long maxHeapMemory, long maxDirectMemory)

Method Detail

acquire back to summary

public RetainableByteBuffer acquire(int size, boolean direct)

Overrides org.eclipse.jetty.io.ArrayByteBufferPool.acquire.

Implements org.eclipse.jetty.io.ByteBufferPool.acquire.

Doc from org.eclipse.jetty.io.ByteBufferPool.acquire.

Acquires a RetainableByteBuffer from this pool.

Parameters

size:int: The size of the buffer. The returned buffer will have at least this capacity.
direct:boolean: true if a direct memory buffer is needed, false otherwise.

Returns:RetainableByteBuffer

a RetainableByteBuffer with position and limit set to 0.

Annotations

@Override

dumpLeaks	back to summary
public String dumpLeaks()

getLeaks	back to summary
public Set<ArrayByteBufferPool.Tracking.Buffer> getLeaks()

org.eclipse.jetty.io back to summary

public Class ArrayByteBufferPool.Tracking.Buffer

Class Inheritance

extends Wrapper

java.lang.Object
org.eclipse.jetty.io.Retainable.Wrapper
org.eclipse.jetty.io.RetainableByteBuffer.Wrapper
org.eclipse.jetty.io.ArrayByteBufferPool.Tracking.Buffer

Field Summary

Modifier and Type	Field and Description
private final Instant	acquireInstant
private final Throwable	acquireStack
private final List<Throwable>	overReleaseStacks
private final List<Throwable>	releaseStacks
private final List<Throwable>	retainStacks
private final int	size

Constructor Summary

Access	Constructor and Description
private	Buffer(RetainableByteBuffer wrapped, int size)

Method Summary

Modifier and Type	Method and Description
public String	dump()
public Instant	getAcquireInstant()
public Throwable	getAcquireStack()
public int	getSize()
public boolean	release() Overrides org.eclipse.jetty.io.Retainable.Wrapper.release. Overrides default org.eclipse.jetty.io.Retainable.release. Releases this resource, potentially decrementing a reference count (if any).
public void	retain() Overrides org.eclipse.jetty.io.Retainable.Wrapper.retain. Overrides default org.eclipse.jetty.io.Retainable.retain. Retains this resource, potentially incrementing a reference count if there are resources that will be released.

Inherited from org.eclipse.jetty.io.RetainableByteBuffer.Wrapper:: capacity clear getByteBuffer getWrapped hasRemaining isDirect isRetained remaining

Field Detail

acquireInstant	back to summary
private final Instant acquireInstant

acquireStack	back to summary
private final Throwable acquireStack

overReleaseStacks	back to summary
private final List<Throwable> overReleaseStacks

releaseStacks	back to summary
private final List<Throwable> releaseStacks

retainStacks	back to summary
private final List<Throwable> retainStacks

size	back to summary
private final int size

Constructor Detail

Buffer	back to summary
private Buffer(RetainableByteBuffer wrapped, int size)

Method Detail

dump	back to summary
public String dump()

getAcquireInstant	back to summary
public Instant getAcquireInstant()

getAcquireStack	back to summary
public Throwable getAcquireStack()

getSize	back to summary
public int getSize()

release back to summary

public boolean release()

Overrides org.eclipse.jetty.io.Retainable.Wrapper.release.

Overrides default org.eclipse.jetty.io.Retainable.release.

Doc from org.eclipse.jetty.io.Retainable.release.

Releases this resource, potentially decrementing a reference count (if any).

Returns:boolean

true when the reference count goes to zero or if there was no reference count, false otherwise.

Annotations

@Override

retain

back to summary

public void retain()

Overrides org.eclipse.jetty.io.Retainable.Wrapper.retain.

Overrides default org.eclipse.jetty.io.Retainable.retain.

Doc from org.eclipse.jetty.io.Retainable.retain.

Retains this resource, potentially incrementing a reference count if there are resources that will be released.

Annotations

@Override