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

Quick Search    Search Deep

org.apache.derby.impl.drda
Class DRDAXAProtocol  view DRDAXAProtocol download DRDAXAProtocol.java

java.lang.Object
  extended byorg.apache.derby.impl.drda.DRDAXAProtocol

public class DRDAXAProtocol
extends java.lang.Object


Field Summary
private  DRDAConnThread connThread
           
private  DDMReader reader
           
private  DDMWriter writer
           
 
Constructor Summary
DRDAXAProtocol(DRDAConnThread connThread)
           
 
Method Summary
private  void commitLocalTransaction()
          Commit local transaction.
private  void commitTransaction(javax.transaction.xa.Xid xid, int xaflags)
          Commit the xa transaction.
private  void commitXATransaction(javax.transaction.xa.Xid xid, int xaflags)
          Commit the xa transaction.
private  void endXA(javax.transaction.xa.Xid xid, int xaflags)
          End the xa transaction.
private  void forgetXATransaction(javax.transaction.xa.Xid xid)
          Forget the xa transaction.
private  javax.transaction.xa.XAResource getXAResource()
          get XAResource for the connection
protected  void parseSYNCCTL()
          Parse SYNCCTL - Parse SYNCCTL command for XAMGR lvl 7
protected  int parseSYNCTYPE()
          parse SYNCTYPE for XAMGR lvl 7 return synctype value CodePoint.SYNCTYPE_NEW_UOW -> XAResource.start() CodePoint.SYNCTYPE_END_UOW -> XAResource.end() CodePoint.SYNCTYPE_PREPARE -> XAResource.prepare() CodePoint.SYNCTYPE_MIGRATE -> not supported //SYNCPT MGR LEVEL 5 CodePoint.SYNCTYPE_REQ_COMMIT -> not supported //SYNCPT MGR LEVEL 5 CodePoint.SYNCTYPE_COMMITTED -> XAResource.commit() or local commit for null XID CodePoint.SYNCTYPE_REQ_LOG -> not supported CodePoint.SYNCTYPE_REQ_FORGET -> XAResource.forget() CodePoint.SYNCTYPE_ROLLBACK -> XAResource.rollback() CodePoint.SYNCTYPE_MIGRATED -> not supported CodePoint.SYNCTYPE_INDOUBT -> XAResource.recover();
private  int parseXAFlags()
          parse XAFlags
private  javax.transaction.xa.Xid parseXID()
          Parse XID formatId -1 translates into a null XID and a local transaction
private  int parseXIDSHR()
          parse XIDSHR
private  void prepareXATransaction(javax.transaction.xa.Xid xid)
          Prepare the xa transaction.
private  int processXAException(javax.transaction.xa.XAException xe)
          return xa exception errorCode.
private  void recoverXA()
           
private  void recoverXA(int xaflags)
          Call recover.
private  void rollbackLocalTransaction()
          Rollback a local transaction
private  void rollbackTransaction(javax.transaction.xa.Xid xid)
          Rollback transaction
private  void rollbackXATransaction(javax.transaction.xa.Xid xid)
          Rollback the xa transaction.
private  void startXATransaction(javax.transaction.xa.Xid xid, int xaflags)
          Start the xa transaction.
private  java.lang.String syncTypeToString(int syncType)
          printable syncType for debug output
private  void writePRPHRCLST(javax.transaction.xa.Xid[] xids)
          write PRPHRCLST (indoubt list)
private  void writeSYNCCRD(int synctype, int xaRetVal, javax.transaction.xa.Xid[] xids)
          Write SYNCCRD (SYNCCTL response)
private  void writeXID(javax.transaction.xa.Xid xid)
          write XID
private  java.lang.String xaflagsToString(int xaflags)
          printable xaflags
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connThread

private DRDAConnThread connThread

reader

private DDMReader reader

writer

private DDMWriter writer
Constructor Detail

DRDAXAProtocol

public DRDAXAProtocol(DRDAConnThread connThread)
Method Detail

parseSYNCCTL

protected void parseSYNCCTL()
                     throws DRDAProtocolException
Parse SYNCCTL - Parse SYNCCTL command for XAMGR lvl 7


parseSYNCTYPE

protected int parseSYNCTYPE()
                     throws DRDAProtocolException
