Copyright header

7 files changed, 174 insertions, 174 deletions

diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/CopyOnWriteHashMapTest.java b/vespajlib/src/test/java/com/yahoo/concurrent/CopyOnWriteHashMapTest.java
index 23d106a2790..f7dae5320f7 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/CopyOnWriteHashMapTest.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/CopyOnWriteHashMapTest.java
@@ -1,4 +1,4 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
 package com.yahoo.concurrent;
 
 import org.junit.Test;
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/EventBarrierTestCase.java b/vespajlib/src/test/java/com/yahoo/concurrent/EventBarrierTestCase.java
index eae792effd4..6a91c502571 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/EventBarrierTestCase.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/EventBarrierTestCase.java
@@ -1,168 +1,168 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-package com.yahoo.concurrent;

-

-import junit.framework.TestCase;

-

-/**

- * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a>

- */

-public class EventBarrierTestCase extends TestCase {

-

-    public void testEmpty() {

-        // waiting for an empty set of events

-        Barrier b = new Barrier();

-        EventBarrier eb = new EventBarrier();

-

-        assertTrue(!eb.startBarrier(b));

-        assertTrue(!b.done);

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        int token = eb.startEvent();

-        eb.completeEvent(token);

-

-        assertTrue(!eb.startBarrier(b));

-        assertTrue(!b.done);

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-    }

-

-    public void testSimple() {

-        // a single barrier waiting for a single event

-        Barrier b = new Barrier();

-        EventBarrier eb = new EventBarrier();

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        int token = eb.startEvent();

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        assertTrue(eb.startBarrier(b));

-        assertTrue(!b.done);

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 1);

-

-        eb.completeEvent(token);

-        assertTrue(b.done);

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-    }

-

-    public void testBarrierChain() {

-        // more than one barrier waiting for the same set of events

-        Barrier b1 = new Barrier();

-        Barrier b2 = new Barrier();

-        Barrier b3 = new Barrier();

-        EventBarrier eb = new EventBarrier();

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        int token = eb.startEvent();

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        assertTrue(eb.startBarrier(b1));

-        assertTrue(eb.startBarrier(b2));

-        assertTrue(eb.startBarrier(b3));

-        assertTrue(!b1.done);

-        assertTrue(!b2.done);

-        assertTrue(!b3.done);

-

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 3);

-

-        eb.completeEvent(token);

-        assertTrue(b1.done);

-        assertTrue(b2.done);

-        assertTrue(b3.done);

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-    }

-

-    public void testEventAfter() {

-        // new events starting after the start of a barrier

-        Barrier b = new Barrier();

-        EventBarrier eb = new EventBarrier();

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        int token = eb.startEvent();

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        assertTrue(eb.startBarrier(b));

-        assertTrue(!b.done);

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 1);

-

-        int t2 = eb.startEvent();

-        assertTrue(!b.done);

-        assertEquals(eb.getNumEvents(), 2);

-        assertEquals(eb.getNumBarriers(), 1);

-

-        eb.completeEvent(token);

-        assertTrue(b.done);

-        assertEquals(eb.getNumEvents(), 1);

-        assertEquals(eb.getNumBarriers(), 0);

-

-        eb.completeEvent(t2);

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-    }

-

-    public void testReorder() {

-        // events completing in a different order than they started

-        Barrier b1 = new Barrier();

-        Barrier b2 = new Barrier();

-        Barrier b3 = new Barrier();

-        EventBarrier eb = new EventBarrier();

-

-        int t1 = eb.startEvent();

-        eb.startBarrier(b1);

-        int t2 = eb.startEvent();

-        eb.startBarrier(b2);

-        int t3 = eb.startEvent();

-        eb.startBarrier(b3);

-        int t4 = eb.startEvent();

-

-        assertEquals(eb.getNumEvents(), 4);

-        assertEquals(eb.getNumBarriers(), 3);

-

-        assertTrue(!b1.done);

-        assertTrue(!b2.done);

-        assertTrue(!b3.done);

-

-        eb.completeEvent(t4);

-        assertTrue(!b1.done);

-        assertTrue(!b2.done);

-        assertTrue(!b3.done);

-

-        eb.completeEvent(t3);

-        assertTrue(!b1.done);

-        assertTrue(!b2.done);

-        assertTrue(!b3.done);

-

-        eb.completeEvent(t1);

-        assertTrue(b1.done);

-        assertTrue(!b2.done);

-        assertTrue(!b3.done);

-

-        eb.completeEvent(t2);

-        assertTrue(b1.done);

-        assertTrue(b2.done);

-        assertTrue(b3.done);

-

-        assertEquals(eb.getNumEvents(), 0);

-        assertEquals(eb.getNumBarriers(), 0);

-    }

-

-    private static class Barrier implements EventBarrier.BarrierWaiter {

-        boolean done = false;

-

-        @Override

-        public void completeBarrier() {

-            done = true;

-        }

-    }

-}

