Examples of com.arjuna.ats.internal.jts.orbspecific.CurrentImple.commit()

Package com.arjuna.ats.internal.jts.orbspecific

Class com.arjuna.ats.internal.jts.orbspecific.CurrentImple

Examples of com.arjuna.ats.internal.jts.orbspecific.CurrentImple.commit()

com.arjuna.ats.internal.jts.orbspecific.CurrentImple.commit()
It's not possible to commit/abort out of order using the current interface. Do we delete the control if the transaction gives an heuristic result? CurrentImplely we do. If another thread has already terminated the transaction then: (i) if it committed, we do nothing - could throw TransactionRequired of INVALID_TRANSACTION, or NoTransaction. Probably not NoTransaction, since it would be better to distinguish between the situation where the transaction has already been terminated and there really is no transaction for this thread. (ii) if it rolledback, we throw TRANSACTION_ROLLEDBACK.


      System.out.println("\ncommitting top-level action");


      try
      {
    current.commit(true);
    assertFailure();
      }
      catch (TRANSACTION_ROLLEDBACK  e2)
      {
    System.out.println("Caught TransactionRolledBack");

View Full Code Here

    System.out.println("\nTrying to print stack contents - should fail.");


    stackVar.printStack();


    cont = null;
    current.commit(true);


    System.out.println("\nCommitted top-level transaction");


    if (current.get_transaction_name() == null)
        System.out.println("current transaction name: null");

View Full Code Here

      current.begin();


      if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
      {
    _value = 0;
    current.commit(true);
      }
      else
    current.rollback();
  }
  catch (Exception e)

View Full Code Here


      if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
      {
    _value = _value + value;


    current.commit(true);
    res = true;
      }
      else
    current.rollback();
  }

View Full Code Here


      if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
      {
    _value = value;


    current.commit(true);
    res = true;
      }
      else
    current.rollback();
  }

View Full Code Here


      if (setlock(new Lock(LockMode.READ), 0) == LockResult.GRANTED)
      {
    value.value = _value;


    current.commit(true);
    res = true;
      }
      else
    current.rollback();
  }

View Full Code Here


      DistributedHammerWorker3.randomOperation(_threadId, 0);
      DistributedHammerWorker3.randomOperation(_threadId, 0);


      if (_commit)
    current.commit(false);
      else
    current.rollback();


      Util.indent(_threadId, 0);

View Full Code Here

      }
      
      System.out.println("committing top-level transaction.");


      if (shouldCommit)
    current.commit(true);
      else
    current.rollback();


      if (rc == null)
    System.out.println("No recovery coordinator reference.");

View Full Code Here

     * action control.
     */


    try
    {
      current.commit(report_heuristics);


      _theStatus = Status.StatusCommitted;
    }
    catch (NoTransaction e)
    {

View Full Code Here

      
  try
  {
      boolean when_return = report_heuristics.booleanValue();
    
      current.commit(when_return);
  }
  catch (NoTransaction e1)
  {
      toReturn = tx.TX_NO_BEGIN;
  }

View Full Code Here

0 1 2 3 4 5

TOP

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.