innov
/
dragonfly
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

chore(server): Add more logging in case of check fail

This commit is contained in:
Roman Gershman 2022-10-04 07:20:45 +03:00
parent a1b800e23b
commit 881e8a1b0c
No known key found for this signature in database
GPG Key ID: 6568CCAB9736B618
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/server/engine_shard_set.cc
View File

@ -135,14 +135,15 @@ void EngineShard::DestroyThreadLocal() {
// Is called by Transaction::ExecuteAsync in order to run transaction tasks.
// Only runs in its own thread.
void EngineShard::PollExecution(const char* context, Transaction* trans) {
VLOG(2) << "PollExecution " << context << " " << (trans ? trans->DebugId() : "")
<< " " << txq_.size() << " " << continuation_trans_;
VLOG(2) << "PollExecution " << context << " " << (trans ? trans->DebugId() : "") << " "
<< txq_.size() << " " << continuation_trans_;
ShardId sid = shard_id();
uint16_t trans_mask = trans ? trans->GetLocalMask(sid) : 0;
if (trans_mask & Transaction::AWAKED_Q) {
DCHECK(continuation_trans_ == nullptr);
DCHECK(continuation_trans_ == nullptr)
<< continuation_trans_->DebugId() << " when polling " << trans->DebugId();
CHECK_EQ(committed_txid_, trans->notify_txid());
bool keep = trans->RunInShard(this);