diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-11-07 09:15:20 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-11-07 09:15:20 +0100 |
commit | 02e9a93817048989152ce04ae1dde8a92d9a818c (patch) | |
tree | 918c37e001993a756d9359a5c7e594520c2c2447 /vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java | |
parent | 0dac2ad839529051b01e2ea4c4be53bb7a14fb16 (diff) |
Replace session timeout with explicit shutdown
Session timeout causes message bus to reply with timeouts when timeout passes.
This works poorly with visitors whose document put acks are delayed until the
network layer consumes the documents, which may take longer than the remaining
session timeout, which is used as message timeout.
Keeping the message timeout fixed, and doing a manual abort of the session instead,
when the specified timeout has occurred, almost eliminates the problem.
Additionally, acking all outstanding documents upon abortion makes the visitors
return in a timely manner, and should take care of the rest of the problem.
Diffstat (limited to 'vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java')
-rw-r--r-- | vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java b/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java index 2452e19bfff..de907f70c19 100644 --- a/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java +++ b/vespaclient-container-plugin/src/test/java/com/yahoo/document/restapi/resource/DocumentV1ApiTest.java @@ -257,7 +257,7 @@ public class DocumentV1ApiTest { assertEquals(1, ((StaticThrottlePolicy) parameters.getThrottlePolicy()).getMaxPendingCount()); assertEquals("[id]", parameters.getFieldSet()); assertEquals("(all the things)", parameters.getDocumentSelection()); - assertEquals(6000, parameters.getSessionTimeoutMs()); + assertEquals(6000, parameters.getTimeoutMs()); assertEquals(4, parameters.getSlices()); assertEquals(1, parameters.getSliceId()); // Put some documents in the response |