Home
last modified time | relevance | path

Searched refs:reqid (Results 1 – 25 of 26) sorted by relevance

12

/openbsd-src/usr.sbin/smtpd/
H A Dlka_filter.c472 lka_filter_proc_in_session(uint64_t reqid, const char *proc) in lka_filter_proc_in_session()
478 if ((fs = tree_get(&sessions, reqid)) == NULL) in lka_filter_proc_in_session()
497 lka_filter_begin(uint64_t reqid, const char *filter_name) in lka_filter_begin()
507 fs->id = reqid; in lka_filter_begin()
511 log_trace(TRACE_FILTERS, "%016"PRIx64" filters session-begin", reqid); in lka_filter_begin()
515 lka_filter_end(uint64_t reqid) in lka_filter_end()
519 fs = tree_xpop(&sessions, reqid); in lka_filter_end()
527 log_trace(TRACE_FILTERS, "%016"PRIx64" filters session-end", reqid); in lka_filter_end()
531 lka_filter_data_begin(uint64_t reqid) in lka_filter_data_begin()
537 fs = tree_xget(&sessions, reqid); in lka_filter_data_begin()
471 lka_filter_proc_in_session(uint64_t reqid,const char * proc) lka_filter_proc_in_session() argument
496 lka_filter_begin(uint64_t reqid,const char * filter_name) lka_filter_begin() argument
514 lka_filter_end(uint64_t reqid) lka_filter_end() argument
530 lka_filter_data_begin(uint64_t reqid) lka_filter_data_begin() argument
556 lka_filter_data_end(uint64_t reqid) lka_filter_data_end() argument
595 uint64_t reqid; lka_filter_process_response() local
666 lka_filter_protocol(uint64_t reqid,enum filter_phase phase,const char * param) lka_filter_protocol() argument
672 filter_protocol_internal(struct filter_session * fs,uint64_t * token,uint64_t reqid,enum filter_phase phase,const char * param) filter_protocol_internal() argument
796 filter_data_internal(struct filter_session * fs,uint64_t token,uint64_t reqid,const char * line) filter_data_internal() argument
831 filter_protocol(uint64_t reqid,enum filter_phase phase,const char * param) filter_protocol() argument
873 filter_protocol_next(uint64_t token,uint64_t reqid,enum filter_phase phase) filter_protocol_next() argument
885 filter_data(uint64_t reqid,const char * line) filter_data() argument
895 filter_data_next(uint64_t token,uint64_t reqid,const char * line) filter_data_next() argument
907 filter_protocol_query(struct filter * filter,uint64_t token,uint64_t reqid,const char * phase,const char * param) filter_protocol_query() argument
933 filter_data_query(struct filter * filter,uint64_t token,uint64_t reqid,const char * line) filter_data_query() argument
951 filter_result_proceed(uint64_t reqid) filter_result_proceed() argument
960 filter_result_junk(uint64_t reqid) filter_result_junk() argument
969 filter_result_rewrite(uint64_t reqid,const char * param) filter_result_rewrite() argument
979 filter_result_reject(uint64_t reqid,const char * message) filter_result_reject() argument
989 filter_result_disconnect(uint64_t reqid,const char * message) filter_result_disconnect() argument
1207 filter_builtins_notimpl(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_notimpl() argument
1213 filter_builtins_global(struct filter_session * fs,struct filter * filter,uint64_t reqid) filter_builtins_global() argument
1232 filter_builtins_connect(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_connect() argument
1238 filter_builtins_helo(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_helo() argument
1244 filter_builtins_mail_from(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_mail_from() argument
1250 filter_builtins_rcpt_to(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_rcpt_to() argument
1258 filter_builtins_data(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_data() argument
1264 filter_builtins_commit(struct filter_session * fs,struct filter * filter,uint64_t reqid,const char * param) filter_builtins_commit() argument
1336 report_smtp_broadcast(uint64_t reqid,const char * direction,struct timeval * tv,const char * event,const char * format,...) report_smtp_broadcast() argument
1371 lka_report_smtp_link_connect(const char * direction,struct timeval * tv,uint64_t reqid,const char * rdns,int fcrdns,const struct sockaddr_storage * ss_src,const struct sockaddr_storage * ss_dest) lka_report_smtp_link_connect() argument
1424 lka_report_smtp_link_disconnect(const char * direction,struct timeval * tv,uint64_t reqid) lka_report_smtp_link_disconnect() argument
1430 lka_report_smtp_link_greeting(const char * direction,uint64_t reqid,struct timeval * tv,const char * domain) lka_report_smtp_link_greeting() argument
1438 lka_report_smtp_link_auth(const char * direction,struct timeval * tv,uint64_t reqid,const char * username,const char * result) lka_report_smtp_link_auth() argument
1453 lka_report_smtp_link_identify(const char * direction,struct timeval * tv,uint64_t reqid,const char * method,const char * heloname) lka_report_smtp_link_identify() argument
1460 lka_report_smtp_link_tls(const char * direction,struct timeval * tv,uint64_t reqid,const char * ciphers) lka_report_smtp_link_tls() argument
1467 lka_report_smtp_tx_reset(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid) lka_report_smtp_tx_reset() argument
1474 lka_report_smtp_tx_begin(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid) lka_report_smtp_tx_begin() argument
1481 lka_report_smtp_tx_mail(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid,const char * address,int ok) lka_report_smtp_tx_mail() argument
1501 lka_report_smtp_tx_rcpt(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid,const char * address,int ok) lka_report_smtp_tx_rcpt() argument
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
1528 lka_report_smtp_tx_data(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid,int ok) lka_report_smtp_tx_data() argument
1548 lka_report_smtp_tx_commit(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid,size_t msgsz) lka_report_smtp_tx_commit() argument
1555 lka_report_smtp_tx_rollback(const char * direction,struct timeval * tv,uint64_t reqid,uint32_t msgid) lka_report_smtp_tx_rollback() argument
1562 lka_report_smtp_protocol_client(const char * direction,struct timeval * tv,uint64_t reqid,const char * command) lka_report_smtp_protocol_client() argument
1569 lka_report_smtp_protocol_server(const char * direction,struct timeval * tv,uint64_t reqid,const char * response) lka_report_smtp_protocol_server() argument
1576 lka_report_smtp_filter_response(const char * direction,struct timeval * tv,uint64_t reqid,int phase,int response,const char * param) lka_report_smtp_filter_response() argument
1658 lka_report_smtp_timeout(const char * direction,struct timeval * tv,uint64_t reqid) lka_report_smtp_timeout() argument
1664 lka_report_filter_report(uint64_t reqid,const char * name,int builtin,const char * direction,struct timeval * tv,const char * message) lka_report_filter_report() argument
1678 uint64_t reqid; lka_report_proc() local
[all...]
H A Dlka.c60 uint64_t reqid; in lka_imsg() local
104 m_get_id(&m, &reqid); in lka_imsg()
113 m_add_id(p, reqid); in lka_imsg()
120 m_get_id(&m, &reqid); in lka_imsg()
123 lka_session(reqid, &evp); in lka_imsg()
128 m_get_id(&m, &reqid); in lka_imsg()
137 m_add_id(p, reqid); in lka_imsg()
146 m_get_id(&m, &reqid); in lka_imsg()
155 m_add_id(p_parent, reqid); in lka_imsg()
165 m_add_id(p, reqid); in lka_imsg()
[all …]
H A Dresolver.c44 uint32_t reqid; member
159 uint32_t reqid; in resolver_dispatch_request() local
162 reqid = imsg->hdr.peerid; in resolver_dispatch_request()
183 s->reqid = reqid; in resolver_dispatch_request()
194 m_create(proc, IMSG_GETADDRINFO_END, reqid, 0, -1); in resolver_dispatch_request()
214 s->reqid = reqid; in resolver_dispatch_request()
228 m_create(proc, IMSG_GETNAMEINFO, reqid, 0, -1); in resolver_dispatch_request()
247 s->reqid = reqid; in resolver_dispatch_request()
258 m_create(proc, IMSG_RES_QUERY, reqid, 0, -1); in resolver_dispatch_request()
392 m_create(s->proc, IMSG_GETADDRINFO, s->reqid, 0, -1); in resolver_getaddrinfo_cb()
[all …]
H A Ddns.c41 uint64_t reqid; member
116 m_get_id(&m, &s->reqid); in dns_imsg()
136 m_add_id(s->p, s->reqid); in dns_imsg()
143 m_add_id(s->p, s->reqid); in dns_imsg()
154 m_add_id(s->p, s->reqid); in dns_imsg()
173 m_add_id(s->p, s->reqid); in dns_imsg()
201 m_add_id(s->p, s->reqid); in dns_dispatch_host()
219 m_add_id(s->p, s->reqid); in dns_dispatch_host()
240 m_add_id(s->p, s->reqid); in dns_dispatch_mx()
279 m_add_id(s->p, s->reqid); in dns_dispatch_mx()
[all …]
H A Dqueue.c50 uint64_t reqid, evpid, holdq; in queue_imsg() local
64 m_get_id(&m, &reqid); in queue_imsg()
70 m_add_id(p, reqid); in queue_imsg()
95 m_get_id(&m, &reqid); in queue_imsg()
102 m_add_id(p, reqid); in queue_imsg()
116 m_get_id(&m, &reqid); in queue_imsg()
123 m_add_id(p, reqid); in queue_imsg()
134 m_get_id(&m, &reqid); in queue_imsg()
145 m_add_id(p_dispatcher, reqid); in queue_imsg()
163 m_get_id(&m, &reqid); in queue_imsg()
[all …]
H A Dca.c41 static uint64_t reqid = 0; variable
315 reqid++; in rsae_send_imsg()
316 m_add_id(p_ca, reqid); in rsae_send_imsg()
352 if (id != reqid) in rsae_send_imsg()
425 reqid++; in ecdsae_send_enc_imsg()
426 m_add_id(p_ca, reqid); in ecdsae_send_enc_imsg()
458 if (id != reqid) in ecdsae_send_enc_imsg()
H A Dmda.c113 uint64_t reqid; in mda_imsg() local
124 m_get_id(&m, &reqid); in mda_imsg()
130 u = tree_xget(&users, reqid); in mda_imsg()
193 m_get_id(&m, &reqid); in mda_imsg()
196 s = tree_xget(&sessions, reqid); in mda_imsg()
275 m_add_id(p_parent, reqid); in mda_imsg()
282 m_get_id(&m, &reqid); in mda_imsg()
285 s = tree_xget(&sessions, reqid); in mda_imsg()
308 m_get_id(&m, &reqid); in mda_imsg()
314 s = tree_xget(&sessions, reqid); in mda_imsg()
H A Dsmtp_session.c703 uint64_t reqid, evpid; in smtp_session_imsg() local
714 m_get_id(&m, &reqid); in smtp_session_imsg()
717 s = tree_xpop(&wait_lka_mail, reqid); in smtp_session_imsg()
737 m_get_id(&m, &reqid); in smtp_session_imsg()
741 s = tree_xpop(&wait_lka_rcpt, reqid); in smtp_session_imsg()
767 m_get_id(&m, &reqid); in smtp_session_imsg()
768 s = tree_xpop(&wait_lka_helo, reqid); in smtp_session_imsg()
780 m_get_id(&m, &reqid); in smtp_session_imsg()
782 s = tree_xpop(&wait_queue_msg, reqid); in smtp_session_imsg()
801 m_get_id(&m, &reqid); in smtp_session_imsg()
[all...]
H A Dmta.c190 uint64_t reqid; in mta_imsg() local
211 m_get_id(&m, &reqid); in mta_imsg()
214 relay = tree_xpop(&wait_secret, reqid); in mta_imsg()
220 m_get_id(&m, &reqid); in mta_imsg()
226 relay = tree_xpop(&wait_source, reqid); in mta_imsg()
233 m_get_id(&m, &reqid); in mta_imsg()
240 e = tree_xpop(&wait_smarthost, reqid); in mta_imsg()
250 m_get_id(&m, &reqid); in mta_imsg()
255 domain = tree_xget(&wait_mx, reqid); in mta_imsg()
271 m_get_id(&m, &reqid); in mta_imsg()
[all …]
H A Dmta_session.c270 uint64_t reqid; in mta_session_imsg() local
279 m_get_id(&m, &reqid); in mta_session_imsg()
283 s = mta_tree_pop(&wait_fd, reqid); in mta_session_imsg()
326 m_get_id(&m, &reqid); in mta_session_imsg()
332 s = mta_tree_pop(&wait_helo, reqid); in mta_session_imsg()
353 mta_tree_pop(struct tree *wait, uint64_t reqid) in mta_tree_pop() argument
357 s = tree_xpop(wait, reqid); in mta_tree_pop()
H A Dsmtpd.c153 uint64_t reqid; in parent_imsg() local
184 m_get_id(&m, &reqid); in parent_imsg()
192 m_add_id(p, reqid); in parent_imsg()
199 m_get_id(&m, &reqid); in parent_imsg()
205 forkmda(p, reqid, &deliver); in parent_imsg()
210 m_get_id(&m, &reqid); in parent_imsg()
217 c->mda_id == reqid && in parent_imsg()
/openbsd-src/usr.sbin/lpd/
H A Dresolver.c53 uint32_t reqid; member
138 uint32_t reqid; in resolver_dispatch_request() local
141 reqid = imsg->hdr.peerid; in resolver_dispatch_request()
161 s->reqid = reqid; in resolver_dispatch_request()
172 m_create(proc, IMSG_GETADDRINFO_END, reqid, 0, -1); in resolver_dispatch_request()
192 s->reqid = reqid; in resolver_dispatch_request()
206 m_create(proc, IMSG_GETNAMEINFO, reqid, 0, -1); in resolver_dispatch_request()
314 m_create(s->proc, IMSG_GETADDRINFO, s->reqid, 0, -1); in resolver_getaddrinfo_cb()
324 m_create(s->proc, IMSG_GETADDRINFO_END, s->reqid, 0, -1); in resolver_getaddrinfo_cb()
339 m_create(s->proc, IMSG_GETNAMEINFO, s->reqid, 0, -1); in resolver_getnameinfo_cb()
/openbsd-src/usr.sbin/pppd/
H A Dfsm.c235 fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
266 fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
455 if (id != f->reqid || f->seen_ack) /* Expected id? */
516 if (id != f->reqid || f->seen_ack) /* Expected id? */
692 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_protreject()
726 f->reqid = ++f->id;
745 fsm_sdata(f, CONFREQ, f->reqid, outp, cilen);
752 PROTO_NAME(f), f->reqid));
H A Dfsm.h72 u_char reqid; /* Current request id */ member
H A Dccp.c264 if (ccp_localstate[f->unit] & RACK_PENDING && id == f->reqid) {
1052 fsm_sdata(f, CCP_RESETREQ, f->reqid = ++f->id, NULL, 0);
1070 fsm_sdata(f, CCP_RESETREQ, f->reqid, NULL, 0);
/openbsd-src/usr.sbin/npppd/npppd/
H A Dfsm.c255 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_close()
286 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_timeout()
466 if (id != f->reqid || f->seen_ack) /* Expected id? */ in fsm_rconfack()
522 if (id != f->reqid || f->seen_ack) /* Expected id? */ in fsm_rconfnakrej()
686 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_protreject()
720 f->reqid = ++f->id; in fsm_sconfreq()
739 fsm_sdata(f, CONFREQ, f->reqid, outp, cilen); in fsm_sconfreq()
H A Dfsm.h62 u_char reqid; /* Current request id */ member
/openbsd-src/usr.sbin/ldpd/
H A Dlabelmapping.c130 uint32_t label = NO_LABEL, reqid = 0; in recv_labelmessage() local
276 reqid = ntohl(reqbuf); in recv_labelmessage()
401 me->map.requestid = reqid; in recv_labelmessage()
502 gen_reqid_tlv(struct ibuf *buf, uint32_t reqid) in gen_reqid_tlv() argument
508 rt.reqid = htonl(reqid); in gen_reqid_tlv()
H A Dldp.h321 uint32_t reqid; member
/openbsd-src/usr.bin/snmp/
H A Dsnmp.c281 long long reqid, rreqid; in snmp_resolve() local
287 if (ober_scanf_elements(pdu, "{i", &reqid) != 0) { in snmp_resolve()
353 if (rreqid != reqid && rreqid != 0) { in snmp_resolve()
/openbsd-src/sys/dev/ic/
H A Dbwfm.c1620 int ret = 1, reqid; in bwfm_proto_bcdc_query_dcmd() local
1622 reqid = sc->sc_bcdc_reqid++; in bwfm_proto_bcdc_query_dcmd()
1631 dcmd->hdr.flags |= BWFM_BCDC_DCMD_ID_SET(reqid); in bwfm_proto_bcdc_query_dcmd()
1636 if (bwfm_proto_bcdc_txctl(sc, reqid, (char *)dcmd, &size)) { in bwfm_proto_bcdc_query_dcmd()
1660 int ret = 1, reqid; in bwfm_proto_bcdc_set_dcmd() local
1662 reqid = sc->sc_bcdc_reqid++; in bwfm_proto_bcdc_set_dcmd()
1671 dcmd->hdr.flags |= BWFM_BCDC_DCMD_ID_SET(reqid); in bwfm_proto_bcdc_set_dcmd()
1676 if (bwfm_proto_bcdc_txctl(sc, reqid, (char *)dcmd, &size)) { in bwfm_proto_bcdc_set_dcmd()
1690 bwfm_proto_bcdc_txctl(struct bwfm_softc *sc, int reqid, char *buf, size_t *len) in bwfm_proto_bcdc_txctl() argument
1696 ctl->reqid = reqid; in bwfm_proto_bcdc_txctl()
[all …]
H A Dbwfmvar.h154 int reqid; member
/openbsd-src/sys/dev/usb/
H A Dif_upgt.c884 eeprom->header2.reqid = htole32(sc->sc_memaddr_frame_start); in upgt_eeprom_read()
1488 txdesc->header2.reqid = htole32(data_tx->addr); in upgt_tx_task()
1584 if (data_tx->addr == letoh32(desc->header2.reqid)) { in upgt_tx_done()
1594 letoh32(desc->header2.reqid), in upgt_tx_done()
1887 filter->header2.reqid = htole32(sc->sc_memaddr_frame_start); in upgt_set_macfilter()
1971 chan->header2.reqid = htole32(sc->sc_memaddr_frame_start); in upgt_set_channel()
2030 led->header2.reqid = htole32(sc->sc_memaddr_frame_start); in upgt_set_led()
2111 stats->header2.reqid = htole32(sc->sc_memaddr_frame_start); in upgt_get_stats()
/openbsd-src/lib/libc/asr/
H A Dres_send_async.c83 as->as.dns.reqid = h.id; in res_send_async()
404 as->as.dns.reqid = h.id; in setup_query()
694 if (h.id != as->as.dns.reqid) { in validate_packet()
H A Dasr_private.h188 uint16_t reqid; member

12