Class Reply

java.lang.Object

org.apache.derby.client.net.Reply

Direct Known Subclasses:

NetConnectionReply

class Reply
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Agent	agent_
protected byte[]	buffer_
protected int	count_
private int	currentPos_
private int[]	ddmCollectionLenStack_
private int	ddmScalarLen_
protected static final int	DEFAULT_BUFFER_SIZE
private int	dssCorrelationID_
private boolean	dssIsChainedWithSameID_
private boolean	dssIsContinued_
protected int	dssLength_
private static final int	EMPTY_STACK
(package private) static final int	END_OF_COLLECTION
(package private) static final int	END_OF_SAME_ID_CHAIN
protected boolean	ensuredLengthForDecryption_
protected byte[]	longBufferForDecryption_
protected int	longCountForDecryption_
protected int	longPosForDecryption_
protected byte[]	longValueForDecryption_
private static final int	MAX_MARKS_NESTING
protected NetAgent	netAgent_
private int	peekedCodePoint_
protected int	peekedLength_
private int	peekedNumOfExtendedLenBytes_
protected int	pos_
private int	topDdmCollectionStack_

Constructor Summary

Constructors

Constructor	Description
Reply(NetAgent netAgent, int bufferSize)

Method Summary

Modifier and Type	Method	Description
private void	adjustCollectionAndDssLengths(int length)
protected int	adjustDdmLength(int ddmLength, int length)
protected final void	adjustLengths(int length)
private void	compressBLayerData(int continueDssHeaderCount)
private void	decryptData(int gdsFormatter, int oldDssLength)
(package private) final void	doSyntaxrmSemantics(int syntaxErrorCode)
protected final void	endOfSameIdChainData()
private int	ensureALayerDataInBuffer(int desiredDataSize)
protected final void	ensureBLayerDataInBuffer(int desiredDataSize)
private void	ensureSpaceInBufferForFill(int desiredSpace)
private int	fill(int minimumBytesNeeded)
(package private) final ByteArrayOutputStream	getData(ByteArrayOutputStream existingBuffer)
(package private) final int	getDdmLength()
(package private) final ByteArrayOutputStream	getFastData(ByteArrayOutputStream existingBuffer)
(package private) final int	getFastSkipSQLCARDrowLength()
(package private) final void	initialize()
(package private) final void	mark()
protected final void	matchCodePoint(int expectedCodePoint)
protected final void	parseLengthAndMatchCodePoint(int expectedCodePoint)
protected final int	peekCodePoint()
private void	peekExtendedLength()
protected final int	peekFastBytes(byte[] b, int offset, int length)
protected final int	peekFastLength()
protected final boolean	peekForNullSqlcagrp()
protected final int	peekNumOfColumns()
protected final int	peekTotalColumnCount(int tripletLength)
protected final void	popCollectionStack()
private int	popMark()
protected final void	pushLengthOnCollectionStack()
(package private) final byte	readByte()
(package private) final byte[]	readBytes()
(package private) final byte[]	readBytes(int length)
private void	readDSSContinuationHeader()
private void	readDssHeader()
private void	readExtendedLength()
(package private) final byte	readFastByte()
(package private) final byte[]	readFastBytes(int length)
(package private) final int	readFastInt()
(package private) final void	readFastIntArray(int[] array)
(package private) final byte[]	readFastLDBytes()
(package private) final long	readFastLong()
(package private) final short	readFastShort()
(package private) final String	readFastString(int length)
(package private) final String	readFastString(int length, Charset encoding)
(package private) final int	readFastUnsignedByte()
(package private) final int	readFastUnsignedShort()
(package private) final int	readInt()
private int	readLengthAndCodePoint()
(package private) final short	readShort()
(package private) final String	readString()
(package private) final String	readString(int length, Charset encoding)
(package private) final int	readUnsignedByte()
(package private) final int	readUnsignedShort()
(package private) final int[]	readUnsignedShortList()
private void	shiftBuffer(byte[] destinationBuffer)
(package private) final void	skipBytes()
(package private) final void	skipBytes(int length)
(package private) final void	skipFastBytes(int length)
private int	skipSQLDHROW(int offset)
protected final void	startSameIdChainParse()

