X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?a=blobdiff_plain;f=statemc.c;h=8d3e728c89a88d4258e36865f2967fe64351d1b1;hb=854f19ae391120e6dd11c33c66250745b3d21aa7;hp=58aaefd6413fec8a5ee4a2ddd6109d01ef51c300;hpb=4332dc9e11bdd1dc45a75aa3b5249f816ef7f148;p=innduct.git diff --git a/statemc.c b/statemc.c index 58aaefd..8d3e728 100644 --- a/statemc.c +++ b/statemc.c @@ -190,8 +190,12 @@ int trigger_flush_ok(const char *why) { case sm_SEPARATED: case sm_DROPPING: - warn("abandoning old feedfile after flush (%s), autodeferring", - why ? why : "took too long to complete"); + if (conns.count) + warn("abandoning old feedfile after flush (%s), autodeferring", + why ? why : "took too long to complete"); + else + info("autodeferring after flush (%s)", + why ? why : "no connections"); assert(flushing_input_file); autodefer_input_file(flushing_input_file); return 1; @@ -234,7 +238,7 @@ static void notice_processed_counts(Counts *counts, int completed, ? xasprintf(" autodeferred=%ld", ipf_xtra->autodefer) : xasprintf("%s",""); - info("%s %s read=%d (+bl=%d,+err=%d)%s%s" + notice("%s %s read=%d (+bl=%d,+err=%d)%s%s" " missing=%d offered=%d (ch=%d,nc=%d) accepted=%d (ch=%d,nc=%d)" RESULT_COUNTS(RCI_NOTHING, RCI_TRIPLE_FMT) , @@ -303,7 +307,7 @@ void statemc_check_flushing_done(void) { assert(sms==sm_SEPARATED || sms==sm_DROPPING); - notice_processed_inputfile(ipf,1,"feedfile"); + notice_processed_inputfile(ipf,1,"batch"); close_defer(); @@ -500,6 +504,7 @@ void preterminate(void) { } void showstats(void) { + notice_conns_stats(); notice_processed_inputfile(main_input_file, 0, "feedfile"); notice_processed_inputfile(flushing_input_file, 0, "flushing");