/openbsd/usr.sbin/smtpd/ |
H A D | scheduler_ramqueue.c | 316 evp->sched = scheduler_next(evp->ctime, in scheduler_ram_update() 512 evp->sched = scheduler_next(evp->ctime, t, 0); in scheduler_ram_batch() 574 if (evp->sched < evp->expire) in scheduler_ram_batch() 961 hq = tree_xget(&holdqs[evp->type], evp->holdq); in rq_envelope_schedule() 965 tree_xpop(&holdqs[evp->type], evp->holdq); in rq_envelope_schedule() 998 hq = tree_xget(&holdqs[evp->type], evp->holdq); in rq_envelope_remove() 1002 tree_xpop(&holdqs[evp->type], evp->holdq); in rq_envelope_remove() 1033 hq = tree_xget(&holdqs[evp->type], evp->holdq); in rq_envelope_suspend() 1037 tree_xpop(&holdqs[evp->type], evp->holdq); in rq_envelope_suspend() 1080 tree_xpop(&evp->message->envelopes, evp->evpid); in rq_envelope_delete() [all …]
|
H A D | ruleset.c | 40 ret = table_match(table, service, evp->tag); in ruleset_match_tag() 57 if (evp->flags & EF_INTERNAL) { in ruleset_match_from() 71 key = evp->hostname; in ruleset_match_from() 74 key = ss_to_text(&evp->ss); in ruleset_match_from() 124 ret = table_match(table, service, evp->helo); in ruleset_match_smtp_helo() 149 if (!(evp->flags & EF_AUTHENTICATED)) in ruleset_match_smtp_auth() 156 service = strchr(evp->username, '@') ? in ruleset_match_smtp_auth() 214 ruleset_match(const struct envelope *evp) in ruleset_match() argument 227 MATCH_EVAL(ruleset_match_tag(r, evp)); in ruleset_match() 228 MATCH_EVAL(ruleset_match_from(r, evp)); in ruleset_match() [all …]
|
H A D | queue_ram.c | 135 free(evp->buf); in queue_ram_message_delete() 136 free(evp); in queue_ram_message_delete() 201 evp = calloc(1, sizeof *evp); in queue_ram_envelope_create() 206 evp->len = len; in queue_ram_envelope_create() 210 free(evp); in queue_ram_envelope_create() 233 free(evp->buf); in queue_ram_envelope_delete() 234 free(evp); in queue_ram_envelope_delete() 264 free(evp->buf); in queue_ram_envelope_update() 265 evp->len = len; in queue_ram_envelope_update() 266 evp->buf = tmp; in queue_ram_envelope_update() [all …]
|
H A D | queue.c | 47 struct envelope evp; in queue_imsg() local 135 m_get_envelope(&m, &evp); in queue_imsg() 138 if (evp.id == 0) in queue_imsg() 205 queue_bounce(&evp, &bounce); in queue_imsg() 241 evp.lasttry = time(NULL); in queue_imsg() 266 evp.lasttry = time(NULL); in queue_imsg() 298 evp.lasttry = nexttry; in queue_imsg() 368 evp.retry++; in queue_imsg() 395 queue_bounce(&evp, &bounce); in queue_imsg() 523 struct envelope evp; in queue_msgid_walk() local [all …]
|
H A D | mda.c | 197 e = s->evp; in mda_imsg() 286 e = s->evp; in mda_imsg() 315 e = s->evp; in mda_imsg() 661 if (evp->rcpt) in mda_log() 667 evp->id, in mda_log() 668 evp->sender ? evp->sender : "", in mda_log() 669 evp->dest, in mda_log() 671 evp->user, in mda_log() 796 if (evp->sender.user[0] && evp->sender.domain[0]) in mda_envelope() 798 evp->sender.user, evp->sender.domain); in mda_envelope() [all …]
|
H A D | scheduler_backend.c | 39 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 D | bounce.c | 120 struct envelope evp; in bounce_add() local 133 if (evp.type != D_BOUNCE) in bounce_add() 135 evp.id); in bounce_add() 141 switch (evp.esc_class) { in bounce_add() 164 evp.sender.domain); in bounce_add() 174 line = evp.errorline; in bounce_add() 517 evp->dest.user, in bounce_next() 518 evp->dest.domain, in bounce_next() 520 esc_code(evp->esc_class, evp->esc_code)); in bounce_next() 600 struct envelope evp; in bounce_delivery() local [all …]
|
H A D | mta.c | 780 if (evp->sender.user[0] || evp->sender.domain[0]) in mta_handle_envelope() 782 evp->sender.user, evp->sender.domain); in mta_handle_envelope() 805 evp->dest.user, evp->dest.domain); in mta_handle_envelope() 808 evp->rcpt.user, evp->rcpt.domain); in mta_handle_envelope() 986 evp = malloc(sizeof(*evp)); in mta_query_smarthost() 987 memmove(evp, evp0, sizeof(*evp)); in mta_query_smarthost() 994 tree_xset(&wait_smarthost, evp->id, evp); in mta_query_smarthost() 1144 free(evp); in mta_on_smarthost() 1788 evp->id, in mta_log() 1790 evp->dest, in mta_log() [all …]
|
H A D | scheduler.c | 49 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() 99 scheduler_info(&si, &evp); in scheduler_imsg() 181 m_get_envelope(&m, &evp); in scheduler_imsg() 185 scheduler_info(&si, &evp); in scheduler_imsg() [all …]
|
H A D | queue_backend.c | 374 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() 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() 424 evp = encbuf; in queue_envelope_load_buffer() 432 evp = compbuf; in queue_envelope_load_buffer() [all …]
|
H A D | smtp_session.c | 101 struct envelope evp; member 856 s->tx->evp.id = evpid; in smtp_session_imsg() 930 s->tx->evp.sender.user, in smtp_session_imsg() 2304 tx->evp.ss = s->ss; in smtp_tx() 2305 (void)strlcpy(tx->evp.tag, s->listener->tag, sizeof(tx->evp.tag)); in smtp_tx() 2306 (void)strlcpy(tx->evp.smtpname, s->smtpname, sizeof(tx->evp.smtpname)); in smtp_tx() 2307 (void)strlcpy(tx->evp.hostname, s->rdns, sizeof tx->evp.hostname); in smtp_tx() 2308 (void)strlcpy(tx->evp.helo, s->helo, sizeof(tx->evp.helo)); in smtp_tx() 2309 (void)strlcpy(tx->evp.username, s->username, sizeof(tx->evp.username)); in smtp_tx() 2312 tx->evp.flags |= EF_BOUNCE; in smtp_tx() [all …]
|
H A D | smtpctl.c | 272 evp->id = evpid; in srv_get_envelope() 388 srv_get_envelope(evp); in srv_iter_envelopes() 391 evp->flags |= flags; in srv_iter_envelopes() 392 evp->nexttry = nexttry; in srv_iter_envelopes() 394 from = evp->id + 1; in srv_iter_envelopes() 404 struct envelope evp; in srv_iter_evpids() local 418 evpids[n++] = evp.id; in srv_iter_evpids() 743 struct envelope evp; in do_show_queue() local 1243 struct envelope evp; in show_offline_envelope() local 1271 evp.id = evpid; in show_offline_envelope() [all …]
|
H A D | mproc.c | 485 m_add_envelope(struct mproc *m, const struct envelope *evp) in m_add_envelope() argument 487 char buf[sizeof(*evp)]; in m_add_envelope() 489 envelope_dump_buffer(evp, buf, sizeof(buf)); in m_add_envelope() 490 m_add_evpid(m, evp->id); in m_add_envelope() 619 m_get_envelope(struct msg *m, struct envelope *evp) in m_get_envelope() argument 629 if (!envelope_load_buffer(evp, buf, strlen(buf))) in m_get_envelope() 631 evp->id = evpid; in m_get_envelope()
|
/openbsd/usr.bin/vi/common/ |
H A D | key.c | 326 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() 361 evp->e_value = KEY_VAL(sp, evp->e_c); in v_event_push() 376 EVENT *evp; in v_event_append() local 394 evp->e_value = KEY_VAL(sp, evp->e_c); in v_event_append() 398 *evp = *argp; in v_event_append() 500 EVENT *evp, ev; in v_event_get() local 581 *argp = *evp; in v_event_get() 598 (evp->e_c < MAX_BIT_SEQ && !bit_test(gp->seqb, evp->e_c))) in v_event_get() [all …]
|
/openbsd/usr.bin/ssh/ |
H A D | cipher.c | 57 EVP_CIPHER_CTX *evp; member 285 if ((cc->evp = EVP_CIPHER_CTX_new()) == NULL) { in cipher_init() 300 klen = EVP_CIPHER_CTX_key_length(cc->evp); in cipher_init() 320 EVP_CIPHER_CTX_free(cc->evp); in cipher_init() 388 if (EVP_Cipher(cc->evp, NULL, NULL, 0) < 0) in cipher_crypt() 425 EVP_CIPHER_CTX_free(cc->evp); in cipher_free() 426 cc->evp = NULL; in cipher_free() 454 evplen = EVP_CIPHER_CTX_iv_length(cc->evp); in cipher_get_keyiv() 464 } else if (!EVP_CIPHER_CTX_get_iv(cc->evp, iv, len)) in cipher_get_keyiv() 484 evplen = EVP_CIPHER_CTX_iv_length(cc->evp); in cipher_set_keyiv() [all …]
|
/openbsd/usr.bin/vi/cl/ |
H A D | cl_read.c | 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() 108 evp->e_event = E_ERR; in cl_event() [all …]
|
/openbsd/gnu/llvm/compiler-rt/lib/tsan/rtl/ |
H A D | tsan_rtl_report.cpp | 369 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() 389 evp++; in TraceReplay() 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() 499 evp->_ == 0) // NopEvent in RestoreStack() 515 if (evp->is_func) { in RestoreStack() [all …]
|
H A D | tsan_rtl.h | 729 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/usr.bin/vi/vi/ |
H A D | v_txt.c | 468 evp = &ev; 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() 528 evp->e_c = 033; in v_txt() 529 evp->e_flags = 0; in v_txt() 602 vip->rep[rcol++] = *evp; in v_txt() 611 if (evp->e_c == ' ') in v_txt() 654 switch (evp->e_value) { in v_txt() 1196 evp->e_c = '^'; in v_txt() [all …]
|
H A D | vs_refresh.c | 42 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/usr.sbin/tcpdump/ |
H A D | print-ipsec.c | 67 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/sys/dev/wscons/ |
H A D | wsmuxvar.h | 64 #define wsevsrc_open(me, evp) \ argument 65 ((me)->me_ops->dopen((me), evp))
|
/openbsd/lib/libedit/ |
H A D | history.c | 197 #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/regress/lib/libcrypto/man/ |
H A D | check_complete.pl | 33 evp => [qw( 68 evp => [qw(
|
/openbsd/lib/libc/sys/ |
H A D | timer_create.c | 13 timer_create(clockid_t clock_id, struct sigevent *evp, timer_t *timerid) in timer_create() argument
|