usr.sbin/smtpd/scheduler.c

1 /*	$OpenBSD: scheduler.c,v 1.62 2021/06/14 17:58:16 eric Exp $	*/
69 		    "scheduler: inserting evp:%016" PRIx64, evp.id);
71 		stat_increment("scheduler.envelope.incoming", 1);
80 		    "scheduler: committing msg:%08" PRIx32, msgid);
82 		stat_decrement("scheduler.envelope.incoming", n);
83 		stat_increment("scheduler.envelope", n);
93 			log_debug("debug: scheduler: evp:%016" PRIx64
98 		    "scheduler: discovering evp:%016" PRIx64, evp.id);
100 		stat_increment("scheduler.envelope.incoming", 1);
110 			log_debug("debug: scheduler: msgid:%08" PRIx32
115 		    "scheduler: committing msg:%08" PRIx32, msgid);
117 		stat_decrement("scheduler.envelope.incoming", n);
118 		stat_increment("scheduler.envelope", n);
126 		log_trace(TRACE_SCHEDULER, "scheduler: aborting msg:%08" PRIx32,
129 		stat_decrement("scheduler.envelope.incoming", n);
139 		    "scheduler: queue requested removal of evp:%016" PRIx64,
141 		stat_decrement("scheduler.envelope", 1);
147 			stat_decrement("scheduler.envelope.inflight", 1);
158 		    "scheduler: queue ack removal of evp:%016" PRIx64,
161 		stat_decrement("scheduler.envelope.inflight", 1);
170 		    "scheduler: deleting evp:%016" PRIx64 " (ok)", evpid);
173 		stat_increment("scheduler.delivery.ok", 1);
174 		stat_decrement("scheduler.envelope.inflight", 1);
175 		stat_decrement("scheduler.envelope", 1);
184 		    "scheduler: updating evp:%016" PRIx64, evp.id);
188 		stat_increment("scheduler.delivery.tempfail", 1);
189 		stat_decrement("scheduler.envelope.inflight", 1);
215 		    "scheduler: deleting evp:%016" PRIx64 " (fail)", evpid);
218 		stat_increment("scheduler.delivery.permfail", 1);
219 		stat_decrement("scheduler.envelope.inflight", 1);
220 		stat_decrement("scheduler.envelope", 1);
229 		    "scheduler: deleting evp:%016" PRIx64 " (loop)", evpid);
232 		stat_increment("scheduler.delivery.loop", 1);
233 		stat_decrement("scheduler.envelope.inflight", 1);
234 		stat_decrement("scheduler.envelope", 1);
244 		    "scheduler: holding evp:%016" PRIx64 " on %016" PRIx64,
248 		stat_decrement("scheduler.envelope.inflight", 1);
259 		    "scheduler: releasing %d on holdq (%d, %016" PRIx64 ")",
266 		log_trace(TRACE_SCHEDULER, "scheduler: pausing mda");
271 		log_trace(TRACE_SCHEDULER, "scheduler: resuming mda");
277 		log_trace(TRACE_SCHEDULER, "scheduler: pausing mta");
282 		log_trace(TRACE_SCHEDULER, "scheduler: resuming mta");
326 			log_debug("debug: scheduler: "
329 			log_debug("debug: scheduler: "
346 			log_debug("debug: scheduler: "
349 			log_debug("debug: scheduler: "
360 			log_debug("debug: scheduler: "
363 			log_debug("debug: scheduler: "
374 			log_debug("debug: scheduler: "
377 			log_debug("debug: scheduler: "
393 	log_debug("debug: scheduler agent exiting");
409 scheduler(void)
415 		fatalx("cannot find scheduler backend \"%s\"",
428 		fatal("scheduler: chroot");
430 		fatal("scheduler: chdir(\"/\")");
435 		fatal("scheduler: cannot drop privileges");
493 	log_trace(TRACE_SCHEDULER, "scheduler: getting batch: mask=0x%x, count=%zu", mask, count);
497 	log_trace(TRACE_SCHEDULER, "scheduler: got r=%i, delay=%i, count=%zu", r, delay, count);
500 		fatalx("scheduler: error in batch handler");
505 			fatalx("scheduler: invalid delay %d", delay);
508 			log_trace(TRACE_SCHEDULER, "scheduler: sleeping");
515 		    "scheduler: waiting for %s", duration_to_text(tv.tv_sec));
529 			log_debug("debug: scheduler: evp:%016" PRIx64
540 			log_debug("debug: scheduler: evp:%016" PRIx64
551 			log_debug("debug: scheduler: evp:%016" PRIx64
557 			log_debug("debug: scheduler: evp:%016" PRIx64
566 			log_debug("debug: scheduler: evp:%016" PRIx64
575 			log_debug("debug: scheduler: evp:%016" PRIx64
585 	stat_decrement("scheduler.envelope", d_envelope);
586 	stat_increment("scheduler.envelope.inflight", d_inflight);
587 	stat_increment("scheduler.envelope.expired", d_expired);
588 	stat_increment("scheduler.envelope.removed", d_removed);
589 	stat_increment("scheduler.envelope.updated", d_updated);