+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+package com.yahoo.concurrent;
+
+import junit.framework.TestCase;
+
+/**
+ * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a>
+ */
+public class EventBarrierTestCase extends TestCase {
+
+    public void testEmpty() {
+        // waiting for an empty set of events
+        Barrier b = new Barrier();
+        EventBarrier eb = new EventBarrier();
+
+        assertTrue(!eb.startBarrier(b));
+        assertTrue(!b.done);
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        int token = eb.startEvent();
+        eb.completeEvent(token);
+
+        assertTrue(!eb.startBarrier(b));
+        assertTrue(!b.done);
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+    }
+
+    public void testSimple() {
+        // a single barrier waiting for a single event
+        Barrier b = new Barrier();
+        EventBarrier eb = new EventBarrier();
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        int token = eb.startEvent();
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        assertTrue(eb.startBarrier(b));
+        assertTrue(!b.done);
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 1);
+
+        eb.completeEvent(token);
+        assertTrue(b.done);
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+    }
+
+    public void testBarrierChain() {
+        // more than one barrier waiting for the same set of events
+        Barrier b1 = new Barrier();
+        Barrier b2 = new Barrier();
+        Barrier b3 = new Barrier();
+        EventBarrier eb = new EventBarrier();
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        int token = eb.startEvent();
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        assertTrue(eb.startBarrier(b1));
+        assertTrue(eb.startBarrier(b2));
+        assertTrue(eb.startBarrier(b3));
+        assertTrue(!b1.done);
+        assertTrue(!b2.done);
+        assertTrue(!b3.done);
+
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 3);
+
+        eb.completeEvent(token);
+        assertTrue(b1.done);
+        assertTrue(b2.done);
+        assertTrue(b3.done);
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+    }
+
+    public void testEventAfter() {
+        // new events starting after the start of a barrier
+        Barrier b = new Barrier();
+        EventBarrier eb = new EventBarrier();
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        int token = eb.startEvent();
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        assertTrue(eb.startBarrier(b));
+        assertTrue(!b.done);
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 1);
+
+        int t2 = eb.startEvent();
+        assertTrue(!b.done);
+        assertEquals(eb.getNumEvents(), 2);
+        assertEquals(eb.getNumBarriers(), 1);
+
+        eb.completeEvent(token);
+        assertTrue(b.done);
+        assertEquals(eb.getNumEvents(), 1);
+        assertEquals(eb.getNumBarriers(), 0);
+
+        eb.completeEvent(t2);
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+    }
+
+    public void testReorder() {
+        // events completing in a different order than they started
+        Barrier b1 = new Barrier();
+        Barrier b2 = new Barrier();
+        Barrier b3 = new Barrier();
+        EventBarrier eb = new EventBarrier();
+
+        int t1 = eb.startEvent();
+        eb.startBarrier(b1);
+        int t2 = eb.startEvent();
+        eb.startBarrier(b2);
+        int t3 = eb.startEvent();
+        eb.startBarrier(b3);
+        int t4 = eb.startEvent();
+
+        assertEquals(eb.getNumEvents(), 4);
+        assertEquals(eb.getNumBarriers(), 3);
+
+        assertTrue(!b1.done);
+        assertTrue(!b2.done);
+        assertTrue(!b3.done);
+
+        eb.completeEvent(t4);
+        assertTrue(!b1.done);
+        assertTrue(!b2.done);
+        assertTrue(!b3.done);
+
+        eb.completeEvent(t3);
+        assertTrue(!b1.done);
+        assertTrue(!b2.done);
+        assertTrue(!b3.done);
+
+        eb.completeEvent(t1);
+        assertTrue(b1.done);
+        assertTrue(!b2.done);
+        assertTrue(!b3.done);
+
+        eb.completeEvent(t2);
+        assertTrue(b1.done);
+        assertTrue(b2.done);
+        assertTrue(b3.done);
+
+        assertEquals(eb.getNumEvents(), 0);
+        assertEquals(eb.getNumBarriers(), 0);
+    }
+
+    private static class Barrier implements EventBarrier.BarrierWaiter {
+        boolean done = false;
+
+        @Override
+        public void completeBarrier() {
+            done = true;
+        }
+    }
+}
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/ExecutorsTestCase.java b/vespajlib/src/test/java/com/yahoo/concurrent/ExecutorsTestCase.java
index b8f2b0e5c58..787260f2e20 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/ExecutorsTestCase.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/ExecutorsTestCase.java
@@ -1,4 +1,4 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
 package com.yahoo.concurrent;
 
 import static org.junit.Assert.assertEquals;
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/ReceiverTestCase.java b/vespajlib/src/test/java/com/yahoo/concurrent/ReceiverTestCase.java
index 88d5283f46a..206c98c53be 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/ReceiverTestCase.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/ReceiverTestCase.java
@@ -1,4 +1,4 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
 package com.yahoo.concurrent;
 
 import static org.junit.Assert.*;
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/ThreadFactoryFactoryTest.java b/vespajlib/src/test/java/com/yahoo/concurrent/ThreadFactoryFactoryTest.java
index b13e4a7af22..da27ed3f7c2 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/ThreadFactoryFactoryTest.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/ThreadFactoryFactoryTest.java
@@ -1,4 +1,4 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
 package com.yahoo.concurrent;
 
 import org.junit.Test;
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/ThreadLocalDirectoryTestCase.java b/vespajlib/src/test/java/com/yahoo/concurrent/ThreadLocalDirectoryTestCase.java
index d813ae1e18d..42e2f4f5f7a 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/ThreadLocalDirectoryTestCase.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/ThreadLocalDirectoryTestCase.java
@@ -1,4 +1,4 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
 package com.yahoo.concurrent;
 
 import static org.junit.Assert.*;
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/ThreadRobustListTestCase.java b/vespajlib/src/test/java/com/yahoo/concurrent/ThreadRobustListTestCase.java
index 88c7a962c95..adeb8846993 100644
--- a/vespajlib/src/test/java/com/yahoo/concurrent/ThreadRobustListTestCase.java
+++ b/vespajlib/src/test/java/com/yahoo/concurrent/ThreadRobustListTestCase.java
@@ -1,4 +1,4 @@
-// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
 package com.yahoo.concurrent;
 
 import static org.junit.Assert.assertEquals;