com.impossibl.postgres.utils

Class StreamingByteBuf

java.lang.Object

io.netty.buffer.ByteBuf

io.netty.buffer.AbstractByteBuf

io.netty.buffer.AbstractReferenceCountedByteBuf

com.impossibl.postgres.utils.StreamingByteBuf

All Implemented Interfaces:

io.netty.util.ReferenceCounted, Comparable<io.netty.buffer.ByteBuf>

public class StreamingByteBuf
extends io.netty.buffer.AbstractReferenceCountedByteBuf

Constructor Summary

Constructors

Constructor and Description
StreamingByteBuf(io.netty.channel.Channel streamChannel, ByteOrder endianness, int estimatedLength)
StreamingByteBuf(io.netty.channel.Channel streamChannel, ByteOrder endianness, int estimatedLength, io.netty.buffer.ByteBufAllocator allocator)
StreamingByteBuf(io.netty.channel.Channel streamChannel, int estimatedLength)

Method Summary

Methods

Modifier and Type	Method and Description
protected byte	_getByte(int index)
protected int	_getInt(int index)
protected long	_getLong(int index)
protected short	_getShort(int index)
protected int	_getUnsignedMedium(int index)
protected void	_setByte(int index, int value)
protected void	_setInt(int index, int value)
protected void	_setLong(int index, long value)
protected void	_setMedium(int index, int value)
protected void	_setShort(int index, int value)
io.netty.buffer.ByteBufAllocator	alloc()
byte[]	array()
int	arrayOffset()
int	capacity()
io.netty.buffer.ByteBuf	capacity(int newCapacity)
io.netty.buffer.ByteBuf	copy(int index, int length)
protected void	deallocate()
io.netty.buffer.ByteBuf	duplicate()
io.netty.buffer.ByteBuf	ensureWritable(int minWritableBytes)
void	flush()
byte	getByte(int index)
io.netty.buffer.ByteBuf	getBytes(int index, byte[] dst, int dstIndex, int length)
io.netty.buffer.ByteBuf	getBytes(int index, ByteBuffer dst)
io.netty.buffer.ByteBuf	getBytes(int index, io.netty.buffer.ByteBuf dst, int dstIndex, int length)
int	getBytes(int index, GatheringByteChannel out, int length)
io.netty.buffer.ByteBuf	getBytes(int index, OutputStream out, int length)
int	getInt(int index)
long	getLong(int index)
short	getShort(int index)
int	getTotalLength()
int	getUnsignedMedium(int index)
boolean	hasArray()
boolean	hasMemoryAddress()
ByteBuffer	internalNioBuffer(int index, int length)
boolean	isDirect()
long	memoryAddress()
ByteBuffer	nioBuffer(int index, int length)
int	nioBufferCount()
ByteBuffer[]	nioBuffers(int index, int length)
ByteOrder	order()
io.netty.buffer.ByteBuf	resetReaderIndex()
io.netty.buffer.ByteBuf	resetWriterIndex()
io.netty.buffer.ByteBuf	setByte(int index, int value)
io.netty.buffer.ByteBuf	setBytes(int index, byte[] src, int srcIndex, int length)
io.netty.buffer.ByteBuf	setBytes(int index, ByteBuffer src)
io.netty.buffer.ByteBuf	setBytes(int index, io.netty.buffer.ByteBuf src, int srcIndex, int length)
int	setBytes(int index, InputStream in, int length)
int	setBytes(int index, ScatteringByteChannel in, int length)
io.netty.buffer.ByteBuf	setInt(int index, int value)
io.netty.buffer.ByteBuf	setLong(int index, long value)
io.netty.buffer.ByteBuf	setMedium(int index, int value)
io.netty.buffer.ByteBuf	setShort(int index, int value)
io.netty.buffer.ByteBuf	slice(int index, int length)
io.netty.buffer.ByteBuf	unwrap()
io.netty.buffer.ByteBuf	writeByte(int value)
io.netty.buffer.ByteBuf	writeBytes(byte[] src, int srcIndex, int length)
io.netty.buffer.ByteBuf	writeBytes(ByteBuffer src)
io.netty.buffer.ByteBuf	writeBytes(io.netty.buffer.ByteBuf src, int srcIndex, int length)
int	writeBytes(InputStream in, int length)
int	writeBytes(ScatteringByteChannel in, int length)
io.netty.buffer.ByteBuf	writeInt(int value)
io.netty.buffer.ByteBuf	writeLong(long value)
io.netty.buffer.ByteBuf	writeMedium(int value)
io.netty.buffer.ByteBuf	writeShort(int value)
io.netty.buffer.ByteBuf	writeZero(int length)

