public class NetAgent extends Agent
accumulatedReadExceptions_, logWriter_, sectionManager_| Constructor and Description |
|---|
NetAgent(NetConnection netConnection,
LogWriter logWriter) |
NetAgent(NetConnection netConnection,
LogWriter netLogWriter,
int loginTimeout,
java.lang.String server,
int port,
int clientSSLMode) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
beginReadChain(Statement statement) |
protected void |
beginReadChainOutsideUOW() |
void |
beginWriteChain(Statement statement) |
void |
beginWriteChainOutsideUOW() |
void |
checkForChainBreakingException_() |
(package private) void |
clearSvrcod() |
void |
close_() |
java.lang.String |
convertToStringTcpIpAddress(int tcpIpAddress) |
void |
endReadChain() |
protected void |
endWriteChain() |
void |
flush_() |
CcsidManager |
getCurrentCcsidManager() |
java.io.InputStream |
getInputStream() |
java.io.OutputStream |
getOutputStream() |
protected int |
getPort() |
(package private) int |
getSvrcod() |
protected int |
getTimeout()
Returns the current timeout value that is set on the socket.
|
protected void |
markChainBreakingException_() |
LogWriter |
newLogWriter_(java.io.PrintWriter printWriter,
int traceLevel) |
private void |
readDeferredResetConnection() |
protected void |
resetAgent_(LogWriter netLogWriter,
int loginTimeout,
java.lang.String server,
int port) |
protected void |
sendRequest() |
(package private) void |
setInputStream(java.io.InputStream inputStream) |
(package private) void |
setOutputStream(java.io.OutputStream outputStream) |
(package private) void |
setSvrcod(int svrcod) |
protected void |
setTimeout(int timeout)
Specifies the maximum blocking time that should be used when sending
and receiving messages.
|
void |
switchToEbcdicMgr()
Switches the current CCSID manager to EBCDIC
|
void |
switchToUtf8CcsidMgr()
Switches the current CCSID manager to UTF-8
|
void |
throwCommunicationsFailure(java.lang.Throwable cause) |
private void |
writeDeferredResetConnection() |
accumulateChainBreakingReadExceptionAndThrow, accumulateDeferredException, accumulateDisconnectException, accumulateReadException, beginBatchedReadChain, beginBatchedWriteChain, checkForExceptions, checkForSupportedDataType, close, disconnectEvent, endBatchedReadChain, endBatchedWriteChain, flow, flowBatch, flowOutsideUOW, getLogWriter, loggingEnabled, resetAgent, resetAgent, setBatchedExceptionLabelIndex, setLogWriterpublic ConnectionRequestInterface connectionRequest_
public NetConnectionRequest packageRequest_
public StatementRequestInterface statementRequest_
public ResultSetRequestInterface resultSetRequest_
public ConnectionReply connectionReply_
public ConnectionReply packageReply_
public StatementReply statementReply_
public ResultSetReply resultSetReply_
NetConnection netConnection_
protected Request request_
public NetConnectionRequest netConnectionRequest_
public NetPackageRequest netPackageRequest_
public NetStatementRequest netStatementRequest_
public NetResultSetRequest netResultSetRequest_
protected Reply reply_
public NetConnectionReply netConnectionReply_
public NetPackageReply netPackageReply_
public NetStatementReply netStatementReply_
public NetResultSetReply netResultSetReply_
java.net.Socket socket_
java.io.InputStream rawSocketInputStream_
java.io.OutputStream rawSocketOutputStream_
java.lang.String server_
int port_
int clientSSLMode_
private EbcdicCcsidManager ebcdicCcsidManager_
private Utf8CcsidManager utf8CcsidManager_
private CcsidManager currentCcsidManager_
public Typdef typdef_
public Typdef targetTypdef_
public Typdef originalTargetTypdef_
protected int svrcod_
public int orignalTargetSqlam_
public int targetSqlam_
public SqlException exceptionOpeningSocket_
public SqlException exceptionConvertingRdbnam
public NetAgent(NetConnection netConnection, LogWriter logWriter) throws SqlException
SqlExceptionNetAgent(NetConnection netConnection, LogWriter netLogWriter, int loginTimeout, java.lang.String server, int port, int clientSSLMode) throws SqlException
SqlExceptionprotected void resetAgent_(LogWriter netLogWriter, int loginTimeout, java.lang.String server, int port) throws SqlException
resetAgent_ in class AgentSqlExceptionvoid setSvrcod(int svrcod)
void clearSvrcod()
int getSvrcod()
public void flush_()
throws DisconnectException
flush_ in class AgentDisconnectExceptionpublic void close_()
throws SqlException
close_ in class AgentSqlExceptionprotected void setTimeout(int timeout)
timeout - The timeout value in seconds. A value of 0 corresponds to
infinite timeout.protected int getTimeout()
protected void sendRequest()
throws DisconnectException
DisconnectExceptionpublic java.io.InputStream getInputStream()
public CcsidManager getCurrentCcsidManager()
public java.io.OutputStream getOutputStream()
void setInputStream(java.io.InputStream inputStream)
void setOutputStream(java.io.OutputStream outputStream)
public void throwCommunicationsFailure(java.lang.Throwable cause)
throws DisconnectException
DisconnectExceptionpublic LogWriter newLogWriter_(java.io.PrintWriter printWriter, int traceLevel)
newLogWriter_ in class Agentprotected void markChainBreakingException_()
markChainBreakingException_ in class Agentpublic void checkForChainBreakingException_()
throws SqlException
checkForChainBreakingException_ in class AgentSqlExceptionprivate void writeDeferredResetConnection()
throws SqlException
SqlExceptionpublic void beginWriteChainOutsideUOW()
throws SqlException
beginWriteChainOutsideUOW in class AgentSqlExceptionpublic void beginWriteChain(Statement statement) throws SqlException
beginWriteChain in class AgentSqlExceptionprotected void endWriteChain()
endWriteChain in class Agentprivate void readDeferredResetConnection()
throws SqlException
SqlExceptionprotected void beginReadChain(Statement statement) throws SqlException
beginReadChain in class AgentSqlExceptionprotected void beginReadChainOutsideUOW()
throws SqlException
beginReadChainOutsideUOW in class AgentSqlExceptionpublic void endReadChain()
throws SqlException
endReadChain in class AgentSqlExceptionpublic void switchToUtf8CcsidMgr()
public void switchToEbcdicMgr()
public java.lang.String convertToStringTcpIpAddress(int tcpIpAddress)
protected int getPort()
Apache Derby V10.10 Internals - Copyright © 2004,2014 The Apache Software Foundation. All Rights Reserved.