public class NetAgent extends Agent
logWriter_
Constructor | 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 | Description |
---|---|---|
protected void |
beginReadChain(ClientStatement statement) |
|
protected void |
beginReadChainOutsideUOW() |
|
void |
beginWriteChain(ClientStatement statement) |
|
void |
beginWriteChainOutsideUOW() |
|
void |
checkForChainBreakingException_() |
|
(package private) void |
clearSvrcod() |
|
void |
close_() |
|
protected void |
endWriteChain() |
|
void |
flush_() |
|
CcsidManager |
getCurrentCcsidManager() |
|
java.io.InputStream |
getInputStream() |
|
java.io.OutputStream |
getOutputStream() |
|
private int |
getSvrcod() |
|
protected int |
getTimeout() |
Returns the current timeout value that is set on the socket.
|
protected void |
markChainBreakingException_() |
|
(package private) void |
markWriteChainAsDirty() |
Marks the agent's write chain as dirty.
|
private void |
readDeferredResetConnection() |
|
protected void |
resetAgent_(LogWriter netLogWriter,
int loginTimeout,
java.lang.String server,
int port) |
|
private 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.
|
(package private) void |
switchToEbcdicMgr() |
Switches the current CCSID manager to EBCDIC
|
(package private) void |
switchToUtf8CcsidMgr() |
Switches the current CCSID manager to UTF-8
|
(package private) void |
throwCommunicationsFailure(java.lang.Throwable cause) |
|
private void |
verifyWriteChainIsClean() |
|
private void |
writeDeferredResetConnection() |
accumulateChainBreakingReadExceptionAndThrow, accumulateReadException, checkForExceptions, close, endReadChain, flow, flowOutsideUOW, getLogWriter, loggingEnabled, setBatchedExceptionLabelIndex, setLogWriter
ConnectionRequestInterface connectionRequest_
StatementRequestInterface statementRequest_
ResultSetRequestInterface resultSetRequest_
ConnectionReply connectionReply_
private ConnectionReply packageReply_
StatementReply statementReply_
ResultSetReply resultSetReply_
NetConnection netConnection_
private Request request_
NetConnectionRequest netConnectionRequest_
private NetPackageRequest netPackageRequest_
private NetStatementRequest netStatementRequest_
private NetResultSetRequest netResultSetRequest_
private Reply reply_
NetConnectionReply netConnectionReply_
private NetPackageReply netPackageReply_
private NetStatementReply netStatementReply_
private NetResultSetReply netResultSetReply_
java.net.Socket socket_
private java.io.InputStream rawSocketInputStream_
private java.io.OutputStream rawSocketOutputStream_
java.lang.String server_
int port_
private int clientSSLMode_
private EbcdicCcsidManager ebcdicCcsidManager_
private Utf8CcsidManager utf8CcsidManager_
private CcsidManager currentCcsidManager_
Typdef typdef_
Typdef targetTypdef_
Typdef originalTargetTypdef_
private int svrcod_
int orignalTargetSqlam_
int targetSqlam_
SqlException exceptionOpeningSocket_
SqlException exceptionConvertingRdbnam
private boolean writeChainIsDirty_
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()
private 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()
private 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)
void throwCommunicationsFailure(java.lang.Throwable cause) throws DisconnectException
DisconnectException
protected void markChainBreakingException_()
markChainBreakingException_
in class Agent
public void checkForChainBreakingException_() throws SqlException
checkForChainBreakingException_
in class Agent
SqlException
private void writeDeferredResetConnection() throws SqlException
SqlException
void markWriteChainAsDirty()
private void verifyWriteChainIsClean() throws DisconnectException
DisconnectException
public void beginWriteChainOutsideUOW() throws SqlException
beginWriteChainOutsideUOW
in class Agent
SqlException
public void beginWriteChain(ClientStatement statement) throws SqlException
beginWriteChain
in class Agent
SqlException
protected void endWriteChain()
endWriteChain
in class Agent
private void readDeferredResetConnection() throws SqlException
SqlException
protected void beginReadChain(ClientStatement statement) throws SqlException
beginReadChain
in class Agent
SqlException
protected void beginReadChainOutsideUOW() throws SqlException
beginReadChainOutsideUOW
in class Agent
SqlException
void switchToUtf8CcsidMgr()
void switchToEbcdicMgr()
Apache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.