Examples of MTOperation

org.jboss.test.jca.mbean.MTOperation
MultiThreaded Operations that can be executed concurrently. Based on Operation class. @author Dimitris Andreadis @version $Revision: 81036 $
org.jboss.test.tm.resource.MTOperation
MultiThreaded Operations that can be executed concurrently. Based on Operation class. @author Dimitris Andreadis @version $Revision: 100025 $

Examples of org.jboss.test.jca.mbean.MTOperation

   {
      runTest(new MTOperation[][]
      {
         {
            // thread 0
            new MTOperation(MTOperation.CF_LOOKUP),
            new MTOperation(MTOperation.TM_BEGIN, 10),               
            new MTOperation(MTOperation.CF_GET_CONN, 1),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 1),
            new MTOperation(MTOperation.CF_GET_CONN, 2),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
            new MTOperation(MTOperation.CF_GET_CONN, 3),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 3),
            new MTOperation(MTOperation.CF_GET_CONN, 4),
            new MTOperation(MTOperation.CF_GET_CONN, 5),
            new MTOperation(MTOperation.CF_GET_CONN, 6),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 6),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 5),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 4),
            new MTOperation(MTOperation.CF_GET_CONN, 7),
            new MTOperation(MTOperation.CF_GET_CONN, 8),
            new MTOperation(MTOperation.CF_GET_CONN, 9),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 7),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 8),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 9),            
            new MTOperation(MTOperation.TM_COMMIT)                
         }
      });      
   }

View Full Code Here

Examples of org.jboss.test.jca.mbean.MTOperation

   {
      runTest(new MTOperation[][]
      {
         {
            // thread 0
            new MTOperation(MTOperation.CF_BY_TX_LOOKUP),
            new MTOperation(MTOperation.TM_BEGIN, 10),               
            new MTOperation(MTOperation.CF_GET_CONN, 1),
            new MTOperation(MTOperation.XX_WAIT_FOR_SIGNAL, 999),               
            new MTOperation(MTOperation.TM_COMMIT)                
         }
         ,
         {
            // thread 1
            new MTOperation(MTOperation.TM_BEGIN, 20),                 
            new MTOperation(MTOperation.XX_WAIT_FOR_CONN, 1),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 1),
            new MTOperation(MTOperation.XX_POST_SIGNAL, 999),
            new MTOperation(MTOperation.TM_COMMIT)                
         }
      });
   }

View Full Code Here

Examples of org.jboss.test.jca.mbean.MTOperation

      
      MTOperation[][] stressTest = new MTOperation[numThreads + 1][];


      // thread 0
      MTOperation[] thread0 = new MTOperation[5 + numThreads];
      thread0[0] = new MTOperation(MTOperation.CF_BY_TX_LOOKUP);
      thread0[1] = new MTOperation(MTOperation.TM_BEGIN, 10);
      thread0[2] = new MTOperation(MTOperation.CF_GET_CONN, 0);
      for (int i = 0; i < numThreads; i++)
      {
         thread0[3+i] = new MTOperation(MTOperation.XX_WAIT_FOR_SIGNAL, i+1);
      }
      thread0[3 + numThreads] = new MTOperation(MTOperation.CN_CLOSE_CONN, 0);
      thread0[4 + numThreads] = new MTOperation(MTOperation.TM_COMMIT);


      stressTest[0] = thread0;
      
      // threads 1 -> numThreads
      for (int i = 1; i <= numThreads; i++)
      {
         stressTest[i] = new MTOperation[] {
            new MTOperation(MTOperation.CF_BY_TX_LOOKUP),
            new MTOperation(MTOperation.XX_WAIT_FOR_TX, 10),
            new MTOperation(MTOperation.TM_RESUME, 10),
            new MTOperation(MTOperation.CF_GET_CONN, 1000+i),
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),
            new MTOperation(MTOperation.CF_GET_CONN, 2000+i),
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),
            new MTOperation(MTOperation.CF_GET_CONN, 3000+i),
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),       
            new MTOperation(MTOperation.CN_CLOSE_CONN, 3000+i),
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
            new MTOperation(MTOperation.CN_CLOSE_CONN, 2000+i),
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
            new MTOperation(MTOperation.CN_CLOSE_CONN, 1000+i),
            new MTOperation(MTOperation.TM_SUSPEND, 10),
            new MTOperation(MTOperation.XX_POST_SIGNAL, i)
         };
      }
      runTest(stressTest);
   }

View Full Code Here

Examples of org.jboss.test.jca.mbean.MTOperation


      // threads 0 -> numThreads
      for (int i = 0; i < numThreads; i++)
      {
         stressTest[i] = new MTOperation[] {
               new MTOperation(MTOperation.CF_LOOKUP),
               new MTOperation(MTOperation.TM_BEGIN, 500+i),               
               new MTOperation(MTOperation.CF_GET_CONN, 1000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               // Uncomment to following to run out of connections!
               // new MTOperation(MTOperation.CF_GET_CONN, 2000+i),
               // new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               // new MTOperation(MTOperation.CN_CLOSE_CONN, 2000+i),
               // new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.CN_CLOSE_CONN, 1000+i),
               new MTOperation(MTOperation.TM_COMMIT)
         };
      }
      runTest(stressTest);
   }

View Full Code Here

