Home
last modified time | relevance | path

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

12

/openbsd/src/usr.sbin/smtpd/
Dlka_filter.c472 lka_filter_proc_in_session(uint64_t reqid, const char *proc) in lka_filter_proc_in_session() argument
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() argument
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() argument
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() argument
537 fs = tree_xget(&sessions, reqid); in lka_filter_data_begin()
[all …]
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 …]
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 …]
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 …]
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 …]
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()
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()
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 …]
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 …]
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()
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/
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/
Dfsm.c235 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_close()
266 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_timeout()
455 if (id != f->reqid || f->seen_ack) /* Expected id? */ in fsm_rconfack()
516 if (id != f->reqid || f->seen_ack) /* Expected id? */ in fsm_rconfnakrej()
692 fsm_sdata(f, TERMREQ, f->reqid = ++f->id, in fsm_protreject()
726 f->reqid = ++f->id; in fsm_sconfreq()
745 fsm_sdata(f, CONFREQ, f->reqid, outp, cilen); in fsm_sconfreq()
752 PROTO_NAME(f), f->reqid)); in fsm_sconfreq()
Dfsm.h72 u_char reqid; /* Current request id */ member
Dccp.c264 if (ccp_localstate[f->unit] & RACK_PENDING && id == f->reqid) { in ccp_extcode()
1052 fsm_sdata(f, CCP_RESETREQ, f->reqid = ++f->id, NULL, 0); in ccp_datainput()
1070 fsm_sdata(f, CCP_RESETREQ, f->reqid, NULL, 0); in ccp_rack_timeout()
/openbsd/src/usr.sbin/npppd/npppd/
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()
Dfsm.h62 u_char reqid; /* Current request id */ member
/openbsd/src/usr.sbin/ldpd/
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()
Dldp.h321 uint32_t reqid; member
/openbsd/src/usr.bin/snmp/
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/
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 …]
Dbwfmvar.h154 int reqid; member
/openbsd/src/sys/dev/usb/
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/
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()
Dasr_private.h188 uint16_t reqid; member

12