Home
last modified time | relevance | path

Searched refs:queue_name (Results 1 – 25 of 40) sorted by relevance

12

/netbsd-src/external/ibm-public/postfix/dist/src/global/
H A Dmail_queue.c147 const char *mail_queue_dir(VSTRING *buf, const char *queue_name, in mail_queue_dir() argument
161 if (mail_queue_name_ok(queue_name) == 0) in mail_queue_dir()
162 msg_panic("%s: bad queue name: %s", myname, queue_name); in mail_queue_dir()
182 vstring_strcpy(buf, queue_name); in mail_queue_dir()
189 if (strcasecmp(*cpp, queue_name) == 0) { in mail_queue_dir()
206 const char *mail_queue_path(VSTRING *buf, const char *queue_name, in mail_queue_path() argument
223 (void) mail_queue_dir(buf, queue_name, queue_id); in mail_queue_path()
276 int mail_queue_remove(const char *queue_name, const char *queue_id) in mail_queue_remove() argument
278 return (REMOVE(mail_queue_path((VSTRING *) 0, queue_name, queue_id))); in mail_queue_remove()
283 int mail_queue_name_ok(const char *queue_name) in mail_queue_name_ok() argument
[all …]
H A Ddeliver_request.c200 static VSTRING *queue_name; in deliver_request_get() local
226 if (queue_name == 0) { in deliver_request_get()
227 queue_name = vstring_alloc(10); in deliver_request_get()
252 RECV_ATTR_STR(MAIL_ATTR_QUEUE, queue_name), in deliver_request_get()
281 if (mail_open_ok(vstring_str(queue_name), in deliver_request_get()
289 request->queue_name = mystrdup(vstring_str(queue_name)); in deliver_request_get()
353 mail_queue_open(request->queue_name, request->queue_id, O_RDWR, 0); in deliver_request_get()
356 msg_fatal("open %s %s: %m", request->queue_name, request->queue_id); in deliver_request_get()
357 msg_warn("open %s %s: %m", request->queue_name, request->queue_id); in deliver_request_get()
377 request->queue_name = 0; in deliver_request_alloc()
[all …]
H A Dmail_open_ok.c79 int mail_open_ok(const char *queue_name, const char *queue_id, in mail_open_ok() argument
82 if (mail_queue_name_ok(queue_name) == 0) { in mail_open_ok()
83 msg_warn("bad mail queue name: %s", queue_name); in mail_open_ok()
96 *path = mail_queue_path((VSTRING *) 0, queue_name, queue_id); in mail_open_ok()
H A Dbounce_log.c121 BOUNCE_LOG *bounce_log_open(const char *queue_name, const char *queue_id, in bounce_log_open() argument
135 if ((fp = mail_queue_open(queue_name, queue_id, flags, mode)) == 0) { in bounce_log_open()
141 if (STREQ(queue_name, MAIL_QUEUE_DEFER)) { in bounce_log_open()
/netbsd-src/external/ibm-public/postfix/dist/src/oqmgr/
H A Dqmgr_active.c152 static void qmgr_active_defer(const char *queue_name, const char *queue_id, in qmgr_active_defer() argument
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()
309 message->queue_name, in qmgr_active_done()
320 message->queue_name, in qmgr_active_done()
405 message->queue_name, in qmgr_active_done_2_generic()
467 message->queue_name, in qmgr_active_done_25_generic()
478 message->queue_name, in qmgr_active_done_25_generic()
[all …]
H A Dqmgr_message.c158 static QMGR_MESSAGE *qmgr_message_create(const char *queue_name, in qmgr_message_create() argument
178 message->queue_name = mystrdup(queue_name); in qmgr_message_create()
230 if ((message->fp = mail_queue_open(message->queue_name, in qmgr_message_open()
234 msg_fatal("open %s %s: %m", message->queue_name, message->queue_id); in qmgr_message_open()
235 msg_warn("open %s %s: %m", message->queue_name, message->queue_id); in qmgr_message_open()
622 "queue %s", message->queue_name); in qmgr_message_read()
1012 VSTRING *queue_name; in qmgr_message_resolve() local
1027 queue_name = vstring_alloc(1); in qmgr_message_resolve()
1237 vstring_strcpy(queue_name, STR(reply.nexthop)); in qmgr_message_resolve()
1245 vstring_strncpy(queue_name, STR(reply.recipient), len); in qmgr_message_resolve()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/qmgr/
H A Dqmgr_active.c152 static void qmgr_active_defer(const char *queue_name, const char *queue_id, in qmgr_active_defer() argument
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()
309 message->queue_name, in qmgr_active_done()
320 message->queue_name, in qmgr_active_done()
405 message->queue_name, in qmgr_active_done_2_generic()
467 message->queue_name, in qmgr_active_done_25_generic()
478 message->queue_name, in qmgr_active_done_25_generic()
[all …]
H A Dqmgr_message.c167 static QMGR_MESSAGE *qmgr_message_create(const char *queue_name, in qmgr_message_create() argument
189 message->queue_name = mystrdup(queue_name); in qmgr_message_create()
245 if ((message->fp = mail_queue_open(message->queue_name, in qmgr_message_open()
249 msg_fatal("open %s %s: %m", message->queue_name, message->queue_id); in qmgr_message_open()
250 msg_warn("open %s %s: %m", message->queue_name, message->queue_id); in qmgr_message_open()
663 "queue %s", message->queue_name); in qmgr_message_read()
1069 VSTRING *queue_name; in qmgr_message_resolve() local
1084 queue_name = vstring_alloc(1); in qmgr_message_resolve()
1296 vstring_strcpy(queue_name, STR(reply.nexthop)); in qmgr_message_resolve()
1304 vstring_strncpy(queue_name, STR(reply.recipient), len); in qmgr_message_resolve()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/bounce/
H A Dbounce.c220 static VSTRING *queue_name; variable
326 RECV_ATTR_STR(MAIL_ATTR_QUEUE, queue_name), in bounce_notify_proto()
341 if (mail_queue_name_ok(STR(queue_name)) == 0) { in bounce_notify_proto()
342 msg_warn("malformed queue name: %s", printable(STR(queue_name), '?')); in bounce_notify_proto()
354 myname, flags, service_name, STR(queue_name), STR(queue_id), in bounce_notify_proto()
368 return (service(flags, service_name, STR(queue_name), in bounce_notify_proto()
388 RECV_ATTR_STR(MAIL_ATTR_QUEUE, queue_name), in bounce_verp_proto()
404 if (mail_queue_name_ok(STR(queue_name)) == 0) { in bounce_verp_proto()
405 msg_warn("malformed queue name: %s", printable(STR(queue_name), '?')); in bounce_verp_proto()
422 myname, flags, service_name, STR(queue_name), in bounce_verp_proto()
[all …]
H A Dbounce_notify_util.c223 const char *queue_name, in bounce_mail_alloc() argument
250 bounce_info->queue_name = queue_name; in bounce_mail_alloc()
307 if ((bounce_info->orig_fp = mail_queue_open(queue_name, queue_id, in bounce_mail_alloc()
476 const char *queue_name, in bounce_mail_init() argument
505 bounce_info = bounce_mail_alloc(service, queue_name, queue_id, encoding, in bounce_mail_init()
513 BOUNCE_INFO *bounce_mail_one_init(const char *queue_name, in bounce_mail_one_init() argument
527 bounce_info = bounce_mail_alloc("none", queue_name, queue_id, encoding, in bounce_mail_one_init()
547 bounce_info->queue_id, bounce_info->queue_name, in bounce_mail_free()
H A Dbounce_notify_verp.c90 int bounce_notify_verp(int flags, char *service, char *queue_name, in bounce_notify_verp() argument
119 bounce_info = bounce_mail_init(service, queue_name, queue_id, in bounce_notify_verp()
135 bounce_status = bounce_one_service(flags, queue_name, queue_id, in bounce_notify_verp()
H A Dbounce_trace_service.c84 int bounce_trace_service(int flags, char *service, char *queue_name, in bounce_trace_service() argument
144 bounce_info = bounce_mail_init(service, queue_name, queue_id, in bounce_trace_service()
H A Dbounce_warn_service.c87 int bounce_warn_service(int unused_flags, char *service, char *queue_name, in bounce_warn_service() argument
125 bounce_info = bounce_mail_init(service, queue_name, queue_id, in bounce_warn_service()
H A Dbounce_one_service.c87 int bounce_one_service(int flags, char *queue_name, char *queue_id, in bounce_one_service() argument
104 bounce_info = bounce_mail_one_init(queue_name, queue_id, encoding, in bounce_one_service()
/netbsd-src/external/ibm-public/postfix/dist/src/postsuper/
H A Dpostsuper.c488 static struct queue_info *find_queue_info(const char *queue_name) in find_queue_info() argument
493 if (strcmp(queue_name, qp->name) == 0) in find_queue_info()
495 msg_fatal("invalid directory name: %s", queue_name); in find_queue_info()
909 const char *queue_name; in super() local
933 while ((queue_name = *queues++) != 0) { in super()
936 msg_info("queue: %s", queue_name); in super()
943 qp = find_queue_info(queue_name); in super()
949 if (strcmp(*cpp, queue_name) == 0) { in super()
959 msg_fatal("%s queue must not be hashed", queue_name); in super()
964 info = scan_dir_open(queue_name); in super()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/postqueue/
H A Dshowq_compat.c86 static VSTRING *queue_name = 0; in showq_message() local
103 if (queue_name == 0) { in showq_message()
104 queue_name = vstring_alloc(100); in showq_message()
116 RECV_ATTR_STR(MAIL_ATTR_QUEUE, queue_name), in showq_message()
131 if (strcmp(STR(queue_name), MAIL_QUEUE_ACTIVE) == 0) in showq_message()
133 else if (strcmp(STR(queue_name), MAIL_QUEUE_HOLD) == 0) in showq_message()
H A Dshowq_json.c130 static VSTRING *queue_name = 0; in format_json() local
144 if (queue_name == 0) { in format_json()
145 queue_name = vstring_alloc(100); in format_json()
157 RECV_ATTR_STR(MAIL_ATTR_QUEUE, queue_name), in format_json()
167 json_quote(quote_buf, STR(queue_name))); in format_json()
/netbsd-src/external/ibm-public/postfix/dist/src/cleanup/
H A Dcleanup_api.c163 state->queue_name = mystrdup(MAIL_QUEUE_INCOMING); in cleanup_open()
164 state->handle = mail_stream_file(state->queue_name, in cleanup_open()
307 myfree(state->queue_name); in cleanup_flush()
309 state->queue_name = mystrdup((state->flags & CLEANUP_FLAG_HOLD) ? in cleanup_flush()
312 state->queue_name = mystrdup(MAIL_QUEUE_HOLD); in cleanup_flush()
315 CA_MAIL_STREAM_CTL_QUEUE(state->queue_name), in cleanup_flush()
H A Dcleanup_state.c79 state->queue_name = 0; in cleanup_state_alloc()
168 if (state->queue_name) in cleanup_state_free()
169 myfree(state->queue_name); in cleanup_state_free()
/netbsd-src/external/ibm-public/postfix/dist/src/flush/
H A Dflush.c415 const char *queue_name; in flush_one_file() local
422 for (queue_name = MAIL_QUEUE_DEFERRED; /* see below */ ; in flush_one_file()
423 queue_name = MAIL_QUEUE_INCOMING) { in flush_one_file()
424 path = mail_queue_path(queue_file, queue_name, queue_id); in flush_one_file()
429 if (STREQ(queue_name, MAIL_QUEUE_INCOMING)) in flush_one_file()
453 queue_name = MAIL_QUEUE_INCOMING, in flush_one_file()
454 path = mail_queue_path(queue_file, queue_name, queue_id)) { in flush_one_file()
459 if (errno != ENOENT || STREQ(queue_name, MAIL_QUEUE_INCOMING)) { in flush_one_file()
477 if (STREQ(queue_name, MAIL_QUEUE_INCOMING) == 0 in flush_one_file()
478 && mail_queue_rename(queue_id, queue_name, MAIL_QUEUE_INCOMING) < 0 in flush_one_file()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/virtual/
H A Ddeliver_attr.c57 attrp->queue_name = 0; in deliver_attr_init()
75 msg_info("queue_name: %s", attrp->queue_name ? attrp->queue_name : "null"); in deliver_attr_dump()
/netbsd-src/external/ibm-public/postfix/dist/src/discard/
H A Ddiscard.c173 src = mail_queue_open(request->queue_name, request->queue_id, in deliver_message()
177 request->queue_name, request->queue_id); in deliver_message()
201 msg_warn("close %s %s: %m", request->queue_name, request->queue_id); in deliver_message()
/netbsd-src/external/ibm-public/postfix/dist/src/local/
H A Ddeliver_attr.c59 attrp->queue_name = 0; in deliver_attr_init()
84 msg_info("queue_name: %s", attrp->queue_name ? attrp->queue_name : "null"); in deliver_attr_dump()
/netbsd-src/external/ibm-public/postfix/dist/src/error/
H A Derror.c181 src = mail_queue_open(request->queue_name, request->queue_id, in deliver_message()
185 request->queue_name, request->queue_id); in deliver_message()
209 msg_warn("close %s %s: %m", request->queue_name, request->queue_id); in deliver_message()
/netbsd-src/external/ibm-public/postfix/dist/src/pickup/
H A Dpickup.c536 char *queue_name; in pickup_service() local
558 queue_name = MAIL_QUEUE_MAILDROP; /* XXX should be a list */ in pickup_service()
561 scan = scan_dir_open(queue_name); in pickup_service()
563 if (mail_open_ok(queue_name, id, &info.st, &path) == MAIL_OPEN_YES) { in pickup_service()

12