Home
last modified time | relevance | path

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

123

/illumos-gate/usr/src/ucblib/librpcsoc/
H A Dsvc_tcp.c163 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 Dsvc_udp.c55 #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 Dsvc_vc.c161 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 Dsvc_door.c86 #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 Dsvc_dg.c70 #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 Dsvc_generic.c119 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 Dsvc_run.c263 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 Dsvc.c877 } 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 Dsvid_funcs.c105 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 Dsvc_gen.c181 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 Dsvc.c805 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 Dsvc.h543 (*(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 Dsvc_mt.h53 #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 Dsvc_cots.c197 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 Dsvc_rdma.c205 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 Dsvc_clts.c165 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 Dpmap_svc.c77 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 Drpcbind.h93 #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 Dypserv_resolv_common.h44 #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 Dypserv_resolv.c73 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 Dsvc.c166 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 Dkey_generic.c74 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 Dtest_svc_tp_create.c93 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 Daudit_kadmind.c95 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 Dnfs4_dispatch.c375 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 …]

123