class NetConnectionReply extends Reply implements ConnectionReplyInterface
Modifier and Type | Field and Description |
---|---|
private static MessageUtil |
msgutil_ |
agent_, buffer_, count_, DEFAULT_BUFFER_SIZE, dssLength_, END_OF_COLLECTION, END_OF_SAME_ID_CHAIN, ensuredLengthForDecryption_, longBufferForDecryption_, longCountForDecryption_, longPosForDecryption_, longValueForDecryption_, netAgent_, peekedLength_, pos_
Constructor and Description |
---|
NetConnectionReply(NetAgent netAgent,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
(package private) boolean |
checkAndGetReceivedFlag(boolean receivedFlag) |
(package private) void |
checkRequiredObjects(boolean receivedFlag) |
(package private) void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2) |
(package private) void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3) |
private void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4) |
(package private) void |
doDtamchrmSemantics() |
private void |
doMgrlvlrmSemantics(int[] nameList,
int[] levelList) |
private void |
doMgrlvlrmSemantics(int manager,
int level) |
private void |
doMgrlvlrmSemantics(java.lang.String manager,
java.lang.String level) |
private void |
doObjnsprmSemantics(int codePoint) |
private void |
doPrccnvrmSemantics(int conversationProtocolErrorCode) |
(package private) void |
doPrmnsprmSemantics(int codePoint) |
(package private) void |
doValnsprmSemantics(int codePoint,
int value) |
private void |
doValnsprmSemantics(int codePoint,
java.lang.String value) |
private NetSqlca |
parseAbnormalEndUow(ConnectionCallbackInterface connection,
UnitOfWorkListener uwl)
Perform necessary actions for parsing of a ABNUOWRM message.
|
(package private) NetSqlca |
parseAbnormalEndUow(ResultSetCallbackInterface r)
Perform necessary actions for parsing of a ABNUOWRM message.
|
(package private) NetSqlca |
parseAbnormalEndUow(StatementCallbackInterface s)
Perform necessary actions for parsing of a ABNUOWRM message.
|
private void |
parseABNUOWRM() |
private void |
parseAccessRdbError(NetConnection netConnection) |
private void |
parseAccessSecurityError(NetConnection netConnection) |
private void |
parseACCRDBreply(NetConnection netConnection) |
private void |
parseACCRDBRM(NetConnection netConnection) |
private void |
parseACCSECRD(NetConnection netConnection,
int securityMechanism) |
private void |
parseACCSECreply(NetConnection netConnection,
int securityMechanism) |
private int |
parseCCSIDDBC() |
private int |
parseCCSIDMBC() |
private int |
parseCCSIDSBC() |
(package private) void |
parseCMDCHKRM() |
(package private) void |
parseCMDNSPRM() |
private int |
parseCODPNT() |
private int |
parseCODPNTDR() |
private void |
parseCommitError(ConnectionCallbackInterface connection) |
(package private) void |
parseCommonError(int peekCP) |
private byte[] |
parseCRRTKN(boolean skip) |
private void |
parseDummyEXCSATRD(NetConnection netConnection) |
private void |
parseDummyEXCSATreply(NetConnection netConnection) |
(package private) void |
parseENDUOWRM(ConnectionCallbackInterface connection) |
private void |
parseExchangeServerAttributesError() |
private void |
parseEXCSATRD(NetConnection netConnection) |
private void |
parseEXCSATreply(NetConnection netConnection) |
private java.lang.String |
parseEXTNAM() |
private java.lang.String |
parseFastNVCMorNVCS() |
private int |
parseFastSQLNUMGRP() |
(package private) int |
parseFastSQLNUMROW() |
(package private) int |
parseFastSVRCOD(int minSvrcod,
int maxSvrcod) |
(package private) java.lang.String |
parseFastVCS() |
(package private) java.util.List<javax.transaction.xa.Xid> |
parseIndoubtList() |
private void |
parseInitialPBSD(ClientConnection connection)
Parse the initial PBSD - PiggyBackedSessionData code point.
|
private void |
parseMGRLVLLS(NetConnection netConnection) |
private int |
parseMGRLVLN() |
private void |
parseMGRLVLRM() |
(package private) void |
parseOBJNSPRM() |
(package private) void |
parsePBSD()
Parse a PBSD - PiggyBackedSessionData code point.
|
private int |
parsePRCCNVCD() |
private void |
parsePRCCNVRM() |
private java.lang.String |
parsePRDID(boolean skip) |
private void |
parseRdbAccessFailed(NetConnection netConnection) |
private void |
parseRDBACCRM() |
private void |
parseRDBAFLRM() |
private void |
parseRDBATHRM(NetConnection netConnection) |
private void |
parseRDBCMMreply(ConnectionCallbackInterface connection) |
(package private) void |
parseRDBNACRM() |
(package private) java.lang.String |
parseRDBNAM(boolean skip) |
private void |
parseRDBNFNRM(NetConnection netConnection) |
private void |
parseRDBRLLBCKreply(ConnectionCallbackInterface connection) |
private void |
parseRollbackError() |
private int |
parseSECCHKCD() |
private void |
parseSECCHKreply(NetConnection netConnection) |
private void |
parseSECCHKRM(NetConnection netConnection) |
private int[] |
parseSECMEC() |
private byte[] |
parseSECTKN(boolean skip) |
private void |
parseSecurityCheckError(NetConnection netConnection) |
private NetSqlca |
parseSQLCAGRP(Sqlca[] rowsetSqlca) |
(package private) NetSqlca |
parseSQLCARD(Sqlca[] rowsetSqlca) |
(package private) NetSqlca |
parseSQLCARDrow(Sqlca[] rowsetSqlca) |
private void |
parseSQLCAXGRP(NetSqlca netSqlca) |
private void |
parseSQLCNGRP() |
private void |
parseSQLCNROW() |
private int |
parseSQLDCGRP(Sqlca[] rowsetSqlca,
int lastRow) |
private int |
parseSQLDCROW(Sqlca[] rowsetSqlca,
int lastRow) |
private void |
parseSQLDCTOKS() |
private void |
parseSQLDCXGRP() |
private void |
parseSQLDIAGCI(Sqlca[] rowsetSqlca) |
private void |
parseSQLDIAGCN() |
private long |
parseSQLDIAGGRP(Sqlca[] rowsetSqlca) |
private long |
parseSQLDIAGSTT(Sqlca[] rowsetSqlca) |
private int |
parseSQLNUMGRP() |
(package private) int |
parseSQLNUMROW() |
private void |
parseSQLTOKGRP() |
private void |
parseSQLTOKROW() |
private java.lang.String |
parseSRVCLSNM() |
private java.lang.String |
parseSRVNAM() |
private java.lang.String |
parseSRVRLSLV() |
(package private) int |
parseSVRCOD(int minSvrcod,
int maxSvrcod) |
(package private) int |
parseSYNCCRD(ConnectionCallbackInterface connection) |
(package private) void |
parseSYNCCTLError(int peekCP) |
(package private) int |
parseSYNCCTLreply(ConnectionCallbackInterface connection) |
(package private) byte |
parseSYNCTYPE() |
private int |
parseSYNERRCD() |
private void |
parseSYNTAXRM() |
private void |
parseTYPDEFNAM() |
private void |
parseTYPDEFOVR() |
(package private) int |
parseTypdefsOrMgrlvlovrs() |
private int |
parseUOWDSP() |
private java.lang.String |
parseUSRID(boolean skip) |
private void |
parseVALNSPRM() |
(package private) int |
parseXARETVAL() |
(package private) javax.transaction.xa.Xid |
parseXID() |
(package private) int |
parseXIDCNT() |
(package private) void |
readAccessDatabase(ClientConnection connection) |
(package private) void |
readAccessSecurity(ClientConnection connection,
int securityMechanism) |
void |
readCommitSubstitute(ConnectionCallbackInterface connection) |
(package private) void |
readExchangeServerAttributes(ClientConnection connection) |
void |
readLocalCommit(ConnectionCallbackInterface connection) |
void |
readLocalRollback(ConnectionCallbackInterface connection) |
void |
readLocalXACommit(ConnectionCallbackInterface connection) |
void |
readLocalXARollback(ConnectionCallbackInterface connection) |
void |
readLocalXAStart(ConnectionCallbackInterface connection) |
(package private) void |
readSecurityCheck(ClientConnection connection) |
(package private) void |
readXaCommit(NetConnection conn) |
(package private) int |
readXaEndUnitOfWork(NetConnection conn) |
(package private) void |
readXaForget(NetConnection conn) |
(package private) int |
readXaPrepare(NetConnection conn) |
(package private) void |
readXaRecover(NetConnection conn) |
(package private) int |
readXaRollback(NetConnection conn) |
(package private) void |
readXaStartUnitOfWork(NetConnection conn) |
private void |
resetRowsetSqlca(Sqlca[] rowsetSqlca,
int row) |
private void |
skipFastNVCMorNVCS() |
adjustDdmLength, adjustLengths, doSyntaxrmSemantics, endOfSameIdChainData, ensureBLayerDataInBuffer, getData, getDdmLength, getFastData, getFastSkipSQLCARDrowLength, initialize, mark, matchCodePoint, parseLengthAndMatchCodePoint, peekCodePoint, peekFastBytes, peekFastLength, peekForNullSqlcagrp, peekNumOfColumns, peekTotalColumnCount, popCollectionStack, pushLengthOnCollectionStack, readByte, readBytes, readBytes, readFastByte, readFastBytes, readFastInt, readFastIntArray, readFastLDBytes, readFastLong, readFastShort, readFastString, readFastString, readFastUnsignedByte, readFastUnsignedShort, readInt, readShort, readString, readString, readUnsignedByte, readUnsignedShort, readUnsignedShortList, skipBytes, skipBytes, skipFastBytes, startSameIdChainParse
private static MessageUtil msgutil_
NetConnectionReply(NetAgent netAgent, int bufferSize)
void readExchangeServerAttributes(ClientConnection connection) throws SqlException
SqlException
void readAccessSecurity(ClientConnection connection, int securityMechanism) throws SqlException
SqlException
void readSecurityCheck(ClientConnection connection) throws SqlException
SqlException
void readAccessDatabase(ClientConnection connection) throws SqlException
SqlException
public void readCommitSubstitute(ConnectionCallbackInterface connection) throws DisconnectException
readCommitSubstitute
in interface ConnectionReplyInterface
DisconnectException
public void readLocalCommit(ConnectionCallbackInterface connection) throws DisconnectException
readLocalCommit
in interface ConnectionReplyInterface
DisconnectException
public void readLocalRollback(ConnectionCallbackInterface connection) throws DisconnectException
readLocalRollback
in interface ConnectionReplyInterface
DisconnectException
public void readLocalXAStart(ConnectionCallbackInterface connection) throws DisconnectException
readLocalXAStart
in interface ConnectionReplyInterface
DisconnectException
public void readLocalXACommit(ConnectionCallbackInterface connection) throws DisconnectException
readLocalXACommit
in interface ConnectionReplyInterface
DisconnectException
public void readLocalXARollback(ConnectionCallbackInterface connection) throws DisconnectException
readLocalXARollback
in interface ConnectionReplyInterface
DisconnectException
void readXaStartUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectException
int readXaEndUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectException
int readXaPrepare(NetConnection conn) throws DisconnectException
DisconnectException
void readXaCommit(NetConnection conn) throws DisconnectException
DisconnectException
int readXaRollback(NetConnection conn) throws DisconnectException
DisconnectException
void readXaRecover(NetConnection conn) throws DisconnectException
DisconnectException
void readXaForget(NetConnection conn) throws DisconnectException
DisconnectException
private void parseRDBCMMreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
private void parseRDBRLLBCKreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
private void parseEXCSATreply(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseDummyEXCSATreply(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseACCSECreply(NetConnection netConnection, int securityMechanism) throws DisconnectException
DisconnectException
private void parseSECCHKreply(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseACCRDBreply(NetConnection netConnection) throws DisconnectException
DisconnectException
int parseTypdefsOrMgrlvlovrs() throws DisconnectException
DisconnectException
private void parseCommitError(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
private void parseRollbackError() throws DisconnectException
DisconnectException
private void parseExchangeServerAttributesError() throws DisconnectException
DisconnectException
private void parseAccessSecurityError(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseSecurityCheckError(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseAccessRdbError(NetConnection netConnection) throws DisconnectException
DisconnectException
void parseCommonError(int peekCP) throws DisconnectException
DisconnectException
private NetSqlca parseAbnormalEndUow(ConnectionCallbackInterface connection, UnitOfWorkListener uwl) throws DisconnectException
connection
- an implementation of the ConnectionCallbackInterfaceDisconnectException
NetSqlca parseAbnormalEndUow(StatementCallbackInterface s) throws DisconnectException
s
- an implementation of the StatementCallbackInterfaceDisconnectException
NetSqlca parseAbnormalEndUow(ResultSetCallbackInterface r) throws DisconnectException
r
- an implementation of the ResultsetCallbackInterfaceDisconnectException
private void parseRdbAccessFailed(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseSECCHKRM(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseACCRDBRM(NetConnection netConnection) throws DisconnectException
DisconnectException
void parseENDUOWRM(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
void parseCMDCHKRM() throws DisconnectException
DisconnectException
void parseRDBNACRM() throws DisconnectException
DisconnectException
private void parseRDBNFNRM(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseRDBATHRM(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseSYNTAXRM() throws DisconnectException
DisconnectException
private void parseRDBACCRM() throws DisconnectException
DisconnectException
private void parseRDBAFLRM() throws DisconnectException
DisconnectException
private void parseVALNSPRM() throws DisconnectException
DisconnectException
private void parsePRCCNVRM() throws DisconnectException
DisconnectException
void parseOBJNSPRM() throws DisconnectException
DisconnectException
private void parseMGRLVLRM() throws DisconnectException
DisconnectException
void parseCMDNSPRM() throws DisconnectException
DisconnectException
private void parseABNUOWRM() throws DisconnectException
DisconnectException
private void parseEXCSATRD(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseDummyEXCSATRD(NetConnection netConnection) throws DisconnectException
DisconnectException
private void parseACCSECRD(NetConnection netConnection, int securityMechanism) throws DisconnectException
DisconnectException
private void parseTYPDEFNAM() throws DisconnectException
DisconnectException
private void parseTYPDEFOVR() throws DisconnectException
DisconnectException
int parseSYNCCRD(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
int parseXARETVAL() throws DisconnectException
DisconnectException
byte parseSYNCTYPE() throws DisconnectException
DisconnectException
int parseSYNCCTLreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
void parseSYNCCTLError(int peekCP) throws DisconnectException
DisconnectException
private void parseMGRLVLLS(NetConnection netConnection) throws DisconnectException
DisconnectException
private java.lang.String parseEXTNAM() throws DisconnectException
DisconnectException
private java.lang.String parseSRVCLSNM() throws DisconnectException
DisconnectException
private java.lang.String parseSRVNAM() throws DisconnectException
DisconnectException
private java.lang.String parseSRVRLSLV() throws DisconnectException
DisconnectException
private int parseMGRLVLN() throws DisconnectException
DisconnectException
private int[] parseSECMEC() throws DisconnectException
DisconnectException
private byte[] parseSECTKN(boolean skip) throws DisconnectException
DisconnectException
private int parseSECCHKCD() throws DisconnectException
DisconnectException
private java.lang.String parsePRDID(boolean skip) throws DisconnectException
DisconnectException
private java.lang.String parseUSRID(boolean skip) throws DisconnectException
DisconnectException
private int parseCODPNTDR() throws DisconnectException
DisconnectException
private byte[] parseCRRTKN(boolean skip) throws DisconnectException
DisconnectException
private int parseUOWDSP() throws DisconnectException
DisconnectException
java.lang.String parseRDBNAM(boolean skip) throws DisconnectException
DisconnectException
int parseXIDCNT() throws DisconnectException
DisconnectException
javax.transaction.xa.Xid parseXID() throws DisconnectException
DisconnectException
java.util.List<javax.transaction.xa.Xid> parseIndoubtList() throws DisconnectException
DisconnectException
private int parseSYNERRCD() throws DisconnectException
DisconnectException
private int parseCODPNT() throws DisconnectException
DisconnectException
private int parsePRCCNVCD() throws DisconnectException
DisconnectException
private int parseCCSIDSBC() throws DisconnectException
DisconnectException
private int parseCCSIDMBC() throws DisconnectException
DisconnectException
private int parseCCSIDDBC() throws DisconnectException
DisconnectException
int parseSVRCOD(int minSvrcod, int maxSvrcod) throws DisconnectException
DisconnectException
int parseFastSVRCOD(int minSvrcod, int maxSvrcod) throws DisconnectException
DisconnectException
NetSqlca parseSQLCARD(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectException
NetSqlca parseSQLCARDrow(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectException
int parseSQLNUMROW() throws DisconnectException
DisconnectException
int parseFastSQLNUMROW() throws DisconnectException
DisconnectException
private int parseSQLNUMGRP() throws DisconnectException
DisconnectException
private int parseFastSQLNUMGRP() throws DisconnectException
DisconnectException
private NetSqlca parseSQLCAGRP(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectException
private void parseSQLCAXGRP(NetSqlca netSqlca) throws DisconnectException
DisconnectException
private long parseSQLDIAGGRP(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectException
java.lang.String parseFastVCS() throws DisconnectException
DisconnectException
boolean checkAndGetReceivedFlag(boolean receivedFlag) throws DisconnectException
DisconnectException
void checkRequiredObjects(boolean receivedFlag) throws DisconnectException
DisconnectException
void checkRequiredObjects(boolean receivedFlag, boolean receivedFlag2) throws DisconnectException
DisconnectException
void checkRequiredObjects(boolean receivedFlag, boolean receivedFlag2, boolean receivedFlag3) throws DisconnectException
DisconnectException
private void checkRequiredObjects(boolean receivedFlag, boolean receivedFlag2, boolean receivedFlag3, boolean receivedFlag4) throws DisconnectException
DisconnectException
private void doObjnsprmSemantics(int codePoint) throws DisconnectException
DisconnectException
void doPrmnsprmSemantics(int codePoint) throws DisconnectException
DisconnectException
void doValnsprmSemantics(int codePoint, int value) throws DisconnectException
DisconnectException
private void doValnsprmSemantics(int codePoint, java.lang.String value) throws DisconnectException
DisconnectException
void doDtamchrmSemantics() throws DisconnectException
DisconnectException
private void doMgrlvlrmSemantics(java.lang.String manager, java.lang.String level) throws DisconnectException
DisconnectException
private void doMgrlvlrmSemantics(int manager, int level) throws DisconnectException
DisconnectException
private void doMgrlvlrmSemantics(int[] nameList, int[] levelList) throws DisconnectException
DisconnectException
private void doPrccnvrmSemantics(int conversationProtocolErrorCode) throws DisconnectException
DisconnectException
private void parseSQLDCTOKS() throws DisconnectException
DisconnectException
private void parseSQLDIAGCI(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectException
private void parseSQLDIAGCN() throws DisconnectException
DisconnectException
private void parseSQLCNROW() throws DisconnectException
DisconnectException
private int parseSQLDCROW(Sqlca[] rowsetSqlca, int lastRow) throws DisconnectException
DisconnectException
private void parseSQLTOKROW() throws DisconnectException
DisconnectException
private void parseSQLTOKGRP() throws DisconnectException
DisconnectException
private long parseSQLDIAGSTT(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectException
private void parseSQLCNGRP() throws DisconnectException
DisconnectException
private int parseSQLDCGRP(Sqlca[] rowsetSqlca, int lastRow) throws DisconnectException
DisconnectException
private void parseSQLDCXGRP() throws DisconnectException
DisconnectException
private java.lang.String parseFastNVCMorNVCS() throws DisconnectException
DisconnectException
private void skipFastNVCMorNVCS() throws DisconnectException
DisconnectException
private void resetRowsetSqlca(Sqlca[] rowsetSqlca, int row)
private void parseInitialPBSD(ClientConnection connection) throws DisconnectException
If sent by the server, it contains a PBSD_ISO code point followed by a byte representing the JDBC isolation level, and a PBSD_SCHEMA code point followed by the name of the current schema as an UTF-8 String.
DisconnectException
void parsePBSD() throws DisconnectException
DisconnectException
Apache Derby V10.13 Internals - Copyright © 2004,2016 The Apache Software Foundation. All Rights Reserved.