com.splicemachine.db.client.net

Class Reply

java.lang.Object

com.splicemachine.db.client.net.Reply

Direct Known Subclasses:

NetConnectionReply

public class Reply
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Agent	agent_
protected byte[]	buffer_
protected int	count_
protected static int	DEFAULT_BUFFER_SIZE
protected int	dssCorrelationID_
protected boolean	dssIsContinued_
protected int	dssLength_
static int	END_OF_COLLECTION
static int	END_OF_SAME_ID_CHAIN
protected boolean	ensuredLengthForDecryption_
protected byte[]	longBufferForDecryption_
protected int	longCountForDecryption_
protected int	longPosForDecryption_
protected byte[]	longValueForDecryption_
protected NetAgent	netAgent_
protected int	peekedCodePoint_
protected int	peekedLength_
protected int	pos_

Constructor Summary

Constructors

Constructor and Description
Reply(NetAgent netAgent, int bufferSize)

Method Summary

Modifier and Type	Method and Description
protected int	adjustDdmLength(int ddmLength, int length)
protected void	adjustLengths(int length)
(package private) void	doSyntaxrmSemantics(int syntaxErrorCode)
protected void	endOfSameIdChainData()
protected int	ensureALayerDataInBuffer(int desiredDataSize)
protected void	ensureBLayerDataInBuffer(int desiredDataSize)
protected void	ensureSpaceInBufferForFill(int desiredSpace)
protected int	fill(int minimumBytesNeeded)
(package private) java.io.ByteArrayOutputStream	getData(java.io.ByteArrayOutputStream existingBuffer)
(package private) int	getDdmLength()
(package private) java.io.ByteArrayOutputStream	getFastData(java.io.ByteArrayOutputStream existingBuffer)
(package private) int	getFastSkipSQLCARDrowLength()
(package private) void	initialize()
(package private) void	mark()
protected void	matchCodePoint(int expectedCodePoint)
protected void	parseLengthAndMatchCodePoint(int expectedCodePoint)
protected int	peekCodePoint()
protected int	peekFastBytes(byte[] b, int offset, int length)
protected int	peekFastLength()
protected boolean	peekForNullSqlcagrp()
protected int	peekLength()
protected int	peekNumOfColumns()
protected int	peekTotalColumnCount(int tripletLength)
protected void	popCollectionStack()
(package private) int	popMark()
protected void	pushLengthOnCollectionStack()
(package private) boolean	readBoolean()
(package private) byte	readByte()
(package private) byte[]	readBytes()
(package private) byte[]	readBytes(int length)
protected void	readDSSContinuationHeader()
protected void	readDssHeader()
(package private) byte	readFastByte()
(package private) byte[]	readFastBytes(int length)
(package private) int	readFastInt()
(package private) void	readFastIntArray(int[] array)
(package private) byte[]	readFastLDBytes()
(package private) long	readFastLong()
(package private) short	readFastShort()
(package private) java.lang.String	readFastString(int length)
(package private) java.lang.String	readFastString(int length, java.lang.String encoding)
(package private) int	readFastUnsignedByte()
(package private) int	readFastUnsignedShort()
(package private) int	readInt()
(package private) void	readIntArray(int[] array)
(package private) byte[]	readLDBytes()
protected int	readLengthAndCodePoint()
(package private) long	readLong()
(package private) short	readShort()
(package private) java.lang.String	readString()
(package private) java.lang.String	readString(int length)
(package private) java.lang.String	readString(int length, java.lang.String encoding)
(package private) int	readUnsignedByte()
(package private) int	readUnsignedShort()
(package private) int[]	readUnsignedShortList()
(package private) void	skipBytes()
(package private) void	skipBytes(int length)
(package private) void	skipFastBytes(int length)
protected void	startSameIdChainParse()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

agent_

protected Agent agent_

netAgent_

protected NetAgent netAgent_

DEFAULT_BUFFER_SIZE

protected static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

buffer_

protected byte[] buffer_

pos_

protected int pos_

count_

protected int count_

ensuredLengthForDecryption_

protected boolean ensuredLengthForDecryption_

longBufferForDecryption_

protected byte[] longBufferForDecryption_

longPosForDecryption_

protected int longPosForDecryption_

longValueForDecryption_

protected byte[] longValueForDecryption_

longCountForDecryption_

protected int longCountForDecryption_

dssLength_

protected int dssLength_

dssIsContinued_

protected boolean dssIsContinued_

dssCorrelationID_

protected int dssCorrelationID_

peekedLength_

protected int peekedLength_

peekedCodePoint_

protected int peekedCodePoint_

END_OF_COLLECTION

public static final int END_OF_COLLECTION

See Also:

Constant Field Values

END_OF_SAME_ID_CHAIN

public static final int END_OF_SAME_ID_CHAIN

See Also:

Constant Field Values

Constructor Detail

Reply

Reply(NetAgent netAgent,
      int bufferSize)

Method Detail

initialize

final void initialize()

getDdmLength

final int getDdmLength()

ensureSpaceInBufferForFill

protected final void ensureSpaceInBufferForFill(int desiredSpace)

fill

protected int fill(int minimumBytesNeeded)
            throws DisconnectException

Throws:

DisconnectException

ensureALayerDataInBuffer

protected final int ensureALayerDataInBuffer(int desiredDataSize)
                                      throws DisconnectException

Throws:

DisconnectException

ensureBLayerDataInBuffer

protected final void ensureBLayerDataInBuffer(int desiredDataSize)
                                       throws DisconnectException

Throws:

DisconnectException

readDssHeader

protected final void readDssHeader()
                            throws DisconnectException

Throws:

DisconnectException

