Package io.netty.buffer

Class PooledUnsafeDirectByteBuf

java.lang.Object

io.netty.buffer.ByteBuf

io.netty.buffer.AbstractByteBuf

io.netty.buffer.AbstractReferenceCountedByteBuf

io.netty.buffer.PooledByteBuf<ByteBuffer>

io.netty.buffer.PooledUnsafeDirectByteBuf

All Implemented Interfaces:

ByteBufConvertible, ReferenceCounted, Comparable<ByteBuf>

final class PooledUnsafeDirectByteBuf
extends PooledByteBuf<ByteBuffer>

Field Summary

Fields

Modifier and Type	Field	Description
private long	memoryAddress
private static final ObjectPool<PooledUnsafeDirectByteBuf>	RECYCLER

Fields inherited from class io.netty.buffer.PooledByteBuf

cache, chunk, handle, length, maxLength, memory, offset, tmpNioBuf

Fields inherited from class io.netty.buffer.AbstractByteBuf

checkAccessible, leakDetector, readerIndex, writerIndex

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PooledUnsafeDirectByteBuf(ObjectPool.Handle<PooledUnsafeDirectByteBuf> recyclerHandle, int maxCapacity)

Method Summary

Modifier and Type	Method	Description
protected byte	_getByte(int index)
protected int	_getInt(int index)
protected int	_getIntLE(int index)
protected long	_getLong(int index)
protected long	_getLongLE(int index)
protected short	_getShort(int index)
protected short	_getShortLE(int index)
protected int	_getUnsignedMedium(int index)
protected int	_getUnsignedMediumLE(int index)
protected void	_setByte(int index, int value)
protected void	_setInt(int index, int value)
protected void	_setIntLE(int index, int value)
protected void	_setLong(int index, long value)
protected void	_setLongLE(int index, long value)
protected void	_setMedium(int index, int value)
protected void	_setMediumLE(int index, int value)
protected void	_setShort(int index, int value)
protected void	_setShortLE(int index, int value)
private long	addr(int index)
byte[]	array()	Returns the backing byte array of this buffer.
int	arrayOffset()	Returns the offset of the first byte within the backing byte array of this buffer.
ByteBuf	copy(int index, int length)	Returns a copy of this buffer's sub-region.
ByteBuf	getBytes(int index, byte[] dst, int dstIndex, int length)	Transfers this buffer's data to the specified destination starting at the specified absolute index.
ByteBuf	getBytes(int index, ByteBuf dst, int dstIndex, int length)	Transfers this buffer's data to the specified destination starting at the specified absolute index.
ByteBuf	getBytes(int index, OutputStream out, int length)	Transfers this buffer's data to the specified stream starting at the specified absolute index.
ByteBuf	getBytes(int index, ByteBuffer dst)	Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit.
boolean	hasArray()	Returns true if and only if this buffer has a backing byte array.
boolean	hasMemoryAddress()	Returns true if and only if this buffer has a reference to the low-level memory address that points to the backing data.
(package private) void	init(PoolChunk<ByteBuffer> chunk, ByteBuffer nioBuffer, long handle, int offset, int length, int maxLength, PoolThreadCache cache)
private void	initMemoryAddress()
(package private) void	initUnpooled(PoolChunk<ByteBuffer> chunk, int length)
boolean	isDirect()	Returns true if and only if this buffer is backed by an NIO direct buffer.
long	memoryAddress()	Returns the low-level memory address that point to the first byte of ths backing data.
(package private) static PooledUnsafeDirectByteBuf	newInstance(int maxCapacity)
protected ByteBuffer	newInternalNioBuffer(ByteBuffer memory)
protected SwappedByteBuf	newSwappedByteBuf()	Creates a new SwappedByteBuf for this ByteBuf instance.
ByteBuf	setBytes(int index, byte[] src, int srcIndex, int length)	Transfers the specified source array's data to this buffer starting at the specified absolute index.
ByteBuf	setBytes(int index, ByteBuf src, int srcIndex, int length)	Transfers the specified source buffer's data to this buffer starting at the specified absolute index.
int	setBytes(int index, InputStream in, int length)	Transfers the content of the specified source stream to this buffer starting at the specified absolute index.
ByteBuf	setBytes(int index, ByteBuffer src)	Transfers the specified source buffer's data to this buffer starting at the specified absolute index until the source buffer's position reaches its limit.
ByteBuf	setZero(int index, int length)	Fills this buffer with NUL (0x00) starting at the specified absolute index.
ByteBuf	writeZero(int length)	Fills this buffer with NUL (0x00) starting at the current writerIndex and increases the writerIndex by the specified length.

