public class NetConnectionReply extends Reply implements ConnectionReplyInterface
Modifier and Type | Field and Description |
---|---|
private static MessageUtil |
msgutil_ |
agent_, buffer_, count_, DEFAULT_BUFFER_SIZE, dssCorrelationID_, dssIsContinued_, dssLength_, END_OF_COLLECTION, END_OF_SAME_ID_CHAIN, ensuredLengthForDecryption_, longBufferForDecryption_, longCountForDecryption_, longPosForDecryption_, longValueForDecryption_, netAgent_, peekedCodePoint_, peekedLength_, pos_
Constructor and Description |
---|
NetConnectionReply(NetAgent netAgent,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkAndGetReceivedFlag(boolean receivedFlag) |
protected void |
checkRequiredObjects(boolean receivedFlag) |
protected void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2) |
protected void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3) |
protected 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) |
protected void |
doObjnsprmSemantics(int codePoint) |
protected void |
doPrccnvrmSemantics(int conversationProtocolErrorCode) |
protected void |
doPrmnsprmSemantics(int codePoint) |
(package private) void |
doValnsprmSemantics(int codePoint,
int value) |
(package private) void |
doValnsprmSemantics(int codePoint,
java.lang.String value) |
(package 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.
|
(package private) void |
parseABNUOWRM() |
(package private) void |
parseAccessRdbError(NetConnection netConnection) |
(package 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) |
protected int |
parseCCSIDDBC() |
protected int |
parseCCSIDMBC() |
protected int |
parseCCSIDSBC() |
protected void |
parseCMDCHKRM() |
protected void |
parseCMDNSPRM() |
protected int |
parseCODPNT() |
protected int |
parseCODPNTDR() |
protected void |
parseCommitError(ConnectionCallbackInterface connection) |
(package private) void |
parseCommonError(int peekCP) |
protected byte[] |
parseCRRTKN(boolean skip) |
private void |
parseDummyEXCSATRD(NetConnection netConnection) |
private void |
parseDummyEXCSATreply(NetConnection netConnection) |
(package private) void |
parseENDUOWRM(ConnectionCallbackInterface connection) |
(package private) void |
parseExchangeServerAttributesError() |
private void |
parseEXCSATRD(NetConnection netConnection) |
private void |
parseEXCSATreply(NetConnection netConnection) |
protected java.lang.String |
parseEXTNAM() |
private java.lang.String |
parseFastNVCMorNVCS() |
private int |
parseFastSQLNUMGRP() |
(package private) int |
parseFastSQLNUMROW() |
protected int |
parseFastSVRCOD(int minSvrcod,
int maxSvrcod) |
protected java.lang.String |
parseFastVCS() |
protected java.util.Hashtable |
parseIndoubtList() |
protected void |
parseInitialPBSD(Connection connection)
Parse the initial PBSD - PiggyBackedSessionData code point.
|
private void |
parseMGRLVLLS(NetConnection netConnection) |
protected int |
parseMGRLVLN() |
private void |
parseMGRLVLRM() |
(package private) void |
parseOBJNSPRM() |
protected void |
parsePBSD()
Parse a PBSD - PiggyBackedSessionData code point.
|
protected int |
parsePRCCNVCD() |
protected void |
parsePRCCNVRM() |
protected java.lang.String |
parsePRDID(boolean skip) |
(package 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() |
protected java.lang.String |
parseRDBNAM(boolean skip) |
private void |
parseRDBNFNRM(NetConnection netConnection) |
private void |
parseRDBRLLBCKreply(ConnectionCallbackInterface connection) |
(package private) void |
parseRollbackError() |
protected int |
parseSECCHKCD() |
private void |
parseSECCHKreply(NetConnection netConnection) |
private void |
parseSECCHKRM(NetConnection netConnection) |
protected int[] |
parseSECMEC() |
protected byte[] |
parseSECTKN(boolean skip) |
(package private) void |
parseSecurityCheckError(NetConnection netConnection) |
private NetSqlca |
parseSQLCAGRP(Sqlca[] rowsetSqlca) |
protected 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) |
(package 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() |
protected java.lang.String |
parseSRVCLSNM() |
protected java.lang.String |
parseSRVNAM() |
protected java.lang.String |
parseSRVRLSLV() |
protected int |
parseSVRCOD(int minSvrcod,
int maxSvrcod) |
(package private) int |
parseSYNCCRD(ConnectionCallbackInterface connection) |
(package private) void |
parseSYNCCTLError(int peekCP) |
protected int |
parseSYNCCTLreply(ConnectionCallbackInterface connection) |
protected byte |
parseSYNCTYPE() |
protected int |
parseSYNERRCD() |
protected void |
parseSYNTAXRM() |
(package private) void |
parseTYPDEFNAM() |
(package private) void |
parseTYPDEFOVR() |
protected int |
parseTypdefsOrMgrlvlovrs() |
protected int |
parseUOWDSP() |
protected java.lang.String |
parseUSRID(boolean skip) |
protected void |
parseVALNSPRM() |
protected int |
parseXARETVAL() |
protected javax.transaction.xa.Xid |
parseXID() |
protected int |
parseXIDCNT() |
(package private) void |
readAccessDatabase(Connection connection) |
(package private) void |
readAccessSecurity(Connection connection,
int securityMechanism) |
void |
readCommitSubstitute(ConnectionCallbackInterface connection) |
(package private) void |
readExchangeServerAttributes(Connection 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(Connection connection) |
protected void |
readXaCommit(NetConnection conn) |
protected int |
readXaEndUnitOfWork(NetConnection conn) |
protected void |
readXaForget(NetConnection conn) |
protected int |
readXaPrepare(NetConnection conn) |
protected void |
readXaRecover(NetConnection conn) |
protected int |
readXaRollback(NetConnection conn) |
protected void |
readXaStartUnitOfWork(NetConnection conn) |
(package private) void |
resetRowsetSqlca(Sqlca[] rowsetSqlca,
int row) |
private void |
skipFastNVCMorNVCS() |
adjustDdmLength, adjustLengths, doSyntaxrmSemantics, endOfSameIdChainData, ensureALayerDataInBuffer, ensureBLayerDataInBuffer, ensureSpaceInBufferForFill, fill, getData, getDdmLength, getFastData, getFastSkipSQLCARDrowLength, initialize, mark, matchCodePoint, parseLengthAndMatchCodePoint, peekCodePoint, peekFastBytes, peekFastLength, peekForNullSqlcagrp, peekLength, peekNumOfColumns, peekTotalColumnCount, popCollectionStack, popMark, pushLengthOnCollectionStack, readBoolean, readByte, readBytes, readBytes, readDSSContinuationHeader, readDssHeader, readFastByte, readFastBytes, readFastInt, readFastIntArray, readFastLDBytes, readFastLong, readFastShort, readFastString, readFastString, readFastUnsignedByte, readFastUnsignedShort, readInt, readIntArray, readLDBytes, readLengthAndCodePoint, readLong, readShort, readString, readString, readString, readUnsignedByte, readUnsignedShort, readUnsignedShortList, skipBytes, skipBytes, skipFastBytes, startSameIdChainParse
private static MessageUtil msgutil_
NetConnectionReply(NetAgent netAgent, int bufferSize)
void readExchangeServerAttributes(Connection connection) throws SqlException
SqlException
void readAccessSecurity(Connection connection, int securityMechanism) throws SqlException
SqlException
void readSecurityCheck(Connection connection) throws SqlException
SqlException
void readAccessDatabase(Connection 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
protected void readXaStartUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectException
protected int readXaEndUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectException
protected int readXaPrepare(NetConnection conn) throws DisconnectException
DisconnectException
protected void readXaCommit(NetConnection conn) throws DisconnectException
DisconnectException
protected int readXaRollback(NetConnection conn) throws DisconnectException
DisconnectException
protected void readXaRecover(NetConnection conn) throws DisconnectException
DisconnectException
protected 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
protected int parseTypdefsOrMgrlvlovrs() throws DisconnectException
DisconnectException
protected void parseCommitError(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
void parseRollbackError() throws DisconnectException
DisconnectException
void parseExchangeServerAttributesError() throws DisconnectException
DisconnectException
void parseAccessSecurityError(NetConnection netConnection) throws DisconnectException
DisconnectException
void parseSecurityCheckError(NetConnection netConnection) throws DisconnectException
DisconnectException
void parseAccessRdbError(NetConnection netConnection) throws DisconnectException
DisconnectException
void parseCommonError(int peekCP) throws DisconnectException
DisconnectException
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
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
protected 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
protected void parseSYNTAXRM() throws DisconnectException
DisconnectException
private void parseRDBACCRM() throws DisconnectException
DisconnectException
private void parseRDBAFLRM() throws DisconnectException
DisconnectException
protected void parseVALNSPRM() throws DisconnectException
DisconnectException
protected void parsePRCCNVRM() throws DisconnectException
DisconnectException
void parseOBJNSPRM() throws DisconnectException
DisconnectException
private void parseMGRLVLRM() throws DisconnectException
DisconnectException
protected void parseCMDNSPRM() throws DisconnectException
DisconnectException
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
void parseTYPDEFNAM() throws DisconnectException
DisconnectException
void parseTYPDEFOVR() throws DisconnectException
DisconnectException
int parseSYNCCRD(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
protected int parseXARETVAL() throws DisconnectException
DisconnectException
protected byte parseSYNCTYPE() throws DisconnectException
DisconnectException
protected int parseSYNCCTLreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectException
void parseSYNCCTLError(int peekCP) throws DisconnectException
DisconnectException
private void parseMGRLVLLS(NetConnection netConnection) throws DisconnectException
DisconnectException
protected java.lang.String parseEXTNAM() throws DisconnectException
DisconnectException
protected java.lang.String parseSRVCLSNM() throws DisconnectException
DisconnectException
protected java.lang.String parseSRVNAM() throws DisconnectException
DisconnectException
protected java.lang.String parseSRVRLSLV() throws DisconnectException
DisconnectException
protected int parseMGRLVLN() throws DisconnectException
DisconnectException
protected int[] parseSECMEC() throws DisconnectException
DisconnectException
protected byte[] parseSECTKN(boolean skip) throws DisconnectException
DisconnectException
protected int parseSECCHKCD() throws DisconnectException
DisconnectException
protected java.lang.String parsePRDID(boolean skip) throws DisconnectException
DisconnectException
protected java.lang.String parseUSRID(boolean skip) throws DisconnectException
DisconnectException
protected int parseCODPNTDR() throws DisconnectException
DisconnectException
protected byte[] parseCRRTKN(boolean skip) throws DisconnectException
DisconnectException
protected int parseUOWDSP() throws DisconnectException
DisconnectException
protected java.lang.String parseRDBNAM(boolean skip) throws DisconnectException
DisconnectException
protected int parseXIDCNT() throws DisconnectException
DisconnectException
protected javax.transaction.xa.Xid parseXID() throws DisconnectException
DisconnectException
protected java.util.Hashtable parseIndoubtList() throws DisconnectException
DisconnectException
protected int parseSYNERRCD() throws DisconnectException
DisconnectException
protected int parseCODPNT() throws DisconnectException
DisconnectException
protected int parsePRCCNVCD() throws DisconnectException
DisconnectException
protected int parseCCSIDSBC() throws DisconnectException
DisconnectException
protected int parseCCSIDMBC() throws DisconnectException
DisconnectException
protected int parseCCSIDDBC() throws DisconnectException
DisconnectException
protected int parseSVRCOD(int minSvrcod, int maxSvrcod) throws DisconnectException
DisconnectException
protected int parseFastSVRCOD(int minSvrcod, int maxSvrcod) throws DisconnectException
DisconnectException
protected 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
protected java.lang.String parseFastVCS() throws DisconnectException
DisconnectException
protected boolean checkAndGetReceivedFlag(boolean receivedFlag) throws DisconnectException
DisconnectException
protected void checkRequiredObjects(boolean receivedFlag) throws DisconnectException
DisconnectException
protected void checkRequiredObjects(boolean receivedFlag, boolean receivedFlag2) throws DisconnectException
DisconnectException
protected void checkRequiredObjects(boolean receivedFlag, boolean receivedFlag2, boolean receivedFlag3) throws DisconnectException
DisconnectException
protected void checkRequiredObjects(boolean receivedFlag, boolean receivedFlag2, boolean receivedFlag3, boolean receivedFlag4) throws DisconnectException
DisconnectException
protected void doObjnsprmSemantics(int codePoint) throws DisconnectException
DisconnectException
protected void doPrmnsprmSemantics(int codePoint) throws DisconnectException
DisconnectException
void doValnsprmSemantics(int codePoint, int value) throws DisconnectException
DisconnectException
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
protected void doPrccnvrmSemantics(int conversationProtocolErrorCode) throws DisconnectException
DisconnectException
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
void resetRowsetSqlca(Sqlca[] rowsetSqlca, int row)
protected void parseInitialPBSD(Connection 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
protected void parsePBSD() throws DisconnectException
DisconnectException
Apache Derby V10.10 Internals - Copyright © 2004,2013 The Apache Software Foundation. All Rights Reserved.