diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-23 17:54:02 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-23 17:54:02 +0000 |
commit | 75ca432ec38e5cff9a58702fb4c42cf89dd0c844 (patch) | |
tree | 248f2ed658e2f5e9f8996e30b4acd2c37dbf43fb /docproc/src/test/java/com/yahoo | |
parent | daf76f530fa8e0f09b33e17c6728af2065ec8d44 (diff) |
Priority has not been there for years....
Diffstat (limited to 'docproc/src/test/java/com/yahoo')
-rw-r--r-- | docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingTaskPrioritizationTestCase.java | 131 |
1 files changed, 0 insertions, 131 deletions
diff --git a/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingTaskPrioritizationTestCase.java b/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingTaskPrioritizationTestCase.java deleted file mode 100644 index f050b6c5450..00000000000 --- a/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingTaskPrioritizationTestCase.java +++ /dev/null @@ -1,131 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.docproc.jdisc; - -import com.yahoo.docproc.Processing; -import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol; -import org.junit.Test; - -import java.net.URI; -import java.util.List; -import java.util.Queue; -import java.util.concurrent.PriorityBlockingQueue; - -import static org.hamcrest.CoreMatchers.nullValue; -import static org.hamcrest.CoreMatchers.sameInstance; -import static org.junit.Assert.assertThat; - -/** - * @author <a href="mailto:einarmr@yahoo-inc.com">Einar M R Rosenvinge</a> - */ -public class DocumentProcessingTaskPrioritizationTestCase { - - @Test - public void proritization() { - Queue<DocumentProcessingTask> queue = new PriorityBlockingQueue<>(); - - DocumentProcessingTask highest = new TestDocumentProcessingTask(DocumentProtocol.Priority.HIGHEST); - DocumentProcessingTask veryhigh = new TestDocumentProcessingTask(DocumentProtocol.Priority.VERY_HIGH); - DocumentProcessingTask high1 = new TestDocumentProcessingTask(DocumentProtocol.Priority.HIGH_1); - DocumentProcessingTask normal_1 = new TestDocumentProcessingTask(DocumentProtocol.Priority.NORMAL_1); - DocumentProcessingTask low_1 = new TestDocumentProcessingTask(DocumentProtocol.Priority.LOW_1); - DocumentProcessingTask verylow = new TestDocumentProcessingTask(DocumentProtocol.Priority.VERY_LOW); - DocumentProcessingTask lowest = new TestDocumentProcessingTask(DocumentProtocol.Priority.LOWEST); - - DocumentProcessingTask normal_2 = new TestDocumentProcessingTask(DocumentProtocol.Priority.NORMAL_1); - DocumentProcessingTask normal_3 = new TestDocumentProcessingTask(DocumentProtocol.Priority.NORMAL_1); - DocumentProcessingTask normal_4 = new TestDocumentProcessingTask(DocumentProtocol.Priority.NORMAL_1); - - DocumentProcessingTask highest_2 = new TestDocumentProcessingTask(DocumentProtocol.Priority.HIGHEST); - DocumentProcessingTask highest_3 = new TestDocumentProcessingTask(DocumentProtocol.Priority.HIGHEST); - - - queue.add(highest); - queue.add(veryhigh); - queue.add(high1); - queue.add(normal_1); - queue.add(low_1); - queue.add(verylow); - queue.add(lowest); - - queue.add(normal_2); - queue.add(normal_3); - queue.add(normal_4); - - queue.add(highest_2); - queue.add(highest_3); - - assertThat(queue.poll(), sameInstance(highest)); - assertThat(queue.poll(), sameInstance(highest_2)); - assertThat(queue.poll(), sameInstance(highest_3)); - assertThat(queue.poll(), sameInstance(veryhigh)); - assertThat(queue.poll(), sameInstance(high1)); - assertThat(queue.poll(), sameInstance(normal_1)); - assertThat(queue.poll(), sameInstance(normal_2)); - assertThat(queue.poll(), sameInstance(normal_3)); - assertThat(queue.poll(), sameInstance(normal_4)); - assertThat(queue.poll(), sameInstance(low_1)); - assertThat(queue.poll(), sameInstance(verylow)); - assertThat(queue.poll(), sameInstance(lowest)); - assertThat(queue.poll(), nullValue()); - } - - private class TestDocumentProcessingTask extends DocumentProcessingTask { - private TestDocumentProcessingTask(DocumentProtocol.Priority priority) { - super(new TestRequestContext(priority), null, null, null); - } - } - - private class TestRequestContext implements RequestContext { - private final DocumentProtocol.Priority priority; - - public TestRequestContext(DocumentProtocol.Priority priority) { - this.priority = priority; - } - - @Override - public List<Processing> getProcessings() { - return null; - } - - @Override - public void skip() { - } - - @Override - public void processingDone(List<Processing> processing) { - } - - @Override - public void processingFailed(ErrorCode error, String msg) { - } - - @Override - public void processingFailed(Exception exception) { - } - - @Override - public int getApproxSize() { - return 0; - } - - @Override - public int getPriority() { - return priority.getValue(); - } - - @Override - public boolean isProcessable() { - return true; - } - - @Override - public URI getUri() { - return null; - } - - @Override - public String getServiceName() { - return null; - } - } -} |