Methods inherited from class Object

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

Field Details

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_

topDdmCollectionStack_

private int topDdmCollectionStack_

MAX_MARKS_NESTING

private static final int MAX_MARKS_NESTING

See Also:

• Constant Field Values

ddmCollectionLenStack_

private int[] ddmCollectionLenStack_

ddmScalarLen_

private int ddmScalarLen_

EMPTY_STACK

private static final int EMPTY_STACK

See Also:

• Constant Field Values

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_

private boolean dssIsContinued_

dssIsChainedWithSameID_

private boolean dssIsChainedWithSameID_

dssCorrelationID_

private int dssCorrelationID_

peekedLength_

protected int peekedLength_

peekedCodePoint_

private int peekedCodePoint_

peekedNumOfExtendedLenBytes_

private int peekedNumOfExtendedLenBytes_

currentPos_

private int currentPos_

END_OF_COLLECTION

static final int END_OF_COLLECTION

See Also:

• Constant Field Values

END_OF_SAME_ID_CHAIN

static final int END_OF_SAME_ID_CHAIN

See Also:

• Constant Field Values

Constructor Details

Reply

Reply(NetAgent netAgent,
 int bufferSize)

Method Details

initialize

final void initialize()

getDdmLength

final int getDdmLength()

shiftBuffer

private void shiftBuffer(byte[] destinationBuffer)

ensureSpaceInBufferForFill

private void ensureSpaceInBufferForFill(int desiredSpace)

fill

private int fill(int minimumBytesNeeded)
          throws DisconnectException

Throws:

DisconnectException

ensureALayerDataInBuffer

private int ensureALayerDataInBuffer(int desiredDataSize)
                              throws DisconnectException

Throws:

DisconnectException

ensureBLayerDataInBuffer

protected final void ensureBLayerDataInBuffer(int desiredDataSize)
                                       throws DisconnectException

Throws:

DisconnectException

compressBLayerData

private void compressBLayerData(int continueDssHeaderCount)
                         throws DisconnectException

Throws:

DisconnectException

readDssHeader

private void readDssHeader()
                    throws DisconnectException

Throws:

DisconnectException

decryptData

private void decryptData(int gdsFormatter,
 int oldDssLength)
                  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

readUnsignedShortList

final int[] readUnsignedShortList()
                           throws DisconnectException

Throws:

DisconnectException

readUnsignedByte

final int readUnsignedByte()
                    throws DisconnectException

Throws:

DisconnectException

readByte

final byte readByte()
             throws DisconnectException

Throws:

DisconnectException

readString

final String readString(int length,
 Charset encoding)
                 throws DisconnectException

Throws:

DisconnectException

readString

final String readString()
                 throws DisconnectException

Throws:

DisconnectException

readBytes

final byte[] readBytes(int length)
                throws DisconnectException

Throws:

DisconnectException

readBytes

final byte[] readBytes()
                throws DisconnectException

Throws:

DisconnectException

skipBytes

final void skipBytes(int length)
              throws DisconnectException

Throws:

DisconnectException

skipBytes

final void skipBytes()
              throws DisconnectException

Throws:

DisconnectException

getData

final ByteArrayOutputStream getData(ByteArrayOutputStream existingBuffer)
                             throws DisconnectException

Throws:

DisconnectException

readDSSContinuationHeader

private 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

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

private int readLengthAndCodePoint()
                            throws DisconnectException

Throws:

DisconnectException

readExtendedLength

private void readExtendedLength()
                         throws DisconnectException

Throws:

DisconnectException

adjustCollectionAndDssLengths

private void adjustCollectionAndDssLengths(int length)

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

peekExtendedLength

private void peekExtendedLength()
                         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 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 String readFastString(int length,
 Charset encoding)

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

private int popMark()

getFastSkipSQLCARDrowLength

final int getFastSkipSQLCARDrowLength()

getFastData

final ByteArrayOutputStream getFastData(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()

skipSQLDHROW

private int skipSQLDHROW(int offset)