Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.apache.derby.client.net
Class NetAgent  view NetAgent download NetAgent.java

java.lang.Object
  extended byorg.apache.derby.client.am.Agent
      extended byorg.apache.derby.client.net.NetAgent

public class NetAgent
extends org.apache.derby.client.am.Agent


Field Summary
 ConnectionReply connectionReply_
           
 ConnectionRequestInterface connectionRequest_
           
 org.apache.derby.client.am.SqlException exceptionOpeningSocket_
           
(package private)  NetConnection netConnection_
           
 NetConnectionReply netConnectionReply_
           
 NetConnectionRequest netConnectionRequest_
           
 NetPackageReply netPackageReply_
           
 NetPackageRequest netPackageRequest_
           
 NetResultSetReply netResultSetReply_
           
 NetResultSetRequest netResultSetRequest_
           
 NetStatementReply netStatementReply_
           
 NetStatementRequest netStatementRequest_
           
 Typdef originalTargetTypdef_
           
 int orignalTargetSqlam_
           
 ConnectionReply packageReply_
           
 NetConnectionRequest packageRequest_
           
(package private)  int port_
           
(package private)  java.io.InputStream rawSocketInputStream_
           
(package private)  java.io.OutputStream rawSocketOutputStream_
           
protected  Reply reply_
           
protected  Request request_
           
 ResultSetReply resultSetReply_
           
 ResultSetRequestInterface resultSetRequest_
           
(package private)  java.lang.String server_
           
(package private)  java.net.Socket socket_
           
 CcsidManager sourceCcsidManager_
           
 StatementReply statementReply_
           
 StatementRequestInterface statementRequest_
           
protected  int svrcod_
           
 CcsidManager targetCcsidManager_
           
 int targetSqlam_
           
 Typdef targetTypdef_
           
 Typdef typdef_
           
 
Fields inherited from class org.apache.derby.client.am.Agent
accumulatedReadExceptions_, logWriter_, sectionManager_
 
Constructor Summary
  NetAgent(NetConnection netConnection, org.apache.derby.client.am.LogWriter logWriter)
           
(package private) NetAgent(NetConnection netConnection, org.apache.derby.client.am.LogWriter netLogWriter, int loginTimeout, java.lang.String server, int port)
           
 
Method Summary
protected  void beginReadChain(org.apache.derby.client.am.Statement statement)
           
protected  void beginReadChainOutsideUOW()
           
 void beginWriteChain(org.apache.derby.client.am.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_()
           
 java.io.InputStream getInputStream()
           
 java.io.OutputStream getOutputStream()
           
protected  int getPort()
           
(package private)  int getSvrcod()
           
protected  void markChainBreakingException_()
           
 org.apache.derby.client.am.LogWriter newLogWriter_(java.io.PrintWriter printWriter, int traceLevel)
           
private  void readDeferredResetConnection()
           
protected  void resetAgent_(org.apache.derby.client.am.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)
           
 void throwCommunicationsFailure(java.lang.String location, java.lang.String function, java.lang.String rc1, java.lang.String rc2)
           
private  void writeDeferredResetConnection()
           
 
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
 

Field Detail

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_
Constructor Detail

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
Method Detail

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()