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/sender.c | |
| 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/sender.c')
| -rw-r--r-- | streaming/sender.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/sender.c b/streaming/sender.c index f4624f5998..8e637d2bd7 100644 --- a/streaming/sender.c +++ b/streaming/sender.c @@ -1345,7 +1345,7 @@ void *rrdpush_sender_thread(void *ptr) { rrdpush_sender_thread_close_socket(s->host); } - worker_set_metric(WORKER_SENDER_JOB_REPLAY_DICT_SIZE, (NETDATA_DOUBLE) dictionary_entries(s->replication_requests)); + worker_set_metric(WORKER_SENDER_JOB_REPLAY_DICT_SIZE, (NETDATA_DOUBLE) dictionary_entries(s->replication.requests)); } netdata_thread_cleanup_pop(1); |