Home
last modified time | relevance | path

Searched refs:evp (Results 1 – 25 of 42) sorted by relevance

12

/openbsd-src/usr.sbin/smtpd/
H A Dscheduler_ramqueue.c266 struct rq_envelope *evp; in scheduler_ram_rollback() local
275 while ((evp = TAILQ_FIRST(&update->q_pending))) { in scheduler_ram_rollback()
276 TAILQ_REMOVE(&update->q_pending, evp, entry); in scheduler_ram_rollback()
277 rq_envelope_delete(update, evp); in scheduler_ram_rollback()
290 struct rq_envelope *evp; in scheduler_ram_update() local
297 evp = tree_xget(&msg->envelopes, si->evpid); in scheduler_ram_update()
300 if (evp->state != RQ_EVPSTATE_INFLIGHT) in scheduler_ram_update()
301 fatalx("evp:%016" PRIx64 " not in-flight", si->evpid); in scheduler_ram_update()
303 TAILQ_REMOVE(&ramqueue.q_inflight, evp, entry); in scheduler_ram_update()
309 if (evp in scheduler_ram_update()
332 struct rq_envelope *evp; scheduler_ram_delete() local
359 struct rq_envelope *evp; scheduler_ram_hold() local
417 struct rq_envelope *evp; scheduler_ram_release() local
465 struct rq_envelope *evp; scheduler_ram_batch() local
606 struct rq_envelope *evp; scheduler_ram_envelopes() local
658 struct rq_envelope *evp; scheduler_ram_schedule() local
696 struct rq_envelope *evp; scheduler_ram_remove() local
730 struct rq_envelope *evp; scheduler_ram_suspend() local
764 struct rq_envelope *evp; scheduler_ram_resume() local
811 sorted_insert(struct rq_queue * rq,struct rq_envelope * evp) sorted_insert() argument
877 struct rq_envelope *evp; rq_queue_schedule() local
907 rq_envelope_list(struct rq_queue * rq,struct rq_envelope * evp) rq_envelope_list() argument
940 rq_envelope_schedule(struct rq_queue * rq,struct rq_envelope * evp) rq_envelope_schedule() argument
982 rq_envelope_remove(struct rq_queue * rq,struct rq_envelope * evp) rq_envelope_remove() argument
1024 rq_envelope_suspend(struct rq_queue * rq,struct rq_envelope * evp) rq_envelope_suspend() argument
1057 rq_envelope_resume(struct rq_queue * rq,struct rq_envelope * evp) rq_envelope_resume() argument
1078 rq_envelope_delete(struct rq_queue * rq,struct rq_envelope * evp) rq_envelope_delete() argument
[all...]
H A Druleset.c27 ruleset_match_tag(struct rule *r, const struct envelope *evp) in ruleset_match_tag() argument
40 ret = table_match(table, service, evp->tag); in ruleset_match_tag()
46 ruleset_match_from(struct rule *r, const struct envelope *evp) in ruleset_match_from() argument
57 if (evp->flags & EF_INTERNAL) { in ruleset_match_from()
66 has_rdns = strcmp(evp->hostname, "<unknown>") != 0; in ruleset_match_from()
71 key = evp->hostname; in ruleset_match_from()
74 key = ss_to_text(&evp->ss); in ruleset_match_from()
92 ruleset_match_to(struct rule *r, const struct envelope *evp) in ruleset_match_to() argument
105 ret = table_match(table, service, evp->dest.domain); in ruleset_match_to()
111 ruleset_match_smtp_helo(struct rule *r, const struct envelope *evp) in ruleset_match_smtp_helo() argument
[all …]
H A Dqueue_ram.c126 struct qr_envelope *evp; in queue_ram_message_delete() local
133 while (tree_poproot(&messages, &evpid, (void**)&evp)) { in queue_ram_message_delete()
134 stat_decrement("queue.ram.envelope.size", evp->len); in queue_ram_message_delete()
135 free(evp->buf); in queue_ram_message_delete()
136 free(evp); in queue_ram_message_delete()
192 struct qr_envelope *evp; in queue_ram_envelope_create() local
201 evp = calloc(1, sizeof *evp); in queue_ram_envelope_create()
202 if (evp == NULL) { in queue_ram_envelope_create()
206 evp->len = len; in queue_ram_envelope_create()
207 evp->buf = malloc(len); in queue_ram_envelope_create()
[all …]
H A Dqueue.c47 struct envelope evp; in queue_imsg() local
135 m_get_envelope(&m, &evp); in queue_imsg()
138 if (evp.id == 0) in queue_imsg()
140 if (evpid_to_msgid(evp.id) == 0) in queue_imsg()
142 "evpid=%016"PRIx64, evp.id); in queue_imsg()
143 ret = queue_envelope_create(&evp); in queue_imsg()
150 m_add_evpid(p_dispatcher, evp.id); in queue_imsg()
156 m_add_envelope(p_scheduler, &evp); in queue_imsg()
181 if (queue_envelope_load(evpid, &evp) == 0) in queue_imsg()
184 queue_log(&evp, "Remove", "Removed by administrator"); in queue_imsg()
[all …]
H A Dmda.c71 struct mda_envelope *evp; member
108 struct envelope evp; in mda_imsg() local
153 m_get_envelope(&m, &evp); in mda_imsg()
156 u = mda_user(&evp); in mda_imsg()
171 m_add_evpid(p_queue, evp.id); in mda_imsg()
177 e = mda_envelope(u->id, &evp); in mda_imsg()
197 e = s->evp; in mda_imsg()
260 (void)text_to_mailaddr(&deliver.sender, s->evp->sender); in mda_imsg()
261 (void)text_to_mailaddr(&deliver.rcpt, s->evp->rcpt); in mda_imsg()
262 (void)text_to_mailaddr(&deliver.dest, s->evp->dest); in mda_imsg()
[all …]
H A Dscheduler_backend.c39 scheduler_info(struct scheduler_info *sched, struct envelope *evp) in scheduler_info() argument
43 disp = evp->type == D_BOUNCE ? in scheduler_info()
45 dict_xget(env->sc_dispatchers, evp->dispatcher); in scheduler_info()
60 sched->evpid = evp->id; in scheduler_info()
61 sched->creation = evp->creation; in scheduler_info()
62 sched->retry = evp->retry; in scheduler_info()
63 sched->lasttry = evp->lasttry; in scheduler_info()
64 sched->lastbounce = evp->lastbounce; in scheduler_info()
H A Dbounce.c120 struct envelope evp; in bounce_add() local
126 if (queue_envelope_load(evpid, &evp) == 0) { in bounce_add()
133 if (evp.type != D_BOUNCE) in bounce_add()
135 evp.id); in bounce_add()
138 key.bounce = evp.agent.bounce; in bounce_add()
139 key.smtpname = evp.smtpname; in bounce_add()
141 switch (evp.esc_class) { in bounce_add()
152 key.bounce.dsn_ret = evp.dsn_ret; in bounce_add()
153 key.bounce.ttl = evp.ttl; in bounce_add()
162 msg->smtpname = xstrdup(evp.smtpname); in bounce_add()
[all …]
H A Dmta.c184 struct envelope evp, *e; in mta_imsg() local
200 m_get_envelope(&m, &evp); in mta_imsg()
202 mta_handle_envelope(&evp, NULL); in mta_imsg()
687 mta_handle_envelope(struct envelope *evp, const char *smarthost) in mta_handle_envelope() argument
697 dispatcher = dict_xget(env->sc_dispatchers, evp->dispatcher); in mta_handle_envelope()
699 mta_query_smarthost(evp); in mta_handle_envelope()
708 m_add_evpid(p_queue, evp->id); in mta_handle_envelope()
717 evp->dispatcher, smarthost); in mta_handle_envelope()
719 m_add_evpid(p_queue, evp->id); in mta_handle_envelope()
730 evp->dispatcher); in mta_handle_envelope()
[all …]
H A Dscheduler.c49 struct envelope evp; in scheduler_imsg() local
66 m_get_envelope(&m, &evp); in scheduler_imsg()
69 "scheduler: inserting evp:%016" PRIx64, evp.id); in scheduler_imsg()
70 scheduler_info(&si, &evp); in scheduler_imsg()
89 m_get_envelope(&m, &evp); in scheduler_imsg()
91 r = backend->query(evp.id); in scheduler_imsg()
94 " already scheduled", evp.id); in scheduler_imsg()
98 "scheduler: discovering evp:%016" PRIx64, evp.id); in scheduler_imsg()
99 scheduler_info(&si, &evp); in scheduler_imsg()
181 m_get_envelope(&m, &evp); in scheduler_imsg()
[all …]
H A Dqueue_backend.c374 char *evp; in queue_envelope_dump_buffer() local
381 evp = evpbuf; in queue_envelope_dump_buffer()
387 complen = compress_chunk(evp, evplen, compbuf, sizeof compbuf); in queue_envelope_dump_buffer()
390 evp = compbuf; in queue_envelope_dump_buffer()
395 enclen = crypto_encrypt_buffer(evp, evplen, encbuf, sizeof encbuf); in queue_envelope_dump_buffer()
398 evp = encbuf; in queue_envelope_dump_buffer()
402 memmove(evpbuf, evp, evplen); in queue_envelope_dump_buffer()
410 char *evp; in queue_envelope_load_buffer() local
417 evp = evpbuf; in queue_envelope_load_buffer()
421 enclen = crypto_decrypt_buffer(evp, evplen, encbuf, sizeof encbuf); in queue_envelope_load_buffer()
[all …]
H A Dsmtp_session.c101 struct envelope evp; member
505 header_address_rewrite_buffer(buffer, mailaddr_to_text(&tx->evp.sender), in header_domain_append_callback()
555 header_address_rewrite_buffer(buffer, mailaddr_to_text(&tx->evp.sender), in header_domain_append_callback()
744 if (s->tx->evp.rcpt.user[0]) { in smtp_session_imsg()
745 (void)strlcpy(tmp, s->tx->evp.rcpt.user, sizeof tmp); in smtp_session_imsg()
746 if (s->tx->evp.rcpt.domain[0]) { in smtp_session_imsg()
748 (void)strlcat(tmp, s->tx->evp.rcpt.domain, in smtp_session_imsg()
786 s->tx->evp.id = msgid_to_evpid(msgid); in smtp_session_imsg()
856 s->tx->evp.id = evpid; in smtp_session_imsg()
871 fatalx("commit evp faile in smtp_session_imsg()
[all...]
H A Dsmtpctl.c265 srv_get_envelope(struct envelope *evp) in srv_get_envelope()
273 envelope_load_buffer(evp, str, strlen(str)); in srv_get_envelope()
274 evp->id = evpid;
349 srv_iter_envelopes(uint32_t msgid, struct envelope *evp) in srv_iter_envelopes()
390 srv_get_envelope(evp); in srv_iter_envelopes()
393 evp->flags |= flags; in srv_iter_envelopes()
394 evp->nexttry = nexttry; in srv_iter_envelopes()
396 from = evp->id + 1; in srv_iter_envelopes()
406 struct envelope evp; in srv_iter_evpids()
410 while (srv_iter_envelopes(msgid, &evp)) { in srv_iter_evpids()
263 srv_get_envelope(struct envelope * evp) srv_get_envelope() argument
347 srv_iter_envelopes(uint32_t msgid,struct envelope * evp) srv_iter_envelopes() argument
404 struct envelope evp; srv_iter_evpids() local
743 struct envelope evp; do_show_queue() local
1243 struct envelope evp; show_offline_envelope() local
[all...]
H A Dmproc.c460 m_add_envelope(struct mproc *m, const struct envelope *evp) in m_add_evpid()
462 char buf[sizeof(*evp)]; in m_add_evpid()
464 envelope_dump_buffer(evp, buf, sizeof(buf));
465 m_add_evpid(m, evp->id);
594 m_get_envelope(struct msg *m, struct envelope *evp) in m_get_msgid()
604 if (!envelope_load_buffer(evp, buf, strlen(buf))) in m_get_sockaddr()
606 evp->id = evpid; in m_get_sockaddr()
485 m_add_envelope(struct mproc * m,const struct envelope * evp) m_add_envelope() argument
619 m_get_envelope(struct msg * m,struct envelope * evp) m_get_envelope() argument
/openbsd-src/usr.bin/vi/common/
H A Dkey.c326 EVENT *evp; in v_event_push() local
355 for (evp = gp->i_event + gp->i_next; nitems--; ++evp) { in v_event_push()
357 *evp = *p_evp++; in v_event_push()
359 evp->e_event = E_CHARACTER; in v_event_push()
360 evp->e_c = *p_s++; in v_event_push()
361 evp->e_value = KEY_VAL(sp, evp->e_c); in v_event_push()
362 F_INIT(&evp->e_ch, flags); in v_event_push()
376 EVENT *evp; in v_event_append() local
386 evp = gp->i_event + gp->i_next + gp->i_cnt; in v_event_append()
391 for (s = argp->e_csp; nevents--; ++evp) { in v_event_append()
[all …]
/openbsd-src/usr.bin/ssh/
H A Dcipher.c57 EVP_CIPHER_CTX *evp; member
59 struct aesctr_ctx ac_ctx; /* XXX union with evp? */
285 if ((cc->evp = EVP_CIPHER_CTX_new()) == NULL) { in cipher_init()
289 if (EVP_CipherInit(cc->evp, type, NULL, (u_char *)iv, in cipher_init()
295 !EVP_CIPHER_CTX_ctrl(cc->evp, EVP_CTRL_GCM_SET_IV_FIXED, in cipher_init()
300 klen = EVP_CIPHER_CTX_key_length(cc->evp); in cipher_init()
302 if (EVP_CIPHER_CTX_set_key_length(cc->evp, keylen) == 0) { in cipher_init()
307 if (EVP_CipherInit(cc->evp, NULL, (u_char *)key, NULL, -1) == 0) { in cipher_init()
320 EVP_CIPHER_CTX_free(cc->evp); in cipher_init()
366 if (!EVP_CIPHER_CTX_ctrl(cc->evp, EVP_CTRL_GCM_IV_GE in cipher_crypt()
[all...]
/openbsd-src/usr.bin/vi/cl/
H A Dcl_read.c45 cl_event(SCR *sp, EVENT *evp, u_int32_t flags, int ms) in cl_event() argument
60 evp->e_event = E_INTERRUPT; in cl_event()
62 evp->e_event = E_TIMEOUT; in cl_event()
67 evp->e_event = E_SIGHUP; in cl_event()
70 evp->e_event = E_SIGTERM; in cl_event()
81 evp->e_event = E_WRESIZE; in cl_event()
100 evp->e_csp = clp->ibuf; in cl_event()
101 evp->e_len = nr; in cl_event()
102 evp->e_event = E_STRING; in cl_event()
105 evp->e_event = E_EOF; in cl_event()
[all …]
/openbsd-src/gnu/llvm/compiler-rt/lib/tsan/rtl/
H A Dtsan_rtl_report.cpp369 for (Event *evp = &part->events[0]; evp < end; evp++) { in TraceReplay() local
370 Event *evp0 = evp; in TraceReplay()
371 if (!evp->is_access && !evp->is_func) { in TraceReplay()
372 switch (evp->type) { in TraceReplay()
374 auto *ev = reinterpret_cast<EventTime *>(evp); in TraceReplay()
389 evp++; in TraceReplay()
488 [&](Sid ev_sid, Epoch ev_epoch, Event *evp) { in RestoreStack() argument
489 if (evp == nullptr) { in RestoreStack()
497 if (evp->is_access) { in RestoreStack()
498 if (evp->is_func == 0 && evp->type == EventType::kAccessExt && in RestoreStack()
[all …]
H A Dtsan_rtl.h729 ALWAYS_INLINE void TraceRelease(ThreadState *thr, EventT *evp) { in TraceRelease() argument
730 DCHECK_LE(evp + 1, &thr->tctx->trace.parts.Back()->events[TracePart::kSize]); in TraceRelease()
731 atomic_store_relaxed(&thr->trace_pos, (uptr)(evp + 1)); in TraceRelease()
736 EventT *evp; in TraceEvent() local
737 if (!TraceAcquire(thr, &evp)) { in TraceEvent()
739 UNUSED bool res = TraceAcquire(thr, &evp); in TraceEvent()
742 *evp = ev; in TraceEvent()
743 TraceRelease(thr, evp); in TraceEvent()
/openbsd-src/usr.bin/vi/vi/
H A Dv_txt.c244 EVENT ev, *evp = NULL; /* Current event. */ in v_txt() local
468 evp = &ev; in v_txt()
469 next: if (v_event_get(sp, evp, 0, ec_flags)) in v_txt()
491 switch (evp->e_event) { in v_txt()
507 if (evp->e_event != E_INTERRUPT && evp->e_event != E_WRESIZE) in v_txt()
508 v_event_err(sp, evp); in v_txt()
527 evp->e_event = E_CHARACTER; in v_txt()
528 evp->e_c = 033; in v_txt()
529 evp->e_flags = 0; in v_txt()
530 evp->e_value = K_ESCAPE; in v_txt()
[all …]
H A Dvs_refresh.c42 vs_repaint(SCR *sp, EVENT *evp) in vs_repaint() argument
46 for (; evp->e_flno <= evp->e_tlno; ++evp->e_flno) { in vs_repaint()
47 smp = HMAP + evp->e_flno - 1; in vs_repaint()
/openbsd-src/usr.sbin/tcpdump/
H A Dprint-ipsec.c67 const EVP_CIPHER *evp; in esp_init() local
72 evp = EVP_aes_128_cbc(); /* default */ in esp_init()
89 if ((evp = EVP_get_cipherbyname(name)) == NULL) in esp_init()
92 klen = EVP_CIPHER_key_length(evp); in esp_init()
112 if (!EVP_CipherInit(ctx, evp, key, NULL, 0)) { in esp_init()
/openbsd-src/sys/dev/wscons/
H A Dwsmuxvar.h64 #define wsevsrc_open(me, evp) \ argument
65 ((me)->me_ops->dopen((me), evp))
/openbsd-src/lib/libedit/
H A Dhistory.c197 #define he_seterrev(evp, code) {\ argument
198 evp->num = code;\
199 evp->str = he_strerror(code);\
411 HistEventPrivate *evp = (void *)&h->cursor->ev; in history_def_add() local
415 len = Strlen(evp->str) + Strlen(str) + 1; in history_def_add()
424 free(evp->str); in history_def_add()
425 evp->str = s; in history_def_add()
473 HistEventPrivate *evp = (void *)&hp->ev; in history_def_delete() local
483 free(evp->str); in history_def_delete()
/openbsd-src/regress/lib/libcrypto/man/
H A Dcheck_complete.pl33 evp => [qw(
75 evp => [qw(
/openbsd-src/lib/libc/sys/
H A Dtimer_create.c13 timer_create(clockid_t clock_id, struct sigevent *evp, timer_t *timerid) in timer_create() argument

12