Examples of org.jboss.test.tm.resource.MTOperation

      {
         runTest(new MTOperation[][]
           {
              {
                 // thread 0
                 new MTOperation(MTOperation.TM_BEGIN, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),
                 new MTOperation(MTOperation.XX_SLEEP_200), // other thread must commit
                 new MTOperation(MTOperation.TM_GET_STATUS)
              }
              ,
              {
                 // thread 1
                 new MTOperation(MTOperation.XX_WAIT_FOR, 10),  
                 new MTOperation(MTOperation.TX_COMMIT, 10, new RollbackException()),
                 new MTOperation(MTOperation.TM_GET_STATUS),
              }
           });         
      }
      else
      {
         runTest(new MTOperation[][]
         {
            {
               // thread 0
               new MTOperation(MTOperation.TM_BEGIN, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
               new MTOperation(MTOperation.XX_SLEEP_200), // other thread must commit
               new MTOperation(MTOperation.TM_GET_STATUS)
            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.XX_WAIT_FOR, 10),  
               new MTOperation(MTOperation.TX_COMMIT, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
         });
      }
   }

View Full Code Here

Examples of org.jboss.test.tm.resource.MTOperation

      {
         runTest(new MTOperation[][]
         {
            {
               // thread 0
               new MTOperation(MTOperation.TM_BEGIN, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.TM_GET_STATUS),                  
               new MTOperation(MTOperation.XX_WAIT_FOR, 10),               
               new MTOperation(MTOperation.TM_RESUME, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),               
               new MTOperation(MTOperation.TX_COMMIT, 10, new RollbackException()),
               new MTOperation(MTOperation.TM_GET_STATUS),               
            }
         });
      }
      else
      {
         runTest(new MTOperation[][]
           {
              {
                 // thread 0
                 new MTOperation(MTOperation.TM_BEGIN, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),
              }
              ,
              {
                 // thread 1
                 new MTOperation(MTOperation.TM_GET_STATUS),                  
                 new MTOperation(MTOperation.XX_WAIT_FOR, 10),               
                 new MTOperation(MTOperation.TM_RESUME, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),               
                 new MTOperation(MTOperation.TX_COMMIT, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),               
              }
        });
      }
   }

View Full Code Here

Examples of org.jboss.test.tm.resource.MTOperation

      {
         runTest(new MTOperation[][]
         {
            {
               // thread 0
               new MTOperation(MTOperation.TM_BEGIN, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
               new MTOperation(MTOperation.XX_SLEEP_200),
               new MTOperation(MTOperation.TM_GET_STATUS),


               // FIXME - JBTM-558
               new MTOperation(MTOperation.TM_COMMIT, -1, new RollbackException(), false)


            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.XX_WAIT_FOR, 10),  
               new MTOperation(MTOperation.TX_COMMIT, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
         });
      }
   }

View Full Code Here

Examples of org.jboss.test.tm.resource.MTOperation

      {
         runTest(new MTOperation[][]
           {
              {
                 // thread 0
                 new MTOperation(MTOperation.TM_BEGIN, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),
                 new MTOperation(MTOperation.XX_SLEEP_200), // other thread must commit
                 new MTOperation(MTOperation.TM_GET_STATUS)
              }
              ,
              {
                 // thread 1
                 new MTOperation(MTOperation.XX_WAIT_FOR, 10),
                 new MTOperation(MTOperation.TX_COMMIT, 10, new RollbackException()),
                 new MTOperation(MTOperation.TM_GET_STATUS),
              }
           });
      }
      else
      {
         runTest(new MTOperation[][]
         {
            {
               // thread 0
               new MTOperation(MTOperation.TM_BEGIN, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
               new MTOperation(MTOperation.XX_SLEEP_200), // other thread must commit
               new MTOperation(MTOperation.TM_GET_STATUS)
            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.XX_WAIT_FOR, 10),
               new MTOperation(MTOperation.TX_COMMIT, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
         });
      }
   }

View Full Code Here

Examples of org.jboss.test.tm.resource.MTOperation

      {
         runTest(new MTOperation[][]
         {
            {
               // thread 0
               new MTOperation(MTOperation.TM_BEGIN, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.TM_GET_STATUS),
               new MTOperation(MTOperation.XX_WAIT_FOR, 10),
               new MTOperation(MTOperation.TM_RESUME, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
               new MTOperation(MTOperation.TX_COMMIT, 10, new RollbackException()),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
         });
      }
      else
      {
         runTest(new MTOperation[][]
           {
              {
                 // thread 0
                 new MTOperation(MTOperation.TM_BEGIN, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),
              }
              ,
              {
                 // thread 1
                 new MTOperation(MTOperation.TM_GET_STATUS),
                 new MTOperation(MTOperation.XX_WAIT_FOR, 10),
                 new MTOperation(MTOperation.TM_RESUME, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),
                 new MTOperation(MTOperation.TX_COMMIT, 10),
                 new MTOperation(MTOperation.TM_GET_STATUS),
              }
        });
      }
   }

View Full Code Here

Examples of org.jboss.test.tm.resource.MTOperation

      {
         runTest(new MTOperation[][]
         {
            {
               // thread 0
               new MTOperation(MTOperation.TM_BEGIN, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
               new MTOperation(MTOperation.XX_SLEEP_200),
               new MTOperation(MTOperation.TM_GET_STATUS),


               // FIXME - JBTM-558
               new MTOperation(MTOperation.TM_COMMIT, -1, new RollbackException(), false)


            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.XX_WAIT_FOR, 10),
               new MTOperation(MTOperation.TX_COMMIT, 10),
               new MTOperation(MTOperation.TM_GET_STATUS),
            }
         });
      }
   }

View Full Code Here

0 1

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.