java.lang.Object
org.apache.derby.client.am.Agent
org.apache.derby.client.net.NetAgent
- public class NetAgent
- extends org.apache.derby.client.am.Agent
| Methods inherited from class org.apache.derby.client.am.Agent |
accumulateChainBreakingReadExceptionAndThrow, accumulateDeferredException, accumulateDisconnectException, accumulateReadException, beginBatchedReadChain, beginBatchedWriteChain, checkForExceptions, close, disconnectEvent, endBatchedReadChain, endBatchedWriteChain, flow, flowBatch, flowOutsideUOW, getLogWriter, loggingEnabled, resetAgent, resetAgent, setBatchedExceptionLabelIndex, setLogWriter |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connectionRequest_
public ConnectionRequestInterface connectionRequest_
packageRequest_
public NetConnectionRequest packageRequest_
statementRequest_
public StatementRequestInterface statementRequest_
resultSetRequest_
public ResultSetRequestInterface resultSetRequest_
connectionReply_
public ConnectionReply connectionReply_
packageReply_
public ConnectionReply packageReply_
statementReply_
public StatementReply statementReply_
resultSetReply_
public ResultSetReply resultSetReply_
netConnection_
NetConnection netConnection_
request_
protected Request request_
netConnectionRequest_
public NetConnectionRequest netConnectionRequest_
netPackageRequest_
public NetPackageRequest netPackageRequest_
netStatementRequest_
public NetStatementRequest netStatementRequest_
netResultSetRequest_
public NetResultSetRequest netResultSetRequest_
reply_
protected Reply reply_
netConnectionReply_
public NetConnectionReply netConnectionReply_
netPackageReply_
public NetPackageReply netPackageReply_
netStatementReply_
public NetStatementReply netStatementReply_
netResultSetReply_
public NetResultSetReply netResultSetReply_
socket_
java.net.Socket socket_
rawSocketInputStream_
java.io.InputStream rawSocketInputStream_
rawSocketOutputStream_
java.io.OutputStream rawSocketOutputStream_
server_
java.lang.String server_
port_
int port_
sourceCcsidManager_
public CcsidManager sourceCcsidManager_
targetCcsidManager_
public CcsidManager targetCcsidManager_
typdef_
public Typdef typdef_
targetTypdef_
public Typdef targetTypdef_
originalTargetTypdef_
public Typdef originalTargetTypdef_
svrcod_
protected int svrcod_
orignalTargetSqlam_
public int orignalTargetSqlam_
targetSqlam_
public int targetSqlam_
exceptionOpeningSocket_
public org.apache.derby.client.am.SqlException exceptionOpeningSocket_
NetAgent
public NetAgent(NetConnection netConnection,
org.apache.derby.client.am.LogWriter logWriter)
throws org.apache.derby.client.am.SqlException
NetAgent
NetAgent(NetConnection netConnection,
org.apache.derby.client.am.LogWriter netLogWriter,
int loginTimeout,
java.lang.String server,
int port)
throws org.apache.derby.client.am.SqlException
resetAgent_
protected void resetAgent_(org.apache.derby.client.am.LogWriter netLogWriter,
int loginTimeout,
java.lang.String server,
int port)
throws org.apache.derby.client.am.SqlException
setSvrcod
void setSvrcod(int svrcod)
clearSvrcod
void clearSvrcod()
getSvrcod
int getSvrcod()
flush_
public void flush_()
throws org.apache.derby.client.am.DisconnectException
close_
public void close_()
throws org.apache.derby.client.am.SqlException
sendRequest
protected void sendRequest()
throws org.apache.derby.client.am.DisconnectException
getInputStream
public java.io.InputStream getInputStream()
getOutputStream
public java.io.OutputStream getOutputStream()
setInputStream
void setInputStream(java.io.InputStream inputStream)
setOutputStream
void setOutputStream(java.io.OutputStream outputStream)
throwCommunicationsFailure
public void throwCommunicationsFailure(java.lang.String location,
java.lang.String function,
java.lang.String rc1,
java.lang.String rc2)
throws org.apache.derby.client.am.DisconnectException
newLogWriter_
public org.apache.derby.client.am.LogWriter newLogWriter_(java.io.PrintWriter printWriter,
int traceLevel)
markChainBreakingException_
protected void markChainBreakingException_()
checkForChainBreakingException_
public void checkForChainBreakingException_()
throws org.apache.derby.client.am.SqlException
writeDeferredResetConnection
private void writeDeferredResetConnection()
throws org.apache.derby.client.am.SqlException
beginWriteChainOutsideUOW
public void beginWriteChainOutsideUOW()
throws org.apache.derby.client.am.SqlException
beginWriteChain
public void beginWriteChain(org.apache.derby.client.am.Statement statement)
throws org.apache.derby.client.am.SqlException
endWriteChain
protected void endWriteChain()
readDeferredResetConnection
private void readDeferredResetConnection()
throws org.apache.derby.client.am.SqlException
beginReadChain
protected void beginReadChain(org.apache.derby.client.am.Statement statement)
throws org.apache.derby.client.am.SqlException
beginReadChainOutsideUOW
protected void beginReadChainOutsideUOW()
throws org.apache.derby.client.am.SqlException
endReadChain
public void endReadChain()
throws org.apache.derby.client.am.SqlException
convertToStringTcpIpAddress
public java.lang.String convertToStringTcpIpAddress(int tcpIpAddress)
getPort
protected int getPort()