diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2022-11-29 16:03:40 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-29 16:03:40 +0200 |
| commit | 462988dac901e95e765cd6be2dc24a5c33595526 (patch) | |
| tree | 601474721ffe5cbe7885faa1b78947ce467d2e89 /streaming/replication.h | |
| parent | 009029052f54224b2387e652a6a81a9887008b15 (diff) | |
replication fixes No 8 (#14061)
* replication requests with start_streaming=true are executed immediately upon reception, instead of being placed in the queue
* disable thread cancelability while workers cleanup
* remove obsolete worker from replication
* multi-threaded replication with netdata.conf option to set number of replication threads
* revert spinlock to mutex
* separate worker and main thread worker jobs
* restart the queue every 10 seconds only
* use atomic for sender buffer percentage
* reset the queue position after sleeping
* use sender resets to sleep properly
* fix condition
* cleanup sender members related to replication
Diffstat (limited to 'streaming/replication.h')
| -rw-r--r-- | streaming/replication.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/streaming/replication.h b/streaming/replication.h index e17073bba0..00462cc3a1 100644 --- a/streaming/replication.h +++ b/streaming/replication.h @@ -6,6 +6,7 @@ #include "daemon/common.h" struct replication_query_statistics { + SPINLOCK spinlock; size_t queries_started; size_t queries_finished; size_t points_read; |