diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2023-01-14 00:09:02 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-14 00:09:02 +0200 |
| commit | f10f19c8c8bba37e8364fa6138d6ea0f6160c3ea (patch) | |
| tree | 6d71bc40d56362dd4de892239a633bdcfa2183be /streaming/rrdpush.c | |
| parent | 3e2924fd466dbc05338518412f426d34b215ef0b (diff) | |
More 32bit fixes (#14264)
* query planer weight calculation using long long
* adjust replication query ahead pipeline for smaller systems
* do not generate huge replication messages
* add message to indicate replication message was interrupted
* improved message
* max replication size 25% of sender buffer
* fix for last commit
* use less cache and smaller page sizes and fewer threads on 32-bits
* fix reserved libuv workers for 32bits
* fix detection of 32/64 bit
Diffstat (limited to 'streaming/rrdpush.c')
| -rw-r--r-- | streaming/rrdpush.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index 27c0b24f4e..9fa32b9df5 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -633,9 +633,10 @@ int rrdpush_receiver_thread_spawn(struct web_client *w, char *url) { struct receiver_state *rpt = callocz(1, sizeof(*rpt)); rpt->last_msg_t = now_realtime_sec(); rpt->capabilities = STREAM_CAP_INVALID; + rpt->hops = 1; rpt->system_info = callocz(1, sizeof(struct rrdhost_system_info)); - rpt->system_info->hops = 1; + rpt->system_info->hops = rpt->hops; rpt->fd = w->ifd; rpt->client_ip = strdupz(w->client_ip); @@ -689,7 +690,7 @@ int rrdpush_receiver_thread_spawn(struct web_client *w, char *url) { rpt->utc_offset = (int32_t)strtol(value, NULL, 0); else if(!strcmp(name, "hops")) - rpt->system_info->hops = (uint16_t) strtoul(value, NULL, 0); + rpt->hops = rpt->system_info->hops = (uint16_t) strtoul(value, NULL, 0); else if(!strcmp(name, "ml_capable")) rpt->system_info->ml_capable = strtoul(value, NULL, 0); |