mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

chore: flush journal to channel for non auto journal commands (#3945)

Browse source 
* flush journal to channel for non auto journal commands
This commit is contained in:
Kostas Kyrimis 2024-10-30 12:09:01 +02:00 committed by GitHub
parent c8b56b69b4
commit daf8604175
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/server/tx_base.cc
View file

@ -53,13 +53,13 @@ size_t ShardArgs::Size() const {
void RecordJournal(const OpArgs& op_args, string_view cmd, const ShardArgs& args, void RecordJournal(const OpArgs& op_args, string_view cmd, const ShardArgs& args,
uint32_t shard_cnt) { uint32_t shard_cnt) {
VLOG(2) << "Logging command " << cmd << " from txn " << op_args.tx->txid(); 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, void RecordJournal(const OpArgs& op_args, std::string_view cmd, facade::ArgSlice args,
uint32_t shard_cnt) { uint32_t shard_cnt) {
VLOG(2) << "Logging command " << cmd << " from txn " << op_args.tx->txid(); 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) { void RecordExpiry(DbIndex dbid, string_view key) {