ISNODE(Conn);
int fd; /* may be 0, meaning closed (during construction/destruction) */
oop_read *rd; /* likewise */
- int max_queue, stream, quitting;
+ int max_queue, stream;
+ const char *quitting;
int since_activity; /* periods */
ArticleList waiting; /* not yet told peer */
ArticleList priority; /* peer says send it now */
static pid_t self_pid;
static int *lowvol_perperiod;
static int lowvol_circptr;
-static int lowvol_total;
+static int lowvol_total; /* does not include current period */
/* statemc_init initialises */
static StateMachineState sms;
assert(r<=todo);
todo -= r;
if (!todo) {
- conn->quitting= 1;
+ conn->quitting= why;
conn->since_activity= 0;
debug("C%d is idle (%s), quitting", conn->fd, why);
break;
static void check_idle_conns(void) {
Conn *conn;
- int verylowvol= lowvol_perperiod[lowvol_circptr];
+ int volthisperiod= lowvol_perperiod[lowvol_circptr];
lowvol_circptr++;
lowvol_circptr %= lowvol_periods;
+ lowvol_total += volthisperiod;
lowvol_total -= lowvol_perperiod[lowvol_circptr];
lowvol_perperiod[lowvol_circptr]= 0;
/* We need to shut this down */
if (conn->quitting)
- connfail(conn,"timed out waiting for response to QUIT");
+ connfail(conn,"timed out waiting for response to QUIT (%s)",
+ conn->quitting);
else if (conn->sent.count)
connfail(conn,"timed out waiting for responses");
else if (conn->waiting.count || conn->priority.count)
}
conn= LIST_HEAD(conns);
- if (!verylowvol &&
+ if (!volthisperiod &&
conns.count==1 &&
- lowvol_total+verylowvol < lowvol_thresh &&
+ lowvol_total < lowvol_thresh &&
!conn_busy(conn))
conn_idle_close(conn, "low volume");
}
assert(!connecting_fdpass_sock);
info("starting connection attempt");
- int ok_reconnect_delay_periods= reconnect_delay_periods;
+ int ok_until_connect= until_connect;
reconnect_blocking_event();
int socks[2];
on_fd_read_except(connecting_fdpass_sock, connchild_event);
if (!conns.count)
- reconnect_delay_periods= ok_reconnect_delay_periods;
+ until_connect= ok_until_connect;
}
/*---------- assigning articles to conns, and transmitting ----------*/
}
static void autodefer_input_file(InputFile *ipf) {
+ static const char *const abandon= "stuck";
ipf->autodefer= 0;
autodefer_input_file_articles(ipf);
if (has_article_in(&walk->waiting, ipf) ||
has_article_in(&walk->priority, ipf) ||
has_article_in(&walk->sent, ipf))
- walk->quitting= -1;
+ walk->quitting= abandon;
}
while (ipf->inprogress) {
FOR_CONN(walk)
- if (walk->quitting < 0) goto found;
+ if (walk->quitting == abandon) goto found;
abort(); /* where are they ?? */
found:
if (conn->quitting) {
if (code!=205 && code!=400) {
- connfail(conn, "peer gave unexpected response to QUIT: %s", sani);
+ connfail(conn, "peer gave unexpected response to QUIT (%s): %s",
+ conn->quitting, sani);
} else {
LIST_REMOVE(conns,conn);
- notice("C%d (now %d) idle connection closed by us",
- conn->fd, conns.count);
+ notice("C%d (now %d) idle connection closed (%s)",
+ conn->fd, conns.count, conn->quitting);
assert(!busy);
conn_dispose(conn);
}
debug("PERIOD"
" sms=%s[%d] conns=%d until_connect=%d"
" input_files main:%s flushing:%s backlog:%s[%d]"
- " children connecting=%ld inndcomm=%ld"
+ " children connecting=%ld inndcomm=%ld lowvol_total=%d"
,
sms_names[sms], until_flush, conns.count, until_connect,
dipf_main, dipf_flushing, dipf_backlog, until_backlog_nextscan,
- (long)connecting_child, (long)inndcomm_child
+ (long)connecting_child, (long)inndcomm_child, lowvol_total
);
free(dipf_main);
DUMPV("%d", , cli_master);
fprintf(f,"\n");
+ fprintf(f,"lowvol");
+ DUMPV("%d", , lowvol_circptr);
+ DUMPV("%d", , lowvol_total);
+ fprintf(f,":");
+ for (i=0; i<lowvol_periods; i++) {
+ fprintf(f," ");
+ if (i==lowvol_circptr) fprintf(f,"*");
+ fprintf(f,"%d",lowvol_perperiod[i]);
+ }
+ fprintf(f,"\n");
+
fprintf(f,"filemon ");
filemon_method_dump_info(f);
fprintf(f,"C%d",conn->fd);
DUMPV("%p",conn->,rd); DUMPV("%d",conn->,max_queue);
- DUMPV("%d",conn->,stream); DUMPV("%d",conn->,quitting);
+ DUMPV("%d",conn->,stream); DUMPV("\"%s\"",conn->,quitting);
DUMPV("%d",conn->,since_activity);
fprintf(f,"\n");
lowvol_perperiod[i]= lowvol_thresh;
lowvol_total += lowvol_thresh;
}
+ lowvol_total -= lowvol_thresh;
/* set things up */