NetConnectionReply
class Reply
extends java.lang.Object
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 int |
DEFAULT_BUFFER_SIZE |
|
private int |
dssCorrelationID_ |
|
private boolean |
dssIsChainedWithSameID_ |
|
private boolean |
dssIsContinued_ |
|
protected int |
dssLength_ |
|
private static int |
EMPTY_STACK |
|
(package private) static int |
END_OF_COLLECTION |
|
(package private) static int |
END_OF_SAME_ID_CHAIN |
|
protected boolean |
ensuredLengthForDecryption_ |
|
protected byte[] |
longBufferForDecryption_ |
|
protected int |
longCountForDecryption_ |
|
protected int |
longPosForDecryption_ |
|
protected byte[] |
longValueForDecryption_ |
|
private static int |
MAX_MARKS_NESTING |
|
protected NetAgent |
netAgent_ |
|
private int |
peekedCodePoint_ |
|
protected int |
peekedLength_ |
|
private int |
peekedNumOfExtendedLenBytes_ |
|
protected int |
pos_ |
|
private int |
topDdmCollectionStack_ |
Modifier and Type | Method | Description |
---|---|---|
private void |
adjustCollectionAndDssLengths(int length) |
|
protected int |
adjustDdmLength(int ddmLength,
int length) |
|
protected void |
adjustLengths(int length) |
|
private void |
compressBLayerData(int continueDssHeaderCount) |
|
private void |
decryptData(int gdsFormatter,
int oldDssLength) |
|
(package private) void |
doSyntaxrmSemantics(int syntaxErrorCode) |
|
protected void |
endOfSameIdChainData() |
|
private int |
ensureALayerDataInBuffer(int desiredDataSize) |
|
protected void |
ensureBLayerDataInBuffer(int desiredDataSize) |
|
private void |
ensureSpaceInBufferForFill(int desiredSpace) |
|
private 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() |
|
private void |
peekExtendedLength() |
|
protected int |
peekFastBytes(byte[] b,
int offset,
int length) |
|
protected int |
peekFastLength() |
|
protected boolean |
peekForNullSqlcagrp() |
|
protected int |
peekNumOfColumns() |
|
protected int |
peekTotalColumnCount(int tripletLength) |
|
protected void |
popCollectionStack() |
|
private int |
popMark() |
|
protected void |
pushLengthOnCollectionStack() |
|
(package private) byte |
readByte() |
|
(package private) byte[] |
readBytes() |
|
(package private) byte[] |
readBytes(int length) |
|
private void |
readDSSContinuationHeader() |
|
private void |
readDssHeader() |
|
private void |
readExtendedLength() |
|
(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.nio.charset.Charset encoding) |
|
(package private) int |
readFastUnsignedByte() |
|
(package private) int |
readFastUnsignedShort() |
|
(package private) int |
readInt() |
|
private int |
readLengthAndCodePoint() |
|
(package private) short |
readShort() |
|
(package private) java.lang.String |
readString() |
|
(package private) java.lang.String |
readString(int length,
java.nio.charset.Charset encoding) |
|
(package private) int |
readUnsignedByte() |
|
(package private) int |
readUnsignedShort() |
|
(package private) int[] |
readUnsignedShortList() |
|
private void |
shiftBuffer(byte[] destinationBuffer) |
|
(package private) void |
skipBytes() |
|
(package private) void |
skipBytes(int length) |
|
(package private) void |
skipFastBytes(int length) |
|
private int |
skipSQLDHROW(int offset) |
|
protected void |
startSameIdChainParse() |
protected Agent agent_
protected NetAgent netAgent_
protected static final int DEFAULT_BUFFER_SIZE
protected byte[] buffer_
protected int pos_
protected int count_
private int topDdmCollectionStack_
private static final int MAX_MARKS_NESTING
private int[] ddmCollectionLenStack_
private int ddmScalarLen_
private static final int EMPTY_STACK
protected boolean ensuredLengthForDecryption_
protected byte[] longBufferForDecryption_
protected int longPosForDecryption_
protected byte[] longValueForDecryption_
protected int longCountForDecryption_
protected int dssLength_
private boolean dssIsContinued_
private boolean dssIsChainedWithSameID_
private int dssCorrelationID_
protected int peekedLength_
private int peekedCodePoint_
private int peekedNumOfExtendedLenBytes_
private int currentPos_
static final int END_OF_COLLECTION
static final int END_OF_SAME_ID_CHAIN
Reply(NetAgent netAgent, int bufferSize)
final void initialize()
final int getDdmLength()
private void shiftBuffer(byte[] destinationBuffer)
private void ensureSpaceInBufferForFill(int desiredSpace)
private int fill(int minimumBytesNeeded) throws DisconnectException
DisconnectException
private int ensureALayerDataInBuffer(int desiredDataSize) throws DisconnectException
DisconnectException
protected final void ensureBLayerDataInBuffer(int desiredDataSize) throws DisconnectException
DisconnectException
private void compressBLayerData(int continueDssHeaderCount) throws DisconnectException
DisconnectException
private void readDssHeader() throws DisconnectException
DisconnectException
private void decryptData(int gdsFormatter, int oldDssLength) throws DisconnectException
DisconnectException
final int readUnsignedShort() throws DisconnectException
DisconnectException
final short readShort() throws DisconnectException
DisconnectException
final int readInt() throws DisconnectException
DisconnectException
final int[] readUnsignedShortList() throws DisconnectException
DisconnectException
final int readUnsignedByte() throws DisconnectException
DisconnectException
final byte readByte() throws DisconnectException
DisconnectException
final java.lang.String readString(int length, java.nio.charset.Charset encoding) throws DisconnectException
DisconnectException
final java.lang.String readString() throws DisconnectException
DisconnectException
final byte[] readBytes(int length) throws DisconnectException
DisconnectException
final byte[] readBytes() throws DisconnectException
DisconnectException
final void skipBytes(int length) throws DisconnectException
DisconnectException
final void skipBytes() throws DisconnectException
DisconnectException
final java.io.ByteArrayOutputStream getData(java.io.ByteArrayOutputStream existingBuffer) throws DisconnectException
DisconnectException
private void readDSSContinuationHeader() throws DisconnectException
DisconnectException
final void doSyntaxrmSemantics(int syntaxErrorCode) throws DisconnectException
DisconnectException
protected final void pushLengthOnCollectionStack()
protected final void adjustLengths(int length)
protected int adjustDdmLength(int ddmLength, int length)
protected final void popCollectionStack()
protected final int peekCodePoint() throws DisconnectException
DisconnectException
protected final int peekFastBytes(byte[] b, int offset, int length) throws DisconnectException
DisconnectException
protected final void parseLengthAndMatchCodePoint(int expectedCodePoint) throws DisconnectException
DisconnectException
private int readLengthAndCodePoint() throws DisconnectException
DisconnectException
private void readExtendedLength() throws DisconnectException
DisconnectException
private void adjustCollectionAndDssLengths(int length)
protected final void startSameIdChainParse() throws DisconnectException
DisconnectException
protected final void endOfSameIdChainData() throws DisconnectException
DisconnectException
protected final int peekTotalColumnCount(int tripletLength) throws DisconnectException
DisconnectException
private void peekExtendedLength() throws DisconnectException
DisconnectException
final int readFastUnsignedByte() throws DisconnectException
DisconnectException
final short readFastShort() throws DisconnectException
DisconnectException
final int readFastUnsignedShort() throws DisconnectException
DisconnectException
final int readFastInt() throws DisconnectException
DisconnectException
final java.lang.String readFastString(int length) throws DisconnectException
DisconnectException
final byte[] readFastBytes(int length) throws DisconnectException
DisconnectException
protected final int peekFastLength() throws DisconnectException
DisconnectException
final void skipFastBytes(int length) throws DisconnectException
DisconnectException
final void readFastIntArray(int[] array) throws DisconnectException
DisconnectException
final java.lang.String readFastString(int length, java.nio.charset.Charset encoding)
final byte[] readFastLDBytes() throws DisconnectException
DisconnectException
final long readFastLong() throws DisconnectException
DisconnectException
final byte readFastByte() throws DisconnectException
DisconnectException
final void mark()
private int popMark()
final int getFastSkipSQLCARDrowLength()
final java.io.ByteArrayOutputStream getFastData(java.io.ByteArrayOutputStream existingBuffer) throws DisconnectException
DisconnectException
protected final void matchCodePoint(int expectedCodePoint) throws DisconnectException
DisconnectException
protected final int peekNumOfColumns() throws DisconnectException
DisconnectException
protected final boolean peekForNullSqlcagrp()
private int skipSQLDHROW(int offset)
Apache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.