From c5f3c8a3c957d732b880a42dce3ad3e5c048eda3 Mon Sep 17 00:00:00 2001 From: chejinge Date: Mon, 30 Dec 2024 14:08:24 +0800 Subject: [PATCH] fix RpushLpop --- src/pika_conf.cc | 1 - src/pika_list.cc | 6 ++++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/pika_conf.cc b/src/pika_conf.cc index d905e3fe6..bd3f29385 100644 --- a/src/pika_conf.cc +++ b/src/pika_conf.cc @@ -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_); diff --git a/src/pika_list.cc b/src/pika_list.cc index c3427b93c..12b2e2b53 100644 --- a/src/pika_list.cc +++ b/src/pika_list.cc @@ -831,8 +831,10 @@ void RPopLPushCmd::DoUpdateCache() { if (s_.ok()) { std::vector 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() {