Examples of com.arjuna.ats.internal.jts.ControlWrapper

com.arjuna.ats.internal.jts.ControlWrapper
This class attempts to mask the local/remote control issue. We try to use local controls directly as much as possible and not register them with the ORB until the last minute. This improves performance *significantly*. At present we only do this for top-level transactions, but extending for nested transactions is straightforward. It also acts as a convenience class for ease of use. Therefore, some Coordinator and Terminator methods may be found directly on this class. Because of the way in which the implementation works, however, some of their signatures may be slightly different. @author Mark Little (mark_little@hp.com) @version $Id: ControlWrapper.java 2342 2006-03-30 13:06:17Z $ @since JTS 2.0.


  static final TransactionImple getTransaction ()
  {
    TransactionImple tx = null;


    ControlWrapper otx = OTSImpleManager.current().getControlWrapper();


    if (otx != null)
    {
            synchronized (TransactionImple._transactions)
            {
        try
        {
          tx = (TransactionImple) TransactionImple._transactions.get(otx.get_uid());


          if (tx == null)
          {
            /*
             * If it isn't active then don't add it to the

View Full Code Here

         * have terminated. We should to save time and space!
         */


        TransactionReaper reaper = TransactionReaper.transactionReaper();


        reaper.insert(new ControlWrapper((ControlImple) tranControl), theTimeout);
      }


      return tranControl;
    }
    catch (OutOfMemoryError e)

View Full Code Here

     * If we have a synchronization list then we must be top-level.
     */
        if (_synchs != null)
    {
      boolean doSuspend = false;
      ControlWrapper cw = null;


      try
      {
        /*
         * Make sure that this transaction is active on the thread
         * before we invoke any Synchronizations. They are
         * TransactionalObjects and must have the context flowed to
         * them.
         */


        try
        {
          //        cw = OTSImpleManager.systemCurrent().getControlWrapper();


          cw = OTSImpleManager.current().getControlWrapper();


          /*
           * If there's no transaction incoming, then use the one that
           * we got at creation time.
           */


          if ((cw == null) || (!controlHandle.equals(cw.getImple())))
          {
            //      OTSImpleManager.systemCurrent().resumeImple(controlHandle);


            OTSImpleManager.current().resumeImple(controlHandle);

View Full Code Here

    boolean problem = false;
    SystemException exp = null;


    if (_synchs != null)
    {
      ControlWrapper cw = null;
      boolean doSuspend = false;


      try
      {
        //    cw = OTSImpleManager.systemCurrent().getControlWrapper();


        cw = OTSImpleManager.current().getControlWrapper();


        /*
         * If there isn't a transaction context shipped, then use the
         * one we had during creation.
         */


        if ((cw == null) || (!controlHandle.equals(cw.getImple())))
        {
          //        OTSImpleManager.systemCurrent().resumeImple(controlHandle);


          OTSImpleManager.current().resumeImple(controlHandle);

View Full Code Here

      {
          TransactionImple theTransaction = (TransactionImple) which;


          try
          {
              ControlWrapper cont = ((theTransaction == null) ? null : theTransaction.getControlWrapper());


              OTSImpleManager.current().resumeWrapper(cont);


              cont = null;
              theTransaction = null;

View Full Code Here

     * If we have a synchronization list then we must be top-level.
     */
        if (_synchs != null)
    {
      boolean doSuspend = false;
      ControlWrapper cw = null;


      try
      {
        /*
         * Make sure that this transaction is active on the thread
         * before we invoke any Synchronizations. They are
         * TransactionalObjects and must have the context flowed to
         * them.
         */


        try
        {
          //        cw = OTSImpleManager.systemCurrent().getControlWrapper();


          cw = OTSImpleManager.current().getControlWrapper();


          /*
           * If there's no transaction incoming, then use the one that
           * we got at creation time.
           */


          if ((cw == null) || (!controlHandle.equals(cw.getImple())))
          {
            //      OTSImpleManager.systemCurrent().resumeImple(controlHandle);


            OTSImpleManager.current().resumeImple(controlHandle);

View Full Code Here

    boolean problem = false;
    SystemException exp = null;


    if (_synchs != null)
    {
      ControlWrapper cw = null;
      boolean doSuspend = false;


      try
      {
        //    cw = OTSImpleManager.systemCurrent().getControlWrapper();


        cw = OTSImpleManager.current().getControlWrapper();


        /*
         * If there isn't a transaction context shipped, then use the
         * one we had during creation.
         */


        if ((cw == null) || (!controlHandle.equals(cw.getImple())))
        {
          //        OTSImpleManager.systemCurrent().resumeImple(controlHandle);


          OTSImpleManager.current().resumeImple(controlHandle);

View Full Code Here

    else
        threadId = ThreadUtil.getThreadId() ;


    if (threadId != null)
    {
        ControlWrapper theControl = OTSImpleManager.current().contextManager().current(threadId);


        if (theControl != null)
        {
      try
      {
          Coordinator theCoordinator = theControl.get_coordinator();


          if (theCoordinator != null)
          {
        stringRef = ORBManager.getORB().orb().object_to_string(theCoordinator);
          }

View Full Code Here

      try
      {
    if ((threadId = data.extract_string()) != null)
    {
        //        ControlWrapper ctx = OTSImpleManager.systemCurrent().contextManager().popAction(threadId);
        ControlWrapper ctx = OTSImpleManager.current().contextManager().popAction(threadId);


        //        OTSImpleManager.systemCurrent().contextManager().purgeActions(threadId);


        OTSImpleManager.current().contextManager().purgeActions(threadId);
    }

View Full Code Here


  static final TransactionImple getTransaction ()
  {
    TransactionImple tx = null;


    ControlWrapper otx = OTSImpleManager.current().getControlWrapper();


    if (otx != null)
    {
            synchronized (TransactionImple._transactions)
            {
        try
        {
          tx = (TransactionImple) TransactionImple._transactions.get(otx.get_uid());


          if (tx == null)
          {
            /*
             * If it isn't active then don't add it to the

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.arjuna.ats.internal.jts.ControlWrapper

com.arjuna.ats.internal.jbossatx.jts.PropagationContextManager

com.arjuna.ats.internal.jta.transaction.jts.TransactionImple

com.arjuna.ats.internal.jta.transaction.jts.TransactionManagerImple

com.arjuna.ats.internal.jts.context.ContextManager

com.arjuna.ats.internal.jts.orbspecific.coordinator.ArjunaTransactionImple

com.arjuna.ats.internal.jts.orbspecific.TransactionFactoryImple

com.arjuna.ats.jts.extensions.AtomicTransaction

com.arjuna.ats.jts.orbspecific.hporb.interceptors.context.ContextClientRequestInterceptorImpl

com.arjuna.ats.jts.orbspecific.hporb.interceptors.context.ContextServerRequestInterceptorImpl

com.arjuna.ats.jts.orbspecific.hporb.interceptors.interposition.InterpositionClientRequestInterceptorImpl

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.