/illumos-gate/usr/src/ucblib/librpcsoc/ |
H A D | svc_udp.c | 57 #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 D | svc_mt.h | 46 #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 D | svc_clts.c | 100 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 D | svc_cots.c | 103 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 D | svc.c | 65 * 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 D | svc_rdma.c | 93 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 D | svc_door.c | 73 * 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 D | svc_run.c | 267 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 D | svc_dg.c | 70 #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 D | svc_vc.c | 81 /* 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 D | svc.c | 40 * 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 D | idmapd.c | 73 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 D | ypserv_proc.c | 106 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 D | fmd_rpc_adm.c | 1043 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 D | ses_log_transport.c | 160 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 D | gssd_proc.c | 2622 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 D | rdc_svc.c | 273 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 D | nfs4_callback.c | 695 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 D | nfs_server.c | 200 #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 D | contract.h | 223 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 D | svc_rpcsec_gss.c | 247 * 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 D | nlm_impl.c | 2331 SVCMASTERXPRT *xprt = NULL; local 2334 error = svc_tli_kcreate(fp, 0, (char *)netid, NULL, &xprt,
|