/opensolaris-onvv-gate/usr/src/lib/libbc/inc/include/rpc/ |
H A D | svc.h | 94 * 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 D | svc_tcp.c | 75 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 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...] |
/opensolaris-onvv-gate/usr/src/cmd/ypcmd/ |
H A D | ypserv_resolv_common.h | 37 * 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 D | ypserv_resolv.c | 66 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 D | svc_door.c | 70 * 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 D | svc_vc.c | 79 /* 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 D | svc_dg.c | 69 #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 D | svid_funcs.c | 107 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 D | svc_generic.c | 114 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 D | svc_run.c | 261 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 D | svc.c | 39 * 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 D | svc_gen.c | 110 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 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.h | 186 /* 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 D | svc.c | 61 * 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 D | pmap_svc.c | 68 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 D | rpcbind.h | 91 #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 D | fmd_rpc_api.c | 39 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 D | svc_dg_priv.h | 48 * 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 D | key_generic.c | 76 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 D | rdc_stub.c | 38 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 D | rdcsrv.c | 76 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 D | audit_kadmind.c | 95 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 D | gssd_generic.c | 61 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 */
|