static void postfork(const char *what);
static void postfork_inputfile(InputFile *ipf);
+static void open_defer(void);
+
/*----- configuration options -----*/
static char *sitename, *feedfile;
connect_attempt_discard();
}
+static int allow_connect_start(void) {
+ return conns.count < max_connections
+ && !connecting_child
+ && !until_connect;
+}
+
static void connect_start(void) {
assert(!connecting_sockets[0]);
assert(!connecting_sockets[1]);
spare--;
}
conn_maybe_write(use);
- } else if (conns.count < max_connections &&
- !connecting_child && !until_connect) {
+ } else if (allow_connect_start()) {
until_connect= reconnect_delay_periods;
connect_start();
break;
if (conn->xmitu+5 > CONNIOVS)
break;
- Article *art= LIST_REMHEAD(priority);
- if (!art) art= LIST_REMHEAD(waiting);
+ Article *art= LIST_REMHEAD(conn->priority);
+ if (!art) art= LIST_REMHEAD(conn->waiting);
if (!art) break;
if (art->state >= art_Wanted || (conn->stream && nocheck)) {
XMIT_LITERAL("\r\n");
assert(art->state == art_Unchecked);
- art->ipf->counts[art->state][RCI_sent]++;
+ art->ipf->counts[art->state][RC_sent]++;
LIST_ADDTAIL(conn->sent, art);
}
}