MonetDB: Dec2023 - Also print transaction start (ts) value for o...

[Sjoerd Mullender via checkin-list]

Changeset: ba1c5677388d for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/ba1c5677388d
Modified Files:
        sql/backends/monet5/sql_scenario.c
Branch: Dec2023
Log Message:

Also print transaction start (ts) value for open transactions.


diffs (40 lines):

diff --git a/sql/backends/monet5/sql_scenario.c 
b/sql/backends/monet5/sql_scenario.c
--- a/sql/backends/monet5/sql_scenario.c
+++ b/sql/backends/monet5/sql_scenario.c
@@ -94,8 +94,9 @@ static void
 CLIENTprintinfo(void)
 {
        int nrun = 0, nfinish = 0, nblock = 0;
-       char buf[32];
-       char tbuf[64];
+       char mmbuf[64];
+       char tmbuf[64];
+       char trbuf[64];
        struct tm tm;
 
        MT_lock_set(&mal_contextLock);
@@ -105,15 +106,19 @@ CLIENTprintinfo(void)
                        /* running */
                        nrun++;
                        if (c->qryctx.maxmem)
-                               snprintf(buf, sizeof(buf), " (max %"PRIu64")", 
(uint64_t) c->qryctx.maxmem);
+                               snprintf(mmbuf, sizeof(mmbuf), " (max 
%"PRIu64")", (uint64_t) c->qryctx.maxmem);
                        else
-                               buf[0] = 0;
+                               mmbuf[0] = 0;
                        if (c->idle) {
                                localtime_r(&c->idle, &tm);
-                               strftime(tbuf, sizeof(tbuf), ", idle since %F 
%H:%M:%S%z", &tm);
+                               strftime(tmbuf, sizeof(tmbuf), ", idle since %F 
%H:%M:%S%z", &tm);
                        } else
-                               tbuf[0] = 0;
-                       printf("client %d, user %s, thread %s, using %"PRIu64" 
bytes of transient space%s%s%s\n", c->idx, c->username, c->mythread ? 
c->mythread : "?", (uint64_t) ATOMIC_GET(&c->qryctx.datasize), buf, tbuf, 
c->sqlcontext && ((backend *) c->sqlcontext)->mvc && ((backend *) 
c->sqlcontext)->mvc->session && ((backend *) c->sqlcontext)->mvc->session->tr 
&& ((backend *) c->sqlcontext)->mvc->session->tr->active ? ", active 
transaction" : "");
+                               tmbuf[0] = 0;
+                       if (c->sqlcontext && ((backend *) c->sqlcontext)->mvc 
&& ((backend *) c->sqlcontext)->mvc->session && ((backend *) 
c->sqlcontext)->mvc->session->tr && ((backend *) 
c->sqlcontext)->mvc->session->tr->active)
+                               snprintf(trbuf, sizeof(trbuf), ", active 
transaction, ts: "ULLFMT, ((backend *) c->sqlcontext)->mvc->session->tr->ts);
+                       else
+                               trbuf[0] = 0;
+                       printf("client %d, user %s, thread %s, using %"PRIu64" 
bytes of transient space%s%s%s\n", c->idx, c->username, c->mythread ? 
c->mythread : "?", (uint64_t) ATOMIC_GET(&c->qryctx.datasize), mmbuf, tmbuf, 
trbuf);
                        break;
                case FINISHCLIENT:
                        /* finishing */
_______________________________________________
checkin-list mailing list -- checkin-list@monetdb.org
To unsubscribe send an email to checkin-list-le...@monetdb.org