Skip to content

Commit 56c1d28

Browse files
authored
fix: fix data race around spop Dobinlog (OpenAtomFoundation#2674)
* fix spop binlog data race * adjust format --------- Co-authored-by: cjh <1271435567@qq.com>
1 parent 2c13e7b commit 56c1d28

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

include/pika_set.h

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,12 @@ class SPopCmd : public Cmd {
6666
public:
6767
SPopCmd(const std::string& name, int arity, uint32_t flag)
6868
: Cmd(name, arity, flag, static_cast<uint32_t>(AclCategory::SET)) {
69-
srem_cmd_ = std::make_shared<SRemCmd>(kCmdNameSRem, -3, kCmdFlagsWrite | kCmdFlagsSet);
70-
}
69+
srem_cmd_ = std::make_shared<SRemCmd>(kCmdNameSRem, -3, kCmdFlagsWrite | kCmdFlagsSet);
70+
}
71+
SPopCmd(const SPopCmd& other)
72+
: Cmd(other), key_(other.key_), members_(other.members_), count_(other.count_), s_(other.s_) {
73+
srem_cmd_ = std::make_shared<SRemCmd>(kCmdNameSRem, -3, kCmdFlagsWrite | kCmdFlagsSet);
74+
}
7175
std::vector<std::string> current_key() const override {
7276
std::vector<std::string> res;
7377
res.push_back(key_);

0 commit comments

Comments
 (0)