|
|||||||||
| Home >> All >> org >> apache >> derby >> impl >> [ drda overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
org.apache.derby.impl.drda
Class DRDAXAProtocol

java.lang.Objectorg.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.
|
|||||||||
| Home >> All >> org >> apache >> derby >> impl >> [ drda overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
JAVADOC
org.apache.derby.impl.drda.DRDAXAProtocol