aboutsummaryrefslogtreecommitdiffstats
path: root/slobrok
Commit message (Collapse)AuthorAgeFilesLines
* _executor -> _threadHenning Baldersheim2021-12-091-6/+3
|
* Add init_fun to vespalib::Thread too to figure out what the thread is used for.Henning Baldersheim2021-12-091-2/+4
|
* Update Verizon Media copyright notices.gjoranv2021-10-0736-36/+36
|
* Update 2017 copyright notices.gjoranv2021-10-0773-73/+73
|
* Fix format strings.Tor Egge2021-09-271-2/+2
|
* remove wiring of useNewLogic flagArne H Juul2021-09-205-34/+12
|
* simplify moreArne H Juul2021-09-202-10/+6
|
* remove unused filesArne H Juul2021-09-2011-705/+0
|
* match in unnamed namespaceArne H Juul2021-09-202-39/+19
|
* removing more codeArne H Juul2021-09-2012-144/+35
|
* remove unused variablesArne H Juul2021-09-207-28/+8
|
* stop sending old-sync RPC callsArne H Juul2021-09-203-193/+4
|
* remove unused variablesArne H Juul2021-09-203-6/+4
|
* no double logic if feature flag is onArne H Juul2021-09-202-5/+7
|
* test rpc_mapping_monitorHåvard Pettersen2021-09-204-1/+235
| | | | using the new fnet::TransportDebugger tool
* Merge pull request #19182 from vespa-engine/arnej/move-some-codeArne H Juul2021-09-2011-84/+44
|\ | | | | Arnej/move some code
| * use _exchanger.removePartner for symmetryArne H Juul2021-09-171-6/+2
| |
| * remove unused RpcServerMap::lookupPattern, move match to RPCHooksArne H Juul2021-09-174-38/+21
| |
| * more peer management logic directly in SBEnvArne H Juul2021-09-177-41/+22
| |
* | Merge pull request #19192 from vespa-engine/arnej/tune-timingArne H Juul2021-09-171-2/+2
|\ \ | | | | | | use same timing for initial health check
| * | use same timing for initial health checkArne H Juul2021-09-171-2/+2
| |/ | | | | | | | | | | * use the 2.7s +- 0.2s timing for first health check, that is also used for subsequent health checks * also, set timeout for ping to the usual 5 seconds value
* / no need to check useNewLogic() hereArne H Juul2021-09-171-10/+1
|/
* Merge pull request #19171 from vespa-engine/arnej/always-use-new-logic-2Håvard Pettersen2021-09-161-181/+17
|\ | | | | cosmetic code style changes
| * cosmetic code style changesArne H Juul2021-09-161-181/+17
| |
* | low-level testing of fnet enabled byHåvard Pettersen2021-09-161-1/+1
|/ | | | | | | | | | | | | | | | | | | 1. Manipulating how much time is spent waiting for events while also manipulating how the passing of time is observed by the transport threads. (fnet::TimeTools) 2. Periodic call-backs from FNET_Transport. All transport threads are blocked during these call-backs. Between each call-back, all transport threads perform a single event loop iteration and any async operations not performed in transport threads are flushed. (FNET_Transport::attach_capture_hook) 3. Combining 1 and 2 in a way that lets the test code run all transport threads one iteration at a time, letting the transport threads run concurrently with each other, but no transport thread is allowed to run concurrently with the test code. (fnet::TransportDebugger)
* always run with new logicArne H Juul2021-09-162-5/+5
| | | | | * we decided to avoid any warnings on unregister, so update unit test accordingly.
* simplify request completion handlingArne H Juul2021-09-157-31/+77
|
* avoid spurious errorArne H Juul2021-09-101-8/+2
| | | | | | * last changes triggered this warning: slobrok.unregisterRpcServer(foo -> tcp/bar:4294967295) failed: conflict detected * why it wants to unregister "-1" as port number is unclear, but it's a no-op anyway
* take no local action in new doAdd()Arne H Juul2021-09-101-2/+0
|
* also register in old worldArne H Juul2021-09-101-0/+3
|
* rewrite to use new logicArne H Juul2021-09-103-1/+131
|
* add wouldConflict() for LocalRpcMonitorMapArne H Juul2021-09-102-0/+10
|
* extend testHåvard Pettersen2021-09-091-3/+50
|
* remove ignoreFirstOk flagArne H Juul2021-09-092-10/+3
| | | | | * instead of ignoring one ping, restart monitoring of the mapping (without hurry flag).
* handle addLocal for down services betterArne H Juul2021-09-092-5/+53
| | | | | | | | * if we already have a registration in progress, hook the second one to the first so they get the same answer at the same time * if we think the service is down, restart its monitoring to avoid getting stale information, and add the inflight hook so we get an answer when the new ping returns.
* add extra method for use by unregister RPC apiArne H Juul2021-09-092-0/+47
|
* added test for local rpc monitor mapHåvard Pettersen2021-09-097-10/+300
|
* Merge pull request #19025 from vespa-engine/arnej/prepare-for-switchArne H Juul2021-09-094-1/+28
|\ | | | | Arnej/prepare for switch
| * add wouldConflict() method to UnionServiceMapArne H Juul2021-09-082-0/+15
| |
| * make more options for making different scriptsArne H Juul2021-09-082-1/+13
| |
* | skip diff between worlds when using new logicArne H Juul2021-09-081-11/+13
| |
* | add convenience method in RPCHooks for feature flagArne H Juul2021-09-082-0/+6
| |
* | wire feature flag into SBEnvArne H Juul2021-09-083-4/+11
|/
* accept option "-N" (for new logic)Arne H Juul2021-09-071-1/+4
| | | | * note: this is a no-op for now.
* we want local add (aka register requests) to start health check at onceArne Juul2021-09-025-10/+14
|
* restrict scope of using statementArne Juul2021-08-301-2/+1
|
* diff with helper functionArne Juul2021-08-302-27/+37
|
* do diff of new/old worlds as part of health checkArne Juul2021-08-266-13/+64
|
* serve RPC calls from global historyArne Juul2021-08-241-55/+54
| | | | | | | * instead of wiring directly to the RpcServerMap, use global history as source of data for more RPC calls. * most of these are only used for unit tests / debugging * this makes it easy to switch underlying implementation later
* make pattern match publicArne Juul2021-08-241-2/+2
|