/illumos-gate/usr/src/ucblib/librpcsoc/ |
H A D | svc_tcp.c | 163 xprt->xp_rtaddr.buf = xprt->xp_raddr; 165 return (xprt); 215 xprt->xp_rtaddr.buf = xprt->xp_raddr; 218 return (xprt); 252 SVCXPRT *xprt; in rendezvous_stat() 341 svctcp_stat(xprt) in svctcp_stat() argument 342 SVCXPRT *xprt; in svctcp_stat() 356 SVCXPRT *xprt; in svctcp_recv() 374 SVCXPRT *xprt; in svctcp_getargs() 385 SVCXPRT *xprt; in svctcp_freeargs() [all …]
|
H A D | svc_udp.c | 55 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument 87 #define su_data(xprt) ((struct svcudp_data *)(xprt->xp_p2)) argument 167 xprt->xp_rtaddr.buf = &xprt->xp_raddr[0]; 169 return (xprt); 182 SVCXPRT *xprt; in svcudp_stat() 238 if (_sendto(xprt->xp_sock, rpc_buffer(xprt), slen, 0, 239 (struct sockaddr *)&(xprt->xp_raddr), xprt->xp_addrlen) 252 SVCXPRT *xprt; in svcudp_getargs() 262 SVCXPRT *xprt; in svcudp_freeargs() 405 SVCXPRT *xprt; in cache_set() [all …]
|
/illumos-gate/usr/src/lib/libnsl/rpc/ |
H A D | svc_vc.c | 161 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL; in svc_vc_xprtfree() 166 if (!xprt) in svc_vc_xprtfree() 201 SVCXPRT *xprt; in svc_vc_create_private() local 286 return (xprt); in svc_vc_create_private() 450 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL; in svc_fd_xprtfree() 454 if (!xprt) in svc_fd_xprtfree() 722 do_accept(xprt->xp_fd, tpname, xprt->xp_netid, r); in rendezvous_request() 1083 if (xprt) in do_accept() 1160 xprt = SVCEXT(xprt)->parent; in _svc_vc_destroy_private() 1176 cb(xprt, (xprt->xp_rtaddr.len != 0)); in _svc_vc_destroy_private() [all …]
|
H A D | svc_door.c | 86 #define su_data(xprt) ((struct svc_door_data *)(xprt->xp_p2)) argument 104 l->xprt = xprt; in __svc_add_to_xlist() 122 if ((*l)->xprt == xprt) { in __svc_rm_from_xlist() 299 struct svc_door_data *su = xprt ? su_data(xprt) : NULL; in svc_door_xprtfree() 427 return (xprt); in svc_door_create() 433 if (xprt) in svc_door_create() 489 return (xprt); in svc_door_xprtcopy() 506 xprt = xret->xprt; in get_xprt_copy() 512 if (xprt) { in get_xprt_copy() 520 return (xprt); in get_xprt_copy() [all …]
|
H A D | svc_dg.c | 70 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument 96 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL; in svc_dg_xprtfree() 98 struct svc_dg_data *su = xprt ? get_svc_dg_data(xprt) : NULL; in svc_dg_xprtfree() 123 SVCXPRT *xprt; in svc_dg_create_private() local 178 return (xprt); in svc_dg_create_private() 181 if (xprt) in svc_dg_create_private() 189 SVCXPRT *xprt; in svc_dg_create() local 193 return (xprt); in svc_dg_create() 235 xprt->xp_rtaddr.buf = malloc(xprt->xp_rtaddr.maxlen); in svc_dg_xprtcopy() 266 return (xprt); in svc_dg_xprtcopy() [all …]
|
H A D | svc_generic.c | 119 SVCXPRT *xprt; in svc_create() local 161 if (xprt) { in svc_create() 228 SVCXPRT *xprt; in svc_tp_create_bind() local 242 if (xprt == NULL) in svc_tp_create_bind() 250 SVC_DESTROY(xprt); in svc_tp_create_bind() 253 return (xprt); in svc_tp_create_bind() 576 if (xprt == NULL) in svc_tli_create_common() 597 if ((xprt->xp_rtaddr.buf = malloc(xprt->xp_rtaddr.maxlen)) == NULL) { in svc_tli_create_common() 626 return (xprt); in svc_tli_create_common() 633 if (xprt) { in svc_tli_create_common() [all …]
|
H A D | svc_run.c | 263 SVCXPRT *xprt; in svc_exit() local 276 xprt = svc_xports[fd]; in svc_exit() 277 if (xprt) { in svc_exit() 278 SVC_DESTROY(xprt); in svc_exit() 849 SVCXPRT *xprt; in make_xprt_copy() local 858 xprt = xret->xprt; in make_xprt_copy() 864 if (xprt) { in make_xprt_copy() 871 return (xprt); in make_xprt_copy() 908 if (svc_failed(xprt) || svc_defunct(xprt)) { in _svc_done_private() 919 svc_done(SVCXPRT *xprt) in svc_done() argument [all …]
|
H A D | svc.c | 877 } else if ((tnconf = __rpcfd_to_nconf(xprt->xp_fd, xprt->xp_type)) in svc_reg() 985 __rpcfd_to_nconf(xprt->xp_fd, xprt->xp_type)) != NULL)) { in svc_register() 1331 SVCXPRT *xprt; in svc_getreq_common() local 1415 r->rq_xprt = xprt; in _svc_prog_dispatch() 1509 xlist->xprt = xprt; in svc_xprt_alloc() 1525 return (xprt); in svc_xprt_alloc() 1540 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL; in svc_xprt_free() 1546 if (xprt) in svc_xprt_free() 1547 free(xprt); in svc_xprt_free() 1573 xprt = SVCEXT(xprt)->parent; in svc_xprt_destroy() [all …]
|
H A D | svid_funcs.c | 105 svc_control(SVCXPRT *xprt, const uint_t rq, void *in) in svc_control() argument 109 *((int *)in) = __svc_versquiet_get(xprt); in svc_control() 113 __svc_versquiet_off(xprt); in svc_control() 115 __svc_versquiet_on(xprt); in svc_control() 118 return ((*(xprt)->xp_ops->xp_control)(xprt, rq, in)); in svc_control() 123 svc_destroy(SVCXPRT *xprt) in svc_destroy() argument 125 (*(xprt)->xp_ops->xp_destroy)(xprt); in svc_destroy() 131 return ((*(xprt)->xp_ops->xp_freeargs)(xprt, xargs, argsp)); in svc_freeargs() 137 return ((*(xprt)->xp_ops->xp_getargs)(xprt, xargs, argsp)); in svc_getargs() 141 svc_getrpccaller(SVCXPRT *xprt) in svc_getrpccaller() argument [all …]
|
/illumos-gate/usr/src/uts/common/rpc/ |
H A D | svc_gen.c | 181 xprt->xp_full = FALSE; in svc_tli_kcreate() 183 xprt->xp_reqs = 0; in svc_tli_kcreate() 184 xprt->xp_size = 0; in svc_tli_kcreate() 188 xprt->xp_threads = 0; in svc_tli_kcreate() 190 xprt->xp_fp = fp; in svc_tli_kcreate() 191 xprt->xp_wq = wq; in svc_tli_kcreate() 193 xprt->xp_sct = sct; in svc_tli_kcreate() 216 SVC_DESTROY(xprt); in svc_tli_kcreate() 226 vp[0] = xprt; in svc_tli_kcreate() 238 *nxprt = xprt; in svc_tli_kcreate() [all …]
|
H A D | svc.c | 805 pool->p_lhead = xprt->xp_prev = xprt->xp_next = xprt; in svc_xprt_register() 841 if (xprt == xprt->xp_next) in svc_xprt_unregister() 854 xprt->xp_next = xprt->xp_prev = NULL; in svc_xprt_unregister() 1008 (*(xprt->xp_closeproc)) (xprt); in svc_xprt_cleanup() 1011 if (xprt->xp_threads + xprt->xp_detached_threads > 0) in svc_xprt_cleanup() 1015 svc_xprt_qdelete(xprt->xp_pool, xprt); in svc_xprt_cleanup() 1532 ASSERT(xprt->xp_threads + xprt->xp_detached_threads > 0); in svc_clone_unlinkdetached() 1851 if (xprt && xprt->xp_req_head && (!pool->p_qoverflow || in svc_poll() 1947 next = xprt ? xprt->xp_next : pool->p_lhead; in svc_poll() 2043 if (xprt && xprt->xp_wq == NULL) in svc_poll() [all …]
|
H A D | svc.h | 543 (*(xprt)->xp_ops->xp_hold)((xprt)->xp_wq) 574 (*(xprt)->xp_ops->xp_destroy)(xprt) 601 (*(xprt)->xp_ops->xp_start)(xprt) 606 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 608 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 611 (*(xprt)->xp_ops->xp_stat)(xprt) 613 (*(xprt)->xp_ops->xp_stat)(xprt) 636 (*(xprt)->xp_ops->xp_freeres)(xprt) 638 (*(xprt)->xp_ops->xp_freeres)(xprt) 641 (*(xprt)->xp_ops->xp_destroy)(xprt) [all …]
|
H A D | svc_mt.h | 53 #define svc_flags(xprt) (SVCEXT(xprt)->flags) argument 54 #define version_keepquiet(xprt) (svc_flags(xprt) & SVC_VERSQUIET) argument 55 #define svc_defunct(xprt) ((svc_flags(xprt) & SVC_DEFUNCT) ? TRUE : FALSE) argument 56 #define svc_failed(xprt) ((svc_flags(xprt) & SVC_FAILED) ? TRUE : FALSE) argument 57 #define svc_type(xprt) (svc_flags(xprt) & SVC_TYPE_MASK) argument 58 #define svc_send_mutex(xprt) (SVCEXT(xprt)->send_mutex) argument 94 SVCXPRT *xprt; member 110 #define SVCEXT(xprt) ((SVCXPRT_EXT *)((xprt)->xp_p3)) argument 111 #define SVC_XP_AUTH(xprt) (SVCEXT(xprt)->xp_auth) argument
|
H A D | svc_cots.c | 197 SVCMASTERXPRT *xprt; in svc_cots_kcreate() local 223 xprt->xp_ops = &svc_cots_op; in svc_cots_kcreate() 224 xprt->xp_p2 = (caddr_t)cmd; in svc_cots_kcreate() 267 *nxprt = xprt; in svc_cots_kcreate() 283 if (xprt->xp_netid) in svc_cots_kdestroy() 284 kmem_free(xprt->xp_netid, strlen(xprt->xp_netid) + 1); in svc_cots_kdestroy() 285 if (xprt->xp_addrmask.maxlen) in svc_cots_kdestroy() 286 kmem_free(xprt->xp_addrmask.buf, xprt->xp_addrmask.maxlen); in svc_cots_kdestroy() 314 xprt->xp_wq != NULL) { in svc_cots_kstart() 315 (*mir_start)(xprt->xp_wq); in svc_cots_kstart() [all …]
|
H A D | svc_rdma.c | 205 SVCMASTERXPRT *xprt; in svc_rdma_kcreate() local 257 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP); in svc_rdma_kcreate() 259 xprt->xp_sct = sct; in svc_rdma_kcreate() 267 xprt->xp_reqs = 0; in svc_rdma_kcreate() 268 xprt->xp_size = 0; in svc_rdma_kcreate() 269 xprt->xp_threads = 0; in svc_rdma_kcreate() 274 rd->rd_xprt = xprt; in svc_rdma_kcreate() 278 xprt->xp_wq = q; in svc_rdma_kcreate() 294 SVC_START(xprt); in svc_rdma_kcreate() 315 SVC_DESTROY(xprt); in svc_rdma_kcreate() [all …]
|
H A D | svc_clts.c | 165 SVCMASTERXPRT *xprt; in svc_clts_kcreate() local 174 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP); in svc_clts_kcreate() 177 xprt->xp_ops = &svc_clts_op; in svc_clts_kcreate() 180 xprt->xp_rtaddr.buf = NULL; in svc_clts_kcreate() 182 xprt->xp_rtaddr.len = 0; in svc_clts_kcreate() 184 *nxprt = xprt; in svc_clts_kcreate() 196 if (xprt->xp_netid) in svc_clts_kdestroy() 197 kmem_free(xprt->xp_netid, strlen(xprt->xp_netid) + 1); in svc_clts_kdestroy() 198 if (xprt->xp_addrmask.maxlen) in svc_clts_kdestroy() 199 kmem_free(xprt->xp_addrmask.buf, xprt->xp_addrmask.maxlen); in svc_clts_kdestroy() [all …]
|
/illumos-gate/usr/src/cmd/rpcbind/ |
H A D | pmap_svc.c | 77 PMAP_CHECK(xprt, rqstp->rq_proc); in pmap_service() 106 pmapproc_getport(rqstp, xprt); in pmap_service() 113 PMAP_CHECK(xprt, rqstp->rq_proc); in pmap_service() 114 pmapproc_dump(rqstp, xprt); in pmap_service() 129 PMAP_CHECK(xprt, rqstp->rq_proc); in pmap_service() 130 svcerr_noproc(xprt); in pmap_service() 175 svcerr_decode(xprt); in pmapproc_change() 181 if (!localxprt(xprt, B_TRUE)) { in pmapproc_change() 224 PMAP_LOG(ans, xprt, op, reg.pm_prog); in pmapproc_change() 250 svcerr_decode(xprt); in pmapproc_getport() [all …]
|
H A D | rpcbind.h | 93 #define RPCB_CHECK(xprt, proc) \ argument 95 !rpcb_check((xprt), (proc), B_FALSE)) \ 98 #define PMAP_CHECK(xprt, proc) \ argument 100 !rpcb_check((xprt), (proc), B_TRUE)) \ 103 #define PMAP_CHECK_RET(xprt, proc, ret) \ argument 105 !rpcb_check((xprt), (proc), B_TRUE)) \ 108 #define RPCB_LOG(xprt, proc, prog) \ argument 112 #define PMAP_LOG(ans, xprt, proc, prog) \ argument 114 rpcb_log(ans, (xprt), (proc), (prog), B_TRUE) 133 void pmap_service(struct svc_req *, SVCXPRT *xprt); [all …]
|
/illumos-gate/usr/src/cmd/ypcmd/ |
H A D | ypserv_resolv_common.h | 44 #define GETCALLER(xprt) svc_getcaller(xprt) argument 45 #define SETCALLER(xprt, addrp) *(svc_getcaller(xprt)) = *addrp; argument 53 #define get_svc_dg_data(xprt) ((struct svc_dg_data *)(xprt->xp_p2)) argument 60 #define GETCALLER(xprt) svc_getrpccaller(xprt) 61 #define SETCALLER(xprt, nbufp) xprt->xp_rtaddr.len = nbufp->len; \ 62 (void) memcpy(xprt->xp_rtaddr.buf, nbufp->buf, nbufp->len); 84 extern ulong_t svc_getxid(SVCXPRT *xprt);
|
H A D | ypserv_resolv.c | 73 SVCXPRT *xprt = NULL; in setup_resolv() local 140 if (xprt) in setup_resolv() 141 svc_destroy(xprt); in setup_resolv() 213 *xprt = NULL; in getprognum() 234 if (*xprt == NULL) in getprognum() 236 port = (*xprt)->xp_port; in getprognum() 237 fd = (*xprt)->xp_sock; in getprognum() 248 nb = &(*xprt)->xp_ltaddr; in getprognum() 249 fd = (*xprt)->xp_fd; in getprognum() 331 addrp = svc_getcaller(xprt); in resolv_req() [all …]
|
/illumos-gate/usr/src/cmd/mdb/common/modules/nfs/ |
H A D | svc.c | 166 svc_print_masterxprt(SVCMASTERXPRT *xprt) in svc_print_masterxprt() argument 175 common_netbuf_str(&xprt->xp_rtaddr)); in svc_print_masterxprt() 179 common_mutex(&xprt->xp_req_lock)); in svc_print_masterxprt() 182 xprt->xp_threads); in svc_print_masterxprt() 184 xprt->xp_detached_threads); in svc_print_masterxprt() 186 common_mutex(&xprt->xp_thread_lock)); in svc_print_masterxprt() 192 SVCMASTERXPRT xprt; in svc_mxprt_dcmd() local 214 if (mdb_vread(&xprt, sizeof (xprt), addr) == -1) { in svc_mxprt_dcmd() 219 svc_print_masterxprt(&xprt); in svc_mxprt_dcmd() 324 SVCMASTERXPRT xprt; in svc_mxprt_walk_step() local [all …]
|
/illumos-gate/usr/src/cmd/keyserv/ |
H A D | key_generic.c | 74 SVCXPRT *xprt; /* Server handle */ member 79 SVCXPRT *xprt; variable 96 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) { 99 if (svc_reg(l->xprt, prognum, versnum, 156 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0); 159 if (xprt) { 161 if (svc_reg(xprt, prognum, versnum, 166 SVC_DESTROY(xprt); 173 SVC_DESTROY(xprt); 176 l->xprt = xprt;
|
/illumos-gate/usr/src/cmd/fs.d/nfs/tests/test_svc_tp_create/ |
H A D | test_svc_tp_create.c | 93 SVCXPRT *xprt = NULL; in test_svc_tp_create() local 114 xprt = svc_tp_create_addr(mysvc, TESTPROG, vers, in test_svc_tp_create() 118 if (xprt == NULL) { in test_svc_tp_create() 125 if (xprt == NULL) { in test_svc_tp_create() 131 xprt = svc_tp_create(mysvc, TESTPROG, vers, nconf); in test_svc_tp_create() 133 if (xprt == NULL) { in test_svc_tp_create() 144 if (!svc_reg(xprt, TESTPROG, vers, mysvc, nconf)) { in test_svc_tp_create() 284 mysvc(struct svc_req *rq, SVCXPRT *xprt) in mysvc() argument 290 (void) svc_sendreply(xprt, xdr_void, (char *)0); in mysvc() 294 svcerr_noproc(xprt); in mysvc()
|
/illumos-gate/usr/src/lib/libbsm/common/ |
H A D | audit_kadmind.c | 95 SVCXPRT *xprt, /* net transport handle */ in common_audit() argument 145 netbuf2pm(svc_getrpccaller(xprt), &r_port, &machine); in common_audit() 159 SVCXPRT *xprt, in audit_kadmind_auth() argument 166 common_audit(AUE_kadmind_auth, xprt, l_port, op, prime_arg, in audit_kadmind_auth() 172 SVCXPRT *xprt, in audit_kadmind_unauth() argument 178 common_audit(AUE_kadmind_unauth, xprt, l_port, op, prime_arg, in audit_kadmind_unauth()
|
/illumos-gate/usr/src/uts/common/fs/nfs/ |
H A D | nfs4_dispatch.c | 375 rfs40_dispatch(struct svc_req *req, SVCXPRT *xprt, char *ap) in rfs40_dispatch() argument 487 struct svc_req *, xprt, in rfs40_dispatch() 489 svcerr_systemerr(xprt); in rfs40_dispatch() 545 SVCXPRT *, xprt, char *, resp); in rfs4_send_minor_mismatch() 546 svcerr_systemerr(xprt); in rfs4_send_minor_mismatch() 575 (void) rfs4_send_minor_mismatch(xprt, argsp); in rfs4_minorvers_mismatch() 633 SVCXPRT *xprt, char *ap) in rfs4_dispatch() argument 641 return (!svc_sendreply(xprt, xdr_void, NULL)); in rfs4_dispatch() 648 return (rfs4_send_minor_mismatch(xprt, cmp)); in rfs4_dispatch() 651 return (rfs40_dispatch(req, xprt, ap)); in rfs4_dispatch() [all …]
|