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

123

/illumos-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...]
/illumos-gate/usr/src/uts/common/rpc/
H A Dsvc_gen.c111 SVCMASTERXPRT *xprt = NULL; /* service handle */ local
162 error = svc_clts_kcreate(fp, max_msgsize, &tinfo, &xprt);
166 error = svc_cots_kcreate(fp, max_msgsize, &tinfo, &xprt);
179 xprt->xp_req_head = (mblk_t *)0;
180 xprt->xp_req_tail = (mblk_t *)0;
181 xprt->xp_full = FALSE;
182 xprt->xp_enable = FALSE;
183 xprt->xp_reqs = 0;
184 xprt->xp_size = 0;
185 mutex_init(&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.h189 /* destroy a clone xprt */
286 int p_max_same_xprt; /* Max reqs from the xprt */
314 * The p_lrwlock protects access to xprt->xp_next and xprt->xp_prev.
326 * Circular linked list for the `xprt-ready' queue (FIFO).
375 * xprt->xp_req_lock governs the following fields in xprt:
377 * xprt->xp_thread_lock governs the following fields in xprt:
439 int xp_full : 1; /* xprt i
[all...]
H A Dsvc.c67 * but it involves locking (master's xprt->xp_thread_lock).
83 * an `xprt-ready' queue and a creator thread (see below). Threads in
122 * If there is none we take a hint from the pool's `xprt-ready' queue.
137 * The `xprt-ready' queue.
140 * this search more efficient each pool has an `xprt-ready' queue.
142 * inserts a pointer to the transport into the `xprt-ready' queue. A
146 * case we try the next hint. The `xprt-ready' queue has fixed size (by
151 * Both the svc_poll() loop and the `xprt-ready' queue are optimized
235 * Size of the `xprt-ready' queue.
266 * A node for the `xprt
765 svc_xprt_register(SVCMASTERXPRT *xprt, int id) argument
828 svc_xprt_unregister(SVCMASTERXPRT *xprt) argument
900 svc_xprt_qput(SVCPOOL *pool, SVCMASTERXPRT *xprt) argument
937 SVCMASTERXPRT *xprt; local
970 svc_xprt_qdelete(SVCPOOL *pool, SVCMASTERXPRT *xprt) argument
997 svc_xprt_cleanup(SVCMASTERXPRT *xprt, bool_t detached) argument
1034 svc_callout_find(SVCXPRT *xprt, rpcprog_t prog, rpcvers_t vers, rpcvers_t *vers_min, rpcvers_t *vers_max) argument
1065 svc_callout_free(SVCMASTERXPRT *xprt) argument
1448 svc_clone_link(SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt, SVCXPRT *clone_xprt2) argument
1491 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
1526 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
1821 svc_poll(SVCPOOL *pool, SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt) argument
2137 svc_flowcontrol(SVCMASTERXPRT *xprt) argument
2199 SVCMASTERXPRT *xprt = NULL; /* master transport handle */ local
2383 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2426 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2499 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2686 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
2734 SVCMASTERXPRT *xprt; local
[all...]
/illumos-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...]
/illumos-gate/usr/src/lib/libnsl/rpc/
H A Dsvc_door.c73 * kept in xprt->xp_p2
86 #define su_data(xprt) ((struct svc_door_data *)(xprt->xp_p2))
98 __svc_add_to_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) argument
104 l->xprt = xprt;
115 __svc_rm_from_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) argument
122 if ((*l)->xprt == xprt) {
160 svc_door_destroy_pvt(l->xprt);
181 svc_door_dispatch(SVCXPRT *xprt, struct rpc_msg *msg, struct svc_req *r) argument
229 SVCXPRT *xprt; local
296 svc_door_xprtfree(SVCXPRT *xprt) argument
316 SVCXPRT *xprt; local
443 SVCXPRT *xprt; local
499 SVCXPRT *xprt; local
524 return_xprt_copy(SVCXPRT *xprt) argument
568 svc_door_stat(SVCXPRT *xprt) argument
574 svc_door_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
588 svc_door_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
604 svc_door_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
611 svc_door_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
621 svc_door_destroy(SVCXPRT *xprt) argument
629 svc_door_destroy_pvt(SVCXPRT *xprt) argument
657 svc_door_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
721 __svc_get_door_cred(SVCXPRT *xprt, svc_local_cred_t *lcred) argument
737 __svc_get_door_ucred(const SVCXPRT *xprt, ucred_t *ucp) argument
[all...]
H A Dsvc_vc.c81 /* Structure used to initialize SVC_XP_AUTH(xprt).svc_ah_ops. */
94 struct cf_rendezvous { /* kept in xprt->xp_p1 for rendezvouser */
106 struct cf_conn { /* kept in xprt->xp_p1 for actual connection */
158 svc_vc_xprtfree(SVCXPRT *xprt) argument
161 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL;
162 struct cf_rendezvous *r = xprt ?
164 (struct cf_rendezvous *)xprt->xp_p1 : NULL;
166 if (!xprt)
169 if (xprt
201 SVCXPRT *xprt; local
292 SVCXPRT *xprt; local
302 SVCXPRT *xprt; local
379 __svc_vc_setflag(SVCXPRT *xprt, int flag) argument
439 SVCXPRT *xprt; local
447 svc_fd_xprtfree(SVCXPRT *xprt) argument
483 SVCXPRT *xprt; local
587 SVCXPRT *xprt; local
666 rendezvous_request(SVCXPRT *xprt, struct rpc_msg *msg) argument
740 SVCXPRT *xprt; local
1139 rendezvous_stat(SVCXPRT *xprt) argument
1145 svc_vc_destroy(SVCXPRT *xprt) argument
1154 _svc_vc_destroy_private(SVCXPRT *xprt, bool_t lock_not_held) argument
1195 svc_vc_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
1216 rendezvous_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
1291 read_vc(SVCXPRT *xprt, caddr_t buf, int len) argument
1368 t_rcvnonblock(SVCXPRT *xprt, caddr_t buf, int len) argument
1418 SVCXPRT *xprt; local
1527 write_vc(SVCXPRT *xprt, caddr_t buf, int len) argument
1629 svc_vc_stat(SVCXPRT *xprt) argument
1652 svc_vc_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
1701 svc_vc_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
1714 svc_vc_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
1724 svc_vc_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
1814 __svc_vc_dupcache_init(SVCXPRT *xprt, void *condition, int basis) argument
[all...]
H A Dsvc_dg.c70 #define rpc_buffer(xprt) ((xprt)->xp_p1)
74 * xprt = svc_dg_create(sock, sendsize, recvsize);
76 * Once *xprt is initialized, it is registered.
88 /* Structure used to initialize SVC_XP_AUTH(xprt).svc_ah_ops. */
93 svc_dg_xprtfree(SVCXPRT *xprt) argument
96 SVCXPRT_EXT *xt = xprt ? SVCEXT(xprt) : NULL;
98 struct svc_dg_data *su = xprt ? get_svc_dg_data(xprt)
123 SVCXPRT *xprt; local
189 SVCXPRT *xprt; local
199 SVCXPRT *xprt; local
271 svc_dg_stat(SVCXPRT *xprt) argument
312 set_src_addr(SVCXPRT *xprt, struct netbuf *opt) argument
360 svc_dg_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
475 svc_dg_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
529 svc_dg_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
539 svc_dg_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
549 svc_dg_destroy(SVCXPRT *xprt) argument
557 _svc_dg_destroy_private(SVCXPRT *xprt) argument
582 svc_dg_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
687 svc_dg_enablecache(SVCXPRT *xprt, const uint_t size) argument
752 cache_set(SVCXPRT *xprt, uint32_t replylen) argument
866 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.c119 SVCXPRT *xprt; local
143 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
146 if (svc_reg(l->xprt, prognum, versnum,
160 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
161 if (xprt) {
162 if (!__svc_add_to_xlist(&_svc_xprtlist, xprt,
228 SVCXPRT *xprt; local
240 xprt = svc_tli_create_common(RPC_ANYFD, nconf, bindaddr, 0, 0,
242 if (xprt == NULL)
246 if (svc_reg(xprt, prognu
277 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc_run.c263 SVCXPRT *xprt; local
276 xprt = svc_xports[fd];
277 if (xprt) {
278 SVC_DESTROY(xprt);
395 SVCXPRT *parent_xprt, *xprt; local
631 * Get parent xprt. It is possible for the parent service
647 * Make a copy of parent xprt, update svc_fdset.
649 if ((xprt = make_xprt_copy(parent_xprt)) == NULL)
673 msg = SVCEXT(xprt)->msg;
675 r = SVCEXT(xprt)
849 SVCXPRT *xprt; local
878 _svc_done_private(SVCXPRT *xprt) argument
919 svc_done(SVCXPRT *xprt) argument
948 svc_args_done(SVCXPRT *xprt) argument
[all...]
H A Dsvc.c42 * There are two sets of procedures here. The xprt routines are
575 __svc_get_svcauth(SVCXPRT *xprt) argument
578 return (&SVC_XP_AUTH(xprt));
743 xprt_register(const SVCXPRT *xprt) argument
745 int fd = xprt->xp_fd;
792 svc_xports[fd] = (SVCXPRT *)xprt;
831 __xprt_unregister_private(const SVCXPRT *xprt, bool_t lock_not_held) argument
833 int fd = xprt->xp_fd;
837 if ((fd < nsvc_xports) && (svc_xports[fd] == xprt)) {
843 __svc_rm_from_xlist(&_svc_xprtlist, xprt,
847 xprt_unregister(const SVCXPRT *xprt) argument
860 svc_reg(const SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(), const struct netconfig *nconf) argument
972 svc_register(SVCXPRT *xprt, rpcprog_t prog, rpcvers_t vers, void (*dispatch)(), int protocol) argument
1098 svc_sendreply(const SVCXPRT *xprt, const xdrproc_t xdr_results, const caddr_t xdr_location) argument
1116 svcerr_noproc(const SVCXPRT *xprt) argument
1131 svcerr_decode(const SVCXPRT *xprt) argument
1146 svcerr_systemerr(const SVCXPRT *xprt) argument
1164 __svc_versquiet_on(const SVCXPRT *xprt) argument
1171 __svc_versquiet_off(const SVCXPRT *xprt) argument
1178 svc_versquiet(const SVCXPRT *xprt) argument
1184 __svc_versquiet_get(const SVCXPRT *xprt) argument
1194 svcerr_auth(const SVCXPRT *xprt, const enum auth_stat why) argument
1209 svcerr_weakauth(const SVCXPRT *xprt) argument
1218 svcerr_noprog(const SVCXPRT *xprt) argument
1233 svcerr_progvers(const SVCXPRT *xprt, const rpcvers_t low_vers, const rpcvers_t high_vers) argument
1331 SVCXPRT *xprt; local
1406 _svc_prog_dispatch(SVCXPRT *xprt, struct rpc_msg *msg, struct svc_req *r) argument
1492 SVCXPRT *xprt = NULL; local
1537 svc_xprt_free(SVCXPRT *xprt) argument
1565 svc_xprt_destroy(SVCXPRT *xprt) argument
1602 svc_copy(SVCXPRT *xprt) argument
1621 _svc_destroy_private(SVCXPRT *xprt) argument
1642 svc_get_local_cred(SVCXPRT *xprt, svc_local_cred_t *lcred) argument
[all...]
H A Dsvc_raw.c132 svc_raw_stat(SVCXPRT *xprt) argument
139 svc_raw_recv(SVCXPRT *xprt, struct rpc_msg *msg) argument
167 svc_raw_reply(SVCXPRT *xprt, struct rpc_msg *msg) argument
199 svc_raw_getargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
216 svc_raw_freeargs(SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr) argument
237 svc_raw_destroy(SVCXPRT *xprt) argument
243 svc_raw_control(SVCXPRT *xprt, const uint_t rq, void *in) argument
/illumos-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);
/illumos-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))
/illumos-gate/usr/src/cmd/rpcbind/
H A Drpcbind.h93 #define RPCB_CHECK(xprt, proc) \
95 !rpcb_check((xprt), (proc), B_FALSE)) \
98 #define PMAP_CHECK(xprt, proc) \
100 !rpcb_check((xprt), (proc), B_TRUE)) \
103 #define PMAP_CHECK_RET(xprt, proc, ret) \
105 !rpcb_check((xprt), (proc), B_TRUE)) \
108 #define RPCB_LOG(xprt, proc, prog) \
110 rpcb_log(B_TRUE, (xprt), (proc), (prog), B_FALSE)
112 #define PMAP_LOG(ans, xprt, proc, prog) \
114 rpcb_log(ans, (xprt), (pro
[all...]
H A Dpmap_svc.c68 pmap_service(struct svc_req *rqstp, SVCXPRT *xprt) argument
77 PMAP_CHECK(xprt, rqstp->rq_proc);
79 if ((!svc_sendreply(xprt, (xdrproc_t)xdr_void, NULL)) &&
91 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
98 pmapproc_change(rqstp, xprt, rqstp->rq_proc);
106 pmapproc_getport(rqstp, xprt);
113 PMAP_CHECK(xprt, rqstp->rq_proc);
114 pmapproc_dump(rqstp, xprt);
125 rpcbproc_callit_com(rqstp, xprt, PMAPPROC_CALLIT, PMAPVERS);
129 PMAP_CHECK(xprt, rqst
166 pmapproc_change(struct svc_req *rqstp, SVCXPRT *xprt, unsigned long op) argument
242 pmapproc_getport(struct svc_req *rqstp, SVCXPRT *xprt) argument
317 pmapproc_dump(struct svc_req *rqstp, SVCXPRT *xprt) argument
[all...]
/illumos-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...]
/illumos-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
/illumos-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 */
/illumos-gate/usr/src/cmd/krb5/kwarn/
H A Dkwarnd_generic.c39 SVCXPRT *xprt; local
105 xprt = svc_tli_create(fd, nconf, bind_addr, 0, 0);
108 if (xprt == NULL) {
115 if (svc_reg(xprt, prognum, versnum, dispatch, nconf)
121 SVC_DESTROY(xprt); /* also t_closes fd */
/illumos-gate/usr/src/cmd/fs.d/nfs/tests/
H A Dtest_svc_tp_create.c93 SVCXPRT *xprt = NULL; local
114 xprt = svc_tp_create_addr(mysvc, TESTPROG, vers,
118 if (xprt == NULL) {
125 if (xprt == NULL) {
131 xprt = svc_tp_create(mysvc, TESTPROG, vers, nconf);
133 if (xprt == NULL) {
144 if (!svc_reg(xprt, TESTPROG, vers, mysvc, nconf)) {
284 mysvc(struct svc_req *rq, SVCXPRT *xprt) argument
290 (void) svc_sendreply(xprt, xdr_void, (char *)0);
294 svcerr_noproc(xprt);
[all...]

Completed in 97 milliseconds

123