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

123

/illumos-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...]
/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.c65 * but it involves locking (master's xprt->xp_thread_lock).
81 * an `xprt-ready' queue and a creator thread (see below). Threads in
120 * If there is none we take a hint from the pool's `xprt-ready' queue.
135 * The `xprt-ready' queue.
138 * this search more efficient each pool has an `xprt-ready' queue.
140 * inserts a pointer to the transport into the `xprt-ready' queue. A
144 * case we try the next hint. The `xprt-ready' queue has fixed size (by
149 * 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
786 svc_xprt_register(SVCMASTERXPRT *xprt, int id) argument
849 svc_xprt_unregister(SVCMASTERXPRT *xprt) argument
921 svc_xprt_qput(SVCPOOL *pool, SVCMASTERXPRT *xprt) argument
958 SVCMASTERXPRT *xprt; local
991 svc_xprt_qdelete(SVCPOOL *pool, SVCMASTERXPRT *xprt) argument
1018 svc_xprt_cleanup(SVCMASTERXPRT *xprt, bool_t detached) argument
1055 svc_callout_find(SVCXPRT *xprt, rpcprog_t prog, rpcvers_t vers, rpcvers_t *vers_min, rpcvers_t *vers_max) argument
1086 svc_callout_free(SVCMASTERXPRT *xprt) argument
1469 svc_clone_link(SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt, SVCXPRT *clone_xprt2) argument
1512 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
1547 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
1842 svc_poll(SVCPOOL *pool, SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt) argument
2158 svc_flowcontrol(SVCMASTERXPRT *xprt) argument
2220 SVCMASTERXPRT *xprt = NULL; /* master transport handle */ local
2404 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2447 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2520 SVCMASTERXPRT *xprt = ((void **) q->q_ptr)[0]; local
2707 SVCMASTERXPRT *xprt = clone_xprt->xp_master; local
2755 SVCMASTERXPRT *xprt; local
[all...]
H A Dsvc.h187 /* destroy a clone xprt */
280 int p_max_same_xprt; /* Max reqs from the xprt */
308 * The p_lrwlock protects access to xprt->xp_next and xprt->xp_prev.
320 * Circular linked list for the `xprt-ready' queue (FIFO).
369 * xprt->xp_req_lock governs the following fields in xprt:
371 * xprt->xp_thread_lock governs the following fields in xprt:
433 int xp_full : 1; /* xprt i
[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
1822 __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.c115 SVCXPRT *xprt; local
139 if (strcmp(l->xprt->xp_netid, nconf->nc_netid) == 0) {
142 if (svc_reg(l->xprt, prognum, versnum,
156 xprt = svc_tp_create(dispatch, prognum, versnum, nconf);
157 if (xprt) {
158 if (!__svc_add_to_xlist(&_svc_xprtlist, xprt,
185 SVCXPRT *xprt; local
197 xprt = svc_tli_create_common(RPC_ANYFD, nconf, NULL, 0, 0, anon_mlp);
198 if (xprt == NULL)
202 if (svc_reg(xprt, prognu
233 SVCXPRT *xprt = NULL; /* service handle */ local
[all...]
H A Dsvc_run.c267 SVCXPRT *xprt; local
280 xprt = svc_xports[fd];
281 if (xprt) {
282 SVC_DESTROY(xprt);
399 SVCXPRT *parent_xprt, *xprt; local
635 * Get parent xprt. It is possible for the parent service
651 * Make a copy of parent xprt, update svc_fdset.
653 if ((xprt = make_xprt_copy(parent_xprt)) == NULL)
677 msg = SVCEXT(xprt)->msg;
679 r = SVCEXT(xprt)
853 SVCXPRT *xprt; local
882 _svc_done_private(SVCXPRT *xprt) argument
923 svc_done(SVCXPRT *xprt) argument
952 svc_args_done(SVCXPRT *xprt) argument
[all...]
H A Dsvc.c40 * There are two sets of procedures here. The xprt routines are
571 __svc_get_svcauth(SVCXPRT *xprt) argument
574 return (&SVC_XP_AUTH(xprt));
739 xprt_register(const SVCXPRT *xprt) argument
741 int fd = xprt->xp_fd;
788 svc_xports[fd] = (SVCXPRT *)xprt;
827 __xprt_unregister_private(const SVCXPRT *xprt, bool_t lock_not_held) argument
829 int fd = xprt->xp_fd;
833 if ((fd < nsvc_xports) && (svc_xports[fd] == xprt)) {
839 __svc_rm_from_xlist(&_svc_xprtlist, xprt,
843 xprt_unregister(const SVCXPRT *xprt) argument
856 svc_reg(const SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers, void (*dispatch)(), const struct netconfig *nconf) argument
968 svc_register(SVCXPRT *xprt, rpcprog_t prog, rpcvers_t vers, void (*dispatch)(), int protocol) argument
1094 svc_sendreply(const SVCXPRT *xprt, const xdrproc_t xdr_results, const caddr_t xdr_location) argument
1112 svcerr_noproc(const SVCXPRT *xprt) argument
1127 svcerr_decode(const SVCXPRT *xprt) argument
1142 svcerr_systemerr(const SVCXPRT *xprt) argument
1160 __svc_versquiet_on(const SVCXPRT *xprt) argument
1167 __svc_versquiet_off(const SVCXPRT *xprt) argument
1174 svc_versquiet(const SVCXPRT *xprt) argument
1180 __svc_versquiet_get(const SVCXPRT *xprt) argument
1190 svcerr_auth(const SVCXPRT *xprt, const enum auth_stat why) argument
1205 svcerr_weakauth(const SVCXPRT *xprt) argument
1214 svcerr_noprog(const SVCXPRT *xprt) argument
1229 svcerr_progvers(const SVCXPRT *xprt, const rpcvers_t low_vers, const rpcvers_t high_vers) argument
1327 SVCXPRT *xprt; local
1402 _svc_prog_dispatch(SVCXPRT *xprt, struct rpc_msg *msg, struct svc_req *r) argument
1488 SVCXPRT *xprt = NULL; local
1533 svc_xprt_free(SVCXPRT *xprt) argument
1561 svc_xprt_destroy(SVCXPRT *xprt) argument
1598 svc_copy(SVCXPRT *xprt) argument
1617 _svc_destroy_private(SVCXPRT *xprt) argument
1638 svc_get_local_cred(SVCXPRT *xprt, svc_local_cred_t *lcred) argument
[all...]
/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/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/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/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...]
/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 */

Completed in 140 milliseconds

123