Methods inherited from class io.netty.buffer.PooledByteBuf

_internalNioBuffer, alloc, capacity, capacity, deallocate, duplicateInternalNioBuffer, getBytes, getBytes, idx, internalNioBuffer, internalNioBuffer, isContiguous, maxFastWritableBytes, nioBuffer, nioBufferCount, nioBuffers, order, readBytes, readBytes, retainedDuplicate, retainedSlice, retainedSlice, reuse, setBytes, setBytes, unwrap

Methods inherited from class io.netty.buffer.AbstractReferenceCountedByteBuf

isAccessible, refCnt, release, release, resetRefCnt, retain, retain, setRefCnt, touch, touch

Methods inherited from class io.netty.buffer.AbstractByteBuf

adjustMarkers, asReadOnly, bytesBefore, bytesBefore, bytesBefore, checkDstIndex, checkDstIndex, checkIndex, checkIndex, checkIndex0, checkNewCapacity, checkReadableBytes, checkSrcIndex, clear, compareTo, copy, discardMarks, discardReadBytes, discardSomeReadBytes, duplicate, ensureAccessible, ensureWritable, ensureWritable, ensureWritable0, equals, forEachByte, forEachByte, forEachByteAsc0, forEachByteDesc, forEachByteDesc, forEachByteDesc0, getBoolean, getByte, getBytes, getBytes, getBytes, getChar, getCharSequence, getDouble, getFloat, getInt, getIntLE, getLong, getLongLE, getMedium, getMediumLE, getShort, getShortLE, getUnsignedByte, getUnsignedInt, getUnsignedIntLE, getUnsignedMedium, getUnsignedMediumLE, getUnsignedShort, getUnsignedShortLE, hashCode, indexOf, isReadable, isReadable, isReadOnly, isWritable, isWritable, markReaderIndex, markWriterIndex, maxCapacity, maxCapacity, maxWritableBytes, nioBuffer, nioBuffers, order, readableBytes, readBoolean, readByte, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readChar, readCharSequence, readDouble, readerIndex, readerIndex, readFloat, readInt, readIntLE, readLong, readLongLE, readMedium, readMediumLE, readRetainedSlice, readShort, readShortLE, readSlice, readUnsignedByte, readUnsignedInt, readUnsignedIntLE, readUnsignedMedium, readUnsignedMediumLE, readUnsignedShort, readUnsignedShortLE, resetReaderIndex, resetWriterIndex, setBoolean, setByte, setBytes, setBytes, setBytes, setChar, setCharSequence, setDouble, setFloat, setIndex, setIndex0, setInt, setIntLE, setLong, setLongLE, setMedium, setMediumLE, setShort, setShortLE, skipBytes, slice, slice, toString, toString, toString, trimIndicesToCapacity, writableBytes, writeBoolean, writeByte, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeChar, writeCharSequence, writeDouble, writeFloat, writeInt, writeIntLE, writeLong, writeLongLE, writeMedium, writeMediumLE, writerIndex, writerIndex, writeShort, writeShortLE

Methods inherited from class io.netty.buffer.ByteBuf

asByteBuf, getDoubleLE, getFloatLE, readDoubleLE, readFloatLE, setDoubleLE, setFloatLE, writeDoubleLE, writeFloatLE

Methods inherited from class java.lang.Object

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

Field Details

RECYCLER

private static final ObjectPool<PooledUnsafeDirectByteBuf> RECYCLER

memoryAddress

private long memoryAddress

Constructor Details

PooledUnsafeDirectByteBuf

private PooledUnsafeDirectByteBuf(ObjectPool.Handle<PooledUnsafeDirectByteBuf> recyclerHandle,
 int maxCapacity)

Method Details

newInstance

