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.c112 register SVCXPRT *xprt; local
148 xprt = svc_xprt_alloc();
149 if (xprt == NULL) {
156 xprt->xp_p2 = NULL;
157 xprt->xp_netid = NULL;
158 xprt->xp_p1 = (caddr_t)r;
159 xprt->xp_verf = _null_auth;
160 xprt->xp_ops = svctcp_rendezvous_ops();
161 xprt->xp_port = ntohs(addr.sin_port);
162 xprt->xp_sock = sock;
[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
108 register SVCXPRT *xprt; local
134 xprt = svc_xprt_alloc();
135 if (xprt == NULL) {
144 svc_xprt_free(xprt);
150 if ((rpc_buffer(xprt) = (char *)mem_alloc(su->su_iosz)) == NULL) {
153 svc_xprt_free(xprt);
159 &(su->su_xdrs), rpc_buffer(xprt), su->su_iosz, XDR_DECODE);
161 xprt->xp_p2 = (caddr_t)su;
[all …]
/illumos-gate/usr/src/lib/libnsl/rpc/
H A Dsvc_vc.c158 svc_vc_xprtfree(SVCXPRT *xprt) in svc_vc_xprtfree() argument
161 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL; in svc_vc_xprtfree()
162 struct cf_rendezvous *r = xprt ? in svc_vc_xprtfree()
164 (struct cf_rendezvous *)xprt->xp_p1 : NULL; in svc_vc_xprtfree()
166 if (!xprt) in svc_vc_xprtfree()
169 if (xprt->xp_tp) in svc_vc_xprtfree()
170 free(xprt->xp_tp); in svc_vc_xprtfree()
171 if (xprt->xp_netid) in svc_vc_xprtfree()
172 free(xprt->xp_netid); in svc_vc_xprtfree()
174 if (xprt->xp_ltaddr.buf) in svc_vc_xprtfree()
[all …]
H A Dsvc_door.c86 #define su_data(xprt) ((struct svc_door_data *)(xprt->xp_p2)) argument
98 __svc_add_to_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) in __svc_add_to_xlist() argument
104 l->xprt = xprt; in __svc_add_to_xlist()
115 __svc_rm_from_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) in __svc_rm_from_xlist() argument
122 if ((*l)->xprt == xprt) { in __svc_rm_from_xlist()
160 svc_door_destroy_pvt(l->xprt); in __svc_cleanup_door_xprts()
181 svc_door_dispatch(SVCXPRT *xprt, struct rpc_msg *msg, struct svc_req *r) in svc_door_dispatch() argument
185 struct svc_door_data *su = su_data(xprt); in svc_door_dispatch()
188 r->rq_xprt = xprt; in svc_door_dispatch()
199 svcerr_auth(xprt, why); in svc_door_dispatch()
[all …]
H A Dsvc_dg.c70 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument
93 svc_dg_xprtfree(SVCXPRT *xprt) in svc_dg_xprtfree() 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()
100 if (xprt == NULL) in svc_dg_xprtfree()
102 if (xprt->xp_netid) in svc_dg_xprtfree()
103 free(xprt->xp_netid); in svc_dg_xprtfree()
104 if (xprt->xp_tp) in svc_dg_xprtfree()
105 free(xprt->xp_tp); in svc_dg_xprtfree()
107 if (xprt->xp_ltaddr.buf) in svc_dg_xprtfree()
[all …]
H A Dsvc_generic.c119 SVCXPRT *xprt; in svc_create() local
143 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) { in svc_create()
146 if (svc_reg(l->xprt, prognum, versnum, in svc_create()
160 xprt = svc_tp_create(dispatch, prognum, versnum, nconf); in svc_create()
161 if (xprt) { in svc_create()
162 if (!__svc_add_to_xlist(&_svc_xprtlist, xprt, in svc_create()
228 SVCXPRT *xprt; in svc_tp_create_bind() local
240 xprt = svc_tli_create_common(RPC_ANYFD, nconf, bindaddr, 0, 0, in svc_tp_create_bind()
242 if (xprt == NULL) in svc_tp_create_bind()
246 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE) { in svc_tp_create_bind()
[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()
395 SVCXPRT *parent_xprt, *xprt; in _svc_run_mt() local
649 if ((xprt = make_xprt_copy(parent_xprt)) == NULL) in _svc_run_mt()
673 msg = SVCEXT(xprt)->msg; in _svc_run_mt()
675 r = SVCEXT(xprt)->req; in _svc_run_mt()
677 cred_area = SVCEXT(xprt)->cred_area; in _svc_run_mt()
688 if ((dispatch = SVC_RECV(xprt, msg))) { in _svc_run_mt()
[all …]
H A Dsvc.c575 __svc_get_svcauth(SVCXPRT *xprt) in __svc_get_svcauth() argument
578 return (&SVC_XP_AUTH(xprt)); in __svc_get_svcauth()
743 xprt_register(const SVCXPRT *xprt) in xprt_register() argument
745 int fd = xprt->xp_fd; in xprt_register()
792 svc_xports[fd] = (SVCXPRT *)xprt; in xprt_register()
831 __xprt_unregister_private(const SVCXPRT *xprt, bool_t lock_not_held) in __xprt_unregister_private() argument
833 int fd = xprt->xp_fd; in __xprt_unregister_private()
837 if ((fd < nsvc_xports) && (svc_xports[fd] == xprt)) { in __xprt_unregister_private()
843 __svc_rm_from_xlist(&_svc_xprtlist, xprt, &xprtlist_lock); in __xprt_unregister_private()
847 xprt_unregister(const SVCXPRT *xprt) in xprt_unregister() argument
[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()
129 svc_freeargs(SVCXPRT *xprt, xdrproc_t xargs, char *argsp) in svc_freeargs() argument
131 return ((*(xprt)->xp_ops->xp_freeargs)(xprt, xargs, argsp)); in svc_freeargs()
135 svc_getargs(SVCXPRT *xprt, xdrproc_t xargs, char *argsp) in svc_getargs() argument
[all …]
/illumos-gate/usr/src/uts/common/rpc/
H A Dsvc_gen.c111 SVCMASTERXPRT *xprt = NULL; /* service handle */ in svc_tli_kcreate() local
162 error = svc_clts_kcreate(fp, max_msgsize, &tinfo, &xprt); in svc_tli_kcreate()
166 error = svc_cots_kcreate(fp, max_msgsize, &tinfo, &xprt); in svc_tli_kcreate()
179 xprt->xp_req_head = (mblk_t *)0; in svc_tli_kcreate()
180 xprt->xp_req_tail = (mblk_t *)0; in svc_tli_kcreate()
181 xprt->xp_full = FALSE; in svc_tli_kcreate()
182 xprt->xp_enable = FALSE; in svc_tli_kcreate()
183 xprt->xp_reqs = 0; in svc_tli_kcreate()
184 xprt->xp_size = 0; in svc_tli_kcreate()
185 mutex_init(&xprt->xp_req_lock, NULL, MUTEX_DEFAULT, NULL); in svc_tli_kcreate()
[all …]
H A Dsvc.c307 #define version_keepquiet(xprt) (FALSE) argument
766 svc_xprt_register(SVCMASTERXPRT *xprt, int id) in svc_xprt_register() argument
798 xprt->xp_pool = pool; in svc_xprt_register()
805 pool->p_lhead = xprt->xp_prev = xprt->xp_next = xprt; in svc_xprt_register()
810 xprt->xp_next = next; in svc_xprt_register()
811 xprt->xp_prev = prev; in svc_xprt_register()
813 pool->p_lhead = prev->xp_next = next->xp_prev = xprt; in svc_xprt_register()
829 svc_xprt_unregister(SVCMASTERXPRT *xprt) in svc_xprt_unregister() argument
831 SVCPOOL *pool = xprt->xp_pool; in svc_xprt_unregister()
841 if (xprt == xprt->xp_next) in svc_xprt_unregister()
[all …]
H A Dsvc.h541 #define SVC_HOLD(xprt) \ argument
542 if ((xprt)->xp_ops->xp_hold) \
543 (*(xprt)->xp_ops->xp_hold)((xprt)->xp_wq)
545 #define SVC_RELE(xprt, mp, enable) \ argument
546 if ((xprt)->xp_ops->xp_release) \
547 (*(xprt)->xp_ops->xp_release)((xprt)->xp_wq, (mp), (enable))
573 #define SVC_DESTROY(xprt) \ argument
574 (*(xprt)->xp_ops->xp_destroy)(xprt)
600 #define SVC_START(xprt) \ argument
601 (*(xprt)->xp_ops->xp_start)(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
208 xprt = kmem_zalloc(sizeof (SVCMASTERXPRT), KM_SLEEP); in svc_cots_kcreate()
217 xprt->xp_msg_size = COTS_MAX_ALLOCSIZE; in svc_cots_kcreate()
219 xprt->xp_msg_size = tinfo->TIDU_size - in svc_cots_kcreate()
223 xprt->xp_ops = &svc_cots_op; in svc_cots_kcreate()
224 xprt->xp_p2 = (caddr_t)cmd; in svc_cots_kcreate()
239 kmem_free(xprt, sizeof (SVCMASTERXPRT)); in svc_cots_kcreate()
243 xprt->xp_rtaddr.maxlen = ack_p->REMADDR_length; in svc_cots_kcreate()
244 xprt->xp_rtaddr.len = ack_p->REMADDR_length; in svc_cots_kcreate()
245 cmd->cmd_src_addr = xprt->xp_rtaddr.buf = in svc_cots_kcreate()
[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()
258 xprt->xp_ops = &rdma_svc_ops; in svc_rdma_kcreate()
259 xprt->xp_sct = sct; in svc_rdma_kcreate()
260 xprt->xp_type = T_RDMA; in svc_rdma_kcreate()
261 mutex_init(&xprt->xp_req_lock, NULL, MUTEX_DEFAULT, NULL); in svc_rdma_kcreate()
262 mutex_init(&xprt->xp_thread_lock, NULL, MUTEX_DEFAULT, NULL); in svc_rdma_kcreate()
263 xprt->xp_req_head = (mblk_t *)0; in svc_rdma_kcreate()
264 xprt->xp_req_tail = (mblk_t *)0; in svc_rdma_kcreate()
265 xprt->xp_full = FALSE; 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()
175 xprt->xp_lcladdr.buf = kmem_zalloc(sizeof (sin6_t), KM_SLEEP); in svc_clts_kcreate()
176 xprt->xp_p2 = (caddr_t)rpcstat->rpc_clts_server; in svc_clts_kcreate()
177 xprt->xp_ops = &svc_clts_op; in svc_clts_kcreate()
178 xprt->xp_msg_size = tinfo->TSDU_size; in svc_clts_kcreate()
180 xprt->xp_rtaddr.buf = NULL; in svc_clts_kcreate()
181 xprt->xp_rtaddr.maxlen = tinfo->ADDR_size; in svc_clts_kcreate()
182 xprt->xp_rtaddr.len = 0; in svc_clts_kcreate()
184 *nxprt = xprt; in svc_clts_kcreate()
[all …]
/illumos-gate/usr/src/cmd/rpcbind/
H A Dpmap_svc.c68 pmap_service(struct svc_req *rqstp, SVCXPRT *xprt) in pmap_service() argument
77 PMAP_CHECK(xprt, rqstp->rq_proc); in pmap_service()
79 if ((!svc_sendreply(xprt, (xdrproc_t)xdr_void, NULL)) && in pmap_service()
91 pmapproc_change(rqstp, xprt, rqstp->rq_proc); in pmap_service()
98 pmapproc_change(rqstp, 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()
125 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLIT, PMAPVERS); in pmap_service()
129 PMAP_CHECK(xprt, rqstp->rq_proc); in pmap_service()
[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
110 rpcb_log(B_TRUE, (xprt), (proc), (prog), B_FALSE)
112 #define PMAP_LOG(ans, xprt, proc, prog) \ argument
114 rpcb_log(ans, (xprt), (proc), (prog), B_TRUE)
[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.c64 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str,
73 SVCXPRT *xprt = NULL; in setup_resolv() local
106 if (!getprognum(&prognum, &xprt, fd_str, prog_str, YPDNSVERS, tp)) { in setup_resolv()
140 if (xprt) in setup_resolv()
141 svc_destroy(xprt); in setup_resolv()
198 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str, in getprognum() argument
213 *xprt = NULL; in getprognum()
229 *xprt = svcudp_bufcreate(RPC_ANYSOCK, 0, 0); in getprognum()
232 *xprt = svctcp_create(RPC_ANYSOCK, 0, 0); in getprognum()
234 if (*xprt == NULL) in getprognum()
[all …]
/illumos-gate/usr/src/cmd/mdb/common/modules/nfs/
H A Dsvc.c166 svc_print_masterxprt(SVCMASTERXPRT *xprt) in svc_print_masterxprt() argument
169 mdb_printf("queue ptr = %p\n", xprt->xp_wq); in svc_print_masterxprt()
170 mdb_printf("cached cred for server = %d\n", xprt->xp_cred); in svc_print_masterxprt()
171 mdb_printf("transport type = %d\n", xprt->xp_type); in svc_print_masterxprt()
172 mdb_printf("TSDU or TIDU size = %d\n", xprt->xp_msg_size); in svc_print_masterxprt()
175 common_netbuf_str(&xprt->xp_rtaddr)); in svc_print_masterxprt()
176 mdb_printf("Request queue head = %p\n", xprt->xp_req_head); in svc_print_masterxprt()
177 mdb_printf("Request queue tail = %p\n", xprt->xp_req_tail); in svc_print_masterxprt()
179 common_mutex(&xprt->xp_req_lock)); in svc_print_masterxprt()
182 xprt->xp_threads); in svc_print_masterxprt()
[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
485 if (!svc_sendreply(xprt, xdr_COMPOUND4res_srv, (char *)rbp)) { in rfs40_dispatch()
487 struct svc_req *, xprt, in rfs40_dispatch()
489 svcerr_systemerr(xprt); in rfs40_dispatch()
521 rfs4_send_minor_mismatch(SVCXPRT *xprt, COMPOUND4args *argsp) in rfs4_send_minor_mismatch() argument
543 if (!svc_sendreply(xprt, xdr_COMPOUND4res_srv, (char *)resp)) { in rfs4_send_minor_mismatch()
545 SVCXPRT *, xprt, char *, resp); in rfs4_send_minor_mismatch()
546 svcerr_systemerr(xprt); in rfs4_send_minor_mismatch()
563 rfs4_minorvers_mismatch(struct svc_req *req, SVCXPRT *xprt, void *args) in rfs4_minorvers_mismatch() argument
575 (void) rfs4_send_minor_mismatch(xprt, argsp); in rfs4_minorvers_mismatch()
[all …]

123