Package com.arjuna.ats.internal.jta.xa

Examples of com.arjuna.ats.internal.jta.xa.TxInfo.xid()

1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
          }
          else
          {
            if ((flags & XAResource.TMSUSPEND) != 0)
            {
              xaRes.end(info.xid(), XAResource.TMSUSPEND);
              info.setState(TxInfo.ASSOCIATION_SUSPENDED);

              synchronized (this)
              {
                _suspendCount++;
View Full Code Here
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
                _suspendCount++;
              }
            }
            else
            {
              xaRes.end(info.xid(), XAResource.TMFAIL);
              info.setState(TxInfo.FAILED);
            }
          }
        }
          break;
View Full Code Here
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
          {
            // Oracle barfs if we don't send resume first, despite
            // what XA says!

            if (XAUtils.mustEndSuspendedRMs(xaRes))
              xaRes.start(info.xid(), XAResource.TMRESUME);

            xaRes.end(info.xid(), XAResource.TMSUCCESS);
            info.setState(TxInfo.NOT_ASSOCIATED);

            synchronized (this)
View Full Code Here
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
            // what XA says!

            if (XAUtils.mustEndSuspendedRMs(xaRes))
              xaRes.start(info.xid(), XAResource.TMRESUME);

            xaRes.end(info.xid(), XAResource.TMSUCCESS);
            info.setState(TxInfo.NOT_ASSOCIATED);

            synchronized (this)
            {
              _suspendCount--;
View Full Code Here
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
                      + jtaLogger.logMesg
                          .getString("com.arjuna.ats.internal.jta.transaction.arjunacore.ressuspended"));
            }
            else
            {
              xaRes.end(info.xid(), XAResource.TMFAIL);
              info.setState(TxInfo.FAILED);

              synchronized (this)
              {
                _suspendCount--;
View Full Code Here
1584
1585
1586
1587
1588
1589
1590
1591
1592
1593
1594
            TxInfo info = (TxInfo) _resources.get(xaRes);

            if (info.getState() == TxInfo.ASSOCIATION_SUSPENDED)
            {
              if (XAUtils.mustEndSuspendedRMs(xaRes))
                xaRes.start(info.xid(), XAResource.TMRESUME);

              xaRes.end(info.xid(), XAResource.TMSUCCESS);
              info.setState(TxInfo.NOT_ASSOCIATED);
            }
          }
View Full Code Here
1586
1587
1588
1589
1590
1591
1592
1593
1594
1595
1596
            if (info.getState() == TxInfo.ASSOCIATION_SUSPENDED)
            {
              if (XAUtils.mustEndSuspendedRMs(xaRes))
                xaRes.start(info.xid(), XAResource.TMRESUME);

              xaRes.end(info.xid(), XAResource.TMSUCCESS);
              info.setState(TxInfo.NOT_ASSOCIATED);
            }
          }
        }
        catch (XAException ex)
View Full Code Here
1629
1630
1631
1632
1633
1634
1635
1636
1637
1638
1639
            TxInfo info = (TxInfo) _duplicateResources.get(xaRes);

            if (info.getState() == TxInfo.ASSOCIATION_SUSPENDED)
            {
              if (XAUtils.mustEndSuspendedRMs(xaRes))
                xaRes.start(info.xid(), XAResource.TMRESUME);

              xaRes.end(info.xid(), XAResource.TMSUCCESS);
              info.setState(TxInfo.NOT_ASSOCIATED);
            }
          }
View Full Code Here
1631
1632
1633
1634
1635
1636
1637
1638
1639
1640
1641
            if (info.getState() == TxInfo.ASSOCIATION_SUSPENDED)
            {
              if (XAUtils.mustEndSuspendedRMs(xaRes))
                xaRes.start(info.xid(), XAResource.TMRESUME);

              xaRes.end(info.xid(), XAResource.TMSUCCESS);
              info.setState(TxInfo.NOT_ASSOCIATED);
            }
          }
        }
        catch (XAException ex)
View Full Code Here
655
656
657
658
659
660
661
662
663
664
665
/* 1075 */       switch (info.getState())
/*      */       {
/*      */       case 0:
/* 1079 */         if ((flags & 0x4000000) != 0)
/*      */         {
/* 1081 */           xaRes.end(info.xid(), 67108864);
/* 1082 */           info.setState(1);
/*      */         }
/* 1086 */         else if ((flags & 0x2000000) != 0)
/*      */         {
/* 1088 */           xaRes.end(info.xid(), 33554432);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.