| /openbsd-src/usr.sbin/smtpd/ |
| H A D | queue.c | 50 uint64_t reqid, evpid, holdq; in queue_imsg() local
173 m_get_evpid(&m, &evpid); in queue_imsg()
177 m_add_evpid(p_scheduler, evpid); in queue_imsg()
181 if (queue_envelope_load(evpid, &evp) == 0) in queue_imsg()
185 queue_envelope_delete(evpid); in queue_imsg()
190 m_get_evpid(&m, &evpid); in queue_imsg()
194 m_add_evpid(p_scheduler, evpid); in queue_imsg()
198 if (queue_envelope_load(evpid, &evp) == 0) in queue_imsg()
207 queue_envelope_delete(evpid); in queue_imsg()
213 evpid = req_bounce->evpid; in queue_imsg()
[all …]
|
| H A D | queue_proc.c | 178 uint64_t *evpid) in queue_proc_envelope_create() argument
183 msgid = evpid_to_msgid(*evpid); in queue_proc_envelope_create()
194 queue_proc_read(evpid, sizeof(*evpid)); in queue_proc_envelope_create()
201 queue_proc_envelope_delete(uint64_t evpid) in queue_proc_envelope_delete() argument
205 imsg_compose(&ibuf, PROC_QUEUE_ENVELOPE_DELETE, 0, 0, -1, &evpid, in queue_proc_envelope_delete()
206 sizeof(evpid)); in queue_proc_envelope_delete()
216 queue_proc_envelope_update(uint64_t evpid, const char *buf, size_t len) in queue_proc_envelope_update() argument
222 len + sizeof(evpid)); in queue_proc_envelope_update()
223 if (imsg_add(b, &evpid, sizeo in queue_proc_envelope_update()
236 queue_proc_envelope_load(uint64_t evpid,char * buf,size_t len) queue_proc_envelope_load() argument
258 queue_proc_envelope_walk(uint64_t * evpid,char * buf,size_t len) queue_proc_envelope_walk() argument
[all...] |
| H A D | queue_backend.c | 41 static void queue_envelope_cache_del(uint64_t evpid);
178 uint64_t evpid; in queue_message_delete() local
191 evpid = msgid_to_evpid(msgid); in queue_message_delete()
194 if (!tree_iterfrom(&evpcache_tree, &iter, evpid, &evpid, NULL)) in queue_message_delete()
196 if (evpid_to_msgid(evpid) != msgid) in queue_message_delete()
198 queue_envelope_cache_del(evpid); in queue_message_delete()
471 queue_envelope_cache_del(uint64_t evpid) in queue_envelope_cache_del() argument
475 if ((cached = tree_pop(&evpcache_tree, evpid)) == NULL) in queue_envelope_cache_del()
489 uint64_t evpid; in queue_envelope_create() local
497 evpid = ep->id; in queue_envelope_create()
[all …]
|
| H A D | scheduler_proc.c | 190 scheduler_proc_delete(uint64_t evpid) in scheduler_proc_delete()
197 &evpid, sizeof(evpid)); in scheduler_proc_delete()
207 scheduler_proc_hold(uint64_t evpid, uint64_t holdq) in scheduler_proc_hold()
215 sizeof(evpid) + sizeof(holdq)); in scheduler_proc_hold()
218 if (imsg_add(buf, &evpid, sizeof(evpid)) == -1) in scheduler_proc_hold()
346 scheduler_proc_schedule(uint64_t evpid) in scheduler_proc_schedule()
353 &evpid, sizeof(evpid)); in scheduler_proc_schedule()
188 scheduler_proc_delete(uint64_t evpid) scheduler_proc_delete() argument
205 scheduler_proc_hold(uint64_t evpid,uint64_t holdq) scheduler_proc_hold() argument
344 scheduler_proc_schedule(uint64_t evpid) scheduler_proc_schedule() argument
362 scheduler_proc_remove(uint64_t evpid) scheduler_proc_remove() argument
380 scheduler_proc_suspend(uint64_t evpid) scheduler_proc_suspend() argument
398 scheduler_proc_resume(uint64_t evpid) scheduler_proc_resume() argument
[all...] |
| H A D | scheduler_ramqueue.c | 39 uint64_t evpid; member
194 msgid = evpid_to_msgid(si->evpid); in scheduler_ram_insert()
215 envelope->evpid = si->evpid; in scheduler_ram_insert()
222 tree_xset(&message->envelopes, envelope->evpid, envelope); in scheduler_ram_insert()
295 msgid = evpid_to_msgid(si->evpid); in scheduler_ram_update()
297 evp = tree_xget(&msg->envelopes, si->evpid); in scheduler_ram_update()
301 fatalx("evp:%016" PRIx64 " not in-flight", si->evpid); in scheduler_ram_update()
329 scheduler_ram_delete(uint64_t evpid) in scheduler_ram_delete() argument
337 msgid = evpid_to_msgid(evpid); in scheduler_ram_delete()
355 scheduler_ram_hold(uint64_t evpid,uint64_t holdq) scheduler_ram_hold() argument
655 scheduler_ram_schedule(uint64_t evpid) scheduler_ram_schedule() argument
693 scheduler_ram_remove(uint64_t evpid) scheduler_ram_remove() argument
727 scheduler_ram_suspend(uint64_t evpid) scheduler_ram_suspend() argument
761 scheduler_ram_resume(uint64_t evpid) scheduler_ram_resume() argument
795 scheduler_ram_query(uint64_t evpid) scheduler_ram_query() argument
[all...] |
| H A D | queue_ram.c | 127 uint64_t evpid; in queue_ram_message_delete() local
133 while (tree_poproot(&messages, &evpid, (void**)&evp)) { in queue_ram_message_delete()
190 uint64_t *evpid) in queue_ram_envelope_create() argument
199 *evpid = queue_generate_evpid(msgid); in queue_ram_envelope_create()
200 } while (tree_check(&msg->envelopes, *evpid)); in queue_ram_envelope_create()
214 tree_xset(&msg->envelopes, *evpid, evp); in queue_ram_envelope_create()
220 queue_ram_envelope_delete(uint64_t evpid) in queue_ram_envelope_delete() argument
225 if ((msg = get_message(evpid_to_msgid(evpid))) == NULL) in queue_ram_envelope_delete()
228 if ((evp = tree_pop(&msg->envelopes, evpid)) == NULL) { in queue_ram_envelope_delete()
236 tree_xpop(&messages, evpid_to_msgid(evpid)); in queue_ram_envelope_delete()
[all …]
|
| H A D | queue_fs.c | 200 uint64_t *evpid) in queue_fs_envelope_create() argument
207 log_warnx("warn: queue-fs: msgid=0, evpid=%016"PRIx64, *evpid); in queue_fs_envelope_create()
216 *evpid = queue_generate_evpid(msgid); in queue_fs_envelope_create()
218 fsqueue_envelope_path(*evpid, path, sizeof(path)); in queue_fs_envelope_create()
220 fsqueue_envelope_incoming_path(*evpid, path, in queue_fs_envelope_create()
241 queue_fs_envelope_load(uint64_t evpid, char *buf, size_t len) in queue_fs_envelope_load() argument
247 fsqueue_envelope_path(evpid, pathname, sizeof(pathname)); in queue_fs_envelope_load()
271 queue_fs_envelope_update(uint64_t evpid, const char *buf, size_t len) in queue_fs_envelope_update() argument
275 fsqueue_envelope_path(evpid, dest, sizeof(dest)); in queue_fs_envelope_update()
281 queue_fs_envelope_delete(uint64_t evpid) in queue_fs_envelope_delete() argument
[all …]
|
| H A D | queue_null.c | 48 uint64_t *evpid) in queue_null_envelope_create() argument
50 *evpid = queue_generate_evpid(msgid); in queue_null_envelope_create()
55 queue_null_envelope_delete(uint64_t evpid) in queue_null_envelope_delete() argument
61 queue_null_envelope_update(uint64_t evpid, const char *buf, size_t len) in queue_null_envelope_update() argument
67 queue_null_envelope_load(uint64_t evpid, char *buf, size_t len) in queue_null_envelope_load() argument
73 queue_null_envelope_walk(uint64_t *evpid, char *buf, size_t len) in queue_null_envelope_walk() argument
|
| H A D | scheduler.c | 52 uint64_t evpid, id, holdq; in scheduler_imsg() local
135 m_get_evpid(&m, &evpid); in scheduler_imsg()
140 evpid); in scheduler_imsg()
143 backend->remove(evpid); in scheduler_imsg()
145 backend->delete(evpid); in scheduler_imsg()
155 m_get_evpid(&m, &evpid); in scheduler_imsg()
159 evpid); in scheduler_imsg()
167 m_get_evpid(&m, &evpid); in scheduler_imsg()
170 "scheduler: deleting evp:%016" PRIx64 " (ok)", evpid); in scheduler_imsg()
171 backend->delete(evpid); in scheduler_imsg()
[all …]
|
| H A D | scheduler_null.c | 90 scheduler_null_delete(uint64_t evpid) in scheduler_null_delete() argument
96 scheduler_null_hold(uint64_t evpid, uint64_t holdq) in scheduler_null_hold() argument
116 scheduler_null_schedule(uint64_t evpid) in scheduler_null_schedule() argument
122 scheduler_null_remove(uint64_t evpid) in scheduler_null_remove() argument
128 scheduler_null_suspend(uint64_t evpid) in scheduler_null_suspend() argument
134 scheduler_null_resume(uint64_t evpid) in scheduler_null_resume() argument
|
| H A D | smtpctl.c | 230 srv_get_evpid(uint64_t *evpid) in srv_get_evpid()
232 srv_read(evpid, sizeof(*evpid));
267 uint64_t evpid; in srv_get_envelope()
270 srv_get_evpid(&evpid); in srv_get_envelope()
274 evp->id = evpid;
402 srv_iter_evpids(uint32_t msgid, uint64_t *evpid, int *offset) in srv_iter_evpids()
426 *evpid = evpids[*offset]; in srv_iter_evpids()
435 uint64_t evpid; in srv_foreach_envelope()
444 while (srv_iter_evpids(msgid, &evpid, in srv_foreach_envelope()
228 srv_get_evpid(uint64_t * evpid) srv_get_evpid() argument
265 uint64_t evpid; srv_get_envelope() local
400 srv_iter_evpids(uint32_t msgid,uint64_t * evpid,int * offset) srv_iter_evpids() argument
433 uint64_t evpid; srv_foreach_envelope() local
749 uint64_t evpid; do_show_queue() local
989 uint64_t evpid; do_discover() local
1234 show_offline_envelope(uint64_t evpid) show_offline_envelope() argument
[all...] |
| H A D | smtpd-api.h | 87 uint64_t evpid; member
100 uint64_t evpid; member
227 evpid_to_msgid(uint64_t evpid) in evpid_to_msgid() argument
229 return (evpid >> 32); in evpid_to_msgid()
|
| H A D | mda.c | 678 mda_queue_ok(uint64_t evpid) in mda_queue_ok() argument
681 m_add_evpid(p_queue, evpid); in mda_queue_ok()
686 mda_queue_tempfail(uint64_t evpid, const char *reason, in mda_queue_tempfail() argument
690 m_add_evpid(p_queue, evpid); in mda_queue_tempfail()
697 mda_queue_permfail(uint64_t evpid, const char *reason, in mda_queue_permfail() argument
701 m_add_evpid(p_queue, evpid); in mda_queue_permfail()
708 mda_queue_loop(uint64_t evpid) in mda_queue_loop() argument
711 m_add_evpid(p_queue, evpid); in mda_queue_loop()
|
| H A D | mproc.c | 561 m_get_evpid(struct msg *m, uint64_t *evpid) in m_get_string()
563 m_get(m, evpid, sizeof(*evpid)); in m_get_string()
596 uint64_t evpid;
599 m_get_evpid(m, &evpid); in m_get_id()
606 evp->id = evpid; in m_get_sockaddr()
586 m_get_evpid(struct msg * m,uint64_t * evpid) m_get_evpid() argument
621 uint64_t evpid; m_get_envelope() local
|
| H A D | bounce.c | 117 bounce_add(uint64_t evpid) in bounce_add() argument
126 if (queue_envelope_load(evpid, &evp) == 0) { in bounce_add()
128 m_add_evpid(p_scheduler, evpid); in bounce_add()
137 key.msgid = evpid_to_msgid(evpid); in bounce_add()
181 be->id = evpid; in bounce_add()
|
| H A D | control.c | 421 uint64_t evpid; in control_dispatch_ext() local
733 if (imsg->hdr.len - IMSG_HEADER_SIZE != sizeof evpid) in control_dispatch_ext()
736 memmove(&evpid, imsg->data, sizeof evpid); in control_dispatch_ext()
738 m_add_evpid(p_queue, evpid); in control_dispatch_ext()
|
| H A D | scheduler_backend.c | 60 sched->evpid = evp->id; in scheduler_info()
|
| H A D | report_smtp.c | 183 report_smtp_tx_envelope(const char *direction, uint64_t qid, uint32_t msgid, uint64_t evpid) in report_smtp_tx_envelope() argument
194 m_add_id(p_lka, evpid); in report_smtp_tx_envelope()
|
| H A D | smtp_session.c | 92 uint64_t evpid; member
703 uint64_t reqid, evpid; in smtp_session_imsg() local
855 m_get_evpid(&m, &evpid); in smtp_session_imsg()
856 s->tx->evp.id = evpid; in smtp_session_imsg()
858 smtp_report_tx_envelope(s, s->tx->msgid, evpid); in smtp_session_imsg()
885 rcpt->evpid = s->tx->evp.id; in smtp_session_imsg()
927 "evpid=%016"PRIx64" from=<%s%s%s> to=<%s%s%s>", in smtp_session_imsg()
929 rcpt->evpid, in smtp_session_imsg()
3042 smtp_report_tx_envelope(struct smtp_session *s, uint32_t msgid, uint64_t evpid) in smtp_report_tx_envelope()
3047 report_smtp_tx_envelope("smtp-in", s->id, msgid, evpid); in smtp_report_tx_envelope()
3041 smtp_report_tx_envelope(struct smtp_session * s,uint32_t msgid,uint64_t evpid) smtp_report_tx_envelope() argument
[all...] |
| H A D | lka.c | 80 uint64_t evpid; in lka_imsg() local
491 m_get_id(&m, &evpid); in lka_imsg()
494 lka_report_smtp_tx_envelope(direction, &tv, reqid, msgid, evpid); in lka_imsg()
|
| H A D | mta.c | 2652 mta_hoststat_cache(const char *host, uint64_t evpid) in mta_hoststat_cache() argument
2667 tree_set(&hs->deferred, evpid, NULL); in mta_hoststat_cache()
2671 mta_hoststat_uncache(const char *host, uint64_t evpid) in mta_hoststat_uncache() argument
2683 tree_pop(&hs->deferred, evpid); in mta_hoststat_uncache()
2691 uint64_t evpid; in mta_hoststat_reschedule() local
2700 while (tree_poproot(&hs->deferred, &evpid, NULL)) { in mta_hoststat_reschedule()
2702 &evpid, sizeof evpid); in mta_hoststat_reschedule()
|
| H A D | lka_filter.c | 1534 lka_report_smtp_tx_envelope(const char *direction, struct timeval *tv, uint64_t reqid, uint32_t msgid, uint64_t evpid) in lka_report_smtp_tx_data()
1537 "%08x|%016"PRIx64"\n", msgid, evpid); in lka_report_smtp_tx_data()
1521 lka_report_smtp_tx_envelope(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid,uint64_t evpid) lka_report_smtp_tx_envelope() argument
|
| H A D | mta_session.c | 1843 mta_report_tx_envelope(struct mta_session *s, uint32_t msgid, uint64_t evpid) in mta_report_tx_envelope() argument
1848 report_smtp_tx_envelope("smtp-out", s->id, msgid, evpid); in mta_report_tx_envelope()
|
| H A D | smtpd.h | 1021 uint64_t evpid; member
|