Searched refs:xprt (Results 1 - 25 of 34) sorted by relevance

12

/freebsd-13-stable/usr.sbin/ypserv/
H A Dyp_svc_udp.c42 #define su_data(xprt) ((struct svc_dg_data *)((xprt)->xp_p2))
51 svcudp_get_xid(SVCXPRT *xprt) argument
55 if (xprt == NULL)
57 su = su_data(xprt);
62 svcudp_set_xid(SVCXPRT *xprt, unsigned long xid) argument
67 if (xprt == NULL)
69 su = su_data(xprt);
H A Dyp_dnslookup.c112 SVCXPRT *xprt; member in struct:circleq_dnsentry
297 xid = svcudp_set_xid(q->xprt, q->xid);
298 client_addr = q->xprt->xp_raddr;
299 q->xprt->xp_raddr = q->client_addr;
301 if (!svc_sendreply(q->xprt, xdrfunc, result))
309 svcudp_set_xid(q->xprt, xid);
310 q->xprt->xp_raddr = client_addr;
441 q->xprt = rqstp->rq_xprt;
445 q->xid = svcudp_get_xid(q->xprt);
446 q->client_addr = q->xprt
[all...]
/freebsd-13-stable/sys/rpc/
H A Dsvc_dg.c86 * xprt = svc_dg_create(sock, sendsize, recvsize);
88 * Once *xprt is initialized, it is registered.
102 SVCXPRT *xprt; local
121 xprt = svc_xprt_alloc();
122 sx_init(&xprt->xp_lock, "xprt->xp_lock");
123 xprt->xp_pool = pool;
124 xprt->xp_socket = so;
125 xprt->xp_p1 = NULL;
126 xprt
154 svc_dg_stat(SVCXPRT *xprt) argument
164 svc_dg_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
233 svc_dg_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument
273 svc_dg_destroy(SVCXPRT *xprt) argument
303 SVCXPRT *xprt = (SVCXPRT *) arg; local
[all...]
H A Dsvc_vc.c91 static bool_t svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in);
92 static bool_t svc_vc_rendezvous_control (SVCXPRT *xprt, const u_int rq,
100 static bool_t svc_vc_backchannel_control(SVCXPRT *xprt, const u_int rq,
136 * xprt = svc_vc_create(sock, send_buf_size, recv_buf_size);
139 * Once *xprt is initialized, it is registered as a transporter
154 SVCXPRT *xprt; local
166 xprt = svc_vc_create_conn(pool, so, sa);
168 return (xprt);
172 xprt = svc_xprt_alloc();
173 sx_init(&xprt
214 SVCXPRT *xprt; local
303 SVCXPRT *xprt = NULL; local
367 svc_vc_rendezvous_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
445 svc_vc_rendezvous_stat(SVCXPRT *xprt) argument
452 svc_vc_destroy_common(SVCXPRT *xprt) argument
486 svc_vc_rendezvous_destroy(SVCXPRT *xprt) argument
500 svc_vc_destroy(SVCXPRT *xprt) argument
522 svc_vc_backchannel_destroy(SVCXPRT *xprt) argument
539 svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in) argument
545 svc_vc_rendezvous_control(SVCXPRT *xprt, const u_int rq, void *in) argument
552 svc_vc_backchannel_control(SVCXPRT *xprt, const u_int rq, void *in) argument
559 svc_vc_stat(SVCXPRT *xprt) argument
578 svc_vc_ack(SVCXPRT *xprt, uint32_t *ack) argument
587 svc_vc_backchannel_stat(SVCXPRT *xprt) argument
605 svc_vc_process_pending(SVCXPRT *xprt) argument
681 svc_vc_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
889 svc_vc_backchannel_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
927 svc_vc_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument
1003 svc_vc_backchannel_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument
1087 SVCXPRT *xprt = (SVCXPRT *) arg; local
1097 SVCXPRT *xprt = (SVCXPRT *) arg; local
[all...]
H A Dsvc.h423 * SVCXPRT *xprt;
430 #define SVC_ACQUIRE(xprt) \
431 refcount_acquire(&(xprt)->xp_refs)
433 #define SVC_RELEASE(xprt) \
434 if (refcount_release(&(xprt)->xp_refs)) \
435 SVC_DESTROY(xprt)
437 #define SVC_RECV(xprt, msg, addr, args) \
438 (*(xprt)->xp_ops->xp_recv)((xprt), (msg), (addr), (args))
440 #define SVC_STAT(xprt) \
[all...]
H A Dsvc_generic.c93 SVCXPRT *xprt; local
105 TAILQ_FOREACH(xprt, &grp->sg_xlist, xp_link) {
106 if (strcmp(xprt->xp_netid, nconf->nc_netid))
111 if (svc_reg(xprt, prognum, versnum,
126 if (xprt == NULL) {
128 xprt = svc_tp_create(pool, dispatch, prognum, versnum,
130 if (xprt) {
132 SVC_RELEASE(xprt);
161 SVCXPRT *xprt; local
174 xprt
215 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc.c43 * There are two sets of procedures here. The xprt routines are
77 static void xprt_unregister_locked(SVCXPRT *xprt);
188 SVCXPRT *xprt, *nxprt; local
199 while ((xprt = TAILQ_FIRST(&grp->sg_xlist)) != NULL) {
200 xprt_unregister_locked(xprt);
201 TAILQ_INSERT_TAIL(&cleanup, xprt, xp_link);
205 TAILQ_FOREACH_SAFE(xprt, &cleanup, xp_link, nxprt) {
206 if (xprt->xp_socket != NULL)
207 soshutdown(xprt->xp_socket, SHUT_WR);
208 SVC_RELEASE(xprt);
345 xprt_register(SVCXPRT *xprt) argument
367 xprt_unregister_locked(SVCXPRT *xprt) argument
380 xprt_unregister(SVCXPRT *xprt) argument
402 xprt_assignthread(SVCXPRT *xprt) argument
435 xprt_active(SVCXPRT *xprt) argument
463 xprt_inactive_locked(SVCXPRT *xprt) argument
476 xprt_inactive(SVCXPRT *xprt) argument
490 xprt_inactive_self(SVCXPRT *xprt) argument
504 svc_reg(SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(struct svc_req *, SVCXPRT *), const struct netconfig *nconf) argument
593 svc_loss_reg(SVCXPRT *xprt, void (*dispatch)(SVCXPRT *)) argument
665 SVCXPRT *xprt = rqstp->rq_xprt; local
743 SVCXPRT *xprt = rqstp->rq_xprt; local
765 SVCXPRT *xprt = rqstp->rq_xprt; local
787 SVCXPRT *xprt = rqstp->rq_xprt; local
809 SVCXPRT *xprt = rqstp->rq_xprt; local
841 SVCXPRT *xprt = rqstp->rq_xprt; local
863 SVCXPRT *xprt = rqstp->rq_xprt; local
890 SVCXPRT *xprt; local
905 svc_xprt_free(SVCXPRT *xprt) argument
922 svc_getreq(SVCXPRT *xprt, struct svc_req **rqstp_ret) argument
1018 SVCXPRT *xprt = rqstp->rq_xprt; local
1063 SVCXPRT *xprt, *nxprt; local
1095 SVCXPRT *xprt; local
1146 SVCXPRT *xprt; local
[all...]
H A Dsvc_auth.c182 SVCXPRT *xprt = rqst->rq_xprt; local
193 if ((xprt->xp_tls & (RPCTLS_FLAGS_CERTUSER |
197 cr->cr_uid = cr->cr_ruid = cr->cr_svuid = xprt->xp_uid;
198 crsetgroups(cr, xprt->xp_ngrps, xprt->xp_gidp);
199 cr->cr_rgid = cr->cr_svgid = xprt->xp_gidp[0];
H A Dclnt_vc.c646 SVCXPRT *xprt; local
762 xprt = (SVCXPRT *)info;
764 xprt->xp_p2 = ct;
766 xprt->xp_tls = RPCTLS_FLAGS_HANDSHAKE;
767 ct->ct_backchannelxprt = xprt;
865 SVCXPRT *xprt; local
872 xprt = ct->ct_backchannelxprt;
874 if (xprt != NULL) {
876 sx_xlock(&xprt->xp_lock);
878 xprt
953 SVCXPRT *xprt; local
[all...]
H A Dclnt_bck.c196 SVCXPRT *xprt)
307 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0) {
322 sx_xlock(&xprt->xp_lock);
323 error = sosend(xprt->xp_socket, NULL, NULL, mreq, NULL, 0, curthread);
328 SOCKBUF_LOCK(&xprt->xp_socket->so_snd);
329 sbwait(&xprt->xp_socket->so_snd);
330 SOCKBUF_UNLOCK(&xprt->xp_socket->so_snd);
331 sx_xunlock(&xprt->xp_lock);
337 sx_xunlock(&xprt->xp_lock);
189 clnt_bck_call( CLIENT *cl, struct rpc_callextra *ext, rpcproc_t proc, struct mbuf *args, struct mbuf **resultsp, struct timeval utimeout, SVCXPRT *xprt) argument
H A Dclnt_rc.c414 SVCXPRT *xprt; local
499 xprt = (SVCXPRT *)info;
500 xprt_register(xprt);
564 SVCXPRT *xprt; local
569 xprt = (SVCXPRT *)rc->rc_backchannel;
570 KASSERT(xprt->xp_socket == NULL,
572 xprt_unregister(xprt);
573 SVC_RELEASE(xprt);
/freebsd-13-stable/include/rpc/
H A Dsvc.h172 * SVCXPRT *xprt;
177 #define SVC_RECV(xprt, msg) \
178 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
179 #define svc_recv(xprt, msg) \
180 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
182 #define SVC_STAT(xprt) \
183 (*(xprt)->xp_ops->xp_stat)(xprt)
[all...]
/freebsd-13-stable/lib/libc/rpc/
H A Dsvc.c43 * There are two sets of procedures here. The xprt routines are
94 static void __xprt_do_unregister (SVCXPRT *xprt, bool_t dolock);
102 xprt_register(SVCXPRT *xprt) argument
106 assert(xprt != NULL);
108 sock = xprt->xp_fd;
121 __svc_xports[sock] = xprt;
125 __svc_xports[sock] = xprt;
130 xprt_unregister(SVCXPRT *xprt) argument
132 __xprt_do_unregister(xprt, TRUE);
136 __xprt_unregister_unlocked(SVCXPRT *xprt) argument
145 __xprt_do_unregister(SVCXPRT *xprt, bool_t dolock) argument
175 svc_reg(SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(struct svc_req *, SVCXPRT *), const struct netconfig *nconf) argument
275 svc_register(SVCXPRT *xprt, u_long prog, u_long vers, void (*dispatch)(struct svc_req *, SVCXPRT *), int protocol) argument
362 svc_sendreply(SVCXPRT *xprt, xdrproc_t xdr_results, void * xdr_location) argument
382 svcerr_noproc(SVCXPRT *xprt) argument
399 svcerr_decode(SVCXPRT *xprt) argument
416 svcerr_systemerr(SVCXPRT *xprt) argument
468 svcerr_auth(SVCXPRT *xprt, enum auth_stat why) argument
485 svcerr_weakauth(SVCXPRT *xprt) argument
497 svcerr_noprog(SVCXPRT *xprt) argument
514 svcerr_progvers(SVCXPRT *xprt, rpcvers_t low_vers, rpcvers_t high_vers) argument
538 SVCXPRT *xprt; local
561 svc_xprt_free(SVCXPRT *xprt) argument
619 SVCXPRT *xprt; local
[all...]
H A Dsvc_generic.c87 SVCXPRT *xprt; /* Server handle */ member in struct:xlist
92 SVCXPRT *xprt; local
105 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
108 if (svc_reg(l->xprt, prognum, versnum,
121 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
122 if (xprt) {
130 l->xprt = xprt;
160 SVCXPRT *xprt; local
168 xprt
204 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc_vc.c88 static bool_t svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in);
89 static bool_t svc_vc_rendezvous_control (SVCXPRT *xprt, const u_int rq,
92 struct cf_rendezvous { /* kept in xprt->xp_p1 for rendezvouser */
98 struct cf_conn { /* kept in xprt->xp_p1 for actual connection */
112 * xprt = svc_vc_create(sock, send_buf_size, recv_buf_size);
115 * Once *xprt is initialized, it is registered as a transporter
129 SVCXPRT *xprt = NULL; local
146 xprt = svc_xprt_alloc();
147 if (xprt == NULL) {
151 xprt
243 SVCXPRT *xprt; local
280 rendezvous_request(SVCXPRT *xprt, struct rpc_msg *msg) argument
373 rendezvous_stat(SVCXPRT *xprt) argument
380 svc_vc_destroy(SVCXPRT *xprt) argument
389 __svc_vc_dodestroy(SVCXPRT *xprt) argument
419 svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in) argument
425 svc_vc_rendezvous_control(SVCXPRT *xprt, const u_int rq, void *in) argument
455 SVCXPRT *xprt; local
515 SVCXPRT *xprt; local
557 svc_vc_stat(SVCXPRT *xprt) argument
573 svc_vc_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
601 svc_vc_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) argument
612 svc_vc_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) argument
626 svc_vc_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
668 svc_vc_ops(SVCXPRT *xprt) argument
691 svc_vc_rendezvous_ops(SVCXPRT *xprt) argument
745 SVCXPRT *xprt, *least_active; local
[all...]
H A Dsvc_dg.c71 #define su_data(xprt) ((struct svc_dg_data *)((xprt)->xp_p2))
72 #define rpc_buffer(xprt) ((xprt)->xp_p1)
92 * xprt = svc_dg_create(sock, sendsize, recvsize);
94 * Once *xprt is initialized, it is registered.
109 SVCXPRT *xprt; local
129 xprt = svc_xprt_alloc();
130 if (xprt == NULL)
137 if ((rpc_buffer(xprt)
190 svc_dg_stat(SVCXPRT *xprt) argument
251 svc_dg_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
334 svc_dg_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
375 svc_dg_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) argument
386 svc_dg_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) argument
395 svc_dg_destroy(SVCXPRT *xprt) argument
417 svc_dg_control(SVCXPRT *xprt, const u_int rq, void *in) argument
423 svc_dg_ops(SVCXPRT *xprt) argument
576 cache_set(SVCXPRT *xprt, size_t replylen) argument
664 cache_get(SVCXPRT *xprt, struct rpc_msg *msg, char **replyp, size_t *replylenp) argument
[all...]
H A Dsvc_raw.c130 svc_raw_stat(SVCXPRT *xprt) argument
137 svc_raw_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
161 svc_raw_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
188 SVCAUTH_WRAP(&SVC_AUTH(xprt), xdrs, xdr_proc, xdr_where);
201 svc_raw_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) argument
213 return (SVCAUTH_UNWRAP(&SVC_AUTH(xprt), &srp->xdr_stream,
219 svc_raw_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) argument
239 svc_raw_destroy(SVCXPRT *xprt) argument
245 svc_raw_control(SVCXPRT *xprt, const u_int rq, void *in) argument
251 svc_raw_ops(SVCXPRT *xprt) argument
[all...]
/freebsd-13-stable/usr.sbin/rpcbind/
H A Dpmap_svc.c73 pmap_service(struct svc_req *rqstp, SVCXPRT *xprt) argument
85 check_access(xprt, rqstp->rq_proc, NULL, PMAPVERS);
86 if ((!svc_sendreply(xprt, (xdrproc_t) xdr_void, NULL)) &&
98 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
105 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
113 pmapproc_getport(rqstp, xprt);
124 pmapproc_dump(rqstp, xprt);
135 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLIT, PMAPVERS);
139 svcerr_noproc(xprt);
171 pmapproc_change(struct svc_req *rqstp __unused, SVCXPRT *xprt, unsigne argument
265 pmapproc_getport(struct svc_req *rqstp __unused, SVCXPRT *xprt) argument
346 pmapproc_dump(struct svc_req *rqstp __unused, SVCXPRT *xprt) argument
[all...]
H A Dcheck_bound.c161 mergeaddr(SVCXPRT *xprt, char *netid, char *uaddr, char *saddr) argument
185 dg_data = (struct svc_dg_data*)xprt->xp_p2;
193 c_uaddr = taddr2uaddr(fdl->nconf, svc_getrpccaller(xprt));
217 m_uaddr = addrmerge(svc_getrpccaller(xprt), s_uaddr, c_uaddr, netid);
H A Drpcb_svc_com.c75 SVCXPRT *xprt; member in struct:rmtcallfd_list
490 SVCXPRT *xprt; local
499 xprt = svc_tli_create(fd, 0, (struct t_bind *) 0, 0, 0);
500 if (xprt == NULL) {
511 rmt->xprt = xprt;
513 xprt->xp_netid = rmt->netid;
550 return (rmt->xprt);
1023 /* XXX may be too big, but can't access xprt array here */
1181 SVCXPRT *xprt; local
1209 xprt_set_caller(SVCXPRT *xprt, struct finfo *fi) argument
1222 send_svcsyserr(SVCXPRT *xprt, struct finfo *fi) argument
1232 handle_reply(int fd, SVCXPRT *xprt) argument
[all...]
H A Dsecurity.c59 check_access(SVCXPRT *xprt, rpcproc_t proc, void *args, unsigned int rpcbvers) argument
61 struct netbuf *caller = svc_getrpccaller(xprt);
228 check_callit(SVCXPRT *xprt, struct r_rmtcall_args *args, int versnum __unused) argument
230 struct sockaddr *sa = (struct sockaddr *)svc_getrpccaller(xprt)->buf;
/freebsd-13-stable/sys/fs/nfsserver/
H A Dnfs_nfsdkrpc.c103 static int nfs_proc(struct nfsrv_descript *, u_int32_t, SVCXPRT *xprt,
119 nfssvc_program(struct svc_req *rqst, SVCXPRT *xprt) argument
241 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0) {
243 if ((xprt->xp_tls & RPCTLS_FLAGS_VERIFIED) != 0)
245 if ((xprt->xp_tls & RPCTLS_FLAGS_CERTUSER) != 0)
284 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0 &&
288 cacherep = nfs_proc(&nd, rqst->rq_xid, xprt, &rp);
325 SVC_ACK(xprt, NULL)), rqst->rq_reply_seq);
339 nfs_proc(struct nfsrv_descript *nd, u_int32_t xid, SVCXPRT *xprt, argument
378 nd->nd_sockref = xprt
437 nfssvc_loss(SVCXPRT *xprt) argument
455 SVCXPRT *xprt; local
[all...]
/freebsd-13-stable/sys/rpc/rpcsec_tls/
H A Drpctls_impl.c85 static enum clnt_stat rpctls_server(SVCXPRT *xprt, struct socket *so,
116 SVCXPRT *xprt; local
293 xprt = rpctls_server_xprt;
305 sx_xlock(&xprt->xp_lock);
306 xprt->xp_tls = RPCTLS_FLAGS_HANDSHFAIL;
307 sx_xunlock(&xprt->xp_lock);
550 rpctls_server(SVCXPRT *xprt, struct socket *so, uint32_t *flags, uint64_t *sslp, argument
572 rpctls_server_xprt = xprt;
626 SVCXPRT *xprt; local
660 xprt
[all...]
/freebsd-13-stable/sys/fs/nfsclient/
H A Dnfs_clkrpc.c67 nfscb_program(struct svc_req *rqst, SVCXPRT *xprt) argument
116 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0 &&
188 SVCXPRT *xprt; local
202 xprt = svc_dg_create(nfscbd_pool, so, 0, 0);
204 xprt = svc_vc_create(nfscbd_pool, so, 0, 0);
205 if (xprt) {
208 svc_reg(xprt, NFS_CALLBCKPROG, NFSV4_CBVERS, nfscb_program,
210 SVC_RELEASE(xprt);
290 /* Wait for any xprt registrations to complete. */
/freebsd-13-stable/usr.sbin/yppush/
H A Dyppush_main.c374 SVCXPRT *xprt; local
389 xprt = svcudp_create(sock);
391 if (svc_register(xprt, prognum, 1,
403 job->port = xprt->xp_port;

Completed in 238 milliseconds

12