From daf8604175bf71de4ddac28800fc5d2bba455315 Mon Sep 17 00:00:00 2001 From: Kostas Kyrimis Date: Wed, 30 Oct 2024 12:09:01 +0200 Subject: [PATCH] chore: flush journal to channel for non auto journal commands (#3945) * flush journal to channel for non auto journal commands --- src/server/tx_base.cc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/server/tx_base.cc b/src/server/tx_base.cc index a9bd799b9..9eb6ba09b 100644 --- a/src/server/tx_base.cc +++ b/src/server/tx_base.cc @@ -53,13 +53,13 @@ size_t ShardArgs::Size() const { void RecordJournal(const OpArgs& op_args, string_view cmd, const ShardArgs& args, uint32_t shard_cnt) { VLOG(2) << "Logging command " << cmd << " from txn " << op_args.tx->txid(); - op_args.tx->LogJournalOnShard(op_args.shard, Payload(cmd, args), shard_cnt, false); + op_args.tx->LogJournalOnShard(op_args.shard, Payload(cmd, args), shard_cnt, true); } void RecordJournal(const OpArgs& op_args, std::string_view cmd, facade::ArgSlice args, uint32_t shard_cnt) { VLOG(2) << "Logging command " << cmd << " from txn " << op_args.tx->txid(); - op_args.tx->LogJournalOnShard(op_args.shard, Payload(cmd, args), shard_cnt, false); + op_args.tx->LogJournalOnShard(op_args.shard, Payload(cmd, args), shard_cnt, true); } void RecordExpiry(DbIndex dbid, string_view key) {