readUnsignedShort

final int readUnsignedShort()
                     throws DisconnectException

Throws:

DisconnectException

readShort

final short readShort()
               throws DisconnectException

Throws:

DisconnectException

readInt

final int readInt()
           throws DisconnectException

Throws:

DisconnectException

readIntArray

final void readIntArray(int[] array)
                 throws DisconnectException

Throws:

DisconnectException

readLong

final long readLong()
             throws DisconnectException

Throws:

DisconnectException

readUnsignedShortList

final int[] readUnsignedShortList()
                           throws DisconnectException

Throws:

DisconnectException

readUnsignedByte

final int readUnsignedByte()
                    throws DisconnectException

Throws:

DisconnectException

readByte

final byte readByte()
             throws DisconnectException

Throws:

DisconnectException

readBoolean

final boolean readBoolean()
                   throws DisconnectException

Throws:

DisconnectException

readString

final java.lang.String readString(int length)
                           throws DisconnectException

Throws:

DisconnectException

readString

final java.lang.String readString(int length,
                                  java.lang.String encoding)
                           throws DisconnectException

Throws:

DisconnectException

readString

final java.lang.String readString()
                           throws DisconnectException

Throws:

DisconnectException

readBytes

final byte[] readBytes(int length)
                throws DisconnectException

Throws:

DisconnectException

readBytes

final byte[] readBytes()
                throws DisconnectException

Throws:

DisconnectException

readLDBytes

final byte[] readLDBytes()
                  throws DisconnectException

Throws:

DisconnectException

skipBytes

final void skipBytes(int length)
              throws DisconnectException

Throws:

DisconnectException

skipBytes

final void skipBytes()
              throws DisconnectException

Throws:

DisconnectException

getData

final java.io.ByteArrayOutputStream getData(java.io.ByteArrayOutputStream existingBuffer)
                                     throws DisconnectException

Throws:

DisconnectException

readDSSContinuationHeader

protected final void readDSSContinuationHeader()
                                        throws DisconnectException

Throws:

DisconnectException

doSyntaxrmSemantics

final void doSyntaxrmSemantics(int syntaxErrorCode)
                        throws DisconnectException

Throws:

DisconnectException

pushLengthOnCollectionStack

protected final void pushLengthOnCollectionStack()

adjustLengths

protected final void adjustLengths(int length)

adjustDdmLength

protected int adjustDdmLength(int ddmLength,
                              int length)

popCollectionStack

protected final void popCollectionStack()

peekCodePoint

protected final int peekCodePoint()
                           throws DisconnectException

Throws:

DisconnectException

peekLength

protected final int peekLength()
                        throws DisconnectException

Throws:

DisconnectException

peekFastBytes

protected final int peekFastBytes(byte[] b,
                                  int offset,
                                  int length)
                           throws DisconnectException

Throws:

DisconnectException

parseLengthAndMatchCodePoint

protected final void parseLengthAndMatchCodePoint(int expectedCodePoint)
                                           throws DisconnectException

Throws:

DisconnectException

readLengthAndCodePoint

protected final int readLengthAndCodePoint()
                                    throws DisconnectException

Throws:

DisconnectException

startSameIdChainParse

protected final void startSameIdChainParse()
                                    throws DisconnectException

Throws:

DisconnectException

endOfSameIdChainData

protected final void endOfSameIdChainData()
                                   throws DisconnectException

Throws:

DisconnectException

peekTotalColumnCount

protected final int peekTotalColumnCount(int tripletLength)
                                  throws DisconnectException

Throws:

DisconnectException

readFastUnsignedByte

final int readFastUnsignedByte()
                        throws DisconnectException

Throws:

DisconnectException

readFastShort

final short readFastShort()
                   throws DisconnectException

Throws:

DisconnectException

readFastUnsignedShort

final int readFastUnsignedShort()
                         throws DisconnectException

Throws:

DisconnectException

readFastInt

final int readFastInt()
               throws DisconnectException

Throws:

DisconnectException

readFastString

final java.lang.String readFastString(int length)
                               throws DisconnectException

Throws:

DisconnectException

readFastBytes

final byte[] readFastBytes(int length)
                    throws DisconnectException

Throws:

DisconnectException

peekFastLength

protected final int peekFastLength()
                            throws DisconnectException

Throws:

DisconnectException

skipFastBytes

final void skipFastBytes(int length)
                  throws DisconnectException

Throws:

DisconnectException

readFastIntArray

final void readFastIntArray(int[] array)
                     throws DisconnectException

Throws:

DisconnectException

readFastString

final java.lang.String readFastString(int length,
                                      java.lang.String encoding)
                               throws DisconnectException

Throws:

DisconnectException

readFastLDBytes

final byte[] readFastLDBytes()
                      throws DisconnectException

Throws:

DisconnectException

readFastLong

final long readFastLong()
                 throws DisconnectException

Throws:

DisconnectException

readFastByte

final byte readFastByte()
                 throws DisconnectException

Throws:

DisconnectException

mark

final void mark()

popMark

final int popMark()

getFastSkipSQLCARDrowLength

final int getFastSkipSQLCARDrowLength()

getFastData

final java.io.ByteArrayOutputStream getFastData(java.io.ByteArrayOutputStream existingBuffer)
                                         throws DisconnectException

Throws:

DisconnectException

matchCodePoint

protected final void matchCodePoint(int expectedCodePoint)
                             throws DisconnectException

Throws:

DisconnectException

peekNumOfColumns

protected final int peekNumOfColumns()
                              throws DisconnectException

Throws:

DisconnectException

peekForNullSqlcagrp

protected final boolean peekForNullSqlcagrp()