diff options
| author | Jon Marius Venstad <venstad@gmail.com> | 2021-03-15 12:11:35 +0100 |
|---|---|---|
| committer | Jon Marius Venstad <venstad@gmail.com> | 2021-03-15 12:11:35 +0100 |
| commit | cd8853bd1badc9713994c491b65467f8ba8d5554 (patch) | |
| tree | 8fe5b2c27d7164dbfdd8d48f5cf4634f4da1c3bd /vespaclient-container-plugin | |
| parent | 335bc1ee552115d659bb58c0cb8501b743c7df92 (diff) | |
Abort all current visitor sessions before waiting for shutdown of each
Diffstat (limited to 'vespaclient-container-plugin')
| -rw-r--r-- | vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java index c43c79ab5e6..faf15d397c5 100644 --- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java +++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java @@ -259,6 +259,7 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { // This blocks until all visitors are done. These, in turn, may require the asyncSession to be alive // to be able to run, as well as dispatch of operations against it, which is done by visitDispatcher. + visits.values().forEach(VisitorSession::abort); visits.values().forEach(VisitorSession::destroy); // Shut down both dispatchers, so only we empty the queues of outstanding operations, and can be sure they're empty. |