tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix logging in worker_engine

Browse Source 
Summary: log before deleting tx object

Reviewers: msantl

Reviewed By: msantl

Differential Revision: https://phabricator.memgraph.io/D1332
This commit is contained in:
Marin Tomic 2018-03-30 10:39:31 +02:00
parent 3df590a842
commit 86072a993a
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/transactions/engine_worker.cpp
View File

@ -63,15 +63,15 @@ command_id_t WorkerEngine::UpdateCommand(transaction_id_t tx_id) {
void WorkerEngine::Commit(const Transaction &t) { void WorkerEngine::Commit(const Transaction &t) {
auto res = master_client_pool_.Call<CommitRpc>(t.id_); auto res = master_client_pool_.Call<CommitRpc>(t.id_);
CHECK(res) << "CommitRpc failed"; CHECK(res) << "CommitRpc failed";
ClearSingleTransaction(t.id_);
VLOG(11) << "[Tx] Commiting worker transaction " << t.id_; VLOG(11) << "[Tx] Commiting worker transaction " << t.id_;
ClearSingleTransaction(t.id_);
} }
void WorkerEngine::Abort(const Transaction &t) { void WorkerEngine::Abort(const Transaction &t) {
auto res = master_client_pool_.Call<AbortRpc>(t.id_); auto res = master_client_pool_.Call<AbortRpc>(t.id_);
CHECK(res) << "AbortRpc failed"; CHECK(res) << "AbortRpc failed";
ClearSingleTransaction(t.id_);
VLOG(11) << "[Tx] Aborting worker transaction " << t.id_; VLOG(11) << "[Tx] Aborting worker transaction " << t.id_;
ClearSingleTransaction(t.id_);
} }
CommitLog::Info WorkerEngine::Info(transaction_id_t tid) const { CommitLog::Info WorkerEngine::Info(transaction_id_t tid) const {