Home
last modified time | relevance | path

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

12

/freebsd/sys/rpc/
H A Dsvc_vc.c208 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 Dsvc_dg.c98 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 Dsvc.h444 (*(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 Dsvc.c206 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 Dsvc_generic.c86 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 Dsvc_auth.c176 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 Dclnt_vc.c639 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 Dclnt_bck.c189 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 Dclnt_rc.c419 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 Dsvc.h178 (*(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 Dsvc.c99 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 Dsvc_vc.c166 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 Dsvc_dg.c65 #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 Dsvc_generic.c85 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 Dsvc_raw.c122 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 Dpmap_svc.c104 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 Drpcb_svc_com.c72 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 Dcheck_bound.c152 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 Dsecurity.c58 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 Dyp_svc_udp.c40 #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 Dyp_dnslookup.c110 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 Dnfs_nfsdkrpc.c450 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 Drpctls_impl.c150 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 Dnfs_clkrpc.c65 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 Dyppush_main.c371 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()

12