Searched refs:queue_id (Results 1 - 25 of 81) sorted by relevance

1234

/macosx-10.10/postfix-255/postfix/src/oqmgr/
H A Dqmgr_move.c62 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 Dqmgr_active.c9 /* 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 Dqmgr_bounce.c63 status = bounce_append(message->tflags, message->queue_id,
/macosx-10.10/postfix-255/postfix/src/qmgr/
H A Dqmgr_move.c62 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 Dqmgr_active.c9 /* 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 Dqmgr_bounce.c63 status = bounce_append(message->tflags, message->queue_id,
/macosx-10.10/postfix-255/postfix/src/bounce/
H A Dbounce_trace_service.c9 /* 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 Dbounce_append_service.c9 /* 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 Dbounce_one_service.c9 /* 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 Dbounce.c189 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 Dbounce_notify_service.c9 /* 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 Dbounce_cleanup.c11 /* 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 Dbounce_notify_verp.c9 /* 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 Dopened.c9 /* 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 Dmail_queue.c14 /* 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 Dmail_open_ok.c9 /* 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 Dverify.c9 /* 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 Dflush_clnt.c11 /* 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 Dpost_mail.c10 /* 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 Dflush.c282 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 Dcleanup_envelope.c133 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 Dcleanup_final.c56 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 Ddiscard.c160 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 Dqmqpd_state.c69 state->queue_id = 0;
89 if (state->queue_id)
90 myfree(state->queue_id);
/macosx-10.10/postfix-255/postfix/src/virtual/
H A Ddeliver_attr.c56 attrp->queue_id = 0;
74 msg_info("queue_id: %s", attrp->queue_id ? attrp->queue_id : "null");

Completed in 204 milliseconds

1234