136 static void qmgr_active_corrupt(const char *queue_id)  in qmgr_active_corrupt()  argument
140     if (mail_queue_rename(queue_id, MAIL_QUEUE_ACTIVE, MAIL_QUEUE_CORRUPT)) {  in qmgr_active_corrupt()
143 		      myname, MAIL_QUEUE_ACTIVE, queue_id);  in qmgr_active_corrupt()
146 		 queue_id, MAIL_QUEUE_ACTIVE, MAIL_QUEUE_CORRUPT);  in qmgr_active_corrupt()
152 static void qmgr_active_defer(const char *queue_name, const char *queue_id,  in qmgr_active_defer()  argument
160 	msg_info("wakeup %s after %ld secs", queue_id, (long) delay);  in qmgr_active_defer()
163     path = mail_queue_path((VSTRING *) 0, queue_name, queue_id);  in qmgr_active_defer()
166     if (mail_queue_rename(queue_id, queue_name, dest_queue)) {  in qmgr_active_defer()
169 		      queue_id, queue_name, dest_queue);  in qmgr_active_defer()
171 		 queue_id, queue_name, dest_queue);  in qmgr_active_defer()
173 	msg_info("%s: defer %s", myname, queue_id);  in qmgr_active_defer()
179 int     qmgr_active_feed(QMGR_SCAN *scan_info, const char *queue_id)  in qmgr_active_feed()  argument
194     if (mail_open_ok(scan_info->queue, queue_id, &st, &path) == MAIL_OPEN_NO)  in qmgr_active_feed()
207 	    msg_info("%s: skip %s (%ld seconds)", myname, queue_id,  in qmgr_active_feed()
215     if (mail_queue_rename(queue_id, scan_info->queue, MAIL_QUEUE_ACTIVE)) {  in qmgr_active_feed()
218 		      queue_id, scan_info->queue, MAIL_QUEUE_ACTIVE);  in qmgr_active_feed()
220 		 queue_id, scan_info->queue, MAIL_QUEUE_ACTIVE);  in qmgr_active_feed()
247     if ((message = qmgr_message_alloc(MAIL_QUEUE_ACTIVE, queue_id,  in qmgr_active_feed()
252 	qmgr_active_corrupt(queue_id);  in qmgr_active_feed()
255 	qmgr_active_defer(MAIL_QUEUE_ACTIVE, queue_id, MAIL_QUEUE_INCOMING, 60);  in qmgr_active_feed()
277 	msg_info("%s: %s", myname, message->queue_id);  in qmgr_active_done()
299     if (stat(mail_queue_path((VSTRING *) 0, MAIL_QUEUE_BOUNCE, message->queue_id), &st) == 0) {  in qmgr_active_done()
301 	    if (mail_queue_remove(MAIL_QUEUE_BOUNCE, message->queue_id))  in qmgr_active_done()
303 			  MAIL_QUEUE_BOUNCE, message->queue_id);  in qmgr_active_done()
306 		msg_info("%s: bounce %s", myname, message->queue_id);  in qmgr_active_done()
310 			      message->queue_id,  in qmgr_active_done()
321 				   message->queue_id,  in qmgr_active_done()
365 	&& mail_open_ok(MAIL_QUEUE_ACTIVE, message->queue_id, &st, &path) == MAIL_OPEN_NO) {  in qmgr_active_done_2_generic()
366 	qmgr_active_corrupt(message->queue_id);  in qmgr_active_done_2_generic()
381 	    qmgr_active_corrupt(message->queue_id);  in qmgr_active_done_2_generic()
406 		     message->queue_id,  in qmgr_active_done_2_generic()
463 	      message->queue_id, info_log_addr_form_sender(message->sender),  in qmgr_active_done_25_generic()
468 			     message->queue_id,  in qmgr_active_done_25_generic()
479 				  message->queue_id,  in qmgr_active_done_25_generic()
492 		msg_info("%s: sending defer warning for %s", myname, message->queue_id);  in qmgr_active_done_25_generic()
495 			message->queue_id,  in qmgr_active_done_25_generic()
568 	qmgr_active_defer(message->queue_name, message->queue_id,  in qmgr_active_done_3_generic()
576 	if (mail_queue_remove(message->queue_name, message->queue_id)) {  in qmgr_active_done_3_generic()
579 			  message->queue_id, message->queue_name);  in qmgr_active_done_3_generic()
581 		     message->queue_id, message->queue_name);  in qmgr_active_done_3_generic()
584 	    msg_info("%s: removed", message->queue_id);  in qmgr_active_done_3_generic()