Examples of AtomicTransaction

com.arjuna.ats.internal.jta.transaction.jts.AtomicTransaction
An extension of the AtomicTransaction class so we can create new instances without having to create a new transaction. Useful for when we work with imported transactions. @author Mark Little (mark_little@hp.com) @version $Id: AtomicTransaction.java 2342 2006-03-30 13:06:17Z $ @since JTS 3.0.
com.arjuna.ats.jts.extensions.AtomicTransaction
Similar to CosTransactions::Current. However, this class does transaction scoping, so if an instance is garbage collected and the transaction is still running, it will be rolled back automatically. It also adds some convenience routines which Current does not do. @author Mark Little (mark_little@hp.com) @version $Id: AtomicTransaction.java 2342 2006-03-30 13:06:17Z $ @since JTS 1.0.
hudson.plugins.scm_sync_configuration.transactions.AtomicTransaction
This ScmTransaction implementation should be aimed at commiting changes immediately @author fcamblor

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

    public void get_value(IntHolder value)
        throws InvocationException
    {
      try
      {
        AtomicTransaction atomicTransaction = new AtomicTransaction();


        try
        {
          atomicTransaction.begin();


          if (setlock(new Lock(LockMode.READ), 0) == LockResult.GRANTED)
          {
            value.value = _value;
            atomicTransaction.commit(true);
          }
          else
          {
            atomicTransaction.rollback();


            throw new InvocationException(Reason.ReasonConcurrencyControl);
          }
        }
        catch (InvocationException invocationException)
        {
          throw invocationException;
        }
        catch (Exception exception)
        {
          System.err.println("Element.get_value: " + exception);
          if (atomicTransaction.get_status() == Status.StatusActive)
          {
            atomicTransaction.rollback();
          }


          throw new InvocationException(Reason.ReasonUnknown);
        }
      }

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

    public void set_value(int value)
        throws InvocationException
    {
      try
      {
        AtomicTransaction atomicTransaction = new AtomicTransaction();


        try
        {
          atomicTransaction.begin();


          if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
          {
            _value = value;
            atomicTransaction.commit(true);
          }
          else
          {
            atomicTransaction.rollback();


            throw new InvocationException(Reason.ReasonConcurrencyControl);
          }
        }
        catch (InvocationException invocationException)
        {
          throw invocationException;
        }
        catch (Exception exception)
        {
          System.err.println("Element.set_value: " + exception);
          if (atomicTransaction.get_status() == Status.StatusActive)
          {
            atomicTransaction.rollback();
          }


          throw new InvocationException(Reason.ReasonUnknown);
        }
      }

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction


      _value = value;


      try
      {
        AtomicTransaction atomicTransaction = new AtomicTransaction();


        atomicTransaction.begin();


        if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
        {
          atomicTransaction.commit(true);
        }
        else
        {
          System.err.println("Element.Element: failed to get lock");
          atomicTransaction.rollback();


          throw new InvocationException(Reason.ReasonConcurrencyControl);
        }
      }
      catch (InvocationException invocationException)

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction


    _value = 0;


    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      atomicTransaction.begin();


      if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
      {
        atomicTransaction.commit(true);
      }
      else
      {
        System.err.println("CounterImpl0001.CounterImpl001: failed to get lock");
        atomicTransaction.rollback();


        throw new InvocationException();
      }
    }
    catch (InvocationException invocationException)

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

  public void get(IntHolder value)
      throws InvocationException
  {
    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      try
      {
        atomicTransaction.begin();


        if (setlock(new Lock(LockMode.READ), 0) == LockResult.GRANTED)
        {
          value.value = _value;
          atomicTransaction.commit(true);
        }
        else
        {
          atomicTransaction.rollback();


          throw new InvocationException();
        }
      }
      catch (InvocationException invocationException)
      {
        throw invocationException;
      }
      catch (Exception exception)
      {
        System.err.println("CounterImpl0001.get: " + exception);
        if (atomicTransaction.get_status() == Status.StatusActive)
        {
          atomicTransaction.rollback();
        }


        throw new InvocationException();
      }
    }

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

  public void set(int value)
      throws InvocationException
  {
    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      try
      {
        atomicTransaction.begin();


        if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
        {
          _value = value;
          atomicTransaction.commit(true);
        }
        else
        {
          atomicTransaction.rollback();


          throw new InvocationException();
        }
      }
      catch (InvocationException invocationException)
      {
        throw invocationException;
      }
      catch (Exception exception)
      {
        System.err.println("CounterImpl0001.set: " + exception);
        if (atomicTransaction.get_status() == Status.StatusActive)
        {
          atomicTransaction.rollback();
        }


        throw new InvocationException();
      }
    }

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

  public void increase()
      throws InvocationException
  {
    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      try
      {
        atomicTransaction.begin();


        if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
        {
          _value++;
          atomicTransaction.commit(true);
        }
        else
        {
          atomicTransaction.rollback();


          throw new InvocationException();
        }
      }
      catch (InvocationException invocationException)
      {
        throw invocationException;
      }
      catch (Exception exception)
      {
        System.err.println("CounterImpl0001.increase: " + exception);
        if (atomicTransaction.get_status() == Status.StatusActive)
        {
          atomicTransaction.rollback();
        }


        throw new InvocationException();
      }
    }

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

        }
      }
    }
    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      atomicTransaction.begin();


      if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
      {
        atomicTransaction.commit(true);
      }
      else
      {
        System.err.println("AITMatrixImpl01.AITMatrixImpl01: failed to get lock");
        atomicTransaction.rollback();


        throw new InvocationException(Reason.ReasonConcurrencyControl);
      }
    }
    catch (InvocationException invocationException)

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

      throw new InvocationException(Reason.ReasonUnknown);
    }


    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      try
      {
        atomicTransaction.begin();


        if (setlock(new Lock(LockMode.READ), 0) == LockResult.GRANTED)
        {
          value.value = _values[x][y];
          atomicTransaction.commit(true);
        }
        else
        {
          atomicTransaction.rollback();


          throw new InvocationException(Reason.ReasonConcurrencyControl);
        }
      }
      catch (InvocationException invocationException)
      {
        throw invocationException;
      }
      catch (Exception exception)
      {
        System.err.println("AITMatrixImpl01.get_value: " + exception);
        if (atomicTransaction.get_status() == Status.StatusActive)
        {
          atomicTransaction.rollback();
        }


        throw new InvocationException(Reason.ReasonUnknown);
      }
    }

View Full Code Here

Examples of com.arjuna.ats.jts.extensions.AtomicTransaction

      throw new InvocationException(Reason.ReasonUnknown);
    }


    try
    {
      AtomicTransaction atomicTransaction = new AtomicTransaction();


      try
      {
        atomicTransaction.begin();


        if (setlock(new Lock(LockMode.WRITE), 0) == LockResult.GRANTED)
        {
          _values[x][y] = value;
          atomicTransaction.commit(true);
        }
        else
        {
          atomicTransaction.rollback();


          throw new InvocationException(Reason.ReasonConcurrencyControl);
        }
      }
      catch (InvocationException invocationException)
      {
        throw invocationException;
      }
      catch (Exception exception)
      {
        System.err.println("AITMatrixImpl01.set_value: " + exception);
        if (atomicTransaction.get_status() == Status.StatusActive)
        {
          atomicTransaction.rollback();
        }


        throw new InvocationException(Reason.ReasonUnknown);
      }
    }

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.