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(server): Call PostUpdate from LPUSH even for new keys (#2254)

Browse source
This commit is contained in:
Shahar Mike 2023-12-05 14:23:56 +02:00 • committed by GitHub
parent 11ef6623dc
commit 3957370485
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/server/list_family.cc
View file

@ -366,10 +366,10 @@ OpResult<uint32_t> OpPush(const OpArgs& op_args, std::string_view key, ListDir d
absl::StrAppend(debugMessages.Next(), "OpPush AwakeWatched: ", key, " by ", absl::StrAppend(debugMessages.Next(), "OpPush AwakeWatched: ", key, " by ",
op_args.tx->DebugId()); op_args.tx->DebugId());
} }
} else {
es->db_slice().PostUpdate(op_args.db_cntx.db_index, it, key, true);
} }
es->db_slice().PostUpdate(op_args.db_cntx.db_index, it, key, !new_key);
if (journal_rewrite && op_args.shard->journal()) { if (journal_rewrite && op_args.shard->journal()) {
string command = dir == ListDir::LEFT ? "LPUSH" : "RPUSH"; string command = dir == ListDir::LEFT ? "LPUSH" : "RPUSH";
vector<string_view> mapped(vals.size() + 1); vector<string_view> mapped(vals.size() + 1);