MonetDB: Dec2023 - Print some logger info on USR1 signal.

[Sjoerd Mullender via checkin-list]

Changeset: b23e31d29525 for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/b23e31d29525
Modified Files:
        clients/Tests/exports.stable.out
        gdk/gdk_logger.c
        gdk/gdk_logger.h
        sql/backends/monet5/sql_scenario.c
Branch: Dec2023
Log Message:

Print some logger info on USR1 signal.


diffs (67 lines):

diff --git a/clients/Tests/exports.stable.out b/clients/Tests/exports.stable.out
--- a/clients/Tests/exports.stable.out
+++ b/clients/Tests/exports.stable.out
@@ -559,6 +559,7 @@ gdk_return log_delta(logger *lg, BAT *ui
 void log_destroy(logger *lg);
 log_bid log_find_bat(logger *lg, log_id id);
 gdk_return log_flush(logger *lg, ulng saved_id);
+void log_printinfo(logger *lg);
 int log_sequence(logger *lg, int seq, lng *id);
 gdk_return log_tend(logger *lg);
 gdk_return log_tflush(logger *lg, ulng log_file_id, ulng commit_ts);
diff --git a/gdk/gdk_logger.c b/gdk/gdk_logger.c
--- a/gdk/gdk_logger.c
+++ b/gdk/gdk_logger.c
@@ -2256,6 +2256,7 @@ log_new(int debug, const char *fn, const
                .saved_id = getBBPlogno(),      /* get saved log numer from bbp 
*/
                .saved_tid = (int) getBBPtransid(),     /* get saved 
transaction id from bbp */
        };
+       lg->tid = lg->saved_tid;
 
        /* probably open file and check version first, then call call old 
logger code */
        if (snprintf(filename, sizeof(filename), "%s%c%s%c", logdir, DIR_SEP, 
fn, DIR_SEP) >= FILENAME_MAX) {
@@ -3371,3 +3372,23 @@ log_tstart(logger *lg, bool flushnow, ul
 
        return GDK_SUCCEED;
 }
+
+void
+log_printinfo(logger *lg)
+{
+       printf("logger %s:\n", lg->fn);
+       printf("current log file "ULLFMT", last handled log file "ULLFMT"\n",
+              lg->id, lg->saved_id);
+       printf("current transaction id %d, saved transaction id %d\n",
+              lg->tid, lg->saved_tid);
+       printf("number of flushers: %d, number of open files %d\n",
+              (int) ATOMIC_GET(&lg->nr_flushers),
+              (int) ATOMIC_GET(&lg->nr_open_files));
+       printf("number of catalog entries "BUNFMT", of which "BUNFMT" 
deleted\n",
+              lg->catalog_bid->batCount, lg->dcatalog->batCount);
+       int npend = 0;
+       for (logged_range *p = lg->pending; p; p = p->next)
+               npend++;
+       if (npend > 1)
+               printf("number of pending ranges %d\n", npend);
+}
diff --git a/gdk/gdk_logger.h b/gdk/gdk_logger.h
--- a/gdk/gdk_logger.h
+++ b/gdk/gdk_logger.h
@@ -78,4 +78,6 @@ gdk_export gdk_return log_tflush(logger 
 gdk_export gdk_return log_tsequence(logger *lg, int seq, lng id);
 gdk_export log_bid log_find_bat(logger *lg, log_id id);
 
+gdk_export void log_printinfo(logger *lg);
+
 #endif /*_LOGGER_H_*/
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
@@ -89,6 +89,7 @@ static void
 SQLprintinfo(void)
 {
        /* we need to start printing SQL info here... */
+       log_printinfo(((sqlstore *) SQLstore)->logger);
 }
 
 str
_______________________________________________
checkin-list mailing list -- checkin-list@monetdb.org
To unsubscribe send an email to checkin-list-le...@monetdb.org