static PooledUnsafeDirectByteBuf newInstance(int maxCapacity)

init

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

Overrides:

init in class PooledByteBuf<ByteBuffer>

initUnpooled

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

Overrides:

initUnpooled in class PooledByteBuf<ByteBuffer>

initMemoryAddress

private void initMemoryAddress()

newInternalNioBuffer

protected ByteBuffer newInternalNioBuffer(ByteBuffer memory)

Specified by:

newInternalNioBuffer in class PooledByteBuf<ByteBuffer>

isDirect

public boolean isDirect()

Description copied from class: ByteBuf

Returns true if and only if this buffer is backed by an NIO direct buffer.

Specified by:

isDirect in class ByteBuf

_getByte

protected byte _getByte(int index)

Specified by:

_getByte in class AbstractByteBuf

_getShort

protected short _getShort(int index)

Specified by:

_getShort in class AbstractByteBuf

_getShortLE

protected short _getShortLE(int index)

Specified by:

_getShortLE in class AbstractByteBuf

_getUnsignedMedium

protected int _getUnsignedMedium(int index)

Specified by:

_getUnsignedMedium in class AbstractByteBuf

_getUnsignedMediumLE

protected int _getUnsignedMediumLE(int index)

Specified by:

_getUnsignedMediumLE in class AbstractByteBuf

_getInt

protected int _getInt(int index)

Specified by:

_getInt in class AbstractByteBuf

_getIntLE

protected int _getIntLE(int index)

Specified by:

_getIntLE in class AbstractByteBuf

_getLong

protected long _getLong(int index)

Specified by:

_getLong in class AbstractByteBuf

_getLongLE

protected long _getLongLE(int index)

Specified by:

_getLongLE in class AbstractByteBuf

getBytes

public ByteBuf getBytes(int index,
 ByteBuf dst,
 int dstIndex,
 int length)

Description copied from class: ByteBuf

Transfers this buffer's data to the specified destination starting at the specified absolute index. This method does not modify readerIndex or writerIndex of both the source (i.e. this) and the destination.

Specified by:

getBytes in class ByteBuf

Parameters:

dstIndex - the first index of the destination

length - the number of bytes to transfer

getBytes

public ByteBuf getBytes(int index,
 byte[] dst,
 int dstIndex,
 int length)

Description copied from class: ByteBuf

Transfers this buffer's data to the specified destination starting at the specified absolute index. This method does not modify readerIndex or writerIndex of this buffer.

Specified by:

getBytes in class ByteBuf

Parameters:

dstIndex - the first index of the destination

length - the number of bytes to transfer

getBytes

public ByteBuf getBytes(int index,
 ByteBuffer dst)

Description copied from class: ByteBuf

Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit. This method does not modify readerIndex or writerIndex of this buffer while the destination's position will be increased.

Specified by:

getBytes in class ByteBuf

getBytes

public ByteBuf getBytes(int index,
 OutputStream out,
 int length)
                 throws IOException

Description copied from class: ByteBuf

Transfers this buffer's data to the specified stream starting at the specified absolute index. This method does not modify readerIndex or writerIndex of this buffer.

Specified by:

getBytes in class ByteBuf

Parameters:

length - the number of bytes to transfer

Throws:

IOException - if the specified stream threw an exception during I/O

_setByte

protected void _setByte(int index,
 int value)

Specified by:

_setByte in class AbstractByteBuf

_setShort

protected void _setShort(int index,
 int value)

Specified by:

_setShort in class AbstractByteBuf

_setShortLE

protected void _setShortLE(int index,
 int value)

Specified by:

_setShortLE in class AbstractByteBuf

_setMedium

protected void _setMedium(int index,
 int value)

Specified by:

_setMedium in class AbstractByteBuf

_setMediumLE

protected void _setMediumLE(int index,
 int value)

Specified by:

_setMediumLE in class AbstractByteBuf

_setInt

protected void _setInt(int index,
 int value)

Specified by:

_setInt in class AbstractByteBuf

_setIntLE

protected void _setIntLE(int index,
 int value)

Specified by:

_setIntLE in class AbstractByteBuf

_setLong

protected void _setLong(int index,
 long value)

Specified by:

_setLong in class AbstractByteBuf

_setLongLE

protected void _setLongLE(int index,
 long value)

Specified by:

_setLongLE in class AbstractByteBuf

setBytes

public ByteBuf setBytes(int index,
 ByteBuf src,
 int srcIndex,
 int length)

Description copied from class: ByteBuf

Transfers the specified source buffer's data to this buffer starting at the specified absolute index. This method does not modify readerIndex or writerIndex of both the source (i.e. this) and the destination.

Specified by:

setBytes in class ByteBuf

Parameters:

srcIndex - the first index of the source

length - the number of bytes to transfer

setBytes

public ByteBuf setBytes(int index,
 byte[] src,
 int srcIndex,
 int length)

Description copied from class: ByteBuf

Transfers the specified source array's data to this buffer starting at the specified absolute index. This method does not modify readerIndex or writerIndex of this buffer.

Specified by:

setBytes in class ByteBuf

setBytes

public ByteBuf setBytes(int index,
 ByteBuffer src)

Description copied from class: ByteBuf

Transfers the specified source buffer's data to this buffer starting at the specified absolute index until the source buffer's position reaches its limit. This method does not modify readerIndex or writerIndex of this buffer.

Specified by:

setBytes in class ByteBuf

setBytes

public int setBytes(int index,
 InputStream in,
 int length)
             throws IOException

Description copied from class: ByteBuf

Transfers the content of the specified source stream to this buffer starting at the specified absolute index. This method does not modify readerIndex or writerIndex of this buffer.

Specified by:

setBytes in class ByteBuf

Parameters:

length - the number of bytes to transfer

Returns:

the actual number of bytes read in from the specified channel. -1 if the specified InputStream reached EOF.

Throws:

IOException - if the specified stream threw an exception during I/O

copy

public ByteBuf copy(int index,
 int length)

Description copied from class: ByteBuf

Returns a copy of this buffer's sub-region. Modifying the content of the returned buffer or this buffer does not affect each other at all. This method does not modify readerIndex or writerIndex of this buffer.

Specified by:

copy in class ByteBuf

hasArray

public boolean hasArray()

Description copied from class: ByteBuf

Returns true if and only if this buffer has a backing byte array. If this method returns true, you can safely call ByteBuf.array() and ByteBuf.arrayOffset().

Specified by:

hasArray in class ByteBuf

array

public byte[] array()

Description copied from class: ByteBuf

Returns the backing byte array of this buffer.

Specified by:

array in class ByteBuf

arrayOffset

public int arrayOffset()

Description copied from class: ByteBuf

Returns the offset of the first byte within the backing byte array of this buffer.

Specified by:

arrayOffset in class ByteBuf

hasMemoryAddress

public boolean hasMemoryAddress()

Description copied from class: ByteBuf

Returns true if and only if this buffer has a reference to the low-level memory address that points to the backing data.

Specified by:

hasMemoryAddress in class ByteBuf

memoryAddress

public long memoryAddress()

Description copied from class: ByteBuf

Returns the low-level memory address that point to the first byte of ths backing data.

Specified by:

memoryAddress in class ByteBuf

addr

private long addr(int index)

newSwappedByteBuf

protected SwappedByteBuf newSwappedByteBuf()

Description copied from class: AbstractByteBuf

Creates a new SwappedByteBuf for this ByteBuf instance.

Overrides:

newSwappedByteBuf in class AbstractByteBuf

setZero

public ByteBuf setZero(int index,
 int length)

Description copied from class: ByteBuf

Fills this buffer with NUL (0x00) starting at the specified absolute index. This method does not modify readerIndex or writerIndex of this buffer.

Overrides:

setZero in class AbstractByteBuf

Parameters:

length - the number of NULs to write to the buffer

writeZero

public ByteBuf writeZero(int length)

Description copied from class: ByteBuf

Fills this buffer with NUL (0x00) starting at the current writerIndex and increases the writerIndex by the specified length. If this.writableBytes is less than length, ByteBuf.ensureWritable(int) will be called in an attempt to expand capacity to accommodate.

Overrides:

writeZero in class AbstractByteBuf

Parameters:

length - the number of NULs to write to the buffer