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.DS_DEFAULT_LOOKUP),
            new MTOperation(MTOperation.TM_BEGIN, 10),               
            new MTOperation(MTOperation.DS_GET_CONN, 1),
            new MTOperation(MTOperation.DS_GET_CONN, 2),
            new MTOperation(MTOperation.DS_GET_CONN, 3),            
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),
            new MTOperation(MTOperation.DS_CLOSE_CONN, 3),
            new MTOperation(MTOperation.DS_CLOSE_CONN, 2),               
            new MTOperation(MTOperation.DS_CLOSE_CONN, 1),
            new MTOperation(MTOperation.XX_WAIT_FOR_SIGNAL, 999),            
            new MTOperation(MTOperation.TM_COMMIT)               
         }
         ,
         {
            // thread 1
            new MTOperation(MTOperation.DS_DEFAULT_LOOKUP),
            new MTOperation(MTOperation.XX_WAIT_FOR_TX, 10),               
            new MTOperation(MTOperation.TM_RESUME, 10),
            new MTOperation(MTOperation.DS_GET_CONN, 4),
            new MTOperation(MTOperation.DS_GET_CONN, 5),
            new MTOperation(MTOperation.DS_GET_CONN, 6),            
            new MTOperation(MTOperation.XX_SLEEP_RANDOM),
            new MTOperation(MTOperation.DS_CLOSE_CONN, 6),
            new MTOperation(MTOperation.DS_CLOSE_CONN, 5),               
            new MTOperation(MTOperation.DS_CLOSE_CONN, 4),
            new MTOperation(MTOperation.TM_SUSPEND, 10),
            new MTOperation(MTOperation.XX_POST_SIGNAL, 999)            
         }
      });
   }

View Full Code Here

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

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

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.DS_DEFAULT_LOOKUP);
      thread0[1] = new MTOperation(MTOperation.TM_BEGIN, 10);
      thread0[2] = new MTOperation(MTOperation.DS_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.DS_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.DS_DEFAULT_LOOKUP),
               new MTOperation(MTOperation.XX_WAIT_FOR_TX, 10),
               new MTOperation(MTOperation.TM_RESUME, 10),
               new MTOperation(MTOperation.DS_GET_CONN, 1000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_GET_CONN, 2000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_GET_CONN, 3000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),       
               new MTOperation(MTOperation.DS_CLOSE_CONN, 3000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
               new MTOperation(MTOperation.DS_CLOSE_CONN, 2000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
               new MTOperation(MTOperation.DS_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.DS_DEFAULT_LOOKUP),
               new MTOperation(MTOperation.TM_BEGIN, 500+i),               
               new MTOperation(MTOperation.DS_GET_CONN, 1000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_GET_CONN, 2000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_GET_CONN, 3000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_GET_CONN, 4000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_GET_CONN, 5000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_CLOSE_CONN, 5000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),
               new MTOperation(MTOperation.DS_CLOSE_CONN, 4000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
               new MTOperation(MTOperation.DS_CLOSE_CONN, 3000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
               new MTOperation(MTOperation.DS_CLOSE_CONN, 2000+i),
               new MTOperation(MTOperation.XX_SLEEP_RANDOM),                
               new MTOperation(MTOperation.DS_CLOSE_CONN, 1000+i),
               new MTOperation(MTOperation.TM_COMMIT)
         };
      }
      runTest(stressTest);
   }

View Full Code Here

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.XX_WAIT_FOR_SIGNAL, 999),           
               new MTOperation(MTOperation.CN_CLOSE_CONN, 1),               
               new MTOperation(MTOperation.TM_COMMIT)               
            }
            ,
            {
               // thread 1
               new MTOperation(MTOperation.CF_LOOKUP),
               new MTOperation(MTOperation.XX_WAIT_FOR_TX, 10),               
               new MTOperation(MTOperation.TM_RESUME, 10),               
               new MTOperation(MTOperation.CF_GET_CONN, 2),
               new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
               new MTOperation(MTOperation.TM_SUSPEND),                
               new MTOperation(MTOperation.XX_POST_SIGNAL, 999)                 
            }
      });
   }

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.CN_CLOSE_CONN, 1),               
               new MTOperation(MTOperation.TM_COMMIT)               
            }
            ,
            {
               // thread 1
               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, 2),
               new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
               new MTOperation(MTOperation.TM_SUSPEND),                
               new MTOperation(MTOperation.XX_POST_SIGNAL, 999)                 
            }
      });
   }

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.CN_CLOSE_CONN, 1),               
               new MTOperation(MTOperation.TM_COMMIT, -1, new RollbackException())               
            }
            ,
            {
               // thread 1
               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, 2),
               new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
               new MTOperation(MTOperation.XX_POST_SIGNAL, 999)                 
            }
         });
      }
      else
      {
         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.CN_CLOSE_CONN, 1),               
               new MTOperation(MTOperation.TM_COMMIT)               
            }
            ,
            {
               // thread 1
               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, 2),
               new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
               new MTOperation(MTOperation.XX_POST_SIGNAL, 999)                 
            }
         });         
      }
   }

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, 888),   
            new MTOperation(MTOperation.XX_WAIT_FOR_SIGNAL, 999),   
            new MTOperation(MTOperation.TM_COMMIT)                
         }
         ,
         {
            // thread 1
            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, 2),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
            new MTOperation(MTOperation.TM_SUSPEND, 10),
            new MTOperation(MTOperation.TM_BEGIN, 20),               
            new MTOperation(MTOperation.CF_GET_CONN, 3),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 3),
            new MTOperation(MTOperation.TM_COMMIT),
            new MTOperation(MTOperation.XX_POST_SIGNAL, 888)                    
         }
         ,
         {
            // thread 2
            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, 4),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 4),
            new MTOperation(MTOperation.TM_SUSPEND, 10),
            new MTOperation(MTOperation.CF_GET_CONN, 5),
            new MTOperation(MTOperation.CN_CLOSE_CONN, 5),
            new MTOperation(MTOperation.XX_POST_SIGNAL, 999)                  
         }            
      });
   }

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.XX_WAIT_FOR_SIGNAL, 888),
               new MTOperation(MTOperation.CF_GET_CONN, 2),
               new MTOperation(MTOperation.XX_WAIT_FOR_SIGNAL, 999),
               new MTOperation(MTOperation.CN_CLOSE_CONN, 2),
               new MTOperation(MTOperation.TM_COMMIT)                
            }
            ,
            {
               // thread 1
               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, 1),
               new MTOperation(MTOperation.XX_POST_SIGNAL, 888),            
               new MTOperation(MTOperation.CN_CLOSE_CONN, 1),
               new MTOperation(MTOperation.TM_SUSPEND, 10),               
               new MTOperation(MTOperation.XX_POST_SIGNAL, 999)
            }
      });
   }

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.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

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.