779780781782783784785786787788789
} } } int xaStartNormal = ((theModifier == null) ? XAResource.TMNOFLAGS : theModifier .xaStartParameters(XAResource.TMNOFLAGS)); // Pay attention now, this bit is hairy. We need to add a new AbstractRecord (XAResourceRecord) // to the BasicAction, which will thereafter drive its completion. However, the transaction
892893894895896897898899900901902
xid = existingRM.xid(); try { int xaStartJoin = ((theModifier == null) ? XAResource.TMJOIN : theModifier.xaStartParameters(XAResource.TMJOIN)); xaRes.start(xid, xaStartJoin); } catch (XAException ex) {
623624625626627628629630631632633
* Resource instance will still be registered with the * transaction though. */ int xaStartResume = ((theModifier == null) ? XAResource.TMRESUME : theModifier .xaStartParameters(XAResource.TMRESUME)); xaRes.start(info.xid(), xaStartResume); info.setState(TxInfo.ASSOCIATED);
653654655656657658659660661662663
/* * Resource was associated, but was presumably delisted. */ int xaStartJoin = ((theModifier == null) ? XAResource.TMJOIN : theModifier .xaStartParameters(XAResource.TMJOIN)); xaRes.start(info.xid(), xaStartJoin); info.setState(TxInfo.ASSOCIATED);
780781782783784785786787788789790
893894895896897898899900901902903
372373374375376377378379380381382
/* 603 */ if (info != null) /* */ { /* 605 */ switch (info.getState()) /* */ { /* */ case 2: /* 615 */ int xaStartResume = theModifier == null ? 134217728 : theModifier.xaStartParameters(134217728); /* */ /* 619 */ xaRes.start(info.xid(), xaStartResume); /* */ /* 621 */ info.setState(0); /* */
387388389390391392393394395396397
/* */ /* 628 */ return true; /* */ case 0: /* 637 */ return true; /* */ case 1: /* 645 */ int xaStartJoin = theModifier == null ? 2097152 : theModifier.xaStartParameters(2097152); /* */ /* 649 */ xaRes.start(info.xid(), xaStartJoin); /* */ /* 651 */ info.setState(0); /* */
464465466467468469470471472473474
/* */ /* */ } /* */ /* */ } /* */ /* 772 */ int xaStartNormal = theModifier == null ? 0 : theModifier.xaStartParameters(0); /* */ /* 776 */ xaRes.start(xid, xaStartNormal); /* */ /* 778 */ associatedWork = true; /* */
513514515516517518519520521522523
/* */ else /* */ { /* 858 */ xid = existingRM.xid(); /* */ try /* */ { /* 862 */ int xaStartJoin = theModifier == null ? 2097152 : theModifier.xaStartParameters(2097152); /* */ /* 865 */ xaRes.start(xid, xaStartJoin); /* */ } /* */ catch (XAException ex) /* */ {