Skip to content

Commit

Permalink
fix RpushLpop
Browse files Browse the repository at this point in the history
  • Loading branch information
brother-jin committed Dec 30, 2024
1 parent a879330 commit c5f3c8a
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
1 change: 0 additions & 1 deletion src/pika_conf.cc
Original file line number Diff line number Diff line change
Expand Up @@ -782,7 +782,6 @@ int PikaConf::ConfigRewrite() {
SetConfInt("max-cache-files", max_cache_files_);
SetConfInt("max-background-compactions", max_background_compactions_);
SetConfInt("max-background-jobs", max_background_jobs_);
SetConfInt("max-subcompactions", max_subcompactions_);
SetConfInt64("rate-limiter-bandwidth", rate_limiter_bandwidth_);
SetConfInt64("delayed-write-rate", delayed_write_rate_);
SetConfInt64("max-compaction-bytes", max_compaction_bytes_);
Expand Down
6 changes: 4 additions & 2 deletions src/pika_list.cc
Original file line number Diff line number Diff line change
Expand Up @@ -831,8 +831,10 @@ void RPopLPushCmd::DoUpdateCache() {
if (s_.ok()) {
std::vector<std::string> value;
value.resize(1);
db_->cache()->RPop(source_, &value[0]);
db_->cache()->LPushx(receiver_, value);
std::string CachePrefixKeyLR = PCacheKeyPrefixL + source_;
db_->cache()->RPop(CachePrefixKeyLR, &value[0]);
std::string CachePrefixKeyLL = PCacheKeyPrefixL + receiver_;
db_->cache()->LPushx(CachePrefixKeyLL, value);
}
}
void RPopLPushCmd::DoThroughDB() {
Expand Down

0 comments on commit c5f3c8a

Please sign in to comment.