/macosx-10.10/postfix-255/postfix/src/oqmgr/ |
H A D | qmgr_move.c | 62 char *queue_id; local 72 while ((queue_id = mail_scan_dir_next(queue_dir)) != 0) { 73 if (mail_queue_id_ok(queue_id)) { 76 path = mail_queue_path((VSTRING *) 0, src_queue, queue_id); 84 if (mail_queue_rename(queue_id, src_queue, dst_queue)) { 87 myname, queue_id, src_queue, dst_queue); 89 myname, queue_id, src_queue, dst_queue); 94 myname, queue_id, src_queue, dst_queue); 97 myname, src_queue, queue_id);
|
H A D | qmgr_active.c | 9 /* void qmgr_active_feed(scan_info, queue_id) 11 /* const char *queue_id; 128 static void qmgr_active_corrupt(const char *queue_id) argument 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, argument 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_nam 171 qmgr_active_feed(QMGR_SCAN *scan_info, const char *queue_id) argument [all...] |
H A D | qmgr_bounce.c | 63 status = bounce_append(message->tflags, message->queue_id,
|
/macosx-10.10/postfix-255/postfix/src/qmgr/ |
H A D | qmgr_move.c | 62 char *queue_id; local 72 while ((queue_id = mail_scan_dir_next(queue_dir)) != 0) { 73 if (mail_queue_id_ok(queue_id)) { 76 path = mail_queue_path((VSTRING *) 0, src_queue, queue_id); 84 if (mail_queue_rename(queue_id, src_queue, dst_queue)) { 87 myname, queue_id, src_queue, dst_queue); 89 myname, queue_id, src_queue, dst_queue); 94 myname, queue_id, src_queue, dst_queue); 97 myname, src_queue, queue_id);
|
H A D | qmgr_active.c | 9 /* void qmgr_active_feed(scan_info, queue_id) 11 /* const char *queue_id; 128 static void qmgr_active_corrupt(const char *queue_id) argument 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, argument 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_nam 171 qmgr_active_feed(QMGR_SCAN *scan_info, const char *queue_id) argument [all...] |
H A D | qmgr_bounce.c | 63 status = bounce_append(message->tflags, message->queue_id,
|
/macosx-10.10/postfix-255/postfix/src/bounce/ |
H A D | bounce_trace_service.c | 9 /* int bounce_trace_service(flags, queue_name, queue_id, encoding, 13 /* char *queue_id; 78 char *queue_id, char *encoding, 102 "double-bounce message", queue_id); 110 "for single-bounce message", queue_id); 111 if (mail_queue_remove(service, queue_id) && errno != ENOENT) 112 msg_fatal("remove %s %s: %m", service, queue_id); 136 bounce_info = bounce_mail_init(service, queue_name, queue_id, 156 queue_id); 190 queue_id, ST 77 bounce_trace_service(int flags, char *service, char *queue_name, char *queue_id, char *encoding, char *recipient, char *dsn_envid, int unused_dsn_ret, BOUNCE_TEMPLATES *ts) argument [all...] |
H A D | bounce_append_service.c | 9 /* int bounce_append_service(flags, service, queue_id, rcpt, dsn), 12 /* char *queue_id; 69 int bounce_append_service(int unused_flags, char *service, char *queue_id, argument 83 log = mail_queue_open(service, queue_id, 86 msg_fatal("open file %s %s: %m", service, queue_id); 93 msg_fatal("lock file %s %s: %m", service, queue_id); 113 msg_fatal("seek file %s %s: %m", service, queue_id); 156 msg_fatal("truncate file %s %s: %m", service, queue_id); 158 msg_fatal("append file %s %s: %m", service, queue_id); 168 msg_warn("append file %s %s: %m", service, queue_id); [all...] |
H A D | bounce_one_service.c | 9 /* int bounce_one_service(flags, queue_name, queue_id, encoding, 14 /* char *queue_id; 86 int bounce_one_service(int flags, char *queue_name, char *queue_id, argument 103 bounce_info = bounce_mail_one_init(queue_name, queue_id, encoding, 133 queue_id); 169 queue_id, STR(new_id)); 206 queue_id, STR(new_id)); 243 queue_id, STR(new_id)); 247 queue_id, orig_sender);
|
H A D | bounce.c | 189 static VSTRING *queue_id; variable 219 ATTR_TYPE_STR, MAIL_ATTR_QUEUEID, queue_id, 230 if (mail_queue_id_ok(STR(queue_id)) == 0) { 231 msg_warn("malformed queue id: %s", printable(STR(queue_id), '?')); 254 myname, flags, service_name, STR(queue_id), 265 bounce_cleanup_register(service_name, STR(queue_id)); 270 return (bounce_append_service(flags, service_name, STR(queue_id), 291 ATTR_TYPE_STR, MAIL_ATTR_QUEUEID, queue_id, 308 if (mail_queue_id_ok(STR(queue_id)) == 0) { 309 msg_warn("malformed queue id: %s", printable(STR(queue_id), ' [all...] |
H A D | bounce_notify_service.c | 9 /* int bounce_notify_service(flags, queue_name, queue_id, encoding, 13 /* char *queue_id; 85 char *queue_id, char *encoding, 131 bounce_info = bounce_mail_init(service, queue_name, queue_id, 159 queue_id); 199 queue_id, STR(new_id)); 239 queue_id, STR(new_id)); 285 queue_id, STR(new_id)); 295 queue_id, recipient); 310 if (bounce_status == 0 && mail_queue_remove(service, queue_id) 84 bounce_notify_service(int flags, char *service, char *queue_name, char *queue_id, char *encoding, char *recipient, char *dsn_envid, int dsn_ret, BOUNCE_TEMPLATES *ts) argument [all...] |
H A D | bounce_cleanup.c | 11 /* void bounce_cleanup_register(queue_id) 12 /* char *queue_id; 137 void bounce_cleanup_register(char *service, char *queue_id) argument 152 (void) mail_queue_path(bounce_cleanup_path, service, queue_id);
|
H A D | bounce_notify_verp.c | 9 /* int bounce_notify_verp(flags, service, queue_name, queue_id, sender, 14 /* char *queue_id; 87 char *queue_id, char *encoding, 115 bounce_info = bounce_mail_init(service, queue_name, queue_id, 130 bounce_status = bounce_one_service(flags, queue_name, queue_id, 183 queue_id, STR(new_id)); 234 queue_id, STR(new_id)); 240 queue_id, recipient); 249 if (bounce_status == 0 && mail_queue_remove(service, queue_id) 251 msg_fatal("remove %s %s: %m", service, queue_id); 86 bounce_notify_verp(int flags, char *service, char *queue_name, char *queue_id, char *encoding, char *recipient, char *dsn_envid, int dsn_ret, char *verp_delims, BOUNCE_TEMPLATES *ts) argument [all...] |
/macosx-10.10/postfix-255/postfix/src/global/ |
H A D | opened.c | 9 /* void opened(queue_id, sender, size, nrcpt, format, ...) 10 /* const char *queue_id; 21 /* .IP queue_id 64 void opened(const char *queue_id, const char *sender, long size, int nrcpt, argument 70 vopened(queue_id, sender, size, nrcpt, fmt, ap); 76 void vopened(const char *queue_id, const char *sender, long size, int nrcpt, argument 85 queue_id, sender, size, nrcpt,
|
H A D | mail_queue.c | 14 /* VSTREAM *mail_queue_open(queue_name, queue_id, flags, mode) 16 /* const char *queue_id; 20 /* char *mail_queue_dir(buf, queue_name, queue_id) 23 /* const char *queue_id; 25 /* char *mail_queue_path(buf, queue_name, queue_id) 28 /* const char *queue_id; 33 /* int mail_queue_rename(queue_id, old_queue, new_queue) 34 /* const char *queue_id; 38 /* int mail_queue_remove(queue_name, queue_id) 40 /* const char *queue_id; 145 mail_queue_dir(VSTRING *buf, const char *queue_name, const char *queue_id) argument 204 mail_queue_path(VSTRING *buf, const char *queue_name, const char *queue_id) argument 247 mail_queue_rename(const char *queue_id, const char *old_queue, const char *new_queue) argument 274 mail_queue_remove(const char *queue_name, const char *queue_id) argument 296 mail_queue_id_ok(const char *queue_id) argument 424 mail_queue_open(const char *queue_name, const char *queue_id, int flags, mode_t mode) argument [all...] |
H A D | mail_open_ok.c | 9 /* int mail_open_ok(queue_name, queue_id, statp, pathp) 11 /* const char *queue_id; 77 int mail_open_ok(const char *queue_name, const char *queue_id, argument 84 if (mail_queue_id_ok(queue_id) == 0) 94 *path = mail_queue_path((VSTRING *) 0, queue_name, queue_id);
|
H A D | verify.c | 9 /* int verify_append(queue_id, stats, recipient, relay, dsn, 11 /* const char *queue_id; 26 /* .IP queue_id 90 int verify_append(const char *queue_id, MSG_STATS *stats, argument 117 log_adhoc(queue_id, stats, recipient, relay, dsn, my_dsn.action); 120 msg_warn("%s: %s service failure", queue_id, var_verify_service);
|
H A D | flush_clnt.c | 11 /* int flush_add(site, queue_id) 13 /* const char *queue_id; 18 /* int flush_send_file(queue_id) 19 /* const char *queue_id; 197 int flush_send_file(const char *queue_id) argument 203 msg_info("%s: queue_id %s", myname, queue_id); 210 ATTR_TYPE_STR, MAIL_ATTR_QUEUEID, queue_id, 214 msg_info("%s: queue_id %s status %d", myname, queue_id, statu 221 flush_add(const char *site, const char *queue_id) argument [all...] |
H A D | post_mail.c | 10 /* queue_id) 15 /* VSTRING *queue_id; 18 /* filter_class, trace_flags, queue_id) 23 /* VSTRING *queue_id; 27 /* queue_id, notify, context) 32 /* VSTRING *queue_id; 105 /* .IP queue_id 179 VSTRING *queue_id; member in struct:__anon11771 187 VSTRING *queue_id) 189 VSTRING *id = queue_id 184 post_mail_init(VSTREAM *stream, const char *sender, const char *recipient, int filter_class, int trace_flags, VSTRING *queue_id) argument 237 post_mail_fopen(const char *sender, const char *recipient, int filter_class, int trace_flags, VSTRING *queue_id) argument 251 post_mail_fopen_nowait(const char *sender, const char *recipient, int filter_class, int trace_flags, VSTRING *queue_id) argument 335 post_mail_fopen_async(const char *sender, const char *recipient, int filter_class, int trace_flags, VSTRING *queue_id, void (*notify) (VSTREAM *, void *), void *context) argument [all...] |
/macosx-10.10/postfix-255/postfix/src/flush/ |
H A D | flush.c | 282 static int flush_add_service(const char *site, const char *queue_id) argument 289 msg_info("%s: site %s queue_id %s", myname, site, queue_id); 301 status = flush_add_path(STR(site_path), queue_id); 309 static int flush_add_path(const char *path, const char *queue_id) argument 341 vstream_fprintf(log, "%s\n", queue_id); 385 static int flush_one_file(const char *queue_id, VSTRING *queue_file, argument 398 path = mail_queue_path(queue_file, queue_name, queue_id); 428 path = mail_queue_path(queue_file, queue_name, queue_id)) { 452 && mail_queue_rename(queue_id, queue_nam 468 VSTRING *queue_id; local 597 flush_send_file_service(const char *queue_id) argument 724 VSTRING *queue_id = 0; local [all...] |
/macosx-10.10/postfix-255/postfix/src/cleanup/ |
H A D | cleanup_envelope.c | 133 state->queue_id, extra_opts); 143 msg_warn("%s: ignoring bad delay time: %s", state->queue_id, buf); 175 state->queue_id, error_text, buf); 182 state->queue_id, attr_name); 196 state->queue_id, type); 229 state->queue_id); 235 state->queue_id); 260 state->queue_id); 295 state->queue_id, state->dsn_orcpt); 304 state->queue_id, stat [all...] |
H A D | cleanup_final.c | 56 msg_warn("%s: queue file size limit exceeded", state->queue_id); 59 msg_warn("%s: write queue file: %m", state->queue_id);
|
/macosx-10.10/postfix-255/postfix/src/discard/ |
H A D | discard.c | 160 src = mail_queue_open(request->queue_name, request->queue_id, 164 request->queue_name, request->queue_id); 177 status = sent(BOUNCE_FLAGS(request), request->queue_id, 188 msg_warn("close %s %s: %m", request->queue_name, request->queue_id);
|
/macosx-10.10/postfix-255/postfix/src/qmqpd/ |
H A D | qmqpd_state.c | 69 state->queue_id = 0; 89 if (state->queue_id) 90 myfree(state->queue_id);
|
/macosx-10.10/postfix-255/postfix/src/virtual/ |
H A D | deliver_attr.c | 56 attrp->queue_id = 0; 74 msg_info("queue_id: %s", attrp->queue_id ? attrp->queue_id : "null");
|