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

12

/freebsd-10.3-release/usr.sbin/ypserv/
H A Dyp_svc_udp.c40 #define su_data(xprt) ((struct svc_dg_data *)(xprt->xp_p2))
49 svcudp_get_xid(SVCXPRT *xprt) argument
53 if (xprt == NULL)
55 su = su_data(xprt);
60 svcudp_set_xid(SVCXPRT *xprt, unsigned long xid) argument
65 if (xprt == NULL)
67 su = su_data(xprt);
H A Dyp_dnslookup.c110 SVCXPRT *xprt; member in struct:circleq_dnsentry
295 xid = svcudp_set_xid(q->xprt, q->xid);
296 client_addr = q->xprt->xp_raddr;
297 q->xprt->xp_raddr = q->client_addr;
299 if (!svc_sendreply(q->xprt, xdrfunc, result))
307 svcudp_set_xid(q->xprt, xid);
308 q->xprt->xp_raddr = client_addr;
439 q->xprt = rqstp->rq_xprt;
443 q->xid = svcudp_get_xid(q->xprt);
444 q->client_addr = q->xprt
[all...]
/freebsd-10.3-release/sys/rpc/
H A Dsvc_dg.c84 * xprt = svc_dg_create(sock, sendsize, recvsize);
86 * Once *xprt is initialized, it is registered.
100 SVCXPRT *xprt; local
119 xprt = svc_xprt_alloc();
120 sx_init(&xprt->xp_lock, "xprt->xp_lock");
121 xprt->xp_pool = pool;
122 xprt->xp_socket = so;
123 xprt->xp_p1 = NULL;
124 xprt
153 svc_dg_stat(SVCXPRT *xprt) argument
163 svc_dg_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
232 svc_dg_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument
272 svc_dg_destroy(SVCXPRT *xprt) argument
302 SVCXPRT *xprt = (SVCXPRT *) arg; local
[all...]
H A Dsvc.h413 * SVCXPRT *xprt;
420 #define SVC_ACQUIRE(xprt) \
421 refcount_acquire(&(xprt)->xp_refs)
423 #define SVC_RELEASE(xprt) \
424 if (refcount_release(&(xprt)->xp_refs)) \
425 SVC_DESTROY(xprt)
427 #define SVC_RECV(xprt, msg, addr, args) \
428 (*(xprt)->xp_ops->xp_recv)((xprt), (msg), (addr), (args))
430 #define SVC_STAT(xprt) \
[all...]
H A Dsvc_vc.c84 static bool_t svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in);
85 static bool_t svc_vc_rendezvous_control (SVCXPRT *xprt, const u_int rq,
93 static bool_t svc_vc_backchannel_control(SVCXPRT *xprt, const u_int rq,
128 * xprt = svc_vc_create(sock, send_buf_size, recv_buf_size);
131 * Once *xprt is initialized, it is registered as a transporter
146 SVCXPRT *xprt; local
158 xprt = svc_vc_create_conn(pool, so, sa);
160 return (xprt);
164 xprt = svc_xprt_alloc();
165 sx_init(&xprt
206 SVCXPRT *xprt = NULL; local
297 SVCXPRT *xprt = NULL; local
371 svc_vc_rendezvous_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
449 svc_vc_rendezvous_stat(SVCXPRT *xprt) argument
456 svc_vc_destroy_common(SVCXPRT *xprt) argument
474 svc_vc_rendezvous_destroy(SVCXPRT *xprt) argument
481 svc_vc_destroy(SVCXPRT *xprt) argument
495 svc_vc_backchannel_destroy(SVCXPRT *xprt) argument
512 svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in) argument
518 svc_vc_rendezvous_control(SVCXPRT *xprt, const u_int rq, void *in) argument
525 svc_vc_backchannel_control(SVCXPRT *xprt, const u_int rq, void *in) argument
532 svc_vc_stat(SVCXPRT *xprt) argument
551 svc_vc_ack(SVCXPRT *xprt, uint32_t *ack) argument
560 svc_vc_backchannel_stat(SVCXPRT *xprt) argument
578 svc_vc_process_pending(SVCXPRT *xprt) argument
654 svc_vc_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
795 svc_vc_backchannel_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument
833 svc_vc_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument
889 svc_vc_backchannel_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument
956 SVCXPRT *xprt = (SVCXPRT *) arg; local
[all...]
H A Dsvc_generic.c91 SVCXPRT *xprt; local
103 TAILQ_FOREACH(xprt, &grp->sg_xlist, xp_link) {
104 if (strcmp(xprt->xp_netid, nconf->nc_netid))
109 if (svc_reg(xprt, prognum, versnum,
124 if (xprt == NULL) {
126 xprt = svc_tp_create(pool, dispatch, prognum, versnum,
128 if (xprt) {
130 SVC_RELEASE(xprt);
159 SVCXPRT *xprt; local
172 xprt
213 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc.c41 * There are two sets of procedures here. The xprt routines are
75 static void xprt_unregister_locked(SVCXPRT *xprt);
181 SVCXPRT *xprt, *nxprt; local
192 while ((xprt = TAILQ_FIRST(&grp->sg_xlist)) != NULL) {
193 xprt_unregister_locked(xprt);
194 TAILQ_INSERT_TAIL(&cleanup, xprt, xp_link);
198 TAILQ_FOREACH_SAFE(xprt, &cleanup, xp_link, nxprt) {
199 SVC_RELEASE(xprt);
303 xprt_register(SVCXPRT *xprt) argument
305 SVCPOOL *pool = xprt
325 xprt_unregister_locked(SVCXPRT *xprt) argument
338 xprt_unregister(SVCXPRT *xprt) argument
358 xprt_assignthread(SVCXPRT *xprt) argument
391 xprt_active(SVCXPRT *xprt) argument
419 xprt_inactive_locked(SVCXPRT *xprt) argument
432 xprt_inactive(SVCXPRT *xprt) argument
446 xprt_inactive_self(SVCXPRT *xprt) argument
460 svc_reg(SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(struct svc_req *, SVCXPRT *), const struct netconfig *nconf) argument
549 svc_loss_reg(SVCXPRT *xprt, void (*dispatch)(SVCXPRT *)) argument
621 SVCXPRT *xprt = rqstp->rq_xprt; local
699 SVCXPRT *xprt = rqstp->rq_xprt; local
721 SVCXPRT *xprt = rqstp->rq_xprt; local
743 SVCXPRT *xprt = rqstp->rq_xprt; local
765 SVCXPRT *xprt = rqstp->rq_xprt; local
797 SVCXPRT *xprt = rqstp->rq_xprt; local
819 SVCXPRT *xprt = rqstp->rq_xprt; local
846 SVCXPRT *xprt; local
879 svc_getreq(SVCXPRT *xprt, struct svc_req **rqstp_ret) argument
975 SVCXPRT *xprt = rqstp->rq_xprt; local
1020 SVCXPRT *xprt, *nxprt; local
1051 SVCXPRT *xprt; local
1102 SVCXPRT *xprt; local
[all...]
H A Dclnt_rc.c369 SVCXPRT *xprt; local
452 xprt = (SVCXPRT *)info;
453 SVC_ACQUIRE(xprt);
454 xprt_register(xprt);
494 SVCXPRT *xprt; local
499 xprt = (SVCXPRT *)rc->rc_backchannel;
500 xprt_unregister(xprt);
501 SVC_RELEASE(xprt);
H A Dclnt_vc.c598 SVCXPRT *xprt; local
711 xprt = (SVCXPRT *)info;
713 xprt->xp_p2 = ct;
714 ct->ct_backchannelxprt = xprt;
783 SVCXPRT *xprt; local
788 xprt = ct->ct_backchannelxprt;
790 if (xprt != NULL) {
792 sx_xlock(&xprt->xp_lock);
794 xprt->xp_p2 = NULL;
795 xprt_unregister(xprt);
844 SVCXPRT *xprt; local
[all...]
/freebsd-10.3-release/include/rpc/
H A Dsvc.h169 * SVCXPRT *xprt;
174 #define SVC_RECV(xprt, msg) \
175 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
176 #define svc_recv(xprt, msg) \
177 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
179 #define SVC_STAT(xprt) \
180 (*(xprt)->xp_ops->xp_stat)(xprt)
[all...]
/freebsd-10.3-release/lib/libc/rpc/
H A Dsvc.c41 * There are two sets of procedures here. The xprt routines are
89 static void __xprt_do_unregister (SVCXPRT *xprt, bool_t dolock);
97 xprt_register(xprt)
98 SVCXPRT *xprt;
102 assert(xprt != NULL);
104 sock = xprt->xp_fd;
117 __svc_xports[sock] = xprt;
125 xprt_unregister(SVCXPRT *xprt) argument
127 __xprt_do_unregister(xprt, TRUE);
131 __xprt_unregister_unlocked(SVCXPRT *xprt) argument
563 SVCXPRT *xprt; local
648 SVCXPRT *xprt; local
[all...]
H A Dsvc_vc.c87 static bool_t svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in);
88 static bool_t svc_vc_rendezvous_control (SVCXPRT *xprt, const u_int rq,
91 struct cf_rendezvous { /* kept in xprt->xp_p1 for rendezvouser */
97 struct cf_conn { /* kept in xprt->xp_p1 for actual connection */
111 * xprt = svc_vc_create(sock, send_buf_size, recv_buf_size);
114 * Once *xprt is initialized, it is registered as a transporter
131 SVCXPRT *xprt; local
148 xprt = svc_xprt_alloc();
149 if (xprt == NULL) {
153 xprt
251 SVCXPRT *xprt; local
477 SVCXPRT *xprt; local
540 SVCXPRT *xprt; local
783 SVCXPRT *xprt, *least_active; local
[all...]
H A Dsvc_generic.c84 SVCXPRT *xprt; /* Server handle */ member in struct:xlist
89 SVCXPRT *xprt; local
102 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
105 if (svc_reg(l->xprt, prognum, versnum,
118 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
119 if (xprt) {
126 l->xprt = xprt;
154 SVCXPRT *xprt; local
162 xprt
196 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc_dg.c69 #define su_data(xprt) ((struct svc_dg_data *)(xprt->xp_p2))
70 #define rpc_buffer(xprt) ((xprt)->xp_p1)
90 * xprt = svc_dg_create(sock, sendsize, recvsize);
92 * Once *xprt is initialized, it is registered.
110 SVCXPRT *xprt; local
130 xprt = svc_xprt_alloc();
131 if (xprt == NULL)
138 if ((rpc_buffer(xprt)
[all...]
H A Dsvc_raw.c128 svc_raw_stat(xprt)
129 SVCXPRT *xprt; /* args needed to satisfy ANSI-C typechecking */
136 svc_raw_recv(xprt, msg)
137 SVCXPRT *xprt;
162 svc_raw_reply(xprt, msg)
163 SVCXPRT *xprt;
191 SVCAUTH_WRAP(&SVC_AUTH(xprt), xdrs, xdr_proc, xdr_where);
204 svc_raw_getargs(xprt, xdr_args, args_ptr)
205 SVCXPRT *xprt;
219 return (SVCAUTH_UNWRAP(&SVC_AUTH(xprt),
[all...]
/freebsd-10.3-release/contrib/netbsd-tests/fs/nfs/nfsservice/rpcbind/
H A Dpmap_svc.c70 pmap_service(struct svc_req *rqstp, SVCXPRT *xprt) argument
82 check_access(xprt, rqstp->rq_proc, NULL, PMAPVERS);
83 if ((!svc_sendreply(xprt, (xdrproc_t) xdr_void, NULL)) &&
95 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
102 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
110 pmapproc_getport(rqstp, xprt);
121 pmapproc_dump(rqstp, xprt);
132 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLIT, PMAPVERS);
136 svcerr_noproc(xprt);
168 pmapproc_change(struct svc_req *rqstp, SVCXPRT *xprt, unsigne argument
262 pmapproc_getport(struct svc_req *rqstp, SVCXPRT *xprt) argument
343 pmapproc_dump(struct svc_req *rqstp, SVCXPRT *xprt) argument
[all...]
H A Dcheck_bound.c160 mergeaddr(SVCXPRT *xprt, char *netid, char *uaddr, char *saddr) argument
181 c_uaddr = taddr2uaddr(fdl->nconf, svc_getrpccaller(xprt));
205 m_uaddr = addrmerge(svc_getrpccaller(xprt), s_uaddr, c_uaddr, netid);
H A Drpcb_svc_com.c75 SVCXPRT *xprt; member in struct:rmtcallfd_list
483 SVCXPRT *xprt; local
492 xprt = svc_tli_create(fd, 0, (struct t_bind *) 0, 0, 0);
493 if (xprt == NULL) {
505 rmt->xprt = xprt;
507 xprt->xp_netid = rmt->netid;
544 return (rmt->xprt);
1026 /* XXX may be too big, but can't access xprt array here */
1147 SVCXPRT *xprt; local
1175 xprt_set_caller(SVCXPRT *xprt, struct finfo *fi) argument
1188 send_svcsyserr(SVCXPRT *xprt, struct finfo *fi) argument
1198 handle_reply(int fd, SVCXPRT *xprt) argument
[all...]
H A Dsecurity.c60 check_access(SVCXPRT *xprt, rpcproc_t proc, void *args, int rpcbvers) argument
62 struct netbuf *caller = svc_getrpccaller(xprt);
227 check_callit(SVCXPRT *xprt, struct r_rmtcall_args *args, int versnum) argument
229 struct sockaddr *sa = (struct sockaddr *)svc_getrpccaller(xprt)->buf;
/freebsd-10.3-release/usr.sbin/rpcbind/
H A Dpmap_svc.c72 pmap_service(struct svc_req *rqstp, SVCXPRT *xprt) argument
84 check_access(xprt, rqstp->rq_proc, NULL, PMAPVERS);
85 if ((!svc_sendreply(xprt, (xdrproc_t) xdr_void, NULL)) &&
97 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
104 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
112 pmapproc_getport(rqstp, xprt);
123 pmapproc_dump(rqstp, xprt);
134 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLIT, PMAPVERS);
138 svcerr_noproc(xprt);
170 pmapproc_change(struct svc_req *rqstp __unused, SVCXPRT *xprt, unsigne argument
264 pmapproc_getport(struct svc_req *rqstp __unused, SVCXPRT *xprt) argument
345 pmapproc_dump(struct svc_req *rqstp __unused, SVCXPRT *xprt) argument
[all...]
H A Dcheck_bound.c160 mergeaddr(SVCXPRT *xprt, char *netid, char *uaddr, char *saddr) argument
181 c_uaddr = taddr2uaddr(fdl->nconf, svc_getrpccaller(xprt));
205 m_uaddr = addrmerge(svc_getrpccaller(xprt), s_uaddr, c_uaddr, netid);
H A Drpcb_svc_com.c73 SVCXPRT *xprt; member in struct:rmtcallfd_list
493 SVCXPRT *xprt; local
502 xprt = svc_tli_create(fd, 0, (struct t_bind *) 0, 0, 0);
503 if (xprt == NULL) {
514 rmt->xprt = xprt;
516 xprt->xp_netid = rmt->netid;
553 return (rmt->xprt);
1035 /* XXX may be too big, but can't access xprt array here */
1173 SVCXPRT *xprt; local
1201 xprt_set_caller(SVCXPRT *xprt, struct finfo *fi) argument
1214 send_svcsyserr(SVCXPRT *xprt, struct finfo *fi) argument
1224 handle_reply(int fd, SVCXPRT *xprt) argument
[all...]
/freebsd-10.3-release/sys/fs/nfsserver/
H A Dnfs_nfsdkrpc.c103 static int nfs_proc(struct nfsrv_descript *, u_int32_t, SVCXPRT *xprt,
115 nfssvc_program(struct svc_req *rqst, SVCXPRT *xprt) argument
258 cacherep = nfs_proc(&nd, rqst->rq_xid, xprt, &rp);
295 SVC_ACK(xprt, NULL)), rqst->rq_reply_seq);
310 nfs_proc(struct nfsrv_descript *nd, u_int32_t xid, SVCXPRT *xprt, argument
350 nd->nd_sockref = xprt->xp_sockref;
360 SVC_ACK(xprt, &ack);
361 nfsrc_trimcache(xprt->xp_sockref, ack, 0);
373 nd->nd_xprt = xprt;
405 nfssvc_loss(SVCXPRT *xprt) argument
423 SVCXPRT *xprt; local
[all...]
/freebsd-10.3-release/sys/fs/nfsclient/
H A Dnfs_clkrpc.c64 nfscb_program(struct svc_req *rqst, SVCXPRT *xprt) argument
175 SVCXPRT *xprt; local
189 xprt = svc_dg_create(nfscbd_pool, so, 0, 0);
191 xprt = svc_vc_create(nfscbd_pool, so, 0, 0);
192 if (xprt) {
195 svc_reg(xprt, NFS_CALLBCKPROG, NFSV4_CBVERS, nfscb_program,
197 SVC_RELEASE(xprt);
277 /* Wait for any xprt registrations to complete. */
/freebsd-10.3-release/sys/nfsserver/
H A Dnfs_srvkrpc.c253 nfssvc_program(struct svc_req *rqst, SVCXPRT *xprt) argument
391 SVCXPRT *xprt; local
405 xprt = svc_dg_create(nfsrv_pool, so, 0, 0);
407 xprt = svc_vc_create(nfsrv_pool, so, 0, 0);
408 if (xprt) {
411 svc_reg(xprt, NFS_PROG, NFS_VER2, nfssvc_program, NULL);
412 svc_reg(xprt, NFS_PROG, NFS_VER3, nfssvc_program, NULL);
413 SVC_RELEASE(xprt);

Completed in 128 milliseconds

12