X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?a=blobdiff_plain;f=cli.c;h=b4938f42f7360a02aa8aebc71fe3d1dd211a4777;hb=229c6d070b1ddb2cebb0a3f12bc71713795cd627;hp=e44a93949fbedf9f37fea5f169fb14051e7a762a;hpb=8c633440b844eff93ba52a5a64c8600cbf0f4a38;p=innduct.git diff --git a/cli.c b/cli.c index e44a939..b4938f4 100644 --- a/cli.c +++ b/cli.c @@ -323,30 +323,36 @@ static void dump_article_list(FILE *f, const CliCommand *c, fprintf(f, " %s %s\n", TokenToText(art->token), art->messageid); } } - + +static void dump_counts_events(FILE *f, const Counts *counts) { + DUMPV("%d", counts->,events[read_ok]); + DUMPV("%d", counts->,events[read_blank]); + DUMPV("%d", counts->,events[read_err]); + DUMPV("%d", counts->,events[nooffer_missing]); +} + +static void dump_counts_results(FILE *f, const Counts *counts, + const char *wh1, const char *wh2) { + ArtState state; const char *const *statename; + for (state=0, statename=artstate_names; *statename; state++,statename++) { +#define RC_DUMP_FMT(x) " " #x "=%d" +#define RC_DUMP_VAL(x) ,counts->results[state][RC_##x] + fprintf(f,"%s%s counts %-11s" + RESULT_COUNTS(RC_DUMP_FMT,RC_DUMP_FMT) "\n", + wh1,wh2, *statename + RESULT_COUNTS(RC_DUMP_VAL,RC_DUMP_VAL)); + } +} + static void dump_input_file(FILE *f, const CliCommand *c, InputFile *ipf, const char *wh) { char *dipf= dbg_report_ipf(ipf); fprintf(f,"input %s %s", wh, dipf); free(dipf); - - if (ipf) { - DUMPV("%d", ipf->counts.,events[read_ok]); - DUMPV("%d", ipf->counts.,events[read_blank]); - DUMPV("%d", ipf->counts.,events[read_err]); - DUMPV("%d", ipf->counts.,events[nooffer_missing]); - } + if (ipf) dump_counts_events(f, &ipf->counts); fprintf(f,"\n"); if (ipf) { - ArtState state; const char *const *statename; - for (state=0, statename=artstate_names; *statename; state++,statename++) { -#define RC_DUMP_FMT(x) " " #x "=%d" -#define RC_DUMP_VAL(x) ,ipf->counts.results[state][RC_##x] - fprintf(f,"input %s counts %-11s" - RESULT_COUNTS(RC_DUMP_FMT,RC_DUMP_FMT) "\n", - wh, *statename - RESULT_COUNTS(RC_DUMP_VAL,RC_DUMP_VAL)); - } + dump_counts_results(f, &ipf->counts, "input ",wh); fprintf(f,"input %s queue", wh); dump_article_list(f,c,&ipf->queue); } @@ -391,6 +397,12 @@ static void dumpinfo(const CliCommand *c, FILE *f) { dump_input_file(f,c, main_input_file, "main" ); dump_input_file(f,c, flushing_input_file, "flushing"); dump_input_file(f,c, backlog_input_file, "backlog" ); + if (backlog_counts_report) { + fprintf(f,"completed backlogs"); + dump_counts_events(f, &backlog_counts); + fprintf(f,"\n"); + dump_counts_results(f, &backlog_counts, "completed backlogs",""); + } fprintf(f,"conns count=%d\n", conns.count); @@ -413,8 +425,8 @@ static void dumpinfo(const CliCommand *c, FILE *f) { const XmitDetails *xd= &conn->xmitd[i]; char *dinfo; switch (xd->kind) { - case xk_Const: dinfo= xasprintf("Const"); break; - case xk_Artdata: dinfo= xasprintf("A%p", xd->info.sm_art); break; + case xk_Const: dinfo= masprintf("Const"); break; + case xk_Artdata: dinfo= masprintf("A%p", xd->info.sm_art); break; default: abort(); } @@ -448,5 +460,5 @@ CCMD(dump) { CCMD(dumphere) { dumpinfo(c,cc->out); - fprintf(cc->out, "."); + fprintf(cc->out, ".\n"); }