Methods inherited from class io.netty.buffer.AbstractReferenceCountedByteBuf

refCnt, release, release, retain, retain, setRefCnt

Methods inherited from class io.netty.buffer.AbstractByteBuf

adjustMarkers, bytesBefore, bytesBefore, bytesBefore, checkDstIndex, checkIndex, checkIndex, checkReadableBytes, checkSrcIndex, clear, compareTo, copy, discardReadBytes, discardSomeReadBytes, ensureAccessible, ensureWritable, equals, forEachByte, forEachByte, forEachByteDesc, forEachByteDesc, getBoolean, getBytes, getBytes, getBytes, getChar, getDouble, getFloat, getMedium, getUnsignedByte, getUnsignedInt, 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, setBoolean, setBytes, setBytes, setBytes, setChar, setDouble, setFloat, setIndex, setZero, skipBytes, slice, toString, toString, toString, writableBytes, writeBoolean, writeBytes, writeBytes, writeBytes, writeChar, writeDouble, writeFloat, writerIndex, writerIndex

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingByteBuf

public StreamingByteBuf(io.netty.channel.Channel streamChannel,
                int estimatedLength)

StreamingByteBuf

public StreamingByteBuf(io.netty.channel.Channel streamChannel,
                ByteOrder endianness,
                int estimatedLength)

StreamingByteBuf

public StreamingByteBuf(io.netty.channel.Channel streamChannel,
                ByteOrder endianness,
                int estimatedLength,
                io.netty.buffer.ByteBufAllocator allocator)

Method Detail

flush

public void flush()

resetReaderIndex

public io.netty.buffer.ByteBuf resetReaderIndex()

Overrides:

resetReaderIndex in class io.netty.buffer.AbstractByteBuf

resetWriterIndex

public io.netty.buffer.ByteBuf resetWriterIndex()

Overrides:

resetWriterIndex in class io.netty.buffer.AbstractByteBuf

unwrap

public io.netty.buffer.ByteBuf unwrap()

Specified by:

unwrap in class io.netty.buffer.ByteBuf

getTotalLength

public int getTotalLength()

ensureWritable

public io.netty.buffer.ByteBuf ensureWritable(int minWritableBytes)

Overrides:

ensureWritable in class io.netty.buffer.AbstractByteBuf

alloc

public io.netty.buffer.ByteBufAllocator alloc()

Specified by:

alloc in class io.netty.buffer.ByteBuf

order

public ByteOrder order()

Specified by:

order in class io.netty.buffer.ByteBuf

isDirect

public boolean isDirect()

Specified by:

isDirect in class io.netty.buffer.ByteBuf

capacity

public int capacity()

Specified by:

capacity in class io.netty.buffer.ByteBuf

hasArray

public boolean hasArray()

Specified by:

hasArray in class io.netty.buffer.ByteBuf

array

public byte[] array()

Specified by:

array in class io.netty.buffer.ByteBuf

arrayOffset

public int arrayOffset()

Specified by:

arrayOffset in class io.netty.buffer.ByteBuf

getByte

public byte getByte(int index)

Overrides:

getByte in class io.netty.buffer.AbstractByteBuf

getShort

public short getShort(int index)

Overrides:

getShort in class io.netty.buffer.AbstractByteBuf

getUnsignedMedium

