Searched defs:xprt (Results 26 - 47 of 47) sorted by relevance

12

/illumos-gate/usr/src/ucblib/librpcsoc/
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_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_clts.c100 svc_clts_kclone_destroy, /* Destroy a clone xprt */
102 svc_clts_kclone_xprt, /* transport specific clone xprt function */
108 * Kept in xprt->xp_p2buf.
160 SVCMASTERXPRT *xprt; local
169 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP);
170 xprt->xp_lcladdr.buf = kmem_zalloc(sizeof (sin6_t), KM_SLEEP);
171 xprt->xp_p2 = (caddr_t)rpcstat->rpc_clts_server;
172 xprt->xp_ops = &svc_clts_op;
173 xprt
189 svc_clts_kdestroy(SVCMASTERXPRT *xprt) argument
235 svc_clts_kstart(SVCMASTERXPRT *xprt) argument
[all...]
H A Dsvc_cots.c103 svc_cots_kclone_destroy, /* Destroy a clone xprt */
105 NULL, /* Transport specific clone xprt */
111 * Kept in xprt->xp_p2.
192 SVCMASTERXPRT *xprt; local
203 xprt = kmem_zalloc(sizeof (SVCMASTERXPRT), KM_SLEEP);
212 xprt->xp_msg_size = COTS_MAX_ALLOCSIZE;
214 xprt->xp_msg_size = tinfo->TIDU_size -
218 xprt->xp_ops = &svc_cots_op;
219 xprt->xp_p2 = (caddr_t)cmd;
234 kmem_free(xprt, sizeo
272 svc_cots_kdestroy(SVCMASTERXPRT *xprt) argument
297 svc_cots_kstart(SVCMASTERXPRT *xprt) argument
[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_rdma.c93 bool_t cloned; /* xprt cloned for thread processing */
147 svc_rdma_kclone_destroy, /* Destroy a clone xprt */
149 svc_rdma_kclone_xprt, /* Transport specific clone xprt */
200 SVCMASTERXPRT *xprt; local
252 xprt = kmem_zalloc(sizeof (*xprt), KM_SLEEP);
253 xprt->xp_ops = &rdma_svc_ops;
254 xprt->xp_sct = sct;
255 xprt->xp_type = T_RDMA;
256 mutex_init(&xprt
331 svc_rdma_kdestroy(SVCMASTERXPRT *xprt) argument
344 svc_rdma_kstart(SVCMASTERXPRT *xprt) argument
363 svc_rdma_kstop(SVCMASTERXPRT *xprt) 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_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_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 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.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/cmd/idmap/idmapd/
H A Didmapd.c73 SVCXPRT *xprt = NULL; variable
390 xprt = svc_door_create(idmap_prog_1, IDMAP_PROG, IDMAP_V1, connmaxrec);
391 if (xprt == NULL) {
396 if (!svc_control(xprt, SVCSET_CONNMAXREC, &connmaxrec)) {
401 dfd = xprt->xp_fd;
442 if (xprt != NULL)
443 svc_destroy(xprt);
/illumos-gate/usr/src/cmd/ypcmd/
H A Dypserv_proc.c106 SVCXPRT *xprt, DBM *fdb);
108 SVCXPRT *xprt, DBM *fdb);
847 SVCXPRT *xprt, DBM *fdb)
940 nbuf = svc_getrpccaller(xprt);
1451 struct ypresponse *resp, SVCXPRT *xprt, DBM *fdb)
1483 nbuf = svc_getrpccaller(xprt);
846 multihomed(struct ypreq_key req, struct ypresp_val *resp, SVCXPRT *xprt, DBM *fdb) argument
1450 omultihomed(struct yprequest req, struct ypresponse *resp, SVCXPRT *xprt, DBM *fdb) argument
/illumos-gate/usr/src/cmd/fm/fmd/common/
H A Dfmd_rpc_adm.c1043 fmd_adm_1_freeresult(SVCXPRT *xprt, xdrproc_t proc, caddr_t data) argument
1046 svc_done(xprt);
/illumos-gate/usr/src/cmd/fm/modules/common/ses-log-transport/
H A Dses_log_transport.c160 slt_post_ereport(fmd_hdl_t *hdl, fmd_xprt_t *xprt, const char *ereport_class, argument
179 fmd_xprt_post(hdl, xprt, nvl, 0);
/illumos-gate/usr/src/cmd/gss/gssd/
H A Dgssd_proc.c2622 SVCXPRT *xprt = rqstp->rq_xprt; local
2627 if (__rpc_get_local_uid(xprt, &uid) < 0) {
2629 xprt->xp_netid, xprt->xp_tp);
2661 svcerr_weakauth(xprt);
/illumos-gate/usr/src/uts/common/avs/ns/rdc/
H A Drdc_svc.c273 r_net_null(SVCXPRT *xprt) argument
275 (void) svc_sendreply(xprt, xdr_void, 0);
282 r_net_read(SVCXPRT *xprt) argument
297 st = SVC_GETARGS(xprt, xdr_rread, (char *)&diskio);
299 (void) svc_sendreply(xprt, xdr_int, (char *)&st);
306 (void) svc_sendreply(xprt, xdr_readres, (char *)&resp);
320 (void) svc_sendreply(xprt, xdr_int, (char *)&st);
326 if (!svc_sendreply(xprt, xdr_int, (char *)&st)) {
355 (void) svc_sendreply(xprt, xdr_readres, (char *)&resp);
362 (void) svc_sendreply(xprt, xdr_readre
440 r_net_read6(SVCXPRT *xprt) argument
603 r_net_write5(SVCXPRT *xprt) argument
808 r_net_write6(SVCXPRT *xprt) argument
1174 r_net_ping4(SVCXPRT *xprt, struct svc_req *req) argument
1218 r_net_ping7(SVCXPRT *xprt, struct svc_req *req) argument
1268 r_net_bmap(SVCXPRT *xprt) argument
1299 r_net_bmap6(SVCXPRT *xprt) argument
1335 r_net_bdata(SVCXPRT *xprt) argument
1376 r_net_bdata6(SVCXPRT *xprt) argument
1420 r_net_getsize(SVCXPRT *xprt) argument
1439 r_net_getsize6(SVCXPRT *xprt) argument
1466 r_net_state4(SVCXPRT *xprt) argument
1707 r_net_state(SVCXPRT *xprt) argument
1956 r_net_getstate4(SVCXPRT *xprt, struct svc_req *req) argument
2002 r_net_getstate7(SVCXPRT *xprt, struct svc_req *req) argument
[all...]
/illumos-gate/usr/src/uts/common/fs/nfs/
H A Dnfs4_callback.c695 cb_dispatch(struct svc_req *req, SVCXPRT *xprt) argument
728 svcerr_noproc(xprt);
735 if (!SVC_GETARGS(xprt, xdr_args, (caddr_t)&args)) {
738 svcerr_decode(xprt);
744 if (svc_sendreply(xprt, xdr_res, (caddr_t)&res) == FALSE) {
747 svcerr_systemerr(xprt);
753 if (!SVC_FREEARGS(xprt, xdr_args, (caddr_t)&args)) {
H A Dnfs_server.c200 #define NFSLOG_COPY_NETBUF(exi, xprt, nb) { \
201 (nb)->maxlen = (xprt)->xp_rtaddr.maxlen; \
202 (nb)->len = (xprt)->xp_rtaddr.len; \
204 bcopy((xprt)->xp_rtaddr.buf, (nb)->buf, (nb)->len); \
420 SVCMASTERXPRT *xprt; local
489 error = svc_tli_kcreate(fp, readsize, buf, &addrmask, &xprt,
1474 common_dispatch(struct svc_req *req, SVCXPRT *xprt, rpcvers_t min_vers, argument
1542 !SVC_GETARGS(xprt, disp->dis_fastxdrargs, (char *)&args))
1546 !SVC_GETARGS(xprt, disp->dis_fastxdrargs, (char *)&args))
1550 if (!SVC_GETARGS(xprt, dis
1853 rfs_dispatch(struct svc_req *req, SVCXPRT *xprt) argument
1979 acl_dispatch(struct svc_req *req, SVCXPRT *xprt) argument
[all...]
/illumos-gate/usr/src/uts/common/avs/ns/
H A Dcontract.h223 void SVC_FREEARGS(void xprt, void a, void *b) { } argument
224 void SVC_DUP(void xprt, void req, void i, void j, void *dr) { } argument
225 void svcerr_systemerr(void xprt) { } argument
226 void svcerr_noproc(void xprt) { } argument
227 void SVC_DUPDONE(void xprt, void dr, void a, void b, void c) { } argument
/illumos-gate/usr/src/uts/common/rpc/sec_gss/
H A Dsvc_rpcsec_gss.c247 * Kept in xprt->xp_p2buf.
686 SVCXPRT *xprt,
702 rqst->rq_xprt = xprt;
972 /* get a xprt clone for taskq thread, taskq func must free it */
685 do_gss_accept( SVCXPRT *xprt, rpc_gss_init_arg *call_arg, struct rpc_msg *msg, svc_rpc_gss_data *client_data, uint_t cr_version, rpc_gss_service_t cr_service) argument
/illumos-gate/usr/src/uts/common/klm/
H A Dnlm_impl.c2331 SVCMASTERXPRT *xprt = NULL; local
2334 error = svc_tli_kcreate(fp, 0, (char *)netid, NULL, &xprt,

Completed in 135 milliseconds

12