/freebsd-10.1-release/usr.sbin/ypserv/ |
H A D | yp_svc_udp.c | 40 #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 D | yp_dnslookup.c | 110 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.1-release/sys/rpc/ |
H A D | svc_dg.c | 84 * 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 D | svc.h | 413 * 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 D | svc_vc.c | 84 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 156 xprt = svc_vc_create_conn(pool, so, sa); 158 return (xprt); 162 xprt = svc_xprt_alloc(); 163 sx_init(&xprt 202 SVCXPRT *xprt = NULL; local 291 SVCXPRT *xprt = NULL; local 365 svc_vc_rendezvous_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument 443 svc_vc_rendezvous_stat(SVCXPRT *xprt) argument 450 svc_vc_destroy_common(SVCXPRT *xprt) argument 468 svc_vc_rendezvous_destroy(SVCXPRT *xprt) argument 475 svc_vc_destroy(SVCXPRT *xprt) argument 489 svc_vc_backchannel_destroy(SVCXPRT *xprt) argument 506 svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in) argument 512 svc_vc_rendezvous_control(SVCXPRT *xprt, const u_int rq, void *in) argument 519 svc_vc_backchannel_control(SVCXPRT *xprt, const u_int rq, void *in) argument 526 svc_vc_stat(SVCXPRT *xprt) argument 545 svc_vc_ack(SVCXPRT *xprt, uint32_t *ack) argument 554 svc_vc_backchannel_stat(SVCXPRT *xprt) argument 572 svc_vc_process_pending(SVCXPRT *xprt) argument 648 svc_vc_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument 789 svc_vc_backchannel_recv(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr **addrp, struct mbuf **mp) argument 827 svc_vc_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument 883 svc_vc_backchannel_reply(SVCXPRT *xprt, struct rpc_msg *msg, struct sockaddr *addr, struct mbuf *m, uint32_t *seq) argument 950 SVCXPRT *xprt = (SVCXPRT *) arg; local [all...] |
H A D | svc_generic.c | 91 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 D | svc.c | 41 * There are two sets of procedures here. The xprt routines are 75 static void xprt_unregister_locked(SVCXPRT *xprt); 180 SVCXPRT *xprt, *nxprt; local 191 while ((xprt = TAILQ_FIRST(&grp->sg_xlist)) != NULL) { 192 xprt_unregister_locked(xprt); 193 TAILQ_INSERT_TAIL(&cleanup, xprt, xp_link); 197 TAILQ_FOREACH_SAFE(xprt, &cleanup, xp_link, nxprt) { 198 SVC_RELEASE(xprt); 302 xprt_register(SVCXPRT *xprt) argument 304 SVCPOOL *pool = xprt 324 xprt_unregister_locked(SVCXPRT *xprt) argument 337 xprt_unregister(SVCXPRT *xprt) argument 357 xprt_assignthread(SVCXPRT *xprt) argument 390 xprt_active(SVCXPRT *xprt) argument 418 xprt_inactive_locked(SVCXPRT *xprt) argument 431 xprt_inactive(SVCXPRT *xprt) argument 445 xprt_inactive_self(SVCXPRT *xprt) argument 459 svc_reg(SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(struct svc_req *, SVCXPRT *), const struct netconfig *nconf) argument 548 svc_loss_reg(SVCXPRT *xprt, void (*dispatch)(SVCXPRT *)) argument 620 SVCXPRT *xprt = rqstp->rq_xprt; local 698 SVCXPRT *xprt = rqstp->rq_xprt; local 720 SVCXPRT *xprt = rqstp->rq_xprt; local 742 SVCXPRT *xprt = rqstp->rq_xprt; local 764 SVCXPRT *xprt = rqstp->rq_xprt; local 796 SVCXPRT *xprt = rqstp->rq_xprt; local 818 SVCXPRT *xprt = rqstp->rq_xprt; local 845 SVCXPRT *xprt; local 878 svc_getreq(SVCXPRT *xprt, struct svc_req **rqstp_ret) argument 974 SVCXPRT *xprt = rqstp->rq_xprt; local 1019 SVCXPRT *xprt, *nxprt; local 1050 SVCXPRT *xprt; local 1101 SVCXPRT *xprt; local [all...] |
H A D | clnt_rc.c | 369 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 D | clnt_vc.c | 598 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...] |
H A D | clnt_bck.c | 197 SVCXPRT *xprt) 307 sx_xlock(&xprt->xp_lock); 308 error = sosend(xprt->xp_socket, NULL, NULL, mreq, NULL, 0, curthread); 313 SOCKBUF_LOCK(&xprt->xp_socket->so_snd); 314 sbwait(&xprt->xp_socket->so_snd); 315 SOCKBUF_UNLOCK(&xprt->xp_socket->so_snd); 316 sx_xunlock(&xprt->xp_lock); 322 sx_xunlock(&xprt->xp_lock); 190 clnt_bck_call( CLIENT *cl, struct rpc_callextra *ext, rpcproc_t proc, struct mbuf *args, struct mbuf **resultsp, struct timeval utimeout, SVCXPRT *xprt) argument
|
/freebsd-10.1-release/include/rpc/ |
H A D | svc.h | 169 * 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.1-release/lib/libc/rpc/ |
H A D | svc.c | 41 * 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 565 SVCXPRT *xprt; local 650 SVCXPRT *xprt; local [all...] |
H A D | svc_vc.c | 87 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 465 SVCXPRT *xprt; local 528 SVCXPRT *xprt; local 771 SVCXPRT *xprt, *least_active; local [all...] |
H A D | svc_generic.c | 84 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 D | svc_dg.c | 69 #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 D | svc_raw.c | 128 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.1-release/usr.sbin/rpcbind/ |
H A D | pmap_svc.c | 72 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 D | check_bound.c | 160 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 D | rpcb_svc_com.c | 73 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...] |
H A D | security.c | 62 check_access(SVCXPRT *xprt, rpcproc_t proc, void *args, unsigned int rpcbvers) argument 64 struct netbuf *caller = svc_getrpccaller(xprt); 229 check_callit(SVCXPRT *xprt, struct r_rmtcall_args *args, int versnum __unused) argument 231 struct sockaddr *sa = (struct sockaddr *)svc_getrpccaller(xprt)->buf;
|
/freebsd-10.1-release/sys/fs/nfsserver/ |
H A D | nfs_nfsdkrpc.c | 100 static int nfs_proc(struct nfsrv_descript *, u_int32_t, SVCXPRT *xprt, 112 nfssvc_program(struct svc_req *rqst, SVCXPRT *xprt) argument 254 cacherep = nfs_proc(&nd, rqst->rq_xid, xprt, &rp); 291 SVC_ACK(xprt, NULL)), rqst->rq_reply_seq); 304 nfs_proc(struct nfsrv_descript *nd, u_int32_t xid, SVCXPRT *xprt, argument 344 nd->nd_sockref = xprt->xp_sockref; 354 SVC_ACK(xprt, &ack); 355 nfsrc_trimcache(xprt->xp_sockref, ack, 0); 367 nd->nd_xprt = xprt; 399 nfssvc_loss(SVCXPRT *xprt) argument 417 SVCXPRT *xprt; local [all...] |
/freebsd-10.1-release/sys/fs/nfsclient/ |
H A D | nfs_clkrpc.c | 64 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.1-release/sys/nfsserver/ |
H A D | nfs_srvkrpc.c | 253 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);
|
/freebsd-10.1-release/contrib/amd/conf/transp/ |
H A D | transp_sockets.c | 226 amu_svc_getcaller(SVCXPRT *xprt) argument 229 return (struct sockaddr_in *) svc_getcaller(xprt); 237 amu_svc_register(SVCXPRT *xprt, u_long prognum, u_long versnum, argument 241 return svc_register(xprt, prognum, versnum, dispatch, protocol);
|
/freebsd-10.1-release/usr.sbin/yppush/ |
H A D | yppush_main.c | 373 SVCXPRT *xprt; local 388 xprt = svcudp_create(sock); 390 if (svc_register(xprt, prognum, 1, 402 job->port = xprt->xp_port;
|