/freebsd/sys/rpc/ |
H A D | svc_vc.c | 208 SVCXPRT *xprt; in svc_vc_create() local 220 return (xprt); in svc_vc_create() 232 xprt->xp_ltaddr.ss_len = sizeof(xprt->xp_ltaddr); in svc_vc_create() 247 return (xprt); in svc_vc_create() 262 SVCXPRT *xprt; in svc_vc_create_conn() local 311 xprt->xp_ltaddr.ss_len = sizeof(xprt->xp_ltaddr); in svc_vc_create_conn() 331 return (xprt); in svc_vc_create_conn() 359 return (xprt); in svc_vc_create_backchannel() 504 xprt->xp_sslusec, xprt->xp_sslrefno, in svc_vc_destroy_common() 516 (void) mem_free(xprt->xp_netid, strlen(xprt->xp_netid) + 1); in svc_vc_destroy_common() [all …]
|
H A D | svc_dg.c | 98 SVCXPRT *xprt; in svc_dg_create() local 122 xprt->xp_p1 = NULL; in svc_dg_create() 123 xprt->xp_p2 = NULL; in svc_dg_create() 126 xprt->xp_ltaddr.ss_len = sizeof(xprt->xp_ltaddr); in svc_dg_create() 131 xprt_register(xprt); in svc_dg_create() 137 return (xprt); in svc_dg_create() 140 svc_xprt_free(xprt); in svc_dg_create() 260 xprt->xp_p2 = NULL; in svc_dg_reply() 277 if (xprt->xp_netid) in svc_dg_destroy() 278 (void) mem_free(xprt->xp_netid, strlen(xprt->xp_netid) + 1); in svc_dg_destroy() [all …]
|
H A D | svc.h | 444 (*(xprt)->xp_ops->xp_stat)(xprt) 454 (*(xprt)->xp_ops->xp_destroy)(xprt) 457 (*(xprt)->xp_ops->xp_control)((xprt), (rq), (in)) 462 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 464 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 467 (*(xprt)->xp_ops->xp_stat)(xprt) 469 (*(xprt)->xp_ops->xp_stat)(xprt) 477 (*(xprt)->xp_ops->xp_reply) ((xprt), (msg)) 479 (*(xprt)->xp_ops->xp_reply) ((xprt), (msg)) 487 (*(xprt)->xp_ops->xp_destroy)(xprt) [all …]
|
H A D | svc.c | 206 SVC_RELEASE(xprt); in svcpool_cleanup() 349 SVC_ACQUIRE(xprt); in xprt_register() 393 SVC_RELEASE(xprt); in xprt_unregister() 888 SVCXPRT *xprt; in svc_xprt_alloc() local 893 xprt->xp_p3 = ext; in svc_xprt_alloc() 896 return (xprt); in svc_xprt_alloc() 1089 if (!xprt->xp_idletimeout || xprt->xp_thread) in svc_checkidle() 1092 timo = xprt->xp_lastactive + xprt->xp_idletimeout; in svc_checkidle() 1111 SVCXPRT *xprt; in svc_assign_waiting_sockets() local 1162 SVCXPRT *xprt; in svc_run_internal() local [all …]
|
H A D | svc_generic.c | 86 SVCXPRT *xprt; in svc_create() local 119 if (xprt == NULL) { in svc_create() 123 if (xprt) { in svc_create() 125 SVC_RELEASE(xprt); in svc_create() 154 SVCXPRT *xprt; in svc_tp_create() local 172 if (xprt == NULL) { in svc_tp_create() 184 SVC_RELEASE(xprt); in svc_tp_create() 187 return (xprt); in svc_tp_create() 297 if (xprt == NULL) in svc_tli_create() 310 return (xprt); in svc_tli_create() [all …]
|
H A D | svc_auth.c | 176 SVCXPRT *xprt = rqst->rq_xprt; in svc_getcred() local 187 if ((xprt->xp_tls & (RPCTLS_FLAGS_CERTUSER | in svc_getcred() 191 cr->cr_uid = cr->cr_ruid = cr->cr_svuid = xprt->xp_uid; in svc_getcred() 192 crsetgroups(cr, xprt->xp_ngrps, xprt->xp_gidp); in svc_getcred() 193 cr->cr_rgid = cr->cr_svgid = xprt->xp_gidp[0]; in svc_getcred()
|
H A D | clnt_vc.c | 639 SVCXPRT *xprt; in clnt_vc_control() local 757 SVC_ACQUIRE(xprt); in clnt_vc_control() 758 xprt->xp_p2 = ct; in clnt_vc_control() 861 SVCXPRT *xprt; in clnt_vc_destroy() local 869 if (xprt != NULL) { in clnt_vc_destroy() 873 xprt->xp_p2 = NULL; in clnt_vc_destroy() 875 SVC_RELEASE(xprt); in clnt_vc_destroy() 948 SVCXPRT *xprt; in clnt_vc_soupcall() local 1164 if (xprt == NULL) { in clnt_vc_soupcall() 1171 xprt->xp_p1; in clnt_vc_soupcall() [all …]
|
H A D | clnt_bck.c | 189 SVCXPRT *xprt) in clnt_bck_call() argument 300 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0) { in clnt_bck_call() 315 sx_xlock(&xprt->xp_lock); in clnt_bck_call() 316 error = sosend(xprt->xp_socket, NULL, NULL, mreq, NULL, 0, curthread); in clnt_bck_call() 321 SOCK_SENDBUF_LOCK(xprt->xp_socket); in clnt_bck_call() 322 sbwait(xprt->xp_socket, SO_SND); in clnt_bck_call() 323 SOCK_SENDBUF_UNLOCK(xprt->xp_socket); in clnt_bck_call() 324 sx_xunlock(&xprt->xp_lock); in clnt_bck_call() 330 sx_xunlock(&xprt->xp_lock); in clnt_bck_call()
|
H A D | clnt_rc.c | 419 SVCXPRT *xprt; in clnt_reconnect_control() local 504 xprt = (SVCXPRT *)info; in clnt_reconnect_control() 505 xprt_register(xprt); in clnt_reconnect_control() 569 SVCXPRT *xprt; in clnt_reconnect_destroy() local 574 xprt = (SVCXPRT *)rc->rc_backchannel; in clnt_reconnect_destroy() 575 KASSERT(xprt->xp_socket == NULL, in clnt_reconnect_destroy() 577 xprt_unregister(xprt); in clnt_reconnect_destroy() 578 SVC_RELEASE(xprt); in clnt_reconnect_destroy()
|
/freebsd/include/rpc/ |
H A D | svc.h | 178 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 180 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 183 (*(xprt)->xp_ops->xp_stat)(xprt) 185 (*(xprt)->xp_ops->xp_stat)(xprt) 188 (*(xprt)->xp_ops->xp_getargs)((xprt), (xargs), (argsp)) 190 (*(xprt)->xp_ops->xp_getargs)((xprt), (xargs), (argsp)) 193 (*(xprt)->xp_ops->xp_reply) ((xprt), (msg)) 195 (*(xprt)->xp_ops->xp_reply) ((xprt), (msg)) 203 (*(xprt)->xp_ops->xp_destroy)(xprt) 205 (*(xprt)->xp_ops->xp_destroy)(xprt) [all …]
|
/freebsd/lib/libc/rpc/ |
H A D | svc.c | 99 assert(xprt != NULL); in xprt_register() 101 sock = xprt->xp_fd; in xprt_register() 142 assert(xprt != NULL); in __xprt_do_unregister() 144 sock = xprt->xp_fd; in __xprt_do_unregister() 531 SVCXPRT *xprt; in svc_xprt_alloc() local 535 if (xprt == NULL) in svc_xprt_alloc() 544 xprt->xp_p3 = ext; in svc_xprt_alloc() 547 return (xprt); in svc_xprt_alloc() 612 SVCXPRT *xprt; in svc_getreq_common() local 628 if (xprt == NULL) in svc_getreq_common() [all …]
|
H A D | svc_vc.c | 166 return (xprt); in svc_vc_create() 168 if (xprt) in svc_vc_create() 169 mem_free(xprt, sizeof(*xprt)); in svc_vc_create() 236 SVCXPRT *xprt; in makefd_xprt() local 252 xprt = NULL; in makefd_xprt() 268 return (xprt); in makefd_xprt() 402 mem_free(xprt->xp_rtaddr.buf, xprt->xp_rtaddr.maxlen); in __svc_vc_dodestroy() 404 mem_free(xprt->xp_ltaddr.buf, xprt->xp_ltaddr.maxlen); in __svc_vc_dodestroy() 448 SVCXPRT *xprt; in read_vc() local 508 SVCXPRT *xprt; in write_vc() local [all …]
|
H A D | svc_dg.c | 65 #define su_data(xprt) ((struct svc_dg_data *)((xprt)->xp_p2)) argument 66 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument 103 SVCXPRT *xprt; in svc_dg_create() local 124 if (xprt == NULL) in svc_dg_create() 170 return (xprt); in svc_dg_create() 174 if (xprt) { in svc_dg_create() 266 mem_free(xprt->xp_rtaddr.buf, xprt->xp_rtaddr.len); in svc_dg_recv() 273 xprt->xp_raddr = *(struct sockaddr_in *)xprt->xp_rtaddr.buf; in svc_dg_recv() 355 if (svc_dg_sendto(xprt->xp_fd, rpc_buffer(xprt), slen, in svc_dg_reply() 402 (void) mem_free(xprt->xp_rtaddr.buf, xprt->xp_rtaddr.maxlen); in svc_dg_destroy() [all …]
|
H A D | svc_generic.c | 85 SVCXPRT *xprt; in svc_create() local 115 if (xprt) { in svc_create() 123 l->xprt = xprt; in svc_create() 153 SVCXPRT *xprt; in svc_tp_create() local 162 if (xprt == NULL) { in svc_tp_create() 172 SVC_DESTROY(xprt); in svc_tp_create() 175 return (xprt); in svc_tp_create() 286 if (xprt == NULL) in svc_tli_create() 300 return (xprt); in svc_tli_create() 305 if (xprt) { in svc_tli_create() [all …]
|
H A D | svc_raw.c | 122 svc_raw_stat(SVCXPRT *xprt) in svc_raw_stat() argument 129 svc_raw_recv(SVCXPRT *xprt, struct rpc_msg *msg) in svc_raw_recv() argument 153 svc_raw_reply(SVCXPRT *xprt, struct rpc_msg *msg) in svc_raw_reply() argument 180 SVCAUTH_WRAP(&SVC_AUTH(xprt), xdrs, xdr_proc, xdr_where); in svc_raw_reply() 193 svc_raw_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) in svc_raw_getargs() argument 205 return (SVCAUTH_UNWRAP(&SVC_AUTH(xprt), &srp->xdr_stream, in svc_raw_getargs() 231 svc_raw_destroy(SVCXPRT *xprt) in svc_raw_destroy() argument 237 svc_raw_control(SVCXPRT *xprt, const u_int rq, void *in) in svc_raw_control() argument 243 svc_raw_ops(SVCXPRT *xprt) in svc_raw_ops() argument 260 xprt->xp_ops = &ops; in svc_raw_ops() [all …]
|
/freebsd/usr.sbin/rpcbind/ |
H A D | pmap_svc.c | 104 pmapproc_getport(rqstp, xprt); in pmap_service() 115 pmapproc_dump(rqstp, xprt); in pmap_service() 130 svcerr_noproc(xprt); in pmap_service() 179 svcerr_decode(xprt); in pmapproc_change() 184 svcerr_weakauth(xprt); in pmapproc_change() 188 who = svc_getcaller(xprt); in pmapproc_change() 267 svcerr_decode(xprt); in pmapproc_getport() 272 svcerr_weakauth(xprt); in pmapproc_getport() 279 svc_getrpccaller(xprt)); in pmapproc_getport() 340 svcerr_decode(xprt); in pmapproc_dump() [all …]
|
H A D | rpcb_svc_com.c | 72 SVCXPRT *xprt; member 487 SVCXPRT *xprt; in create_rmtcall_fd() local 497 if (xprt == NULL) { in create_rmtcall_fd() 508 rmt->xprt = xprt; in create_rmtcall_fd() 510 xprt->xp_netid = rmt->netid; in create_rmtcall_fd() 547 return (rmt->xprt); in find_rmtcallxprt_by_fd() 1178 SVCXPRT *xprt; in check_rmtcalls() local 1222 xprt_set_caller(xprt, fi); in send_svcsyserr() 1223 svcerr_systemerr(xprt); in send_svcsyserr() 1285 send_svcsyserr(xprt, fi); in handle_reply() [all …]
|
H A D | check_bound.c | 152 mergeaddr(SVCXPRT *xprt, char *netid, char *uaddr, char *saddr) in mergeaddr() argument 176 callee = svc_getrpccallee(xprt); in mergeaddr() 183 c_uaddr = taddr2uaddr(fdl->nconf, svc_getrpccaller(xprt)); in mergeaddr() 207 m_uaddr = addrmerge(svc_getrpccaller(xprt), s_uaddr, c_uaddr, netid); in mergeaddr()
|
H A D | security.c | 58 check_access(SVCXPRT *xprt, rpcproc_t proc, void *args, unsigned int rpcbvers) in check_access() argument 60 struct netbuf *caller = svc_getrpccaller(xprt); in check_access() 227 check_callit(SVCXPRT *xprt, struct r_rmtcall_args *args, int versnum __unused) in check_callit() argument 229 struct sockaddr *sa = (struct sockaddr *)svc_getrpccaller(xprt)->buf; in check_callit()
|
/freebsd/usr.sbin/ypserv/ |
H A D | yp_svc_udp.c | 40 #define su_data(xprt) ((struct svc_dg_data *)((xprt)->xp_p2)) argument 49 svcudp_get_xid(SVCXPRT *xprt) in svcudp_get_xid() argument 53 if (xprt == NULL) in svcudp_get_xid() 55 su = su_data(xprt); in svcudp_get_xid() 60 svcudp_set_xid(SVCXPRT *xprt, unsigned long xid) in svcudp_set_xid() argument 65 if (xprt == NULL) in svcudp_set_xid() 67 su = su_data(xprt); in svcudp_set_xid()
|
H A D | yp_dnslookup.c | 110 SVCXPRT *xprt; member 296 client_addr = q->xprt->xp_raddr; in yp_send_dns_reply() 297 q->xprt->xp_raddr = q->client_addr; in yp_send_dns_reply() 307 svcudp_set_xid(q->xprt, xid); in yp_send_dns_reply() 308 q->xprt->xp_raddr = client_addr; in yp_send_dns_reply() 433 q->xprt = rqstp->rq_xprt; in yp_async_lookup_name() 437 q->xid = svcudp_get_xid(q->xprt); in yp_async_lookup_name() 438 q->client_addr = q->xprt->xp_raddr; in yp_async_lookup_name() 518 q->xprt = rqstp->rq_xprt; in yp_async_lookup_addr() 523 q->xid = svcudp_get_xid(q->xprt); in yp_async_lookup_addr() [all …]
|
/freebsd/sys/fs/nfsserver/ |
H A D | nfs_nfsdkrpc.c | 450 nd->nd_sockref = xprt->xp_sockref; in nfs_proc() 460 SVC_ACK(xprt, &ack); in nfs_proc() 473 nd->nd_xprt = xprt; in nfs_proc() 509 nfssvc_loss(SVCXPRT *xprt) in nfssvc_loss() argument 514 SVC_ACK(xprt, &ack); in nfssvc_loss() 516 nfsrc_trimcache(xprt->xp_sockref, ack, 1); in nfssvc_loss() 529 SVCXPRT *xprt; in nfsrvd_addsock() local 547 if (xprt) { in nfsrvd_addsock() 550 xprt->xp_sockref = ++sockref; in nfsrvd_addsock() 562 svc_loss_reg(xprt, nfssvc_loss); in nfsrvd_addsock() [all …]
|
/freebsd/sys/rpc/rpcsec_tls/ |
H A D | rpctls_impl.c | 150 SVCXPRT *xprt; in sys_rpctls_syscall() local 744 SVCXPRT *xprt; in _svcauth_rpcsec_tls() local 786 xprt = rqst->rq_xprt; in _svcauth_rpcsec_tls() 787 sx_xlock(&xprt->xp_lock); in _svcauth_rpcsec_tls() 788 xprt->xp_dontrcv = TRUE; in _svcauth_rpcsec_tls() 806 stat = rpctls_server(xprt, xprt->xp_socket, &flags, in _svcauth_rpcsec_tls() 810 sx_xlock(&xprt->xp_lock); in _svcauth_rpcsec_tls() 811 xprt->xp_dontrcv = FALSE; in _svcauth_rpcsec_tls() 813 xprt->xp_tls = flags; in _svcauth_rpcsec_tls() 821 xprt->xp_uid = uid; in _svcauth_rpcsec_tls() [all …]
|
/freebsd/sys/fs/nfsclient/ |
H A D | nfs_clkrpc.c | 65 nfscb_program(struct svc_req *rqst, SVCXPRT *xprt) in nfscb_program() argument 114 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0 && in nfscb_program() 186 SVCXPRT *xprt; in nfscbd_addsock() local 200 xprt = svc_dg_create(nfscbd_pool, so, 0, 0); in nfscbd_addsock() 202 xprt = svc_vc_create(nfscbd_pool, so, 0, 0); in nfscbd_addsock() 203 if (xprt) { in nfscbd_addsock() 206 svc_reg(xprt, NFS_CALLBCKPROG, NFSV4_CBVERS, nfscb_program, in nfscbd_addsock() 208 SVC_RELEASE(xprt); in nfscbd_addsock()
|
/freebsd/usr.sbin/yppush/ |
H A D | yppush_main.c | 371 SVCXPRT *xprt; in yp_push() local 386 xprt = svcudp_create(sock); in yp_push() 388 if (svc_register(xprt, prognum, 1, in yp_push() 400 job->port = xprt->xp_port; in yp_push()
|