summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin
Commit message (Collapse)AuthorAgeFilesLines
* Inject DocumentTypeManager into FeedHandlergjoranv2022-03-064-8/+8
|
* No functional changesJon Bratseth2022-03-011-1/+1
|
* Use a typesafe Duration instead of integer milliseondst status.Henning Baldersheim2022-02-251-1/+1
|
* - Use a utility method that recomputes a timeout if VESPA_TIMER_HZ deviates ↵Henning Baldersheim2022-02-251-9/+6
| | | | from the default of 1000hz.
* Remove todoJon Bratseth2022-02-221-1/+0
| | | | We'll let this die so no need.
* add special DocumentOnly fieldset in Java as wellArne H Juul2022-02-151-0/+3
| | | | | | * should have same behavior in Java and C++ * extend unit tests to verify * note various places where we want to change the default on Vespa 8 branch
* Remove dead codeBjørn Christian Seime2022-01-201-16/+1
|
* Cleanup stale clients more frequentlyBjørn Christian Seime2022-01-201-2/+2
| | | | No reason to wait minutes when a client is defined as timed out after 6 seconds inactivity.
* Remove no-opBjørn Christian Seime2022-01-201-1/+0
|
* Improve shutdown logic for ClientFeederV3Bjørn Christian Seime2022-01-202-19/+21
| | | | | | | Remove call to Object.wait(long). This call would always fail since there was no monitor lock on the object being waited on. The 'kill()' method should now longer throw exception and halt kill of subsequent client feeder instances.
* Extend ThreadedHttpReqHndlr instead of deprecated LoggingReqHndlrgjoranv2022-01-173-6/+6
|
* Merge pull request #20678 from ↵Bjørn Christian Seime2022-01-061-1/+2
|\ | | | | | | | | vespa-engine/jonmv/remove-not-found-is-OK-in-metrics Remove not found is OK
| * Remove not found is OKJon Marius Venstad2022-01-061-1/+2
| |
* | unify java warnings (use compiler args from parent)Arne H Juul2022-01-061-8/+0
| |
* | handle switch fallthroughArne H Juul2022-01-061-2/+5
|/ | | | | | * rewrite one switch fallthrough where it made more sense to handle the cases separately * suppress one switch fallthrough (it was clearly commented)
* Guard against wrong class of messageJon Marius Venstad2021-12-221-0/+6
|
* Revert "Merge pull request #20617 from ↵Jon Marius Venstad2021-12-222-3/+7
| | | | | | | vespa-engine/revert-20616-jonmv/filter-when-create-true" This reverts commit 2fd7739b9fa7ce3283d1485dae3726c8e8ec882b, reversing changes made to 7ef261d471f4a11651811957b2f24bb7e0bcf4d5.
* Revert "Updatese with craete true should not increemeent not found metric"Arnstein Ressem2021-12-222-7/+3
|
* Updatese with craete true should not increemeent not found metricJon Marius Venstad2021-12-222-3/+7
|
* Add metric for update-doc-not-found, and update httpapi metrics from /doc/v1Jon Marius Venstad2021-12-215-22/+70
|
* Simnplify testing by sticking to assertEquals/True/FalseHenning Baldersheim2021-12-193-53/+50
|
* Rename metric to 'httpapi_condition_not_met'Bjørn Christian Seime2021-11-252-2/+5
|
* Remove double negation in flow control logicBjørn Christian Seime2021-11-231-7/+7
|
* Track test-and-set condition not met as success + in new metricBjørn Christian Seime2021-11-232-11/+17
|
* Remove early acks after abort againJon Marius Venstad2021-11-081-11/+1
|
* Static import for TimeUnit.MILLISECONDSJon Marius Venstad2021-11-071-9/+10
|
* Replace session timeout with explicit shutdownJon Marius Venstad2021-11-072-9/+24
| | | | | | | | | | | 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.
* Add position and arrayOffset, when writing from ByteBufferJon Marius Venstad2021-10-311-1/+1
|
* Allow slicing for update-where et alJon Marius Venstad2021-10-301-7/+8
|
* Remove dead codeJon Marius Venstad2021-10-301-6/+0
|
* Simplify with separate queues for acks and docsJon Marius Venstad2021-10-301-33/+28
|
* Write visited documents in chunks to synchronization pointJon Marius Venstad2021-10-301-16/+98
|
* Separate return statement, add braces to nested ifJon Marius Venstad2021-10-281-1/+2
|
* Use an optionally bounded, dynamic throttling policy for streamed vistsJon Marius Venstad2021-10-282-15/+25
|
* Stop writing documents once document array is closedJon Marius Venstad2021-10-282-10/+14
|
* Update 2019 Oath copyrights.gjoranv2021-10-271-1/+1
|
* Revert to previous behaviour, and simply delay ack until doc writtenJon Marius Venstad2021-10-262-40/+28
|
* Catch hidden IOExceptions when writingJon Marius Venstad2021-10-261-7/+3
|
* onDone is only called normally _after_ last ack is run, so simplifyJon Marius Venstad2021-10-261-47/+35
|
* Keep writing as long as there is anything to writeJon Marius Venstad2021-10-261-5/+7
|
* Set writing back to false also when exceptional returnJon Marius Venstad2021-10-261-2/+6
|
* Merge pull request #19704 from vespa-engine/jonmv/sliced-visitsJon Marius Venstad2021-10-252-1/+12
|\ | | | | Jonmv/sliced visits
| * Allow specifying slices and sliceId in /document/v1Jon Marius Venstad2021-10-222-1/+12
| |
* | Have an Executor (the default one) injected insteadJon Marius Venstad2021-10-221-3/+2
|/
* Revert "Merge pull request #19686 from ↵Jon Marius Venstad2021-10-212-58/+170
| | | | | | | vespa-engine/jonmv/revert-streamed-visits" This reverts commit 56c3fc7c2a3b7e317e79593aa56ed2d03472cbde, reversing changes made to 367dae08c390833a54c1bae11282df5a7e056d16.
* Revert "Merge pull request #19664 from ↵Jon Marius Venstad2021-10-212-170/+58
| | | | | | | vespa-engine/jonmv/streaming-doc-v1-visit" This reverts commit b5d4b42caabf2c41fcbd8b21814819aae77dc7aa, reversing changes made to 9abe019606f2367b05e4e13d796de65dddf7c449.
* Revert "Merge pull request #19679 from ↵Jon Marius Venstad2021-10-212-7/+7
| | | | | | | vespa-engine/jonmv/streaming-doc-v1-visit" This reverts commit f35099d4816e6a3793efdd2bc0fe79a83ed0ef05, reversing changes made to 44030f533278a9ffa071779c057511be12ec3c8d.
* streaming -> streamJon Marius Venstad2021-10-212-7/+7
|
* Use the default threadpool executor, with minimal blockingJon Marius Venstad2021-10-212-29/+32
|
* Use a queue of pending writes for each visitorJon Marius Venstad2021-10-211-11/+15
|