Home
last modified time | relevance | path

Searched refs:queue_id (Results 1 – 25 of 116) sorted by relevance

12345

/netbsd-src/external/ibm-public/postfix/dist/src/oqmgr/
H A Dqmgr_active.c136 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()
[all …]
H A Dqmgr_move.c64 char *queue_id; in qmgr_move() local
74 while ((queue_id = mail_scan_dir_next(queue_dir)) != 0) { in qmgr_move()
75 if (mail_queue_id_ok(queue_id)) { in qmgr_move()
78 path = mail_queue_path((VSTRING *) 0, src_queue, queue_id); in qmgr_move()
86 if (mail_queue_rename(queue_id, src_queue, dst_queue)) { in qmgr_move()
89 myname, queue_id, src_queue, dst_queue); in qmgr_move()
91 myname, queue_id, src_queue, dst_queue); in qmgr_move()
96 myname, queue_id, src_queue, dst_queue); in qmgr_move()
99 myname, src_queue, queue_id); in qmgr_move()
H A Dqmgr_message.c159 const char *queue_id, int qflags) in qmgr_message_create() argument
177 message->queue_id = mystrdup(queue_id); in qmgr_message_create()
224 msg_panic("%s: queue file is open", message->queue_id); in qmgr_message_open()
231 message->queue_id, 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()
307 msg_fatal("%s: envelope records out of order", message->queue_id); in qmgr_message_oldstyle_scan()
345 message->queue_id); in qmgr_message_read()
400 message->queue_id); in qmgr_message_read()
423 message->queue_id, error_text, start); in qmgr_message_read()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/qmgr/
H A Dqmgr_active.c136 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()
[all …]
H A Dqmgr_move.c64 char *queue_id; in qmgr_move() local
74 while ((queue_id = mail_scan_dir_next(queue_dir)) != 0) { in qmgr_move()
75 if (mail_queue_id_ok(queue_id)) { in qmgr_move()
78 path = mail_queue_path((VSTRING *) 0, src_queue, queue_id); in qmgr_move()
86 if (mail_queue_rename(queue_id, src_queue, dst_queue)) { in qmgr_move()
89 myname, queue_id, src_queue, dst_queue); in qmgr_move()
91 myname, queue_id, src_queue, dst_queue); in qmgr_move()
96 myname, queue_id, src_queue, dst_queue); in qmgr_move()
99 myname, src_queue, queue_id); in qmgr_move()
H A Dqmgr_message.c168 const char *queue_id, int qflags) in qmgr_message_create() argument
188 message->queue_id = mystrdup(queue_id); in qmgr_message_create()
239 msg_panic("%s: queue file is open", message->queue_id); in qmgr_message_open()
246 message->queue_id, 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()
329 msg_fatal("%s: envelope records out of order", message->queue_id); in qmgr_message_oldstyle_scan()
377 message->queue_id); in qmgr_message_read()
391 msg_panic("%s: no recipient slots available", message->queue_id); in qmgr_message_read()
393 msg_info("%s: recipient limit %d", message->queue_id, recipient_limit); in qmgr_message_read()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/flush/
H A Dflush.c306 static int flush_add_service(const char *site, const char *queue_id) in flush_add_service() argument
313 msg_info("%s: site %s queue_id %s", myname, site, queue_id); in flush_add_service()
326 status = flush_add_path(STR(site_path), queue_id); in flush_add_service()
334 static int flush_add_path(const char *path, const char *queue_id) in flush_add_path() argument
366 vstream_fprintf(log, "%s\n", queue_id); in flush_add_path()
411 static int flush_one_file(const char *queue_id, VSTRING *queue_file, in flush_one_file() argument
424 path = mail_queue_path(queue_file, queue_name, queue_id); in flush_one_file()
454 path = mail_queue_path(queue_file, queue_name, queue_id)) { in flush_one_file()
478 && mail_queue_rename(queue_id, queue_name, MAIL_QUEUE_INCOMING) < 0 in flush_one_file()
494 VSTRING *queue_id; in flush_send_path() local
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/global/
H A Dmail_queue.c148 const char *queue_id) in mail_queue_dir() argument
163 if (mail_queue_id_ok(queue_id) == 0) in mail_queue_dir()
164 msg_panic("%s: bad queue id: %s", myname, queue_id); in mail_queue_dir()
190 if (MQID_FIND_LG_INUM_SEPARATOR(delim, queue_id)) { in mail_queue_dir()
194 queue_id = STR(usec_buf); in mail_queue_dir()
197 dir_forest(hash_buf, queue_id, var_hash_queue_depth)); in mail_queue_dir()
207 const char *queue_id) in mail_queue_path() argument
223 (void) mail_queue_dir(buf, queue_name, queue_id); in mail_queue_path()
224 vstring_strcat(buf, queue_id); in mail_queue_path()
249 int mail_queue_rename(const char *queue_id, const char *old_queue, in mail_queue_rename() argument
[all …]
H A Dflush_clnt.c211 int flush_send_file(const char *queue_id) in flush_send_file() argument
217 msg_info("%s: queue_id %s", myname, queue_id); in flush_send_file()
225 SEND_ATTR_STR(MAIL_ATTR_QUEUEID, queue_id), in flush_send_file()
229 msg_info("%s: queue_id %s status %d", myname, queue_id, status); in flush_send_file()
236 int flush_add(const char *site, const char *queue_id) in flush_add() argument
242 msg_info("%s: site %s id %s", myname, site, queue_id); in flush_add()
259 SEND_ATTR_STR(MAIL_ATTR_QUEUEID, queue_id), in flush_add()
267 msg_info("%s: site %s id %s status %d", myname, site, queue_id, in flush_add()
H A Dpost_mail.c204 VSTRING *queue_id; member
222 int utf8_flags, VSTRING *queue_id) in post_mail_init() argument
224 VSTRING *id = queue_id ? queue_id : vstring_alloc(100); in post_mail_init()
286 if (queue_id == 0) in post_mail_init()
294 int utf8_flags, VSTRING *queue_id) in post_mail_fopen() argument
300 utf8_flags, queue_id); in post_mail_fopen()
308 int utf8_flags, VSTRING *queue_id) in post_mail_fopen_nowait() argument
315 utf8_flags, queue_id); in post_mail_fopen_nowait()
345 state->queue_id); in post_mail_open_event()
396 int utf8_flags, VSTRING *queue_id, in post_mail_fopen_async() argument
[all …]
H A Ddeliver_request.c201 static VSTRING *queue_id; in deliver_request_get() local
228 queue_id = vstring_alloc(10); in deliver_request_get()
253 RECV_ATTR_STR(MAIL_ATTR_QUEUEID, queue_id), in deliver_request_get()
282 vstring_str(queue_id), &st, &path) == 0) in deliver_request_get()
290 request->queue_id = mystrdup(vstring_str(queue_id)); in deliver_request_get()
328 request->queue_id, request->nexthop); 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()
378 request->queue_id = 0; in deliver_request_alloc()
[all …]
/netbsd-src/external/ibm-public/postfix/dist/src/bounce/
H A Dbounce.c219 static VSTRING *queue_id; variable
254 RECV_ATTR_STR(MAIL_ATTR_QUEUEID, queue_id), in bounce_append_proto()
265 if (mail_queue_id_ok(STR(queue_id)) == 0) { in bounce_append_proto()
266 msg_warn("malformed queue id: %s", printable(STR(queue_id), '?')); in bounce_append_proto()
289 myname, flags, service_name, STR(queue_id), in bounce_append_proto()
300 bounce_cleanup_register(service_name, STR(queue_id)); in bounce_append_proto()
305 return (bounce_append_service(flags, service_name, STR(queue_id), in bounce_append_proto()
327 RECV_ATTR_STR(MAIL_ATTR_QUEUEID, queue_id), in bounce_notify_proto()
345 if (mail_queue_id_ok(STR(queue_id)) == 0) { in bounce_notify_proto()
346 msg_warn("malformed queue id: %s", printable(STR(queue_id), '?')); in bounce_notify_proto()
[all …]
H A Dbounce_trace_service.c85 char *queue_id, char *encoding, in bounce_trace_service() argument
110 "double-bounce message", queue_id); in bounce_trace_service()
118 "for single-bounce message", queue_id); in bounce_trace_service()
119 if (mail_queue_remove(service, queue_id) && errno != ENOENT) in bounce_trace_service()
120 msg_fatal("remove %s %s: %m", service, queue_id); in bounce_trace_service()
144 bounce_info = bounce_mail_init(service, queue_name, queue_id, in bounce_trace_service()
164 queue_id); in bounce_trace_service()
199 queue_id, STR(new_id)); in bounce_trace_service()
211 if (bounce_status == 0 && mail_queue_remove(service, queue_id) in bounce_trace_service()
213 msg_fatal("remove %s %s: %m", service, queue_id); in bounce_trace_service()
H A Dbounce_notify_service.c88 char *queue_id, char *encoding, in bounce_notify_service() argument
135 bounce_info = bounce_mail_init(service, queue_name, queue_id, in bounce_notify_service()
164 queue_id); in bounce_notify_service()
205 queue_id, STR(new_id)); in bounce_notify_service()
246 queue_id, STR(new_id)); in bounce_notify_service()
293 queue_id, STR(new_id)); in bounce_notify_service()
303 queue_id, recipient); in bounce_notify_service()
318 if (bounce_status == 0 && mail_queue_remove(service, queue_id) in bounce_notify_service()
320 msg_fatal("remove %s %s: %m", service, queue_id); in bounce_notify_service()
H A Dbounce_append_service.c67 int bounce_append_service(int unused_flags, char *service, char *queue_id, in bounce_append_service() argument
81 log = mail_queue_open(service, queue_id, in bounce_append_service()
84 msg_fatal("open file %s %s: %m", service, queue_id); in bounce_append_service()
91 msg_fatal("lock file %s %s: %m", service, queue_id); in bounce_append_service()
111 msg_fatal("seek file %s %s: %m", service, queue_id); in bounce_append_service()
154 msg_fatal("truncate file %s %s: %m", service, queue_id); in bounce_append_service()
156 msg_fatal("append file %s %s: %m", service, queue_id); in bounce_append_service()
166 msg_warn("append file %s %s: %m", service, queue_id); in bounce_append_service()
H A Dbounce_notify_verp.c91 char *queue_id, char *encoding, 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()
190 queue_id, STR(new_id)); in bounce_notify_verp()
242 queue_id, STR(new_id)); in bounce_notify_verp()
248 queue_id, recipient); in bounce_notify_verp()
257 if (bounce_status == 0 && mail_queue_remove(service, queue_id) in bounce_notify_verp()
259 msg_fatal("remove %s %s: %m", service, queue_id); in bounce_notify_verp()
H A Dbounce_notify_util.c224 const char *queue_id, in bounce_mail_alloc() argument
251 bounce_info->queue_id = queue_id; in bounce_mail_alloc()
264 bounce_info->queue_id, encoding); in bounce_mail_alloc()
296 queue_id, (unsigned long) event_time(), var_myhostname); in bounce_mail_alloc()
307 if ((bounce_info->orig_fp = mail_queue_open(queue_name, queue_id, in bounce_mail_alloc()
310 msg_fatal("open %s %s: %m", service, queue_id); in bounce_mail_alloc()
371 bounce_info->queue_id); in bounce_mail_alloc()
414 bounce_info->queue_id); in bounce_mail_alloc()
477 const char *queue_id, in bounce_mail_init() argument
496 if ((log_handle = bounce_log_open(service, queue_id, O_RDONLY, 0)) == 0) { in bounce_mail_init()
[all …]
H A Dbounce_warn_service.c88 char *queue_id, char *encoding, in bounce_warn_service() argument
125 bounce_info = bounce_mail_init(service, queue_name, queue_id, in bounce_warn_service()
153 queue_id); in bounce_warn_service()
194 queue_id, STR(new_id)); in bounce_warn_service()
233 queue_id, STR(new_id)); in bounce_warn_service()
277 queue_id, STR(new_id)); in bounce_warn_service()
286 queue_id, recipient); 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()
134 queue_id); in bounce_one_service()
171 queue_id, STR(new_id)); in bounce_one_service()
209 queue_id, STR(new_id)); in bounce_one_service()
247 queue_id, STR(new_id)); in bounce_one_service()
251 queue_id, orig_sender); in bounce_one_service()
/netbsd-src/external/ibm-public/postfix/dist/src/cleanup/
H A Dcleanup_envelope.c144 state->queue_id, extra_opts); in cleanup_envelope_process()
154 msg_warn("%s: ignoring bad delay time: %s", state->queue_id, buf); in cleanup_envelope_process()
186 state->queue_id, error_text, buf); in cleanup_envelope_process()
193 state->queue_id, attr_name); in cleanup_envelope_process()
207 state->queue_id, type); in cleanup_envelope_process()
240 state->queue_id); in cleanup_envelope_process()
246 state->queue_id); in cleanup_envelope_process()
271 state->queue_id); in cleanup_envelope_process()
306 state->queue_id, state->dsn_orcpt); in cleanup_envelope_process()
315 state->queue_id, state->dsn_notify); in cleanup_envelope_process()
[all …]
H A Dcleanup_extracted.c127 state->queue_id, extra_opts); in cleanup_extracted_process()
137 msg_warn("%s: ignoring bad delay time: %s", state->queue_id, buf); in cleanup_extracted_process()
147 state->queue_id, type); in cleanup_extracted_process()
163 state->queue_id, error_text, buf); in cleanup_extracted_process()
170 state->queue_id, attr_name); in cleanup_extracted_process()
209 state->queue_id); in cleanup_extracted_process()
244 state->queue_id, state->dsn_orcpt); in cleanup_extracted_process()
253 state->queue_id, state->dsn_notify); in cleanup_extracted_process()
258 state->queue_id, buf); in cleanup_extracted_process()
267 state->queue_id, buf); in cleanup_extracted_process()
/netbsd-src/external/ibm-public/postfix/dist/src/postsuper/
H A Dpostsuper.c592 static void delete_one(const char **queue_names, const char *queue_id) in delete_one() argument
605 if (!mail_queue_id_ok(queue_id)) { in delete_one()
606 msg_warn("invalid mail queue id: %s", queue_id); in delete_one()
621 if (mail_open_ok(*msg_qpp, queue_id, &st, &msg_path) != MAIL_OPEN_YES) in delete_one()
624 postremove(mail_queue_path(log_path_buf, *log_qpp, queue_id)); in delete_one()
627 msg_info("%s: removed", queue_id); in delete_one()
638 static void requeue_one(const char **queue_names, const char *queue_id) in requeue_one() argument
651 if (!mail_queue_id_ok(queue_id)) { in requeue_one()
652 msg_warn("invalid mail queue id: %s", queue_id); in requeue_one()
669 if (mail_open_ok(*msg_qpp, queue_id, &st, &old_path) != MAIL_OPEN_YES) in requeue_one()
[all …]
/netbsd-src/sys/external/bsd/drm2/dist/drm/amd/amdgpu/
H A Damdgpu_amdkfd_gfx_v10.c105 uint32_t queue_id) in acquire_queue() argument
112 lock_srbm(kgd, mec, pipe, queue_id, 0); in acquire_queue()
116 uint32_t pipe_id, uint32_t queue_id) in get_queue_mask() argument
119 queue_id; in get_queue_mask()
215 unsigned int queue_id) in get_sdma_rlc_reg_offset() argument
231 + queue_id * (mmSDMA0_RLC1_RB_CNTL - mmSDMA0_RLC0_RB_CNTL); in get_sdma_rlc_reg_offset()
234 queue_id, retval); in get_sdma_rlc_reg_offset()
262 uint32_t queue_id, uint32_t __user *wptr, in kgd_hqd_load() argument
273 pr_debug("Load hqd of pipe %d queue %d\n", pipe_id, queue_id); in kgd_hqd_load()
274 acquire_queue(kgd, pipe_id, queue_id); in kgd_hqd_load()
[all …]
H A Damdgpu_amdkfd_gfx_v9.c101 uint32_t queue_id) in acquire_queue() argument
108 lock_srbm(kgd, mec, pipe, queue_id, 0); in acquire_queue()
112 uint32_t pipe_id, uint32_t queue_id) in get_queue_mask() argument
115 queue_id; in get_queue_mask()
225 unsigned int queue_id) in get_sdma_rlc_reg_offset() argument
234 + queue_id * (mmSDMA0_RLC1_RB_CNTL - mmSDMA0_RLC0_RB_CNTL); in get_sdma_rlc_reg_offset()
237 queue_id, retval); in get_sdma_rlc_reg_offset()
253 uint32_t queue_id, uint32_t __user *wptr, in kgd_gfx_v9_hqd_load() argument
264 acquire_queue(kgd, pipe_id, queue_id); in kgd_gfx_v9_hqd_load()
316 (uint32_t)get_queue_mask(adev, pipe_id, queue_id)); in kgd_gfx_v9_hqd_load()
[all …]
H A Damdgpu_amdkfd_gfx_v9.h35 uint32_t queue_id, uint32_t __user *wptr,
39 uint32_t pipe_id, uint32_t queue_id,
42 uint32_t pipe_id, uint32_t queue_id,
45 uint32_t pipe_id, uint32_t queue_id);
49 uint32_t queue_id);

12345