package org.apidesign.reentrant;

 import java.util.ArrayList;

 import java.util.Iterator;

 import java.util.List;

 import org.junit.Test;

 import static org.junit.Assert.*;

 public abstract class CriticalSectionBase {

     protected abstract CriticalSection<Integer> create();

     protected boolean reentrantJustOnce() {

         return false;

     }

     // BEGIN: reentrant.ok.call

     @Test

     public void testCriticalSectionWith15() {

         final CriticalSection<Integer> cs = create();

         testFor15(cs);

     }

     // END: reentrant.ok.call

     final void testFor15(CriticalSection<Integer> cs) {

         cs.assignPilot(15);

         List<Integer> ints = new ArrayList<Integer>();

         ints.add(8);

         ints.add(11);

         ints.add(10);

         ints.add(5);

         ints.add(12);

         ints.add(18);

         ints.add(13);

         ints.add(7);

         int cnt = cs.sumBigger(ints);

         assertEquals("18 is bigger than 15", 1, cnt);

     }

     @Test 

     public void teaseCriticalSectionWithReentrantCalls() {

         if (Boolean.getBoolean("no.failures")) return;

         final CriticalSection<Integer> cs = create();

         cs.assignPilot(10);

         class ChangePilotTo15 implements Runnable {

             // BEGIN: reentrant.forbidden.call

             // if this runnable is called from inside the critical section,

             // and the locks are non-reentrant then it throws an exception

             public void run() {

                 testFor15(cs);

             }

             // END: reentrant.forbidden.call

         }

         List<Integer> ints = new MyCollection(new ChangePilotTo15(), 3);

         ints.add(8);

         ints.add(11);

         ints.add(10);

         ints.add(5);

         ints.add(12);

         ints.add(18);

         ints.add(13);

         ints.add(7);

         int cnt = cs.sumBigger(ints);

         assertEquals("11, 12, 18, 13 are bigger than 10", 4, cnt);

         assertEquals("Global count is sum of ints(e.g. 4) plus result of testFor15(e.g. 1)", 5, cs.getCount());

     }

     class MyCollection extends ArrayList<Integer> {

         private Runnable callback;

         private final int callbackBeforeIndex;

         public MyCollection(Runnable callback, int callbackAtIndex) {

             this.callback = callback;

             this.callbackBeforeIndex = callbackAtIndex;

         }

         @Override

         public Iterator<Integer> iterator() {

             final Iterator<Integer> delegate = super.iterator();

             class It implements Iterator<Integer> {

                 private int index;

                 public boolean hasNext() {

                     return delegate.hasNext();

                 }

                 public Integer next() {

                     if (index++ == callbackBeforeIndex) {

                         if (callback != null) {

                             callback.run();

                         }

                         if (reentrantJustOnce()) {

                             callback = null;

                         }

                     }

                     return delegate.next();

                 }

                 public void remove() {

                     delegate.remove();

                 }

             } // end of It

             return new It();

         }

     }

 }