mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-10 18:05:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fix: crash during getting info about replication (#4328)

Browse source
This commit is contained in:
Borys 2024-12-18 08:44:24 +02:00 • committed by GitHub
parent 19164badf9
commit 15b293a7ec
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/server/rdb_save.cc
View file

@ -1333,6 +1333,10 @@ size_t RdbSaver::Impl::GetTotalBuffersSize() const {
auto cb = [this, &channel_bytes, &serializer_bytes](ShardId sid) {
auto& snapshot = shard_snapshots_[sid];
// before create a snapshot we save header so shard_snapshots_ are vector of nullptr until we
// start snapshots saving
if (!snapshot)
return;
if (channel_.has_value())
channel_bytes.fetch_add(channel_->GetSize(), memory_order_relaxed);
serializer_bytes.store(snapshot->GetBufferCapacity() + snapshot->GetTempBuffersSize(),
@ -1355,6 +1359,10 @@ RdbSaver::SnapshotStats RdbSaver::Impl::GetCurrentSnapshotProgress() const {
auto cb = [this, &results](ShardId sid) {
auto& snapshot = shard_snapshots_[sid];
// before create a snapshot we save header so shard_snapshots_ are vector of nullptr until we
// start snapshots saving
if (!snapshot)
return;
results[sid] = snapshot->GetCurrentSnapshotProgress();
};