refs Tokutek/ft-engine#30 trace all txn begin calls

1 files changed, 10 insertions, 2 deletions

diff --git a/storage/tokudb/hatoku_defines.h b/storage/tokudb/hatoku_defines.h
index 10b0e2e3833..38525480905 100644
--- a/storage/tokudb/hatoku_defines.h
+++ b/storage/tokudb/hatoku_defines.h
@@ -329,9 +329,17 @@ static inline void make_name(char *newname, const char *tablename, const char *d
     nn += sprintf(nn, "-%s", dictname);
 }
 
+static inline int txn_begin(DB_ENV *env, DB_TXN *parent, DB_TXN **txn, uint32_t flags) {
+    int r = env->txn_begin(env, parent, txn, flags);
+    if ((tokudb_debug & TOKUDB_DEBUG_TXN) && r == 0) {
+        TOKUDB_TRACE("begin txn %p %p %u\n", parent, *txn, flags);
+    }
+    return r;
+}
+
 static inline void commit_txn(DB_TXN* txn, uint32_t flags) {
     if (tokudb_debug & TOKUDB_DEBUG_TXN)
-        TOKUDB_TRACE("commit_txn %p\n", txn);
+        TOKUDB_TRACE("commit txn %p\n", txn);
     int r = txn->commit(txn, flags);
     if (r != 0) {
         sql_print_error("tried committing transaction %p and got error code %d", txn, r);
@@ -341,7 +349,7 @@ static inline void commit_txn(DB_TXN* txn, uint32_t flags) {
 
 static inline void abort_txn(DB_TXN* txn) {
     if (tokudb_debug & TOKUDB_DEBUG_TXN)
-        TOKUDB_TRACE("abort_txn %p\n", txn);
+        TOKUDB_TRACE("abort txn %p\n", txn);
     int r = txn->abort(txn);
     if (r != 0) {
         sql_print_error("tried aborting transaction %p and got error code %d", txn, r);