summaryrefslogtreecommitdiffstats
path: root/docproc/src/test/java/com/yahoo
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-04-23 17:54:02 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-04-23 17:54:02 +0000
commit75ca432ec38e5cff9a58702fb4c42cf89dd0c844 (patch)
tree248f2ed658e2f5e9f8996e30b4acd2c37dbf43fb /docproc/src/test/java/com/yahoo
parentdaf76f530fa8e0f09b33e17c6728af2065ec8d44 (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.java131
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;
- }
- }
-}