public int getUnsignedMedium(int index)

Overrides:

getUnsignedMedium in class io.netty.buffer.AbstractByteBuf

getInt

public int getInt(int index)

Overrides:

getInt in class io.netty.buffer.AbstractByteBuf

getLong

public long getLong(int index)

Overrides:

getLong in class io.netty.buffer.AbstractByteBuf

getBytes

public io.netty.buffer.ByteBuf getBytes(int index,
                               byte[] dst,
                               int dstIndex,
                               int length)

Specified by:

getBytes in class io.netty.buffer.ByteBuf

getBytes

public io.netty.buffer.ByteBuf getBytes(int index,
                               io.netty.buffer.ByteBuf dst,
                               int dstIndex,
                               int length)

Specified by:

getBytes in class io.netty.buffer.ByteBuf

getBytes

public io.netty.buffer.ByteBuf getBytes(int index,
                               ByteBuffer dst)

Specified by:

getBytes in class io.netty.buffer.ByteBuf

getBytes

public int getBytes(int index,
           GatheringByteChannel out,
           int length)
             throws IOException

Specified by:

getBytes in class io.netty.buffer.ByteBuf

Throws:

IOException

getBytes

public io.netty.buffer.ByteBuf getBytes(int index,
                               OutputStream out,
                               int length)
                                 throws IOException

Specified by:

getBytes in class io.netty.buffer.ByteBuf

Throws:

IOException

setByte

public io.netty.buffer.ByteBuf setByte(int index,
                              int value)

Overrides:

setByte in class io.netty.buffer.AbstractByteBuf

setShort

public io.netty.buffer.ByteBuf setShort(int index,
                               int value)

Overrides:

setShort in class io.netty.buffer.AbstractByteBuf

setMedium

public io.netty.buffer.ByteBuf setMedium(int index,
                                int value)

Overrides:

setMedium in class io.netty.buffer.AbstractByteBuf

setInt

public io.netty.buffer.ByteBuf setInt(int index,
                             int value)

Overrides:

setInt in class io.netty.buffer.AbstractByteBuf

setLong

public io.netty.buffer.ByteBuf setLong(int index,
                              long value)

Overrides:

setLong in class io.netty.buffer.AbstractByteBuf

setBytes

public io.netty.buffer.ByteBuf setBytes(int index,
                               byte[] src,
                               int srcIndex,
                               int length)

Specified by:

setBytes in class io.netty.buffer.ByteBuf

setBytes

public io.netty.buffer.ByteBuf setBytes(int index,
                               io.netty.buffer.ByteBuf src,
                               int srcIndex,
                               int length)

Specified by:

setBytes in class io.netty.buffer.ByteBuf

setBytes

public io.netty.buffer.ByteBuf setBytes(int index,
                               ByteBuffer src)

Specified by:

setBytes in class io.netty.buffer.ByteBuf

setBytes

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

Specified by:

setBytes in class io.netty.buffer.ByteBuf

Throws:

IOException

setBytes

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

Specified by:

setBytes in class io.netty.buffer.ByteBuf

Throws:

IOException

writeByte

public io.netty.buffer.ByteBuf writeByte(int value)

Overrides:

writeByte in class io.netty.buffer.AbstractByteBuf

writeShort

public io.netty.buffer.ByteBuf writeShort(int value)

Overrides:

writeShort in class io.netty.buffer.AbstractByteBuf

writeMedium

public io.netty.buffer.ByteBuf writeMedium(int value)

Overrides:

writeMedium in class io.netty.buffer.AbstractByteBuf

writeInt

public io.netty.buffer.ByteBuf writeInt(int value)

Overrides:

writeInt in class io.netty.buffer.AbstractByteBuf

writeLong

public io.netty.buffer.ByteBuf writeLong(long value)

Overrides:

writeLong in class io.netty.buffer.AbstractByteBuf

writeBytes

public io.netty.buffer.ByteBuf writeBytes(byte[] src,
                                 int srcIndex,
                                 int length)

