Skip to content

Commit f2cdc9f

Browse files
committed
fixes
1 parent fd1b9ec commit f2cdc9f

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/server/cluster/cluster_family.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ ClusterFamily::ClusterFamily(ServerFamily* server_family) : server_family_(serve
8181
}
8282

8383
void ClusterFamily::Shutdown() {
84-
Coordinator::Current().Shutdown();
84+
// Coordinator::Current().Shutdown();
8585
shard_set->pool()->at(0)->Await([this]() ABSL_LOCKS_EXCLUDED(set_config_mu) {
8686
PreparedToRemoveOutgoingMigrations outgoing_migrations; // should be removed without mutex lock
8787
{

src/server/hset_family.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -683,7 +683,7 @@ void CmdHDel(CmdArgList args, CommandContext* cmd_cntx) {
683683
deleted += hw.Erase(s);
684684
return deleted;
685685
};
686-
HSetReplies{cmd_cntx->rb}.Send(ExecuteW(cmd_cntx->tx, std::move(cb)));
686+
HSetReplies{cmd_cntx->rb()}.Send(ExecuteW(cmd_cntx->tx, std::move(cb)));
687687
}
688688

689689
void CmdHExpire(CmdArgList args, CommandContext* cmd_cntx) {
@@ -948,7 +948,7 @@ void CmdHSetNx(CmdArgList args, CommandContext* cmd_cntx) {
948948
auto cb = [&](Transaction* t, EngineShard* shard) {
949949
return OpSet(t->GetOpArgs(shard), key, args.subspan(1), OpSetParams{.skip_if_exists = true});
950950
};
951-
HSetReplies{cmd_cntx->rb}.Send(Unwrap(cmd_cntx->tx->ScheduleSingleHopT(cb)));
951+
HSetReplies{cmd_cntx->rb()}.Send(Unwrap(cmd_cntx->tx->ScheduleSingleHopT(cb)));
952952
}
953953

954954
void StrVecEmplaceBack(StringVec& str_vec, const listpackEntry& lp) {

0 commit comments

Comments
 (0)