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

fix: Invalid key lock strings with squashing (#2341)

Browse source 
* fix: clear shard data in squash preparation
This commit is contained in:
Vladislav 2023-12-27 12:48:43 +03:00 • committed by GitHub
parent 16a0becea5
commit 8c873fd71c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/server/transaction.cc
View file

@ -347,6 +347,9 @@ void Transaction::PrepareSquashedMultiHop(const CommandId* cid,
multi_->role = SQUASHER; multi_->role = SQUASHER;
InitBase(db_index_, {}); InitBase(db_index_, {});
// Because squashing already determines active shards by partitioning commands,
// we don't have to work with keys manually and can just mark active shards.
// The partitioned commands know it's keys and assume they have correct access.
DCHECK_EQ(shard_data_.size(), shard_set->size()); DCHECK_EQ(shard_data_.size(), shard_set->size());
for (unsigned i = 0; i < shard_data_.size(); i++) { for (unsigned i = 0; i < shard_data_.size(); i++) {
if (enabled(i)) { if (enabled(i)) {
@ -356,6 +359,8 @@ void Transaction::PrepareSquashedMultiHop(const CommandId* cid,
} else { } else {
shard_data_[i].local_mask &= ~ACTIVE; shard_data_[i].local_mask &= ~ACTIVE;
} }
shard_data_[i].arg_start = 0;
shard_data_[i].arg_count = 0;
} }
} }