Home
last modified time | relevance | path

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

12

/freebsd/crypto/krb5/src/include/gssrpc/
H A Dsvc.h123 #define SVC_RECV(xprt, msg) \ argument
124 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
125 #define svc_recv(xprt, msg) \ argument
126 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
128 #define SVC_STAT(xprt) \ argument
129 (*(xprt)->xp_ops->xp_stat)(xprt)
130 #define svc_stat(xprt) \ argument
131 (*(xprt)->xp_ops->xp_stat)(xprt)
133 #define SVC_GETARGS(xprt, xargs, argsp) \ argument
134 (*(xprt)->xp_ops->xp_getargs)((xprt), (xargs), (argsp))
[all …]
/freebsd/sys/rpc/
H A Dsvc_vc.c145 static bool_t svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in);
146 static bool_t svc_vc_rendezvous_control (SVCXPRT *xprt, const u_int rq,
154 static bool_t svc_vc_backchannel_control(SVCXPRT *xprt, const u_int rq,
208 SVCXPRT *xprt; in svc_vc_create() local
219 xprt = svc_vc_create_conn(pool, so, (struct sockaddr *)&ss); in svc_vc_create()
220 return (xprt); in svc_vc_create()
224 xprt = svc_xprt_alloc(); in svc_vc_create()
225 sx_init(&xprt->xp_lock, "xprt->xp_lock"); in svc_vc_create()
226 xprt->xp_pool = pool; in svc_vc_create()
227 xprt->xp_socket = so; in svc_vc_create()
[all …]
H A Dsvc_dg.c98 SVCXPRT *xprt; in svc_dg_create() local
118 xprt = svc_xprt_alloc(); in svc_dg_create()
119 sx_init(&xprt->xp_lock, "xprt->xp_lock"); in svc_dg_create()
120 xprt->xp_pool = pool; in svc_dg_create()
121 xprt->xp_socket = so; in svc_dg_create()
122 xprt->xp_p1 = NULL; in svc_dg_create()
123 xprt->xp_p2 = NULL; in svc_dg_create()
124 xprt->xp_ops = &svc_dg_ops; in svc_dg_create()
126 xprt->xp_ltaddr.ss_len = sizeof(xprt->xp_ltaddr); in svc_dg_create()
127 error = sosockaddr(so, (struct sockaddr *)&xprt->xp_ltaddr); in svc_dg_create()
[all …]
H A Dsvc.c75 static void xprt_unregister_locked(SVCXPRT *xprt);
186 SVCXPRT *xprt, *nxprt; in svcpool_cleanup() local
197 while ((xprt = TAILQ_FIRST(&grp->sg_xlist)) != NULL) { in svcpool_cleanup()
198 xprt_unregister_locked(xprt); in svcpool_cleanup()
199 TAILQ_INSERT_TAIL(&cleanup, xprt, xp_link); in svcpool_cleanup()
203 TAILQ_FOREACH_SAFE(xprt, &cleanup, xp_link, nxprt) { in svcpool_cleanup()
204 if (xprt->xp_socket != NULL) in svcpool_cleanup()
205 soshutdown(xprt->xp_socket, SHUT_WR); in svcpool_cleanup()
206 SVC_RELEASE(xprt); in svcpool_cleanup()
343 xprt_register(SVCXPRT *xprt) in xprt_register() argument
[all …]
H A Dsvc_generic.c84 SVCXPRT *xprt; in svc_tp_create() local
97 xprt = svc_tli_create(pool, nconf, &bind, 0, 0); in svc_tp_create()
100 xprt = svc_tli_create(pool, nconf, NULL, 0, 0); in svc_tp_create()
102 if (xprt == NULL) { in svc_tp_create()
108 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE) { in svc_tp_create()
113 xprt_unregister(xprt); in svc_tp_create()
114 SVC_RELEASE(xprt); in svc_tp_create()
117 return (xprt); in svc_tp_create()
138 SVCXPRT *xprt = NULL; /* service handle */ in svc_tli_create() local
188 xprt = svc_fd_create(fd, sendsz, recvsz); in svc_tli_create()
[all …]
H A Dsvc.h352 #define SVC_ACQUIRE(xprt) \ argument
353 refcount_acquire(&(xprt)->xp_refs)
355 #define SVC_RELEASE(xprt) \ argument
356 if (refcount_release(&(xprt)->xp_refs)) \
357 SVC_DESTROY(xprt)
359 #define SVC_RECV(xprt, msg, addr, args) \ argument
360 (*(xprt)->xp_ops->xp_recv)((xprt), (msg), (addr), (args))
362 #define SVC_STAT(xprt) \ argument
363 (*(xprt)->xp_ops->xp_stat)(xprt)
365 #define SVC_ACK(xprt, ack) \ argument
[all …]
H A Dsvc_auth.c177 SVCXPRT *xprt = rqst->rq_xprt; in svc_getcred() local
188 if ((xprt->xp_tls & (RPCTLS_FLAGS_CERTUSER | in svc_getcred()
191 if (xprt->xp_ngrps <= 0) in svc_getcred()
194 cr->cr_uid = cr->cr_ruid = cr->cr_svuid = xprt->xp_uid; in svc_getcred()
195 crsetgroups_and_egid(cr, xprt->xp_ngrps, xprt->xp_gidp, GID_NOGROUP); in svc_getcred()
/freebsd/crypto/krb5/src/lib/rpc/
H A Dsvc_tcp.c144 SVCXPRT *xprt; in svctcp_create() local
191 xprt = (SVCXPRT *)mem_alloc(sizeof(SVCXPRT)); in svctcp_create()
192 if (xprt == NULL) { in svctcp_create()
196 xprt->xp_p2 = NULL; in svctcp_create()
197 xprt->xp_p1 = (caddr_t)r; in svctcp_create()
198 xprt->xp_auth = NULL; in svctcp_create()
199 xprt->xp_verf = gssrpc__null_auth; in svctcp_create()
200 xprt->xp_ops = &svctcp_rendezvous_op; in svctcp_create()
201 xprt->xp_port = sa_getport(sa); in svctcp_create()
202 xprt->xp_sock = sock; in svctcp_create()
[all …]
H A Dsvc_udp.c59 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument
94 #define su_data(xprt) ((struct svcudp_data *)(xprt->xp_p2)) argument
116 SVCXPRT *xprt; in svcudp_bufcreate() local
150 xprt = (SVCXPRT *)mem_alloc(sizeof(SVCXPRT)); in svcudp_bufcreate()
151 if (xprt == NULL) { in svcudp_bufcreate()
161 if ((rpc_buffer(xprt) = mem_alloc(su->su_iosz)) == NULL) { in svcudp_bufcreate()
166 &(su->su_xdrs), rpc_buffer(xprt), su->su_iosz, XDR_DECODE); in svcudp_bufcreate()
168 xprt->xp_p2 = (caddr_t)su; in svcudp_bufcreate()
169 xprt->xp_auth = NULL; in svcudp_bufcreate()
170 xprt->xp_verf.oa_base = su->su_verfbody; in svcudp_bufcreate()
[all …]
H A Dsvc.c89 static void svc_do_xprt(SVCXPRT *xprt);
97 xprt_register(SVCXPRT *xprt) in xprt_register() argument
99 int sock = xprt->xp_sock; in xprt_register()
112 xports[sock] = xprt; in xprt_register()
119 xports[sock] = xprt; in xprt_register()
131 xprt_unregister(SVCXPRT *xprt) in xprt_unregister() argument
133 int sock = xprt->xp_sock; in xprt_unregister()
136 if ((sock < FD_SETSIZE) && (xports[sock] == xprt)) { in xprt_unregister()
141 if ((sock < NOFILE) && (xports[sock] == xprt)) { in xprt_unregister()
162 SVCXPRT *xprt, in svc_register() argument
[all …]
H A Dsvc_raw.c94 svcraw_stat(SVCXPRT *xprt) in svcraw_stat() argument
101 svcraw_recv(SVCXPRT *xprt, struct rpc_msg *msg) in svcraw_recv() argument
117 svcraw_reply(SVCXPRT *xprt, struct rpc_msg *msg) in svcraw_reply() argument
134 svcraw_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) in svcraw_getargs() argument
141 (void)svcraw_freeargs(xprt, xdr_args, args_ptr); in svcraw_getargs()
148 svcraw_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) in svcraw_freeargs() argument
161 svcraw_destroy(SVCXPRT *xprt) in svcraw_destroy() argument
/freebsd/lib/libc/rpc/
H A Dsvc.c87 static void __xprt_do_unregister (SVCXPRT *xprt, bool_t dolock);
95 xprt_register(SVCXPRT *xprt) in xprt_register() argument
99 assert(xprt != NULL); in xprt_register()
101 sock = xprt->xp_fd; in xprt_register()
114 __svc_xports[sock] = xprt; in xprt_register()
118 __svc_xports[sock] = xprt; in xprt_register()
123 xprt_unregister(SVCXPRT *xprt) in xprt_unregister() argument
125 __xprt_do_unregister(xprt, TRUE); in xprt_unregister()
129 __xprt_unregister_unlocked(SVCXPRT *xprt) in __xprt_unregister_unlocked() argument
131 __xprt_do_unregister(xprt, FALSE); in __xprt_unregister_unlocked()
[all …]
H A Dsvc_vc.c81 static bool_t svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in);
82 static bool_t svc_vc_rendezvous_control (SVCXPRT *xprt, const u_int rq,
122 SVCXPRT *xprt = NULL; in svc_vc_create() local
139 xprt = svc_xprt_alloc(); in svc_vc_create()
140 if (xprt == NULL) { in svc_vc_create()
144 xprt->xp_p1 = r; in svc_vc_create()
145 xprt->xp_verf = _null_auth; in svc_vc_create()
146 svc_vc_rendezvous_ops(xprt); in svc_vc_create()
147 xprt->xp_port = (u_short)-1; /* It is the rendezvouser */ in svc_vc_create()
148 xprt->xp_fd = fd; in svc_vc_create()
[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
123 xprt = svc_xprt_alloc(); in svc_dg_create()
124 if (xprt == NULL) in svc_dg_create()
131 if ((rpc_buffer(xprt) = mem_alloc(su->su_iosz)) == NULL) in svc_dg_create()
133 xdrmem_create(&(su->su_xdrs), rpc_buffer(xprt), su->su_iosz, in svc_dg_create()
136 xprt->xp_fd = fd; in svc_dg_create()
137 xprt->xp_p2 = su; in svc_dg_create()
138 xprt->xp_verf.oa_base = su->su_verfbody; in svc_dg_create()
[all …]
H A Dsvc_generic.c80 SVCXPRT *xprt; /* Server handle */ in svc_create() member
85 SVCXPRT *xprt; in svc_create() local
98 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) { in svc_create()
101 if (svc_reg(l->xprt, prognum, versnum, in svc_create()
114 xprt = svc_tp_create(dispatch, prognum, versnum, nconf); in svc_create()
115 if (xprt) { in svc_create()
123 l->xprt = xprt; in svc_create()
153 SVCXPRT *xprt; in svc_tp_create() local
161 xprt = svc_tli_create(RPC_ANYFD, nconf, NULL, 0, 0); in svc_tp_create()
162 if (xprt == NULL) { in svc_tp_create()
[all …]
H A Dsvc_nl.c95 SVCXPRT *xprt = NULL; in svc_nl_create() local
110 if ((xprt = svc_xprt_alloc()) == NULL) in svc_nl_create()
123 xprt->xp_fd = sc->snl.fd, in svc_nl_create()
124 xprt->xp_p1 = sc, in svc_nl_create()
125 xprt->xp_ops = &nl_ops, in svc_nl_create()
126 xprt->xp_ops2 = &nl_ops2, in svc_nl_create()
127 xprt->xp_rtaddr = (struct netbuf){ in svc_nl_create()
132 xprt_register(xprt); in svc_nl_create()
134 return (xprt); in svc_nl_create()
136 free(xprt); in svc_nl_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()
211 svc_raw_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, void *args_ptr) in svc_raw_freeargs() argument
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
[all …]
/freebsd/include/rpc/
H A Dsvc.h177 #define SVC_RECV(xprt, msg) \ argument
178 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
179 #define svc_recv(xprt, msg) \ argument
180 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
182 #define SVC_STAT(xprt) \ argument
183 (*(xprt)->xp_ops->xp_stat)(xprt)
184 #define svc_stat(xprt) \ argument
185 (*(xprt)->xp_ops->xp_stat)(xprt)
187 #define SVC_GETARGS(xprt, xargs, argsp) \ argument
188 (*(xprt)->xp_ops->xp_getargs)((xprt), (xargs), (argsp))
[all …]
/freebsd/usr.sbin/rpcbind/
H A Dpmap_svc.c64 pmap_service(struct svc_req *rqstp, SVCXPRT *xprt) in pmap_service() argument
76 check_access(xprt, rqstp->rq_proc, NULL, PMAPVERS); in pmap_service()
77 if ((!svc_sendreply(xprt, (xdrproc_t) xdr_void, NULL)) && in pmap_service()
89 pmapproc_change(rqstp, xprt, rqstp->rq_proc); in pmap_service()
96 pmapproc_change(rqstp, xprt, rqstp->rq_proc); in pmap_service()
104 pmapproc_getport(rqstp, xprt); in pmap_service()
115 pmapproc_dump(rqstp, xprt); in pmap_service()
126 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLIT, PMAPVERS); in pmap_service()
130 svcerr_noproc(xprt); in pmap_service()
162 pmapproc_change(struct svc_req *rqstp __unused, SVCXPRT *xprt, unsigned long op) in pmapproc_change() argument
[all …]
H A Drpcb_svc_com.c72 SVCXPRT *xprt; member
491 SVCXPRT *xprt; in create_rmtcall_fd() local
499 xprt = svc_tli_create(fd, 0, NULL, 0, 0); in create_rmtcall_fd()
500 if (xprt == NULL) { in create_rmtcall_fd()
511 rmt->xprt = xprt; in create_rmtcall_fd()
513 xprt->xp_netid = rmt->netid; in create_rmtcall_fd()
550 return (rmt->xprt); in find_rmtcallxprt_by_fd()
1182 SVCXPRT *xprt; in check_rmtcalls() local
1189 if ((xprt = find_rmtcallxprt_by_fd(pfds[j].fd)) != NULL) { in check_rmtcalls()
1196 __func__, pfds[j].fd, xprt->xp_netid); in check_rmtcalls()
[all …]
/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
295 xid = svcudp_set_xid(q->xprt, q->xid); in yp_send_dns_reply()
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()
299 if (!svc_sendreply(q->xprt, xdrfunc, result)) 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()
[all …]
/freebsd/sys/rpc/rpcsec_tls/
H A Drpctls_impl.c103 static enum clnt_stat rpctls_server(SVCXPRT *xprt, uint32_t *flags,
376 rpctls_server(SVCXPRT *xprt, uint32_t *flags, uid_t *uid, int *ngrps, in rpctls_server() argument
381 .so = xprt->xp_socket, in rpctls_server()
382 .xp = xprt, in rpctls_server()
397 arg.socookie = (uint64_t)xprt->xp_socket; in rpctls_server()
411 rpctls_rpc_failed(&ups, xprt->xp_socket); in rpctls_server()
435 SVCXPRT *xprt; in _svcauth_rpcsec_tls() local
476 xprt = rqst->rq_xprt; in _svcauth_rpcsec_tls()
477 sx_xlock(&xprt->xp_lock); in _svcauth_rpcsec_tls()
478 xprt->xp_dontrcv = TRUE; in _svcauth_rpcsec_tls()
[all …]
/freebsd/sys/fs/nfsserver/
H A Dnfs_nfsdkrpc.c100 static int nfs_proc(struct nfsrv_descript *, u_int32_t, SVCXPRT *xprt,
124 nfssvc_program(struct svc_req *rqst, SVCXPRT *xprt) in nfssvc_program() argument
311 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0) { in nfssvc_program()
313 if ((xprt->xp_tls & RPCTLS_FLAGS_VERIFIED) != 0) in nfssvc_program()
315 if ((xprt->xp_tls & RPCTLS_FLAGS_CERTUSER) != 0) in nfssvc_program()
354 if ((xprt->xp_tls & RPCTLS_FLAGS_HANDSHAKE) != 0 && in nfssvc_program()
358 cacherep = nfs_proc(&nd, rqst->rq_xid, xprt, &rp); in nfssvc_program()
395 SVC_ACK(xprt, NULL)), rqst->rq_reply_seq); in nfssvc_program()
411 nfs_proc(struct nfsrv_descript *nd, u_int32_t xid, SVCXPRT *xprt, in nfs_proc() argument
450 nd->nd_sockref = xprt->xp_sockref; in nfs_proc()
[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()

12