Changeset: 31e395679cef for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/31e395679cef
Modified Files:
        sql/server/sql_mvc.c
        sql/storage/store.c
Branch: sql_profiler
Log Message:

Mark location profiler calls for transaction related events.


diffs (58 lines):

diff --git a/sql/server/sql_mvc.c b/sql/server/sql_mvc.c
--- a/sql/server/sql_mvc.c
+++ b/sql/server/sql_mvc.c
@@ -473,6 +473,7 @@ mvc_trans(mvc *m)
 
        TRC_INFO(SQL_TRANS, "Starting transaction\n");
        res = sql_trans_begin(m->session);
+       // TODO PROFILER EVENT: start of transaction: log m->clientid, 
m->session->tr->tid and m->session->tr->ts
        if (m->qc && (res || err)) {
                int seqnr = m->qc->id;
                if (m->qc)
diff --git a/sql/storage/store.c b/sql/storage/store.c
--- a/sql/storage/store.c
+++ b/sql/storage/store.c
@@ -3575,6 +3575,8 @@ sql_trans_rollback(sql_trans *tr, bool c
 {
        sqlstore *store = tr->store;
 
+       // TODO PROFILER EVENT: start of rollback log tr->tid and ts
+
        /* move back deleted */
        if (tr->localtmps.dset) {
                for(node *n=tr->localtmps.dset->h; n; ) {
@@ -3670,6 +3672,8 @@ sql_trans_rollback(sql_trans *tr, bool c
                list_destroy(tr->depchanges);
                tr->depchanges = NULL;
        }
+
+       // TODO PROFILER EVENT: end of rollback log tr->tid and ts
 }
 
 sql_trans *
@@ -3902,6 +3906,9 @@ sql_trans_commit(sql_trans *tr)
                        }
                }
 
+
+               // TODO PROFILER EVENT: start of commit log tid and ts
+
                /* log changes should only be done if there is something to log 
*/
                const bool log = !tr->parent && tr->logchanges > 0;
 
@@ -4031,6 +4038,8 @@ sql_trans_commit(sql_trans *tr)
 
        if (ok == LOG_OK)
                ok = clean_predicates_and_propagate_to_parent(tr);
+
+       // TODO PROFILER EVENT: end of commit log tid, ts and commit_ts (which 
is now the end timestamp) and ok, i.e. succes or error
        return (ok==LOG_OK)?SQL_OK:SQL_ERR;
 }
 
@@ -7031,5 +7040,6 @@ sql_trans_end(sql_session *s, int ok)
        store->oldest = oldest;
        assert(list_length(store->active) == (int) 
ATOMIC_GET(&store->nr_active));
        store_unlock(store);
+       // TODO PROFILER EVENT: end of transaction log s->tr->tid
        return ok;
 }
_______________________________________________
checkin-list mailing list -- [email protected]
To unsubscribe send an email to [email protected]

Reply via email to