Adding JMCR-Stable version

[Benchmarks_CSolver.git] / JMCR-Stable / mcr-test / src / edu / tamu / aser / rvtest / tso / peterson.java

diff --git a/JMCR-Stable/mcr-test/src/edu/tamu/aser/rvtest/tso/peterson.java b/JMCR-Stable/mcr-test/src/edu/tamu/aser/rvtest/tso/peterson.java
new file mode 100644 (file)
index 0000000..9c9b5d8
--- /dev/null
+++ b/JMCR-Stable/mcr-test/src/edu/tamu/aser/rvtest/tso/peterson.java
@@ -0,0 +1,93 @@
+package edu.tamu.aser.rvtest.tso;
+
+
+import static org.junit.Assert.*;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import edu.tamu.aser.reexecution.JUnit4MCRRunner;
+
+@RunWith(JUnit4MCRRunner.class)
+public class peterson {
+       
+       final static int COUNT = 10;
+       public static int flag1;
+       public static int flag2;
+       public static int turn;
+       public static int x;
+       
+       public static void main(String[] args) {
+               
+               flag1 = 0;
+               flag2 = 0;
+               turn = 0;
+               x = 0;
+               
+               Thread t1 = new Thread(new Runnable() {
+                       
+                       @Override
+                       public void run() {
+                               // TODO Auto-generated method stub
+                               int count = 0;
+                               flag1 = 1;
+                               turn = 2;
+                               while(flag2 == 1 && turn ==2){
+                                       if(count++ > COUNT)break;
+                               }
+                               
+                               //cs
+                               x = 1;
+                               if(x != 1){
+//                                     fail();
+                                       System.out.println("error");
+                               }
+                               flag1 = 0;
+                               
+                       }
+               });
+               
+               Thread t2 = new Thread(new Runnable() {
+                       
+                       @Override
+                       public void run() {
+                               // TODO Auto-generated method stub
+                               int count = 0;
+                               flag2 = 1;
+                               turn = 1;
+                               while(flag1 == 1 && turn ==1){
+                                       if(count++ > COUNT)break;
+                               }
+                               
+                               //cs
+                               x = 2;
+                               if(x != 2) {
+//                                     fail();
+                                       System.out.println("error");
+                               }
+                               flag2 = 0;
+                       }
+               });
+               
+               t1.start();
+               t2.start();
+               try {
+                       t1.join();
+                       t2.join();
+               } catch (Exception e) {
+                       // TODO: handle exception
+                       e.printStackTrace();
+               }
+       }
+       
+       @Test
+       public void test() throws InterruptedException {
+               try {
+               
+               peterson.main(null);
+               } catch (Exception e) {
+                       System.out.println("here");
+                       fail();
+               }
+       }
+}