git.aero2k.de Git - tmp/jakarta-migration.git/blob

   1 package org.collectionspace.services.IntegrationTests.test;
   2
   3 import org.collectionspace.services.IntegrationTests.xmlreplay.ServiceResult;
   4 import org.collectionspace.services.IntegrationTests.xmlreplay.XmlReplay;
   5 import org.collectionspace.services.IntegrationTests.xmlreplay.XmlReplayTest;
   6 import org.collectionspace.services.common.api.Tools;
   7
   8 import org.testng.annotations.Test;
   9
  10 import java.util.ArrayList;
  11 import java.util.List;
  12
  13 /**
  14         Maven surefire doesn't let you pass stuff on the command line
  15         unless you define -DforkMode=never inn the command-line args.
  16         So be sure to use a command-line like:
  17            mvn -e test -DxmlReplayMaster=dev-master.xml -DforkMode=never -Dtest=XmlReplayDevTest
  18  *
  19  * User: laramie
  20  * $LastChangedRevision:  $
  21  * $LastChangedDate:  $
  22  */
  23 public class XmlReplayDevTest extends XmlReplayTest {
  24
  25     @Test
  26     public void runMaster() throws Exception {
  27         String masterFile = System.getProperty("xmlReplayMaster");
  28         if (Tools.notEmpty(masterFile)){
  29             System.out.println("Using masterFile specified in System property: "+masterFile);
  30         } else {
  31             masterFile = XmlReplay.DEFAULT_DEV_MASTER_CONTROL;
  32             System.out.println("Using default masterFile: "+masterFile);
  33         }
  34         XmlReplay replay = createXmlReplayUsingIntegrationTestsModule("..");
  35         if (replay.masterConfigFileExists(masterFile)){           // CSPACE-4027
  36              List<List<ServiceResult>> list = replay.runMaster(masterFile);
  37              logTestForGroup(list, "XmlReplayMasterTest");
  38         } else {
  39             System.out.println("XmlReplayDevTest skipping local dev test "
  40                         + masterFile+" because it doesn't exist in "
  41                         + replay.getBaseDir()
  42                         + ".  This is expected behavior on a production installation.");
  43         }
  44     }
  45
  46     private void bigLoop(String masterFile){
  47         int MAXWORKERS = 20;
  48         long start = System.currentTimeMillis();
  49         for (int t=0; t<MAXWORKERS; t++){
  50             Worker w = new Worker(masterFile, "Worker"+t, this);
  51             synchronized (workers){
  52                 workers.add(w);
  53             }
  54             w.start();
  55         }
  56         while (!quitNow) {
  57             Thread.yield();
  58         }
  59         System.out.println("DONE. workers: " + MAXWORKERS+" time: " + (System.currentTimeMillis()-start));
  60         for (Long l: stats){
  61             System.out.println(""+l);
  62         }
  63     }
  64
  65     private List<Worker> workers = new ArrayList<Worker>();
  66     private List<Long> stats = new ArrayList<Long>();
  67     private volatile boolean quitNow = false;
  68     protected void finished(Worker worker, Long time){
  69         synchronized(workers){
  70             workers.remove(worker);
  71             stats.add(time);
  72             if (workers.size()==0){
  73                 quitNow = true;
  74             }
  75             System.out.println("Workers left: "+workers.size());
  76             workers.notifyAll();
  77         }
  78
  79     }
  80
  81     public static class Worker extends Thread{
  82         public Worker(String masterFile, String ID, XmlReplayDevTest dtest){
  83             super(ID);
  84             this.masterFile = masterFile;
  85             this.dtest = dtest;
  86         }
  87         private String masterFile;
  88         private XmlReplayDevTest dtest;
  89
  90         public void run(){
  91             try {
  92                 long start = System.currentTimeMillis();
  93                 System.out.println("RUNNING Master in Worker: "+this.getName());
  94                 XmlReplay replay = createXmlReplayUsingIntegrationTestsModule("..");
  95                 List<List<ServiceResult>> list = replay.runMaster(masterFile);
  96                 logTestForGroup(list, "XmlReplayMasterTest");
  97                 long stop = System.currentTimeMillis();
  98                 dtest.finished(this, stop-start);
  99             } catch (Exception e){
 100                 System.out.println("ERROR in Worker: "+e);
 101                 return;
 102             }
 103
 104         }
 105     }
 106 }