/freebsd-13-stable/usr.sbin/ypserv/ |
H A D | yp_svc_udp.c | 42 #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 D | yp_dnslookup.c | 112 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 D | svc_dg.c | 86 * 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 D | svc_vc.c | 91 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 D | svc.h | 423 * 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 D | svc_generic.c | 93 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 D | svc.c | 43 * 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 D | svc_auth.c | 182 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 D | clnt_vc.c | 646 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 D | clnt_bck.c | 196 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 D | clnt_rc.c | 414 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 D | svc.h | 172 * 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 D | svc.c | 43 * 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 D | svc_generic.c | 87 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 D | svc_vc.c | 88 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 D | svc_dg.c | 71 #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 D | svc_raw.c | 130 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 D | pmap_svc.c | 73 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 D | check_bound.c | 161 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 D | rpcb_svc_com.c | 75 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 D | security.c | 59 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 D | nfs_nfsdkrpc.c | 103 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 D | rpctls_impl.c | 85 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 D | nfs_clkrpc.c | 67 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 D | yppush_main.c | 374 SVCXPRT *xprt; local 389 xprt = svcudp_create(sock); 391 if (svc_register(xprt, prognum, 1, 403 job->port = xprt->xp_port;
|