Overrides:

writeBytes in class io.netty.buffer.AbstractByteBuf

writeBytes

public io.netty.buffer.ByteBuf writeBytes(io.netty.buffer.ByteBuf src,
                                 int srcIndex,
                                 int length)

Overrides:

writeBytes in class io.netty.buffer.AbstractByteBuf

writeBytes

public io.netty.buffer.ByteBuf writeBytes(ByteBuffer src)

Overrides:

writeBytes in class io.netty.buffer.AbstractByteBuf

writeBytes

public int writeBytes(InputStream in,
             int length)
               throws IOException

Overrides:

writeBytes in class io.netty.buffer.AbstractByteBuf

Throws:

IOException

writeBytes

public int writeBytes(ScatteringByteChannel in,
             int length)
               throws IOException

Overrides:

writeBytes in class io.netty.buffer.AbstractByteBuf

Throws:

IOException

writeZero

public io.netty.buffer.ByteBuf writeZero(int length)

Overrides:

writeZero in class io.netty.buffer.AbstractByteBuf

duplicate

public io.netty.buffer.ByteBuf duplicate()

Overrides:

duplicate in class io.netty.buffer.AbstractByteBuf

copy

public io.netty.buffer.ByteBuf copy(int index,
                           int length)

Specified by:

copy in class io.netty.buffer.ByteBuf

slice

public io.netty.buffer.ByteBuf slice(int index,
                            int length)

Overrides:

slice in class io.netty.buffer.AbstractByteBuf

nioBuffer

public ByteBuffer nioBuffer(int index,
                   int length)

Specified by:

nioBuffer in class io.netty.buffer.ByteBuf

_getByte

protected byte _getByte(int index)

Specified by:

_getByte in class io.netty.buffer.AbstractByteBuf

_getShort

protected short _getShort(int index)

Specified by:

_getShort in class io.netty.buffer.AbstractByteBuf

_getUnsignedMedium

protected int _getUnsignedMedium(int index)

Specified by:

_getUnsignedMedium in class io.netty.buffer.AbstractByteBuf

_getInt

protected int _getInt(int index)

Specified by:

_getInt in class io.netty.buffer.AbstractByteBuf

_getLong

protected long _getLong(int index)

Specified by:

_getLong in class io.netty.buffer.AbstractByteBuf

_setByte

protected void _setByte(int index,
            int value)

Specified by:

_setByte in class io.netty.buffer.AbstractByteBuf

_setShort

protected void _setShort(int index,
             int value)

Specified by:

_setShort in class io.netty.buffer.AbstractByteBuf

_setMedium

protected void _setMedium(int index,
              int value)

Specified by:

_setMedium in class io.netty.buffer.AbstractByteBuf

_setInt

protected void _setInt(int index,
           int value)

Specified by:

_setInt in class io.netty.buffer.AbstractByteBuf

_setLong

protected void _setLong(int index,
            long value)

Specified by:

_setLong in class io.netty.buffer.AbstractByteBuf

capacity

public io.netty.buffer.ByteBuf capacity(int newCapacity)

Specified by:

capacity in class io.netty.buffer.ByteBuf

nioBufferCount

public int nioBufferCount()

Specified by:

nioBufferCount in class io.netty.buffer.ByteBuf

internalNioBuffer

public ByteBuffer internalNioBuffer(int index,
                           int length)

Specified by:

internalNioBuffer in class io.netty.buffer.ByteBuf

nioBuffers

public ByteBuffer[] nioBuffers(int index,
                      int length)

Specified by:

nioBuffers in class io.netty.buffer.ByteBuf

hasMemoryAddress

public boolean hasMemoryAddress()

Specified by:

hasMemoryAddress in class io.netty.buffer.ByteBuf

memoryAddress

public long memoryAddress()

Specified by:

memoryAddress in class io.netty.buffer.ByteBuf

deallocate

protected void deallocate()

Specified by:

deallocate in class io.netty.buffer.AbstractReferenceCountedByteBuf