aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
Commit message (Collapse)AuthorAgeFilesLines
* added reset functionHåvard Pettersen2023-03-081-1/+1
|
* use ref_counted for ReplyGateHåvard Pettersen2023-03-087-22/+23
|
* use ref_counted in fnetHåvard Pettersen2023-03-062-4/+4
| | | | | | also get rid of some cleanup functions on reference counted classes enable specifying low-level parameters to addref/subref (cnt/reserve)
* Include thread to get definition of std::threadTor Egge2023-03-051-0/+1
|
* Reduce transitive includes.Henning Baldersheim2023-03-011-0/+1
|
* Add eol at eof.Henning Baldersheim2023-02-271-1/+1
|
* Modernize code and testHenning Baldersheim2023-02-275-30/+27
|
* GC unused MessageTask and ReplyTask. Also modernize some Sequenzer to c++11Henning Baldersheim2023-02-274-88/+12
|
* untangle messagebus from fastosHåvard Pettersen2023-02-246-92/+37
|
* untangle fnet from fastosHåvard Pettersen2023-02-222-5/+1
|
* Remove capability requirement for 'mbus.getVersion'Bjørn Christian Seime2023-02-201-0/+2
|
* Define required capabilities for existing JRT RPC methodsBjørn Christian Seime2023-02-091-1/+3
|
* Drop boost crc, random and tokenizerHenning Baldersheim2023-02-041-10/+4
|
* Consistent naming and correct type.Henning Baldersheim2023-02-031-2/+2
|
* - Use T && f() && to avoid moving temporaries.Henning Baldersheim2023-02-0329-437/+355
| | | | - std::make_unique/make_shared
* - Deinline destructor.Henning Baldersheim2023-02-0127-451/+237
| | | | | | - Move instead of copy = > noexcept move construtors. - make_unique/make_shared. - c++11 for loops
* deinline destructors.Henning Baldersheim2023-02-015-2/+11
|
* Replace synchronized Stack with Deque in feed and query path.Henning Baldersheim2023-01-251-4/+2
|
* Just use Streams.toList as that is unmdifiable.Henning Baldersheim2023-01-181-3/+2
|
* Unify on Streams.toList()Henning Baldersheim2023-01-181-3/+4
|
* use LOG_WOULD_LOG macroArne Juul2023-01-121-3/+3
|
* Add removal deprecationHenning Baldersheim2023-01-031-1/+1
|
* We have relied on dynamic throttling for 12 years or so.Henning Baldersheim2023-01-033-67/+12
| | | | Time to let the old one go.
* Merge pull request #25325 from vespa-engine/geirst/typedef-to-using-in-cpp-codeHenning Baldersheim2022-12-2137-54/+54
|\ | | | | Change from typedef to using in C++ code.
| * Change from typedef to using in messagebus C++ code.Geir Storli2022-12-2137-54/+54
| |
* | Use the builtin sync capability of the transport object.Henning Baldersheim2022-12-211-33/+2
|/
* add more relevant information when messagebus fails to startArne Juul2022-12-211-2/+8
|
* Remove stacksize from the thread pools and thread executors.Henning Baldersheim2022-12-203-4/+4
|
* Defer MBus DestinationSession registration during content node initTor Brede Vekterli2022-11-297-9/+59
| | | | | | | | | | | | | Creating a `DestinationSession` that is immediately registered as available for business means we may theoretically start receiving messages over the session even before the call returns to the caller. Either way there would be no memory barrier that ensures that `_messageBusSession` would be fully visible to the MessageBus threads (since it's written after return). To avoid this sneaky scenario, defer registration (and thus introduce a barrier) until _after_ we've initialized our internal member variables. This addresses a TSan warning.
* fix typo invokation -> invocationThinh Bui2022-11-143-4/+4
|
* Cleanup, no effective changesjonmv2022-11-011-6/+3
|
* Update ABI spec format, and update all specsjonmv2022-10-251-282/+282
|
* Deinline destructors in messagebus.Tor Egge2022-10-1711-0/+19
|
* Ensure atomicity when removing last registered session ownerjonmv2022-10-102-12/+8
|
* Return X-Vespa-Ignored-Fields if fields were ignoredJon Bratseth2022-10-061-38/+10
|
* don't heap dump every time network fails to become readyArne Juul2022-09-291-3/+11
|
* Merge pull request #24042 from vespa-engine/bratseth/cleanup-671Jon Bratseth2022-09-2322-314/+98
|\ | | | | No functional changes
| * Make list mutableJon Bratseth2022-09-231-0/+2
| |
| * No functional changesJon Bratseth2022-09-1422-314/+96
| |
* | Wait for up to 180s for slobrok/network, in Java messagebusjonmv2022-09-221-1/+1
| |
* | Simplify and unify the use of Timers.Henning Baldersheim2022-09-145-60/+38
|/
* trigger heap dump on "Network failed to become ready in time"Arne Juul2022-08-311-0/+3
|
* remove unused doxygen setup filesArne Juul2022-08-291-1257/+0
|
* Wire RPC capability set filtering to mbus server functionsTor Brede Vekterli2022-08-259-10/+34
| | | | | Required capability set is configured via `RPCNetworkParams` and defaults to the empty set (i.e. no filtering done).
* Update java comment.Henning Baldersheim2022-08-121-2/+1
|
* Add method to use Duration as timeout to make unit explicit, and avoid many ↵Henning Baldersheim2022-08-122-2/+5
| | | | magic conversions.
* Convert messagebus to junit5Bjørn Christian Seime2022-07-2840-974/+933
|
* GC unused numThreads too.Henning Baldersheim2022-07-072-15/+0
|
* Add missing includeHenning Baldersheim2022-07-061-0/+1
|
* Never dispatch to network helper threads.Henning Baldersheim2022-07-065-50/+3
|