Searched refs:xprt (Results 1 - 25 of 58) sorted by relevance

123

/opensolaris-onvv-gate/usr/src/lib/libbc/inc/include/rpc/
H A Dsvc.h94 * SVCXPRT *xprt;
99 #define SVC_RECV(xprt, msg) \
100 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
101 #define svc_recv(xprt, msg) \
102 (*(xprt)->xp_ops->xp_recv)((xprt), (msg))
104 #define SVC_STAT(xprt) \
105 (*(xprt)->xp_ops->xp_stat)(xprt)
[all...]
/opensolaris-onvv-gate/usr/src/ucblib/librpcsoc/
H A Dsvc_tcp.c75 struct tcp_rendezvous { /* kept in xprt->xp_p1 */
80 struct tcp_conn { /* kept in xprt->xp_p1 */
89 * xprt = svctcp_create(sock, send_buf_size, recv_buf_size);
92 * Once *xprt is initialized, it is registered as a transporter
100 * xprt->xp_sock is the registered socket number and xprt->xp_port is the
114 register SVCXPRT *xprt; local
150 xprt = svc_xprt_alloc();
151 if (xprt == NULL) {
158 xprt
190 register SVCXPRT *xprt; local
[all...]
H A Dsvc_udp.c57 #define rpc_buffer(xprt) ((xprt)->xp_p1)
80 * kept in xprt->xp_p2
89 #define su_data(xprt) ((struct svcudp_data *)(xprt->xp_p2))
93 * xprt = svcudp_create(sock);
98 * xprt->xp_sock is the registered socket number and xprt->xp_port is the
100 * Once *xprt is initialized, it is registered as a transporter;
110 register SVCXPRT *xprt; local
[all...]
/opensolaris-onvv-gate/usr/src/cmd/ypcmd/
H A Dypserv_resolv_common.h37 * Stolen from rpcbind and is used to access xprt->xp_p2 fields.
46 #define GETCALLER(xprt) svc_getcaller(xprt)
47 #define SETCALLER(xprt, addrp) *(svc_getcaller(xprt)) = *addrp;
55 #define get_svc_dg_data(xprt) ((struct svc_dg_data *)(xprt->xp_p2))
62 #define GETCALLER(xprt) svc_getrpccaller(xprt)
63 #define SETCALLER(xprt, nbuf
[all...]
H A Dypserv_resolv.c66 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str,
75 SVCXPRT *xprt = NULL; local
108 if (!getprognum(&prognum, &xprt, fd_str, prog_str, YPDNSVERS, tp)) {
109 syslog(LOG_ERR, "can't create resolv xprt for transient.\n");
141 /* close fd, free xprt, but leave mapping */
142 if (xprt)
143 svc_destroy(xprt);
200 static int getprognum(long *prognum, SVCXPRT **xprt, char *fd_str, argument
215 *xprt = NULL;
226 * - close the fd (after exec), free xprt, leav
290 resolv_req(bool *fwding, CLIENT **client, int *pid, char *tp, SVCXPRT *xprt, struct ypreq_key *req, char *map) argument
[all...]
/opensolaris-onvv-gate/usr/src/lib/libnsl/rpc/
H A Dsvc_door.c70 * kept in xprt->xp_p2
83 #define su_data(xprt) ((struct svc_door_data *)(xprt->xp_p2))
95 __svc_add_to_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) argument
101 l->xprt = xprt;
112 __svc_rm_from_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) argument
119 if ((*l)->xprt == xprt) {
157 svc_door_destroy_pvt(l->xprt);
178 svc_door_dispatch(SVCXPRT *xprt, struct rpc_msg *msg, struct svc_req *r) argument
226 SVCXPRT *xprt; local
293 svc_door_xprtfree(SVCXPRT *xprt) argument
313 SVCXPRT *xprt; local
440 SVCXPRT *xprt; local
496 SVCXPRT *xprt; local
521 return_xprt_copy(SVCXPRT *xprt) argument
565 svc_door_stat(SVCXPRT *xprt) argument
571 svc_door_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
585 svc_door_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
601 svc_door_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
608 svc_door_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
618 svc_door_destroy(SVCXPRT *xprt) argument
626 svc_door_destroy_pvt(SVCXPRT *xprt) argument
654 svc_door_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
718 __svc_get_door_cred(SVCXPRT *xprt, svc_local_cred_t *lcred) argument
734 __svc_get_door_ucred(const SVCXPRT *xprt, ucred_t *ucp) argument
[all...]
H A Dsvc_vc.c79 /* Structure used to initialize SVC_XP_AUTH(xprt).svc_ah_ops. */
93 struct cf_rendezvous { /* kept in xprt->xp_p1 for rendezvouser */
105 struct cf_conn { /* kept in xprt->xp_p1 for actual connection */
168 svc_vc_xprtfree(SVCXPRT *xprt) argument
171 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL;
172 struct cf_rendezvous *r = xprt ?
174 (struct cf_rendezvous *)xprt->xp_p1 : NULL;
176 if (!xprt)
179 if (xprt
211 SVCXPRT *xprt; local
302 SVCXPRT *xprt; local
312 SVCXPRT *xprt; local
389 __svc_vc_setflag(SVCXPRT *xprt, int flag) argument
449 SVCXPRT *xprt; local
457 svc_fd_xprtfree(SVCXPRT *xprt) argument
493 SVCXPRT *xprt; local
598 SVCXPRT *xprt; local
677 rendezvous_request(SVCXPRT *xprt, struct rpc_msg *msg) argument
748 SVCXPRT *xprt = NULL; local
1116 rendezvous_stat(SVCXPRT *xprt) argument
1122 svc_vc_destroy(SVCXPRT *xprt) argument
1131 _svc_vc_destroy_private(SVCXPRT *xprt, bool_t lock_not_held) argument
1178 svc_vc_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
1199 rendezvous_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
1307 read_vc(SVCXPRT *xprt, caddr_t buf, int len) argument
1386 t_rcvnonblock(SVCXPRT *xprt, caddr_t buf, int len) argument
1436 SVCXPRT *xprt; local
1545 write_vc(SVCXPRT *xprt, caddr_t buf, int len) argument
1646 svc_vc_stat(SVCXPRT *xprt) argument
1669 svc_vc_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
1718 svc_vc_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
1731 svc_vc_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
1741 svc_vc_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
1876 SVCXPRT *xprt; local
1929 SVCXPRT *xprt; local
1976 __svc_vc_dupcache_init(SVCXPRT *xprt, void *condition, int basis) argument
[all...]
H A Dsvc_dg.c69 #define rpc_buffer(xprt) ((xprt)->xp_p1)
73 * xprt = svc_dg_create(sock, sendsize, recvsize);
75 * Once *xprt is initialized, it is registered.
87 /* Structure used to initialize SVC_XP_AUTH(xprt).svc_ah_ops. */
92 svc_dg_xprtfree(SVCXPRT *xprt) argument
95 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL;
97 struct svc_dg_data *su = xprt ? get_svc_dg_data(xprt)
122 SVCXPRT *xprt; local
188 SVCXPRT *xprt; local
198 SVCXPRT *xprt; local
270 svc_dg_stat(SVCXPRT *xprt) argument
311 set_src_addr(SVCXPRT *xprt, struct netbuf *opt) argument
359 svc_dg_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
474 svc_dg_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
528 svc_dg_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
538 svc_dg_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
548 svc_dg_destroy(SVCXPRT *xprt) argument
556 _svc_dg_destroy_private(SVCXPRT *xprt) argument
581 svc_dg_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
686 svc_dg_enablecache(SVCXPRT *xprt, const uint_t size) argument
751 cache_set(SVCXPRT *xprt, uint32_t replylen) argument
865 cache_get(SVCXPRT *xprt, struct rpc_msg *msg, char **replyp, uint32_t *replylenp) argument
[all...]
H A Dsvid_funcs.c107 svc_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
111 *((int *)in) = __svc_versquiet_get(xprt);
115 __svc_versquiet_off(xprt);
117 __svc_versquiet_on(xprt);
120 return ((*(xprt)->xp_ops->xp_control)(xprt, rq, in));
125 svc_destroy(SVCXPRT *xprt) argument
127 (*(xprt)->xp_ops->xp_destroy)(xprt);
131 svc_freeargs(SVCXPRT *xprt, xdrproc_ argument
137 svc_getargs(SVCXPRT *xprt, xdrproc_t xargs, char *argsp) argument
143 svc_getrpccaller(SVCXPRT *xprt) argument
[all...]
H A Dsvc_generic.c114 SVCXPRT *xprt; local
138 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
141 if (svc_reg(l->xprt, prognum, versnum,
154 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
155 if (xprt) {
156 if (!__svc_add_to_xlist(&_svc_xprtlist, xprt,
183 SVCXPRT *xprt; local
196 xprt = svc_tli_create_common(RPC_ANYFD, nconf, NULL, 0, 0, anon_mlp);
197 if (xprt == NULL)
201 if (svc_reg(xprt, prognu
232 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc_run.c261 SVCXPRT *xprt; local
274 xprt = svc_xports[fd];
275 if (xprt) {
276 SVC_DESTROY(xprt);
393 SVCXPRT *parent_xprt, *xprt; local
629 * Get parent xprt. It is possible for the parent service
645 * Make a copy of parent xprt, update svc_fdset.
647 if ((xprt = make_xprt_copy(parent_xprt)) == NULL)
671 msg = SVCEXT(xprt)->msg;
673 r = SVCEXT(xprt)
848 SVCXPRT *xprt; local
877 _svc_done_private(SVCXPRT *xprt) argument
918 svc_done(SVCXPRT *xprt) argument
947 svc_args_done(SVCXPRT *xprt) argument
[all...]
H A Dsvc.c39 * There are two sets of procedures here. The xprt routines are
566 __svc_get_svcauth(SVCXPRT *xprt) argument
569 return (&SVC_XP_AUTH(xprt));
734 xprt_register(const SVCXPRT *xprt) argument
736 int fd = xprt->xp_fd;
783 svc_xports[fd] = (SVCXPRT *)xprt;
822 __xprt_unregister_private(const SVCXPRT *xprt, bool_t lock_not_held) argument
824 int fd = xprt->xp_fd;
828 if ((fd < nsvc_xports) && (svc_xports[fd] == xprt)) {
834 __svc_rm_from_xlist(&_svc_xprtlist, xprt,
838 xprt_unregister(const SVCXPRT *xprt) argument
851 svc_reg(const SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(), const struct netconfig *nconf) argument
963 svc_register(SVCXPRT *xprt, rpcprog_t prog, rpcvers_t vers, void (*dispatch)(), int protocol) argument
1089 svc_sendreply(const SVCXPRT *xprt, const xdrproc_t xdr_results, const caddr_t xdr_location) argument
1107 svcerr_noproc(const SVCXPRT *xprt) argument
1122 svcerr_decode(const SVCXPRT *xprt) argument
1137 svcerr_systemerr(const SVCXPRT *xprt) argument
1155 __svc_versquiet_on(const SVCXPRT *xprt) argument
1162 __svc_versquiet_off(const SVCXPRT *xprt) argument
1169 svc_versquiet(const SVCXPRT *xprt) argument
1175 __svc_versquiet_get(const SVCXPRT *xprt) argument
1185 svcerr_auth(const SVCXPRT *xprt, const enum auth_stat why) argument
1200 svcerr_weakauth(const SVCXPRT *xprt) argument
1209 svcerr_noprog(const SVCXPRT *xprt) argument
1224 svcerr_progvers(const SVCXPRT *xprt, const rpcvers_t low_vers, const rpcvers_t high_vers) argument
1322 SVCXPRT *xprt; local
1397 _svc_prog_dispatch(SVCXPRT *xprt, struct rpc_msg *msg, struct svc_req *r) argument
1483 SVCXPRT *xprt = NULL; local
1528 svc_xprt_free(SVCXPRT *xprt) argument
1556 svc_xprt_destroy(SVCXPRT *xprt) argument
1593 svc_copy(SVCXPRT *xprt) argument
1612 _svc_destroy_private(SVCXPRT *xprt) argument
1633 svc_get_local_cred(SVCXPRT *xprt, svc_local_cred_t *lcred) argument
[all...]
/opensolaris-onvv-gate/usr/src/uts/common/rpc/
H A Dsvc_gen.c110 SVCMASTERXPRT *xprt = NULL; /* service handle */ local
161 error = svc_clts_kcreate(fp, max_msgsize, &tinfo, &xprt);
165 error = svc_cots_kcreate(fp, max_msgsize, &tinfo, &xprt);
178 xprt->xp_req_head = (mblk_t *)0;
179 xprt->xp_req_tail = (mblk_t *)0;
180 mutex_init(&xprt->xp_req_lock, NULL, MUTEX_DEFAULT, NULL);
181 mutex_init(&xprt->xp_thread_lock, NULL, MUTEX_DEFAULT, NULL);
182 xprt->xp_type = tinfo.SERV_type;
183 xprt->xp_threads = 0;
184 xprt
[all...]
H A Dsvc_mt.h46 #define SVC_DEFUNCT 0x0002 /* xprt is defunct, release asap */
55 #define svc_flags(xprt) (SVCEXT(xprt)->flags)
56 #define version_keepquiet(xprt) (svc_flags(xprt) & SVC_VERSQUIET)
57 #define svc_defunct(xprt) ((svc_flags(xprt) & SVC_DEFUNCT) ? TRUE : FALSE)
58 #define svc_failed(xprt) ((svc_flags(xprt) & SVC_FAILED) ? TRUE : FALSE)
59 #define svc_type(xprt) (svc_flag
96 SVCXPRT *xprt; member in struct:svcxprt_list_t
[all...]
H A Dsvc.h186 /* destroy a clone xprt */
279 int p_max_same_xprt; /* Max reqs from the xprt */
307 * The p_lrwlock protects access to xprt->xp_next and xprt->xp_prev.
319 * Circular linked list for the `xprt-ready' queue (FIFO).
366 * xprt->xp_req_lock governs the following fields in xprt:
368 * xprt->xp_thread_lock governs the following fields in xprt:
454 int xp_same_xprt; /* Reqs from the same xprt */
[all...]
H A Dsvc.c61 * but it involves locking (master's xprt->xp_thread_lock).
77 * an `xprt-ready' queue and a creator thread (see below). Threads in
123 * If there is none we take a hint from the pool's `xprt-ready' queue.
138 * The `xprt-ready' queue.
141 * this search more efficient each pool has an `xprt-ready' queue.
143 * inserts a pointer to the transport into the `xprt-ready' queue. A
147 * case we try the next hint. The `xprt-ready' queue has fixed size (by
152 * Both the svc_poll() loop and the `xprt-ready' queue are optimized
237 * Size of the `xprt-ready' queue.
268 * A node for the `xprt
783 svc_xprt_register(SVCMASTERXPRT *xprt, int id) argument
846 svc_xprt_unregister(SVCMASTERXPRT *xprt) argument
918 svc_xprt_qput(SVCPOOL *pool, SVCMASTERXPRT *xprt) argument
955 SVCMASTERXPRT *xprt; local
988 svc_xprt_qdelete(SVCPOOL *pool, SVCMASTERXPRT *xprt) argument
1021 svc_xprt_cleanup(SVCMASTERXPRT *xprt, bool_t detached) argument
1058 svc_callout_find(SVCXPRT *xprt, rpcprog_t prog, rpcvers_t vers, rpcvers_t *vers_min, rpcvers_t *vers_max) argument
1089 svc_callout_free(SVCMASTERXPRT *xprt) argument
1472 svc_clone_link(SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt, SVCXPRT *clone_xprt2) argument
1515 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
1550 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
1845 svc_poll(SVCPOOL *pool, SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt) argument
2103 SVCMASTERXPRT *xprt = NULL; /* master transport handle */ local
2266 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2302 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2369 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2538 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
2580 SVCMASTERXPRT *xprt; local
[all...]
/opensolaris-onvv-gate/usr/src/cmd/rpcbind/
H A Dpmap_svc.c68 pmap_service(rqstp, xprt)
70 register SVCXPRT *xprt;
81 PMAP_CHECK(xprt, rqstp->rq_proc);
83 if ((!svc_sendreply(xprt, (xdrproc_t)xdr_void, NULL)) &&
95 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
102 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
110 pmapproc_getport(rqstp, xprt);
120 PMAP_CHECK(xprt, rqstp->rq_proc);
121 pmapproc_dump(rqstp, xprt);
132 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLI
[all...]
H A Drpcbind.h91 #define RPCB_CHECK(xprt, proc) \
93 !rpcb_check((xprt), (proc), B_FALSE)) \
96 #define PMAP_CHECK(xprt, proc) \
98 !rpcb_check((xprt), (proc), B_TRUE)) \
101 #define PMAP_CHECK_RET(xprt, proc, ret) \
103 !rpcb_check((xprt), (proc), B_TRUE)) \
106 #define RPCB_LOG(xprt, proc, prog) \
108 rpcb_log(B_TRUE, (xprt), (proc), (prog), B_FALSE)
110 #define PMAP_LOG(ans, xprt, proc, prog) \
112 rpcb_log(ans, (xprt), (pro
[all...]
/opensolaris-onvv-gate/usr/src/cmd/fm/fmd/common/
H A Dfmd_rpc_api.c39 fmd_api_1_freeresult(SVCXPRT *xprt, xdrproc_t proc, caddr_t data) argument
42 svc_done(xprt);
/opensolaris-onvv-gate/usr/src/head/rpcsvc/
H A Dsvc_dg_priv.h48 * kept in xprt->xp_p2
62 #define get_svc_dg_data(xprt) ((struct svc_dg_data *)((xprt)->xp_p2))
/opensolaris-onvv-gate/usr/src/cmd/keyserv/
H A Dkey_generic.c76 SVCXPRT *xprt; /* Server handle */ member in struct:xlist
81 SVCXPRT *xprt; local
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
[all...]
/opensolaris-onvv-gate/usr/src/uts/common/avs/ns/rdc/
H A Drdc_stub.c38 static void null_dispatch(struct svc_req *req, SVCXPRT *xprt);
87 rdcstub_dispatch(struct svc_req *req, SVCXPRT *xprt) argument
89 (*dispatch)(req, xprt);
94 null_dispatch(struct svc_req *req, SVCXPRT *xprt) argument
96 svcerr_noproc(xprt);
H A Drdcsrv.c76 static void rdcsrv_xprtclose(const SVCXPRT *xprt);
168 rdcsrv_dispdup(struct svc_req *req, SVCXPRT *xprt) argument
180 dupstat = SVC_DUP(xprt, req, 0, 0, &dr);
185 svcerr_systemerr(xprt);
195 (*fn)(xprt, req);
196 SVC_DUPDONE(xprt, dr, 0, 0, DUP_DONE);
211 rdcsrv_dispatch(struct svc_req *req, SVCXPRT *xprt) argument
227 svcerr_noproc(xprt);
230 /* svcerr_noproc does a freeargs on xprt */
239 svcerr_noproc(xprt);
280 SVCXPRT *xprt; local
282 SVCMASTERXPRT *xprt; local
400 rdcsrv_xprtclose(const SVCXPRT *xprt) argument
[all...]
/opensolaris-onvv-gate/usr/src/lib/libbsm/common/
H A Daudit_kadmind.c95 SVCXPRT *xprt, /* net transport handle */
145 netbuf2pm(svc_getrpccaller(xprt), &r_port, &machine);
159 SVCXPRT *xprt,
166 common_audit(AUE_kadmind_auth, xprt, l_port, op, prime_arg,
172 SVCXPRT *xprt,
178 common_audit(AUE_kadmind_unauth, xprt, l_port, op, prime_arg,
93 common_audit( au_event_t event, SVCXPRT *xprt, in_port_t l_port, char *op, char *prime_arg, char *clnt_name, int sorf) argument
158 audit_kadmind_auth( SVCXPRT *xprt, in_port_t l_port, char *op, char *prime_arg, char *clnt_name, int sorf) argument
171 audit_kadmind_unauth( SVCXPRT *xprt, in_port_t l_port, char *op, char *prime_arg, char *clnt_name) argument
/opensolaris-onvv-gate/usr/src/cmd/gss/gssd/
H A Dgssd_generic.c61 SVCXPRT *xprt; local
127 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0);
130 if (xprt == NULL) {
137 if (svc_reg(xprt, prognum, versnum, dispatch, nconf)
143 SVC_DESTROY(xprt); /* also t_closes fd */

Completed in 218 milliseconds

123