io.netty.buffer

Class PooledByteBuf<T>

java.lang.Object

io.netty.buffer.ByteBuf

io.netty.buffer.AbstractByteBuf

io.netty.buffer.AbstractReferenceCountedByteBuf

io.netty.buffer.PooledByteBuf<T>

All Implemented Interfaces:

ReferenceCounted, java.lang.Comparable<ByteBuf>

Direct Known Subclasses:

PooledDirectByteBuf, PooledHeapByteBuf, PooledUnsafeDirectByteBuf

abstract class PooledByteBuf<T>
extends AbstractReferenceCountedByteBuf

Field Summary

Fields

Modifier and Type	Field and Description
(package private) PoolThreadCache	cache
protected PoolChunk<T>	chunk
protected long	handle
protected int	length
(package private) int	maxLength
protected T	memory
protected int	offset
private Recycler.Handle	recyclerHandle
private java.nio.ByteBuffer	tmpNioBuf

Fields inherited from class io.netty.buffer.AbstractByteBuf

leakDetector, readerIndex, writerIndex

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PooledByteBuf(Recycler.Handle recyclerHandle, int maxCapacity)

Method Summary

Modifier and Type	Method and Description
ByteBufAllocator	alloc() Returns the ByteBufAllocator which created this buffer.
int	capacity() Returns the number of bytes (octets) this buffer can contain.
ByteBuf	capacity(int newCapacity) Adjusts the capacity of this buffer.
protected void	deallocate() Called once AbstractReferenceCountedByteBuf.refCnt() is equals 0.
protected int	idx(int index)
(package private) void	init(PoolChunk<T> chunk, long handle, int offset, int length, int maxLength, PoolThreadCache cache)
(package private) void	initUnpooled(PoolChunk<T> chunk, int length)
protected java.nio.ByteBuffer	internalNioBuffer()
protected abstract java.nio.ByteBuffer	newInternalNioBuffer(T memory)
java.nio.ByteOrder	order() Returns the endianness of this buffer.
private void	recycle()
protected abstract Recycler<?>	recycler()
(package private) void	reuse(int maxCapacity) Method must be called before reuse this PooledByteBufAllocator
ByteBuf	unwrap() Return the underlying buffer instance if this buffer is a wrapper of another buffer.

Methods inherited from class io.netty.buffer.AbstractReferenceCountedByteBuf

refCnt, release, release, retain, retain, setRefCnt

Methods inherited from class io.netty.buffer.AbstractByteBuf

_getByte, _getInt, _getLong, _getShort, _getUnsignedMedium, _setByte, _setInt, _setLong, _setMedium, _setShort, adjustMarkers, bytesBefore, bytesBefore, bytesBefore, checkDstIndex, checkIndex, checkIndex, checkIndex0, checkReadableBytes, checkSrcIndex, clear, compareTo, copy, discardMarks, discardReadBytes, discardSomeReadBytes, duplicate, ensureAccessible, ensureWritable, ensureWritable, equals, forEachByte, forEachByte, forEachByteDesc, forEachByteDesc, getBoolean, getByte, getBytes, getBytes, getBytes, getChar, getDouble, getFloat, getInt, getLong, getMedium, getShort, getUnsignedByte, getUnsignedInt, getUnsignedMedium, getUnsignedShort, hashCode, indexOf, isReadable, isReadable, isWritable, isWritable, markReaderIndex, markWriterIndex, maxCapacity, maxCapacity, maxWritableBytes, newSwappedByteBuf, nioBuffer, nioBuffers, order, readableBytes, readBoolean, readByte, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readChar, readDouble, readerIndex, readerIndex, readFloat, readInt, readLong, readMedium, readShort, readSlice, readUnsignedByte, readUnsignedInt, readUnsignedMedium, readUnsignedShort, resetReaderIndex, resetWriterIndex, setBoolean, setByte, setBytes, setBytes, setBytes, setChar, setDouble, setFloat, setIndex, setIndex0, setInt, setLong, setMedium, setShort, setZero, skipBytes, slice, slice, toString, toString, toString, writableBytes, writeBoolean, writeByte, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeChar, writeDouble, writeFloat, writeInt, writeLong, writeMedium, writerIndex, writerIndex, writeShort, writeZero

Methods inherited from class io.netty.buffer.ByteBuf

array, arrayOffset, copy, getBytes, getBytes, getBytes, getBytes, getBytes, hasArray, hasMemoryAddress, internalNioBuffer, isDirect, memoryAddress, nioBuffer, nioBufferCount, nioBuffers, setBytes, setBytes, setBytes, setBytes, setBytes

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

recyclerHandle

private final Recycler.Handle recyclerHandle

chunk

protected PoolChunk<T> chunk

handle

protected long handle

memory

protected T memory

offset

protected int offset

length

protected int length

maxLength

int maxLength

cache

PoolThreadCache cache

tmpNioBuf

private java.nio.ByteBuffer tmpNioBuf

Constructor Detail

PooledByteBuf

protected PooledByteBuf(Recycler.Handle recyclerHandle,
                        int maxCapacity)

Method Detail

init

void init(PoolChunk<T> chunk,
          long handle,
          int offset,
          int length,
          int maxLength,
          PoolThreadCache cache)

initUnpooled

void initUnpooled(PoolChunk<T> chunk,
                  int length)

reuse

final void reuse(int maxCapacity)

Method must be called before reuse this PooledByteBufAllocator

capacity

public final int capacity()

Description copied from class: ByteBuf

Returns the number of bytes (octets) this buffer can contain.

Specified by:

capacity in class ByteBuf

capacity

public final ByteBuf capacity(int newCapacity)

Description copied from class: ByteBuf

Adjusts the capacity of this buffer. If the newCapacity is less than the current capacity, the content of this buffer is truncated. If the newCapacity is greater than the current capacity, the buffer is appended with unspecified data whose length is (newCapacity - currentCapacity).

Specified by:

capacity in class ByteBuf

alloc

public final ByteBufAllocator alloc()

Description copied from class: ByteBuf

Returns the ByteBufAllocator which created this buffer.

Specified by:

alloc in class ByteBuf

order

public final java.nio.ByteOrder order()

Description copied from class: ByteBuf

Returns the endianness of this buffer.

Specified by:

order in class ByteBuf

unwrap

public final ByteBuf unwrap()

Description copied from class: ByteBuf

Return the underlying buffer instance if this buffer is a wrapper of another buffer.

Specified by:

unwrap in class ByteBuf

Returns:

null if this buffer is not a wrapper

internalNioBuffer

protected final java.nio.ByteBuffer internalNioBuffer()

newInternalNioBuffer

protected abstract java.nio.ByteBuffer newInternalNioBuffer(T memory)

deallocate

protected final void deallocate()

Description copied from class: AbstractReferenceCountedByteBuf

Called once AbstractReferenceCountedByteBuf.refCnt() is equals 0.

Specified by:

deallocate in class AbstractReferenceCountedByteBuf

recycle

private void recycle()

recycler

protected abstract Recycler<?> recycler()

idx

protected final int idx(int index)