| /freebsd/contrib/ofed/libibmad/ |
| H A D | cc.c | 54 ib_rpc_cc_t rpc = { 0 }; in cc_query_status_via() local
58 rpc.method = IB_MAD_METHOD_GET; in cc_query_status_via()
59 rpc.attr.id = attrid; in cc_query_status_via()
60 rpc.attr.mod = mod; in cc_query_status_via()
61 rpc.timeout = timeout; in cc_query_status_via()
63 rpc.datasz = IB_CC_LOG_DATA_SZ; in cc_query_status_via()
64 rpc.dataoffs = IB_CC_LOG_DATA_OFFS; in cc_query_status_via()
67 rpc.datasz = IB_CC_DATA_SZ; in cc_query_status_via()
68 rpc.dataoffs = IB_CC_DATA_OFFS; in cc_query_status_via()
70 rpc.mgtclass = IB_CC_CLASS; in cc_query_status_via()
[all …]
|
| H A D | serv.c | 51 int mad_send(ib_rpc_t * rpc, ib_portid_t * dport, ib_rmpp_hdr_t * rmpp, in mad_send() argument
54 return mad_send_via(rpc, dport, rmpp, data, ibmp); in mad_send()
57 int mad_send_via(ib_rpc_t * rpc, ib_portid_t * dport, ib_rmpp_hdr_t * rmpp, in mad_send_via() argument
67 if (mad_build_pkt(umad, rpc, dport, rmpp, data) < 0) in mad_send_via()
71 IBWARN("data offs %d sz %d", rpc->dataoffs, rpc->datasz); in mad_send_via()
73 (char *)umad_get_mad(umad) + rpc->dataoffs, rpc->datasz); in mad_send_via()
76 if (umad_send(srcport->port_id, srcport->class_agents[rpc->mgtclass & 0xff], in mad_send_via()
77 umad, IB_MAD_SIZE, mad_get_timeout(srcport, rpc->timeout), in mad_send_via()
96 ib_rpc_t rpc = { 0 }; in mad_respond_via() local
123 rpc.mgtclass = mad_get_field(mad, 0, IB_MAD_MGMTCLASS_F); in mad_respond_via()
[all …]
|
| H A D | smp.c | 64 ib_rpc_t rpc = { 0 }; in smp_set_status_via() local
71 rpc.mgtclass = IB_SMI_DIRECT_CLASS; /* direct SMI */ in smp_set_status_via()
73 rpc.mgtclass = IB_SMI_CLASS; /* Lid routed SMI */ in smp_set_status_via()
75 rpc.method = IB_MAD_METHOD_SET; in smp_set_status_via()
76 rpc.attr.id = attrid; in smp_set_status_via()
77 rpc.attr.mod = mod; in smp_set_status_via()
78 rpc.timeout = timeout; in smp_set_status_via()
79 rpc.datasz = IB_SMP_DATA_SIZE; in smp_set_status_via()
80 rpc.dataoffs = IB_SMP_DATA_OFFS; in smp_set_status_via()
81 rpc.mkey = srcport->smp_mkey; in smp_set_status_via()
[all …]
|
| H A D | gs.c | 54 ib_rpc_v1_t rpc = { 0 }; in pma_query_via() local
55 ib_rpc_t *rpcold = (ib_rpc_t *)(void *)&rpc; in pma_query_via()
66 rpc.mgtclass = IB_PERFORMANCE_CLASS | IB_MAD_RPC_VERSION1; in pma_query_via()
67 rpc.method = IB_MAD_METHOD_GET; in pma_query_via()
68 rpc.attr.id = id; in pma_query_via()
72 rpc.attr.mod = 0; in pma_query_via()
73 rpc.timeout = timeout; in pma_query_via()
74 rpc.datasz = IB_PC_DATA_SZ; in pma_query_via()
75 rpc.dataoffs = IB_PC_DATA_OFFS; in pma_query_via()
83 errno = rpc.error; in pma_query_via()
[all …]
|
| H A D | mad.c | 86 void *mad_encode(void *buf, ib_rpc_t * rpc, ib_dr_path_t * drpath, void *data) in mad_encode() argument
88 int is_resp = rpc->method & IB_MAD_RESPONSE; in mad_encode()
92 mad_set_field(buf, 0, IB_MAD_METHOD_F, rpc->method); in mad_encode()
94 mgtclass = rpc->mgtclass & 0xff; in mad_encode()
99 mad_set_field(buf, 0, IB_MAD_MGMTCLASS_F, rpc->mgtclass & 0xff); in mad_encode()
103 if ((rpc->mgtclass & 0xff) == IB_SMI_DIRECT_CLASS) { in mad_encode()
117 mad_set_field(buf, 0, IB_DRSMP_STATUS_F, rpc->rstatus); in mad_encode()
120 mad_set_field(buf, 0, IB_MAD_STATUS_F, rpc->rstatus); in mad_encode()
123 if (!rpc->trid) in mad_encode()
124 rpc->trid = mad_trid(); in mad_encode()
[all …]
|
| H A D | vendor.c | 67 ib_rpc_v1_t rpc = { 0 }; in ib_vendor_call_via() local
68 ib_rpc_t *rpcold = (ib_rpc_t *)(void *)&rpc; in ib_vendor_call_via()
82 rpc.mgtclass = call->mgmt_class | IB_MAD_RPC_VERSION1; in ib_vendor_call_via()
84 rpc.method = call->method; in ib_vendor_call_via()
85 rpc.attr.id = call->attrid; in ib_vendor_call_via()
86 rpc.attr.mod = call->mod; in ib_vendor_call_via()
87 rpc.timeout = resp_expected ? call->timeout : 0; in ib_vendor_call_via()
88 rpc.datasz = in ib_vendor_call_via()
90 rpc.dataoffs = in ib_vendor_call_via()
94 rpc.oui = call->oui; in ib_vendor_call_via()
[all …]
|
| H A D | bm.c | 54 ib_rpc_t rpc = { 0 }; in bm_call_via() local
70 rpc.mgtclass = IB_BOARD_MGMT_CLASS; in bm_call_via()
72 rpc.method = call->method; in bm_call_via()
73 rpc.attr.id = call->attrid; in bm_call_via()
74 rpc.attr.mod = call->mod; in bm_call_via()
75 rpc.timeout = resp_expected ? call->timeout : 0; in bm_call_via()
77 rpc.datasz = IB_BM_BKEY_AND_DATA_SZ; in bm_call_via()
78 rpc.dataoffs = IB_BM_BKEY_OFFS; in bm_call_via()
87 rpc.method, rpc.attr.id, rpc.attr.mod, rpc.datasz, rpc.dataoffs, in bm_call_via()
96 if (mad_rpc(srcport, &rpc, portid, &bm_data, &bm_data)) in bm_call_via()
[all …]
|
| H A D | rpc.c | 221 void *mad_rpc(const struct ibmad_port *port, ib_rpc_t * rpc, in mad_rpc() argument
226 ib_rpc_v1_t *rpcv1 = (ib_rpc_v1_t *)rpc; in mad_rpc()
229 if ((rpc->mgtclass & IB_MAD_RPC_VERSION_MASK) == IB_MAD_RPC_VERSION1) in mad_rpc()
235 if ((len = mad_build_pkt(sndbuf, rpc, dport, 0, payload)) < 0) in mad_rpc()
239 port->class_agents[rpc->mgtclass & 0xff], in mad_rpc()
240 len, mad_get_timeout(port, rpc->timeout), in mad_rpc()
242 if ((rpc->mgtclass & IB_MAD_RPC_VERSION_MASK) == in mad_rpc()
264 if ((rpc->mgtclass & IB_MAD_RPC_VERSION_MASK) == IB_MAD_RPC_VERSION1) in mad_rpc()
266 rpc->rstatus = status; in mad_rpc()
276 IBWARN("data offs %d sz %d", rpc->dataoffs, rpc->datasz); in mad_rpc()
[all …]
|
| H A D | sa.c | 52 ib_rpc_t rpc = { 0 }; in sa_rpc_call() local
63 rpc.mgtclass = IB_SA_CLASS; in sa_rpc_call()
64 rpc.method = sa->method; in sa_rpc_call()
65 rpc.attr.id = sa->attrid; in sa_rpc_call()
66 rpc.attr.mod = sa->mod; in sa_rpc_call()
67 rpc.mask = sa->mask; in sa_rpc_call()
68 rpc.timeout = timeout; in sa_rpc_call()
69 rpc.datasz = IB_SA_DATA_SIZE; in sa_rpc_call()
70 rpc.dataoffs = IB_SA_DATA_OFFS; in sa_rpc_call()
71 rpc.trid = sa->trid; in sa_rpc_call()
[all …]
|
| /freebsd/lib/libc/tests/nss/ |
| H A D | getrpc_test.c | 109 free_rpcent(struct rpcent *rpc) in free_rpcent() argument
113 ATF_REQUIRE(rpc != NULL); in free_rpcent()
115 free(rpc->r_name); in free_rpcent()
117 for (cp = rpc->r_aliases; *cp; ++cp) in free_rpcent()
119 free(rpc->r_aliases); in free_rpcent()
163 sdump_rpcent(struct rpcent *rpc, char *buffer, size_t buflen) in sdump_rpcent() argument
169 rpc->r_name, rpc->r_number); in sdump_rpcent()
175 if (rpc->r_aliases != NULL) { in sdump_rpcent()
176 if (*(rpc->r_aliases) != NULL) { in sdump_rpcent()
177 for (cp = rpc->r_aliases; *cp; ++cp) { in sdump_rpcent()
[all …]
|
| /freebsd/lib/libc/rpc/ |
| H A D | getrpcent.c | 113 struct rpcent rpc; member
141 rpcent_unpack(char *p, struct rpcent *rpc, char **r_aliases, in rpcent_unpack() argument
159 rpc->r_name = p; in rpcent_unpack()
162 rpc->r_number = atoi(cp); in rpcent_unpack()
163 q = rpc->r_aliases = r_aliases; in rpcent_unpack()
208 struct rpcent *rpc; in files_rpcent() local
239 rpc = va_arg(ap, struct rpcent *); in files_rpcent()
285 rv = rpcent_unpack(buffer, rpc, aliases, aliases_size, errnop); in files_rpcent()
300 if (strcmp(rpc->r_name, name) == 0) in files_rpcent()
302 for (rp = rpc->r_aliases; *rp != NULL; rp++) { in files_rpcent()
[all …]
|
| /freebsd/sys/nlm/ |
| H A D | nlm_prot_server.c | 233 CLIENT *rpc; in nlm_test_msg_1_svc() local
240 if (nlm_do_test(&args4, &res4, rqstp, &rpc)) in nlm_test_msg_1_svc()
250 if (rpc) { in nlm_test_msg_1_svc()
251 nlm_test_res_1(&res, &dummy, rpc, NULL, nlm_zero_tv); in nlm_test_msg_1_svc()
252 CLNT_RELEASE(rpc); in nlm_test_msg_1_svc()
265 CLIENT *rpc; in nlm_lock_msg_1_svc() local
275 if (nlm_do_lock(&args4, &res4, rqstp, TRUE, &rpc)) in nlm_lock_msg_1_svc()
280 if (rpc) { in nlm_lock_msg_1_svc()
281 nlm_lock_res_1(&res, &dummy, rpc, NULL, nlm_zero_tv); in nlm_lock_msg_1_svc()
282 CLNT_RELEASE(rpc); in nlm_lock_msg_1_svc()
[all …]
|
| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | evrpc.c | 95 struct evrpc *rpc; in evrpc_free() local
100 while ((rpc = TAILQ_FIRST(&base->registered_rpcs)) != NULL) { in evrpc_free()
101 r = evrpc_unregister_rpc(base, rpc->uri); in evrpc_free()
228 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc, in evrpc_register_rpc() argument
231 char *constructed_uri = evrpc_construct_uri(rpc->uri); in evrpc_register_rpc()
233 rpc->base = base; in evrpc_register_rpc()
234 rpc->cb = cb; in evrpc_register_rpc()
235 rpc->cb_arg = cb_arg; in evrpc_register_rpc()
237 TAILQ_INSERT_TAIL(&base->registered_rpcs, rpc, next); in evrpc_register_rpc()
242 rpc); in evrpc_register_rpc()
[all …]
|
| /freebsd/contrib/libevent/ |
| H A D | evrpc.c | 95 struct evrpc *rpc; in evrpc_free() local
100 while ((rpc = TAILQ_FIRST(&base->registered_rpcs)) != NULL) { in evrpc_free()
101 r = evrpc_unregister_rpc(base, rpc->uri); in evrpc_free()
228 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc, in evrpc_register_rpc() argument
231 char *constructed_uri = evrpc_construct_uri(rpc->uri); in evrpc_register_rpc()
233 rpc->base = base; in evrpc_register_rpc()
234 rpc->cb = cb; in evrpc_register_rpc()
235 rpc->cb_arg = cb_arg; in evrpc_register_rpc()
237 TAILQ_INSERT_TAIL(&base->registered_rpcs, rpc, next); in evrpc_register_rpc()
242 rpc); in evrpc_register_rpc()
[all …]
|
| /freebsd/contrib/ofed/infiniband-diags/src/ |
| H A D | ibsysstat.c | 75 ib_rpc_t rpc = { 0 }; in server_respond() local
96 rpc.mgtclass = mad_get_field(mad, 0, IB_MAD_MGMTCLASS_F); in server_respond()
97 rpc.method = IB_MAD_METHOD_GET | IB_MAD_RESPONSE; in server_respond()
98 rpc.attr.id = mad_get_field(mad, 0, IB_MAD_ATTRID_F); in server_respond()
99 rpc.attr.mod = mad_get_field(mad, 0, IB_MAD_ATTRMOD_F); in server_respond()
100 rpc.oui = mad_get_field(mad, 0, IB_VEND2_OUI_F); in server_respond()
101 rpc.trid = mad_get_field64(mad, 0, IB_MAD_TRID_F); in server_respond()
107 size, portid2str(&rport), rpc.attr.id, rpc.attr.mod, rport.qkey); in server_respond()
109 if (mad_build_pkt(umad, &rpc, &rport, &rmpp, 0) < 0) in server_respond()
116 mad_rpc_class_agent(srcport, rpc.mgtclass), umad, size, in server_respond()
[all …]
|
| H A D | ibdiag_sa.c | 102 ib_rpc_t rpc; in sa_query() local
106 memset(&rpc, 0, sizeof(rpc)); in sa_query()
107 rpc.mgtclass = IB_SA_CLASS; in sa_query()
108 rpc.method = method; in sa_query()
109 rpc.attr.id = attr; in sa_query()
110 rpc.attr.mod = mod; in sa_query()
111 rpc.mask = comp_mask; in sa_query()
112 rpc.datasz = datasz; in sa_query()
113 rpc.dataoffs = IB_SA_DATA_OFFS; in sa_query()
119 mad_build_pkt(umad, &rpc, &h->dport, NULL, data); in sa_query()
|
| /freebsd/contrib/ofed/libibnetdisc/ |
| H A D | query_smp.c | 76 ib_rpc_t *rpc = &smp->rpc; in send_smp() local
81 if (rpc->mgtclass == IB_SMI_CLASS) { in send_smp()
83 } else if (rpc->mgtclass == IB_SMI_DIRECT_CLASS) { in send_smp()
90 if ((rc = mad_build_pkt(umad, &smp->rpc, &smp->path, NULL, NULL)) in send_smp()
119 cl_qmap_insert(&engine->smps_on_wire, (uint32_t) smp->rpc.trid, in process_smp_queue()
138 smp->rpc.method = IB_MAD_METHOD_GET; in issue_smp()
139 smp->rpc.attr.id = attrid; in issue_smp()
140 smp->rpc.attr.mod = mod; in issue_smp()
141 smp->rpc.timeout = engine->cfg->timeout_ms; in issue_smp()
142 smp->rpc.datasz = IB_SMP_DATA_SIZE; in issue_smp()
[all …]
|
| /freebsd/sys/modules/krpc/ |
| H A D | Makefile | 1 .PATH: ${SRCTOP}/sys/rpc ${SRCTOP}/sys/rpc/rpcsec_tls
34 rpctlscd.h: $S/rpc/rpcsec_tls/rpctlscd.x
35 RPCGEN_CPP=${CPP:Q} rpcgen -hM $S/rpc/rpcsec_tls/rpctlscd.x | grep -v pthread.h > rpctlscd.h
37 rpctlscd_xdr.c: $S/rpc/rpcsec_tls/rpctlscd.x
38 RPCGEN_CPP=${CPP:Q} rpcgen -c $S/rpc/rpcsec_tls/rpctlscd.x -o rpctlscd_xdr.c
40 rpctlscd_clnt.c: $S/rpc/rpcsec_tls/rpctlscd.x
41 RPCGEN_CPP=${CPP:Q} rpcgen -lM $S/rpc/rpcsec_tls/rpctlscd.x | grep -v string.h > rpctlscd_clnt.c
48 rpctlssd.h: $S/rpc/rpcsec_tls/rpctlssd.x
49 RPCGEN_CPP=${CPP:Q} rpcgen -hM $S/rpc/rpcsec_tls/rpctlssd.x | grep -v pthread.h > rpctlssd.h
51 rpctlssd_xdr.c: $S/rpc/rpcsec_tls/rpctlssd.x
[all …]
|
| /freebsd/contrib/llvm-project/libc/src/__support/RPC/ |
| H A D | rpc_server.h | 135 LIBC_INLINE static void handle_printf(rpc::Server::Port &port, in handle_printf()
141 port.recv([&](rpc::Buffer *buffer, uint32_t id) { in handle_printf()
183 port.send([&](rpc::Buffer *buffer, uint32_t id) { in handle_printf()
235 port.send([&](rpc::Buffer *buffer, uint32_t id) { in handle_printf()
303 port.send([&](rpc::Buffer *buffer, uint32_t id) { in handle_printf()
310 LIBC_INLINE static rpc::Status handle_port_impl(rpc::Server::Port &port) { in handle_port_impl()
322 port.recv([&](rpc::Buffer *buffer, uint32_t id) { in handle_port_impl()
332 port.send([&](rpc::Buffer *buffer, uint32_t id) { in handle_port_impl()
345 port.recv([&](rpc::Buffer *buffer, uint32_t id) { in handle_port_impl()
351 port.send([&](rpc::Buffer *buffer, uint32_t id) { in handle_port_impl()
[all …]
|
| H A D | rpc_client.h | 19 namespace rpc {
21 using ::rpc::Buffer;
22 using ::rpc::Client;
23 using ::rpc::Port;
24 using ::rpc::Process;
25 using ::rpc::Server;
|
| /freebsd/usr.sbin/rpc.tlsclntd/ |
| H A D | Makefile | 3 PROG= rpc.tlsclntd
4 MAN= rpc.tlsclntd.8
5 SRCS= rpc.tlsclntd.c rpc.tlscommon.c rpctlscd.h rpctlscd_svc.c rpctlscd_xdr.c
7 CFLAGS+= -I. -I${SRCTOP}/usr.sbin/rpc.tlsservd
13 RPCSRC= ${SRCTOP}/sys/rpc/rpcsec_tls/rpctlscd.x
25 .PATH: ${SRCTOP}/sys/rpc/rpcsec_tls ${SRCTOP}/usr.sbin/rpc.tlsservd
|
| /freebsd/crypto/krb5/src/lib/rpc/ |
| H A D | getrpcent.c | 55 struct rpcent rpc; member
101 struct rpcent *rpc; in getrpcbyname() local
105 while(rpc = getrpcent()) { in getrpcbyname()
106 if (strcmp(rpc->r_name, name) == 0) in getrpcbyname()
107 return (rpc); in getrpcbyname()
108 for (rp = rpc->r_aliases; *rp != NULL; rp++) { in getrpcbyname()
110 return (rpc); in getrpcbyname()
203 d->rpc.r_name = d->line; in interpret()
206 d->rpc.r_number = atoi(cp); in interpret()
207 q = d->rpc.r_aliases = d->rpc_aliases; in interpret()
[all …]
|
| /freebsd/contrib/llvm-project/libc/shared/ |
| H A D | rpc.h | 23 namespace rpc {
117 return rpc::broadcast_value( in load_inbox()
124 return rpc::broadcast_value( in load_outbox()
180 uint32_t id = rpc::get_lane_id(); in try_lock()
185 uint64_t packed = rpc::ballot(lane_mask, before); in try_lock()
219 clear_nth(lock, index, rpc::is_first_lane(lane_mask)); in unlock()
220 rpc::sync_lane(lane_mask); in unlock()
283 fn(&slot[rpc::get_lane_id()], rpc::get_lane_id()); in invoke_rpc()
285 for (uint32_t i = 0; i < lane_size; i += rpc::get_num_lanes()) in invoke_rpc()
309 friend class rpc::optional<Port<T>>;
[all …]
|
| /freebsd/usr.sbin/rpc.tlsservd/ |
| H A D | Makefile | 3 PROG= rpc.tlsservd
4 MAN= rpc.tlsservd.8
5 SRCS= rpc.tlsservd.c rpc.tlscommon.c rpctlssd.h rpctlssd_svc.c rpctlssd_xdr.c
13 RPCSRC= ${SRCTOP}/sys/rpc/rpcsec_tls/rpctlssd.x
25 .PATH: ${SRCTOP}/sys/rpc/rpcsec_tls
|
| /freebsd/contrib/llvm-project/libc/src/__support/OSUtil/gpu/ |
| H A D | exit.cpp | 21 rpc::Client::Port port = rpc::client.open<LIBC_EXIT>(); in exit()
22 port.send_and_recv([](rpc::Buffer *, uint32_t) {}, in exit()
23 [](rpc::Buffer *, uint32_t) {}); in exit()
24 port.send([&](rpc::Buffer *buffer, uint32_t) { in exit()
|