diff options
author | jonmv <venstad@gmail.com> | 2023-11-30 09:49:39 +0100 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-11-30 09:49:39 +0100 |
commit | 7dde0ab9f6d19e25d55f1b1b4798f83b3ba6592d (patch) | |
tree | ae39de27a96e349c7da847af91ce9aea0c3c8276 /docproc | |
parent | 31c7fe405206f4aa86ecd0f93309f26adf2e1205 (diff) |
Add some warnings for unexpected scenarios
Diffstat (limited to 'docproc')
-rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java | 6 |
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() { |