commons-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ozeigerm...@apache.org
Subject cvs commit: jakarta-commons-sandbox/transaction/src/test/org/apache/commons/transaction/memory MapWrapperTest.java
Date Thu, 03 Jun 2004 14:04:31 GMT
ozeigermann    2004/06/03 07:04:31

  Modified:    transaction/src/test/org/apache/commons/transaction/memory
                        MapWrapperTest.java
  Log:
  Sync was still wrong  :(
  ... fixed again
  
  Revision  Changes    Path
  1.4       +16 -11    jakarta-commons-sandbox/transaction/src/test/org/apache/commons/transaction/memory/MapWrapperTest.java
  
  Index: MapWrapperTest.java
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/transaction/src/test/org/apache/commons/transaction/memory/MapWrapperTest.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- MapWrapperTest.java	3 Jun 2004 13:33:39 -0000	1.3
  +++ MapWrapperTest.java	3 Jun 2004 14:04:31 -0000	1.4
  @@ -109,19 +109,24 @@
           final TransactionalMapWrapper txMap1 =
               new TransactionalMapWrapper(map1);
   
  -        final RendezvousBarrier commitBarrier =
  -            new RendezvousBarrier("Commit", 2, BARRIER_TIMEOUT, sLogger);
  +        final RendezvousBarrier beforeCommitBarrier =
  +            new RendezvousBarrier("Before Commit", 2, BARRIER_TIMEOUT, sLogger);
  +
  +		final RendezvousBarrier afterCommitBarrier =
  +			new RendezvousBarrier("After Commit", 2, BARRIER_TIMEOUT, sLogger);
   
           Thread thread1 = new Thread(new Runnable() {
               public void run() {
                   txMap1.startTransaction();
                   try {
  +					beforeCommitBarrier.meet();
                       txMap1.put("key1", "value2");
                       txMap1.commitTransaction();
  -                    commitBarrier.meet();
  +					afterCommitBarrier.call();
                   } catch (InterruptedException e) {
                   	logger.log(Level.WARNING, "Thread interrupted", e);
  -					commitBarrier.reset();
  +					afterCommitBarrier.reset();
  +					beforeCommitBarrier.reset();
                   }
               }
           }, "Thread1");
  @@ -131,10 +136,10 @@
   
           txMap1.startTransaction();
   		thread1.start();
  -
  -        // before commit of other thread
  -        report("value1", (String) txMap1.get("key1"));
  -        commitBarrier.meet();
  +		
  +		report("value1", (String) txMap1.get("key1"));
  +		beforeCommitBarrier.call();
  +		afterCommitBarrier.meet();
           // we have read committed as isolation level, that's why I will see the new value
of the other thread now
   		report("value2", (String) txMap1.get("key1"));
   		
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: commons-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: commons-dev-help@jakarta.apache.org


Mime
View raw message