Lines Matching defs:queue_id
9 /* void qmgr_active_feed(scan_info, queue_id)
11 /* const char *queue_id;
128 static void qmgr_active_corrupt(const char *queue_id)
132 if (mail_queue_rename(queue_id, MAIL_QUEUE_ACTIVE, MAIL_QUEUE_CORRUPT)) {
135 myname, MAIL_QUEUE_ACTIVE, queue_id);
138 queue_id, MAIL_QUEUE_ACTIVE, MAIL_QUEUE_CORRUPT);
144 static void qmgr_active_defer(const char *queue_name, const char *queue_id,
152 msg_info("wakeup %s after %ld secs", queue_id, (long) delay);
155 path = mail_queue_path((VSTRING *) 0, queue_name, queue_id);
158 if (mail_queue_rename(queue_id, queue_name, dest_queue)) {
161 queue_id, queue_name, dest_queue);
163 queue_id, queue_name, dest_queue);
165 msg_info("%s: defer %s", myname, queue_id);
171 int qmgr_active_feed(QMGR_SCAN *scan_info, const char *queue_id)
186 if (mail_open_ok(scan_info->queue, queue_id, &st, &path) == MAIL_OPEN_NO)
199 msg_info("%s: skip %s (%ld seconds)", myname, queue_id,
207 if (mail_queue_rename(queue_id, scan_info->queue, MAIL_QUEUE_ACTIVE)) {
210 queue_id, scan_info->queue, MAIL_QUEUE_ACTIVE);
212 queue_id, scan_info->queue, MAIL_QUEUE_ACTIVE);
232 if ((message = qmgr_message_alloc(MAIL_QUEUE_ACTIVE, queue_id,
239 qmgr_active_corrupt(queue_id);
242 qmgr_active_defer(MAIL_QUEUE_ACTIVE, queue_id, MAIL_QUEUE_INCOMING, 60);
264 msg_info("%s: %s", myname, message->queue_id);
286 if (stat(mail_queue_path((VSTRING *) 0, MAIL_QUEUE_BOUNCE, message->queue_id), &st) == 0) {
288 if (mail_queue_remove(MAIL_QUEUE_BOUNCE, message->queue_id))
290 MAIL_QUEUE_BOUNCE, message->queue_id);
293 msg_info("%s: bounce %s", myname, message->queue_id);
297 message->queue_id,
307 message->queue_id,
350 && mail_open_ok(MAIL_QUEUE_ACTIVE, message->queue_id, &st, &path) == MAIL_OPEN_NO) {
351 qmgr_active_corrupt(message->queue_id);
366 qmgr_active_corrupt(message->queue_id);
390 message->queue_id,
438 message->queue_id, message->sender);
442 message->queue_id,
452 message->queue_id,
464 msg_info("%s: sending defer warning for %s", myname, message->queue_id);
467 message->queue_id,
539 qmgr_active_defer(message->queue_name, message->queue_id,
547 if (mail_queue_remove(message->queue_name, message->queue_id)) {
550 message->queue_id, message->queue_name);
552 message->queue_id, message->queue_name);
555 msg_info("%s: removed", message->queue_id);