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, setLogWriter
public 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
SqlException
NetAgent(NetConnection netConnection, LogWriter netLogWriter, int loginTimeout, java.lang.String server, int port, int clientSSLMode) throws SqlException
SqlException
protected void resetAgent_(LogWriter netLogWriter, int loginTimeout, java.lang.String server, int port) throws SqlException
resetAgent_
in class Agent
SqlException
void setSvrcod(int svrcod)
void clearSvrcod()
int getSvrcod()
public void flush_() throws DisconnectException
flush_
in class Agent
DisconnectException
public void close_() throws SqlException
close_
in class Agent
SqlException
protected 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
DisconnectException
public 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
DisconnectException
public LogWriter newLogWriter_(java.io.PrintWriter printWriter, int traceLevel)
newLogWriter_
in class Agent
protected void markChainBreakingException_()
markChainBreakingException_
in class Agent
public void checkForChainBreakingException_() throws SqlException
checkForChainBreakingException_
in class Agent
SqlException
private void writeDeferredResetConnection() throws SqlException
SqlException
public void beginWriteChainOutsideUOW() throws SqlException
beginWriteChainOutsideUOW
in class Agent
SqlException
public void beginWriteChain(Statement statement) throws SqlException
beginWriteChain
in class Agent
SqlException
protected void endWriteChain()
endWriteChain
in class Agent
private void readDeferredResetConnection() throws SqlException
SqlException
protected void beginReadChain(Statement statement) throws SqlException
beginReadChain
in class Agent
SqlException
protected void beginReadChainOutsideUOW() throws SqlException
beginReadChainOutsideUOW
in class Agent
SqlException
public void endReadChain() throws SqlException
endReadChain
in class Agent
SqlException
public void switchToUtf8CcsidMgr()
public void switchToEbcdicMgr()
public java.lang.String convertToStringTcpIpAddress(int tcpIpAddress)
protected int getPort()
Apache Derby V10.10 Internals - Copyright © 2004,2013 The Apache Software Foundation. All Rights Reserved.