summaryrefslogtreecommitdiffstats
path: root/docproc
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2023-11-30 09:49:39 +0100
committerjonmv <venstad@gmail.com>2023-11-30 09:49:39 +0100
commit7dde0ab9f6d19e25d55f1b1b4798f83b3ba6592d (patch)
treeae39de27a96e349c7da847af91ce9aea0c3c8276 /docproc
parent31c7fe405206f4aa86ecd0f93309f26adf2e1205 (diff)
Add some warnings for unexpected scenarios
Diffstat (limited to 'docproc')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java6
1 files changed, 5 insertions, 1 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java
index e686fe6254f..73d72aabcb9 100644
--- a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java
+++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java
@@ -116,7 +116,11 @@ public class DocumentProcessingHandler extends AbstractRequestHandler {
@Override
protected void destroy() {
laterExecutor.shutdown();
- docprocServiceRegistry.allComponents().forEach(docprocService -> docprocService.deconstruct());
+ if ( ! laterExecutor.getQueue().isEmpty()) {
+ // This should not happen, as container should keep this alive until all requests are served.
+ log.log(Level.SEVERE, "Docproc laterExecutor queue not empty on shutdown, " + laterExecutor.getQueue().size() + " tasks discarded");
+ }
+ docprocServiceRegistry.allComponents().forEach(DocprocService::deconstruct);
}
public ComponentRegistry<DocprocService> getDocprocServiceRegistry() {