NetConnectionReplyclass 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
DisconnectExceptionprivate int ensureALayerDataInBuffer(int desiredDataSize)
throws DisconnectException
DisconnectExceptionprotected final void ensureBLayerDataInBuffer(int desiredDataSize)
throws DisconnectException
DisconnectExceptionprivate void compressBLayerData(int continueDssHeaderCount)
throws DisconnectException
DisconnectExceptionprivate void readDssHeader()
throws DisconnectException
DisconnectExceptionprivate void decryptData(int gdsFormatter,
int oldDssLength)
throws DisconnectException
DisconnectExceptionfinal int readUnsignedShort()
throws DisconnectException
DisconnectExceptionfinal short readShort()
throws DisconnectException
DisconnectExceptionfinal int readInt()
throws DisconnectException
DisconnectExceptionfinal int[] readUnsignedShortList()
throws DisconnectException
DisconnectExceptionfinal int readUnsignedByte()
throws DisconnectException
DisconnectExceptionfinal byte readByte()
throws DisconnectException
DisconnectExceptionfinal java.lang.String readString(int length,
java.nio.charset.Charset encoding)
throws DisconnectException
DisconnectExceptionfinal java.lang.String readString()
throws DisconnectException
DisconnectExceptionfinal byte[] readBytes(int length)
throws DisconnectException
DisconnectExceptionfinal byte[] readBytes()
throws DisconnectException
DisconnectExceptionfinal void skipBytes(int length)
throws DisconnectException
DisconnectExceptionfinal void skipBytes()
throws DisconnectException
DisconnectExceptionfinal java.io.ByteArrayOutputStream getData(java.io.ByteArrayOutputStream existingBuffer)
throws DisconnectException
DisconnectExceptionprivate void readDSSContinuationHeader()
throws DisconnectException
DisconnectExceptionfinal void doSyntaxrmSemantics(int syntaxErrorCode)
throws DisconnectException
DisconnectExceptionprotected 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
DisconnectExceptionprotected final int peekFastBytes(byte[] b,
int offset,
int length)
throws DisconnectException
DisconnectExceptionprotected final void parseLengthAndMatchCodePoint(int expectedCodePoint)
throws DisconnectException
DisconnectExceptionprivate int readLengthAndCodePoint()
throws DisconnectException
DisconnectExceptionprivate void readExtendedLength()
throws DisconnectException
DisconnectExceptionprivate void adjustCollectionAndDssLengths(int length)
protected final void startSameIdChainParse()
throws DisconnectException
DisconnectExceptionprotected final void endOfSameIdChainData()
throws DisconnectException
DisconnectExceptionprotected final int peekTotalColumnCount(int tripletLength)
throws DisconnectException
DisconnectExceptionprivate void peekExtendedLength()
throws DisconnectException
DisconnectExceptionfinal int readFastUnsignedByte()
throws DisconnectException
DisconnectExceptionfinal short readFastShort()
throws DisconnectException
DisconnectExceptionfinal int readFastUnsignedShort()
throws DisconnectException
DisconnectExceptionfinal int readFastInt()
throws DisconnectException
DisconnectExceptionfinal java.lang.String readFastString(int length)
throws DisconnectException
DisconnectExceptionfinal byte[] readFastBytes(int length)
throws DisconnectException
DisconnectExceptionprotected final int peekFastLength()
throws DisconnectException
DisconnectExceptionfinal void skipFastBytes(int length)
throws DisconnectException
DisconnectExceptionfinal void readFastIntArray(int[] array)
throws DisconnectException
DisconnectExceptionfinal java.lang.String readFastString(int length,
java.nio.charset.Charset encoding)
final byte[] readFastLDBytes()
throws DisconnectException
DisconnectExceptionfinal long readFastLong()
throws DisconnectException
DisconnectExceptionfinal byte readFastByte()
throws DisconnectException
DisconnectExceptionfinal void mark()
private int popMark()
final int getFastSkipSQLCARDrowLength()
final java.io.ByteArrayOutputStream getFastData(java.io.ByteArrayOutputStream existingBuffer)
throws DisconnectException
DisconnectExceptionprotected final void matchCodePoint(int expectedCodePoint)
throws DisconnectException
DisconnectExceptionprotected final int peekNumOfColumns()
throws DisconnectException
DisconnectExceptionprotected final boolean peekForNullSqlcagrp()
private int skipSQLDHROW(int offset)
Apache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.