parse SYNCTYPE for XAMGR lvl 7 return synctype value CodePoint.SYNCTYPE_NEW_UOW -> XAResource.start() CodePoint.SYNCTYPE_END_UOW -> XAResource.end() CodePoint.SYNCTYPE_PREPARE -> XAResource.prepare() CodePoint.SYNCTYPE_MIGRATE -> not supported //SYNCPT MGR LEVEL 5 CodePoint.SYNCTYPE_REQ_COMMIT -> not supported //SYNCPT MGR LEVEL 5 CodePoint.SYNCTYPE_COMMITTED -> XAResource.commit() or local commit for null XID CodePoint.SYNCTYPE_REQ_LOG -> not supported CodePoint.SYNCTYPE_REQ_FORGET -> XAResource.forget() CodePoint.SYNCTYPE_ROLLBACK -> XAResource.rollback() CodePoint.SYNCTYPE_MIGRATED -> not supported CodePoint.SYNCTYPE_INDOUBT -> XAResource.recover();


parseXID

private javax.transaction.xa.Xid parseXID()
                                   throws DRDAProtocolException
Parse XID formatId -1 translates into a null XID and a local transaction


parseXIDSHR

private int parseXIDSHR()
                 throws DRDAProtocolException
parse XIDSHR


parseXAFlags

private int parseXAFlags()
                  throws DRDAProtocolException
parse XAFlags


startXATransaction

private void startXATransaction(javax.transaction.xa.Xid xid,
                                int xaflags)
                         throws DRDAProtocolException
Start the xa transaction. Send SYNCRRD response


commitTransaction

private void commitTransaction(javax.transaction.xa.Xid xid,
                               int xaflags)
                        throws DRDAProtocolException
Commit the xa transaction. Send SYNCCRD response


commitLocalTransaction

private void commitLocalTransaction()
                             throws DRDAProtocolException
Commit local transaction. Send SYNCCRD response.


commitXATransaction

private void commitXATransaction(javax.transaction.xa.Xid xid,
                                 int xaflags)
                          throws DRDAProtocolException
Commit the xa transaction. Send SYNCCRD response.


rollbackTransaction

private void rollbackTransaction(javax.transaction.xa.Xid xid)
                          throws DRDAProtocolException
Rollback transaction


rollbackLocalTransaction

private void rollbackLocalTransaction()
                               throws DRDAProtocolException
Rollback a local transaction


rollbackXATransaction

private void rollbackXATransaction(javax.transaction.xa.Xid xid)
                            throws DRDAProtocolException
Rollback the xa transaction. Send SYNCCRD response.


endXA

private void endXA(javax.transaction.xa.Xid xid,
                   int xaflags)
            throws DRDAProtocolException
End the xa transaction. Send SYNCRRD response


prepareXATransaction

private void prepareXATransaction(javax.transaction.xa.Xid xid)
                           throws DRDAProtocolException
Prepare the xa transaction. Send SYNCCRD response.


forgetXATransaction

private void forgetXATransaction(javax.transaction.xa.Xid xid)
                          throws DRDAProtocolException
Forget the xa transaction. Send SYNCCRD response.


recoverXA

private void recoverXA()
                throws DRDAProtocolException

recoverXA

private void recoverXA(int xaflags)
                throws DRDAProtocolException
Call recover. Send SYNCCRD response with indoubt list


writeSYNCCRD

private void writeSYNCCRD(int synctype,
                          int xaRetVal,
                          javax.transaction.xa.Xid[] xids)
                   throws DRDAProtocolException
Write SYNCCRD (SYNCCTL response)


writePRPHRCLST

private void writePRPHRCLST(javax.transaction.xa.Xid[] xids)
                     throws DRDAProtocolException
write PRPHRCLST (indoubt list)


writeXID

private void writeXID(javax.transaction.xa.Xid xid)
               throws DRDAProtocolException
write XID


getXAResource

private javax.transaction.xa.XAResource getXAResource()
get XAResource for the connection


syncTypeToString

private java.lang.String syncTypeToString(int syncType)
printable syncType for debug output


xaflagsToString

private java.lang.String xaflagsToString(int xaflags)
printable xaflags


processXAException

private int processXAException(javax.transaction.xa.XAException xe)
return xa exception errorCode. print to console for debug output.