diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2023-01-13 19:52:55 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-13 19:52:55 +0200 |
| commit | 68658fc1e0a0902343bb165b7ed12b6fba1f2202 (patch) | |
| tree | b4b15043880ca48d146f8d8c09a039db42d69d71 /streaming | |
| parent | 6f587f5aced38d7f55a95fe815bb59499552345d (diff) | |
DBENGINE v2 - improvements 2 (#14257)
* allow extents to be merged for as long as possible
* do not block the event loop while recalculating retention due to datafile rotation
* buffers are incrementally cleaned up, every second, by just 1 entry
* fix order of commands
* remove newline
* measure cancelled extent read requests
* count all cancelled extent requests
* do not double count failed pages
* fixed cancelled name
* Fix error and warnings when compiling with --disable-dbengine
* when the timeframe is outside retention and whole query should fail
* do not mark as failed pages that have been loaded but have been skipped
* added chart to show cache memory calculation variables
* LONG_MAX for 32-bit compatibility
* fix cache size calculation on 32-bit
* fix cache size calculation on 32-bit - use unsinged long long
* fix compilation warnings on 32-bits
* fix another compilation warning on 32-bits
* fix compilation warnings on older 32-bit compilers
* fix compilation warnings on older 32-bit compilers - more of them
* disable ML threads joining
Co-authored-by: Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com>
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/compression.c | 2 | ||||
| -rw-r--r-- | streaming/rrdpush.c | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/streaming/compression.c b/streaming/compression.c index 7ba9dbf198..8f2517a8e3 100644 --- a/streaming/compression.c +++ b/streaming/compression.c @@ -244,7 +244,7 @@ static size_t lz4_decompressor_decompress(struct decompressor_state *state, cons , state->stream->size , state->stream->write_at , decompressed_size - , state->stream->write_at + decompressed_size - state->stream->size + , (size_t)(state->stream->write_at + decompressed_size - state->stream->size) ); state->stream->write_at += decompressed_size; diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index 80addd5566..27c0b24f4e 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -974,7 +974,7 @@ int rrdpush_receiver_thread_spawn(struct web_client *w, char *url) { */ { - time_t age; + time_t age = 0; bool receiver_stale = false; bool receiver_working = false; |