Home
last modified time | relevance | path

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

123

/titanic_44/usr/src/ucblib/librpcsoc/
H A Dsvc_tcp.c114 register SVCXPRT *xprt; local
150 xprt = svc_xprt_alloc();
151 if (xprt == NULL) {
158 xprt->xp_p2 = NULL;
159 xprt->xp_netid = NULL;
160 xprt->xp_p1 = (caddr_t)r;
161 xprt->xp_verf = _null_auth;
162 xprt->xp_ops = svctcp_rendezvous_ops();
163 xprt->xp_port = ntohs(addr.sin_port);
164 xprt->xp_sock = sock;
[all …]
H A Dsvc_udp.c57 #define rpc_buffer(xprt) ((xprt)->xp_p1) argument
89 #define su_data(xprt) ((struct svcudp_data *)(xprt->xp_p2)) argument
110 register SVCXPRT *xprt; local
136 xprt = svc_xprt_alloc();
137 if (xprt == NULL) {
146 svc_xprt_free(xprt);
152 if ((rpc_buffer(xprt) = (char *)mem_alloc(su->su_iosz)) == NULL) {
155 svc_xprt_free(xprt);
161 &(su->su_xdrs), rpc_buffer(xprt), su->su_iosz, XDR_DECODE);
163 xprt->xp_p2 = (caddr_t)su;
[all …]
/titanic_44/usr/src/lib/libbc/inc/include/rpc/
H A Dsvc.h99 #define SVC_RECV(xprt, msg) \ argument
100 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
101 #define svc_recv(xprt, msg) \ argument
102 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
104 #define SVC_STAT(xprt) \ argument
105 (*(xprt)->xp_ops->xp_stat)(xprt)
106 #define svc_stat(xprt) \ argument
107 (*(xprt)->xp_ops->xp_stat)(xprt)
109 #define SVC_GETARGS(xprt, xargs, argsp) \ argument
110 (*(xprt)->xp_ops->xp_getargs)((xprt), (xargs), (argsp))
[all …]
/titanic_44/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.c115 SVCXPRT *xprt; in svc_create() local
139 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) { in svc_create()
142 if (svc_reg(l->xprt, prognum, versnum, in svc_create()
156 xprt = svc_tp_create(dispatch, prognum, versnum, nconf); in svc_create()
157 if (xprt) { in svc_create()
158 if (!__svc_add_to_xlist(&_svc_xprtlist, xprt, in svc_create()
185 SVCXPRT *xprt; in svc_tp_create() local
197 xprt = svc_tli_create_common(RPC_ANYFD, nconf, NULL, 0, 0, anon_mlp); in svc_tp_create()
198 if (xprt == NULL) in svc_tp_create()
202 if (svc_reg(xprt, prognum, versnum, dispatch, nconf) == FALSE) { in svc_tp_create()
[all …]
H A Dsvc_run.c267 SVCXPRT *xprt; in svc_exit() local
280 xprt = svc_xports[fd]; in svc_exit()
281 if (xprt) { in svc_exit()
282 SVC_DESTROY(xprt); in svc_exit()
399 SVCXPRT *parent_xprt, *xprt; in _svc_run_mt() local
653 if ((xprt = make_xprt_copy(parent_xprt)) == NULL) in _svc_run_mt()
677 msg = SVCEXT(xprt)->msg; in _svc_run_mt()
679 r = SVCEXT(xprt)->req; in _svc_run_mt()
681 cred_area = SVCEXT(xprt)->cred_area; in _svc_run_mt()
692 if ((dispatch = SVC_RECV(xprt, msg))) { in _svc_run_mt()
[all …]
H A Dsvid_funcs.c107 svc_control(SVCXPRT *xprt, const uint_t rq, void *in) in svc_control() argument
111 *((int *)in) = __svc_versquiet_get(xprt); in svc_control()
115 __svc_versquiet_off(xprt); in svc_control()
117 __svc_versquiet_on(xprt); in svc_control()
120 return ((*(xprt)->xp_ops->xp_control)(xprt, rq, in)); in svc_control()
125 svc_destroy(SVCXPRT *xprt) in svc_destroy() argument
127 (*(xprt)->xp_ops->xp_destroy)(xprt); in svc_destroy()
131 svc_freeargs(SVCXPRT *xprt, xdrproc_t xargs, char *argsp) in svc_freeargs() argument
133 return ((*(xprt)->xp_ops->xp_freeargs)(xprt, xargs, argsp)); in svc_freeargs()
137 svc_getargs(SVCXPRT *xprt, xdrproc_t xargs, char *argsp) in svc_getargs() argument
[all …]
H A Dsvc.c572 __svc_get_svcauth(SVCXPRT *xprt) in __svc_get_svcauth() argument
575 return (&SVC_XP_AUTH(xprt)); in __svc_get_svcauth()
740 xprt_register(const SVCXPRT *xprt) in xprt_register() argument
742 int fd = xprt->xp_fd; in xprt_register()
789 svc_xports[fd] = (SVCXPRT *)xprt; in xprt_register()
828 __xprt_unregister_private(const SVCXPRT *xprt, bool_t lock_not_held) in __xprt_unregister_private() argument
830 int fd = xprt->xp_fd; in __xprt_unregister_private()
834 if ((fd < nsvc_xports) && (svc_xports[fd] == xprt)) { in __xprt_unregister_private()
840 __svc_rm_from_xlist(&_svc_xprtlist, xprt, &xprtlist_lock); in __xprt_unregister_private()
844 xprt_unregister(const SVCXPRT *xprt) in xprt_unregister() argument
[all …]
/titanic_44/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.c315 #define RELE_PROC(xprt) \ argument
316 ((xprt)->xp_type == T_RDMA ? rdma_rele : \
317 (((xprt)->xp_type == T_CLTS) ? rpc_rele : mir_rele))
325 #define version_keepquiet(xprt) (FALSE) argument
784 svc_xprt_register(SVCMASTERXPRT *xprt, int id) in svc_xprt_register() argument
816 xprt->xp_pool = pool; in svc_xprt_register()
823 pool->p_lhead = xprt->xp_prev = xprt->xp_next = xprt; in svc_xprt_register()
828 xprt->xp_next = next; in svc_xprt_register()
829 xprt->xp_prev = prev; in svc_xprt_register()
831 pool->p_lhead = prev->xp_next = next->xp_prev = xprt; in svc_xprt_register()
[all …]
H A Dsvc_mt.h55 #define svc_flags(xprt) (SVCEXT(xprt)->flags) argument
56 #define version_keepquiet(xprt) (svc_flags(xprt) & SVC_VERSQUIET) argument
57 #define svc_defunct(xprt) ((svc_flags(xprt) & SVC_DEFUNCT) ? TRUE : FALSE) argument
58 #define svc_failed(xprt) ((svc_flags(xprt) & SVC_FAILED) ? TRUE : FALSE) argument
59 #define svc_type(xprt) (svc_flags(xprt) & SVC_TYPE_MASK) argument
60 #define svc_send_mutex(xprt) (SVCEXT(xprt)->send_mutex) argument
96 SVCXPRT *xprt; member
112 #define SVCEXT(xprt) ((SVCXPRT_EXT *)((xprt)->xp_p3)) argument
113 #define SVC_XP_AUTH(xprt) (SVCEXT(xprt)->xp_auth) argument
H A Dsvc.h559 #define SVC_DESTROY(xprt) \ argument
560 (*(xprt)->xp_ops->xp_destroy)(xprt)
586 #define SVC_START(xprt) \ argument
587 (*(xprt)->xp_ops->xp_start)(xprt)
591 #define SVC_RECV(xprt, msg) \ argument
592 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
593 #define svc_recv(xprt, msg) \ argument
594 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
596 #define SVC_STAT(xprt) \ argument
597 (*(xprt)->xp_ops->xp_stat)(xprt)
[all …]
H A Dsvc_cots.c190 SVCMASTERXPRT *xprt; in svc_cots_kcreate() local
201 xprt = kmem_zalloc(sizeof (SVCMASTERXPRT), KM_SLEEP); in svc_cots_kcreate()
210 xprt->xp_msg_size = COTS_MAX_ALLOCSIZE; in svc_cots_kcreate()
212 xprt->xp_msg_size = tinfo->TIDU_size - in svc_cots_kcreate()
216 xprt->xp_ops = &svc_cots_op; in svc_cots_kcreate()
217 xprt->xp_p2 = (caddr_t)cmd; in svc_cots_kcreate()
232 kmem_free(xprt, sizeof (SVCMASTERXPRT)); in svc_cots_kcreate()
236 xprt->xp_rtaddr.maxlen = ack_p->REMADDR_length; in svc_cots_kcreate()
237 xprt->xp_rtaddr.len = ack_p->REMADDR_length; in svc_cots_kcreate()
238 cmd->cmd_src_addr = xprt->xp_rtaddr.buf = in svc_cots_kcreate()
[all …]
H A Dsvc_rdma.c200 SVCMASTERXPRT *xprt; in svc_rdma_kcreate() local
252 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP); in svc_rdma_kcreate()
253 xprt->xp_ops = &rdma_svc_ops; in svc_rdma_kcreate()
254 xprt->xp_sct = sct; in svc_rdma_kcreate()
255 xprt->xp_type = T_RDMA; in svc_rdma_kcreate()
256 mutex_init(&xprt->xp_req_lock, NULL, MUTEX_DEFAULT, NULL); in svc_rdma_kcreate()
257 mutex_init(&xprt->xp_thread_lock, NULL, MUTEX_DEFAULT, NULL); in svc_rdma_kcreate()
258 xprt->xp_req_head = (mblk_t *)0; in svc_rdma_kcreate()
259 xprt->xp_req_tail = (mblk_t *)0; in svc_rdma_kcreate()
260 xprt->xp_full = FALSE; in svc_rdma_kcreate()
[all …]
/titanic_44/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 …]
/titanic_44/usr/src/cmd/ypcmd/
H A Dypserv_resolv_common.h46 #define GETCALLER(xprt) svc_getcaller(xprt) argument
47 #define SETCALLER(xprt, addrp) *(svc_getcaller(xprt)) = *addrp; argument
55 #define get_svc_dg_data(xprt) ((struct svc_dg_data *)(xprt->xp_p2)) argument
62 #define GETCALLER(xprt) svc_getrpccaller(xprt)
63 #define SETCALLER(xprt, nbufp) xprt->xp_rtaddr.len = nbufp->len; \
64 (void) memcpy(xprt->xp_rtaddr.buf, nbufp->buf, nbufp->len);
86 extern ulong_t svc_getxid(SVCXPRT *xprt);
H A Dypserv_resolv.c66 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str,
75 SVCXPRT *xprt = NULL; in setup_resolv() local
108 if (!getprognum(&prognum, &xprt, fd_str, prog_str, YPDNSVERS, tp)) { in setup_resolv()
142 if (xprt) in setup_resolv()
143 svc_destroy(xprt); in setup_resolv()
200 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str, in getprognum() argument
215 *xprt = NULL; in getprognum()
231 *xprt = svcudp_bufcreate(RPC_ANYSOCK, 0, 0); in getprognum()
234 *xprt = svctcp_create(RPC_ANYSOCK, 0, 0); in getprognum()
236 if (*xprt == NULL) in getprognum()
[all …]
/titanic_44/usr/src/uts/common/avs/ns/rdc/
H A Drdcsrv.c76 static void rdcsrv_xprtclose(const SVCXPRT *xprt);
168 rdcsrv_dispdup(struct svc_req *req, SVCXPRT *xprt) in rdcsrv_dispdup() argument
180 dupstat = SVC_DUP(xprt, req, 0, 0, &dr); in rdcsrv_dispdup()
185 svcerr_systemerr(xprt); in rdcsrv_dispdup()
195 (*fn)(xprt, req); in rdcsrv_dispdup()
196 SVC_DUPDONE(xprt, dr, 0, 0, DUP_DONE); in rdcsrv_dispdup()
211 rdcsrv_dispatch(struct svc_req *req, SVCXPRT *xprt) in rdcsrv_dispatch() argument
227 svcerr_noproc(xprt); in rdcsrv_dispatch()
239 svcerr_noproc(xprt); in rdcsrv_dispatch()
245 switch (rdcsrv_dispdup(req, xprt)) { in rdcsrv_dispatch()
[all …]
H A Drdc_stub.c38 static void null_dispatch(struct svc_req *req, SVCXPRT *xprt);
87 rdcstub_dispatch(struct svc_req *req, SVCXPRT *xprt) in rdcstub_dispatch() argument
89 (*dispatch)(req, xprt); in rdcstub_dispatch()
94 null_dispatch(struct svc_req *req, SVCXPRT *xprt) in null_dispatch() argument
96 svcerr_noproc(xprt); in null_dispatch()
H A Drdc_svc.c273 r_net_null(SVCXPRT *xprt) in r_net_null() argument
275 (void) svc_sendreply(xprt, xdr_void, 0); in r_net_null()
282 r_net_read(SVCXPRT *xprt) in r_net_read() argument
297 st = SVC_GETARGS(xprt, xdr_rread, (char *)&diskio); in r_net_read()
299 (void) svc_sendreply(xprt, xdr_int, (char *)&st); in r_net_read()
306 (void) svc_sendreply(xprt, xdr_readres, (char *)&resp); in r_net_read()
320 (void) svc_sendreply(xprt, xdr_int, (char *)&st); in r_net_read()
326 if (!svc_sendreply(xprt, xdr_int, (char *)&st)) { in r_net_read()
355 (void) svc_sendreply(xprt, xdr_readres, (char *)&resp); in r_net_read()
362 (void) svc_sendreply(xprt, xdr_readres, (char *)&resp); in r_net_read()
[all …]
/titanic_44/usr/src/cmd/keyserv/
H A Dkey_generic.c76 SVCXPRT *xprt; /* Server handle */ member
81 SVCXPRT *xprt; variable
98 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
101 if (svc_reg(l->xprt, prognum, versnum,
158 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0);
161 if (xprt) {
163 if (svc_reg(xprt, prognum, versnum,
168 SVC_DESTROY(xprt);
175 SVC_DESTROY(xprt);
178 l->xprt = xprt;
/titanic_44/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()

123