/* for logging, simulation, debugging, etc. */
int simulate_flush= -1;
int logv_use_syslog;
-static char *logv_prefix="";
+static const char *logv_prefix="";
/*========== logging ==========*/
art->offset= old_offset;
art->blanklen= recsz;
strcpy(art->messageid, space+1);
- LIST_ADDTAIL(ipf->queue, art);
- if (ipf->autodefer >= 0)
+ if (ipf->autodefer >= 0) {
article_autodefer(ipf, art);
- else if (ipf==backlog_input_file)
- article_check_expired(art);
+ } else {
+ LIST_ADDTAIL(ipf->queue, art);
+
+ if (ipf==backlog_input_file)
+ article_check_expired(art);
+ }
if (sms==sm_NORMAL && ipf==main_input_file &&
ipf->offset >= target_max_feedfile_size)
static void *statemc_check_input_done(oop_source *lp, struct timeval now,
void *u) {
- assert(!inputfile_is_done(main_input_file));
+ /* main input file may be idle but if so that's because
+ * we haven't got to it yet, but that doesn't mean it's really done */
statemc_check_flushing_done();
statemc_check_backlog_done();
return OOP_CONTINUE;