New tests

Author: guyplusplus

src/test/java/com/geckotechnology/simpleCircuitBreaker/DisabledStateTest.java

@@ -0,0 +1,43 @@
+package com.geckotechnology.simpleCircuitBreaker;
+
+import static org.junit.Assert.*;
+
+import org.junit.Test;
+
+public class DisabledStateTest {
+	
+	private static final int LOOP_COUNT = 100;
+	private static final long SLEEP_TIME = 200;
+	private static final int THREAD_COUNT = 5;
+
+	@Test
+	public void test() {
+		CircuitBreakerConfig config = new CircuitBreakerConfig();
+		config.setSlidingWindowSize(0);
+		final CircuitBreaker circuitBreaker = new CircuitBreaker(config);
+		Thread threads[] = new Thread[THREAD_COUNT];
+		for(int t = 0; t<THREAD_COUNT; t++) {
+			threads[t] = new Thread() {
+				public void run() {
+					for(int i = 0; i<LOOP_COUNT; i++) {
+						assertTrue(circuitBreaker.getBreakerState() instanceof BreakerDisabledState);
+						if(circuitBreaker.isClosedForThisCall()) {
+							assertTrue(circuitBreaker.getBreakerState() instanceof BreakerDisabledState);
+							TestUtils.sleep(SLEEP_TIME);
+							circuitBreaker.callSucceeded(SLEEP_TIME);
+						}
+						else
+							fail("circuitBreaker should always be closed");
+					}					
+				}
+			};
+			threads[t].start();
+		}
+		for(int t = 0; t<THREAD_COUNT; t++)
+			try {
+				threads[t].join();
+			} catch (InterruptedException e) {
+				fail("Exception captured " + e);
+			}
+	}
+}

src/test/java/com/geckotechnology/simpleCircuitBreaker/ForceOpenStateTest.java

@@ -0,0 +1,42 @@
+package com.geckotechnology.simpleCircuitBreaker;
+
+import static org.junit.Assert.*;
+
+import org.junit.Test;
+
+public class ForceOpenStateTest {
+	
+	private static final int LOOP_COUNT = 100;
+	private static final long SLEEP_TIME = 200;
+	private static final int THREAD_COUNT = 5;
+
+	@Test
+	public void test() {
+		CircuitBreakerConfig config = new CircuitBreakerConfig();
+		config.setSlidingWindowSize(-1);
+		final CircuitBreaker circuitBreaker = new CircuitBreaker(config);
+		Thread threads[] = new Thread[THREAD_COUNT];
+		for(int t = 0; t<THREAD_COUNT; t++) {
+			threads[t] = new Thread() {
+				public void run() {
+					for(int i = 0; i<LOOP_COUNT; i++) {
+						assertTrue(circuitBreaker.getBreakerState() instanceof BreakerForcedOpenState);
+						if(circuitBreaker.isClosedForThisCall())
+							fail("circuitBreaker should always be closed");
+						else {
+							assertTrue(circuitBreaker.getBreakerState() instanceof BreakerForcedOpenState);
+							TestUtils.sleep(SLEEP_TIME);
+						}
+					}					
+				}
+			};
+			threads[t].start();
+		}
+		for(int t = 0; t<THREAD_COUNT; t++)
+			try {
+				threads[t].join();
+			} catch (InterruptedException e) {
+				fail("Exception captured " + e);
+			}
+	}
+}

src/test/java/com/geckotechnology/simpleCircuitBreaker/OverheadTest.java

@@ -0,0 +1,72 @@
+package com.geckotechnology.simpleCircuitBreaker;
+
+public class OverheadTest {
+
+	CircuitBreaker breaker;
+	private static final int ARRAY_SIZE = 5017;
+	private static final int LOOP_CALC_COUNT = 500000;
+	private static final int LOOP_TEST = 1000;
+	private static final int LOOP_TEST_WARMUP = 10000;
+	
+	public static void main(String[] args) {
+		new OverheadTest().go();
+
+	}
+
+	public void go() {
+		CircuitBreakerConfig config = new CircuitBreakerConfig();
+		config.setSlidingWindowSize(10);
+		breaker = new CircuitBreaker(config);
+
+		int array[] = null;
+		long start, end = 0;
+		
+		//warm-up
+		array = createArray();
+		for(int i = 0; i<LOOP_TEST_WARMUP; i++)
+			oneCall(array);
+		
+		for(int j = 0; j<5; j++) {
+			//no breaker
+			array = createArray();
+			start = System.currentTimeMillis();
+			for(int i = 0; i<LOOP_TEST; i++)
+				oneCall(array);
+			end = System.currentTimeMillis();
+			double durationPerCallNoBreaker = (double)(end-start)/(double)LOOP_TEST;
+			System.out.println("duration (ms) per oneCall - NO BREAKER: " + durationPerCallNoBreaker);
+	
+			//breaker
+			array = createArray();
+			start = System.currentTimeMillis();
+			for(int i = 0; i<LOOP_TEST; i++) {
+				if(breaker.isClosedForThisCall()) {
+					long startCall = System.currentTimeMillis();
+					oneCall(array);
+					breaker.callSucceeded(System.currentTimeMillis() - startCall);
+				}
+			}
+			end = System.currentTimeMillis();
+			double durationPerCallWithBreaker = (double)(end-start)/(double)LOOP_TEST;
+			System.out.println("duration (ms) per oneCall - WITH BREAKER: " + durationPerCallWithBreaker);
+			System.out.println("Overhead (ms) per oneCall of breaker: " + (durationPerCallWithBreaker - durationPerCallNoBreaker));
+		}
+		System.out.println("Done");
+	}
+	
+	private int[] createArray() {
+		int array[] = new int[ARRAY_SIZE];
+		for(int i = 0; i<ARRAY_SIZE; i++)
+			array[i] = i;
+		return array;
+	}
+	
+	private void oneCall(int array[]) {
+//		long start = System.currentTimeMillis();
+		int s = array.length;
+		for(int i = 0; i<LOOP_CALC_COUNT; i++)
+			array[(7 * i) % s] = array[(3 * i) % s] * array [i % s] + array [(5 * i) % s];
+//		long end = System.currentTimeMillis();
+//		System.out.println("duration: " + (end-start));
+	}
+}

src/test/java/com/geckotechnology/simpleCircuitBreaker/TestUtils.java

@@ -0,0 +1,12 @@
+package com.geckotechnology.simpleCircuitBreaker;
+
+public class TestUtils {
+
+	public static void sleep(long ms) {
+		try {
+			Thread.sleep(ms);
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+	}
+}