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 -- [email protected]
To unsubscribe send an email to [email protected]
