/sunrpc/ |
A D | clnt_raw.c | 57 char msg[MCALL_MSG_SIZE]; member 137 struct rpc_msg msg; in libc_hidden_nolink_sunrpc() local 173 msg.acpted_rply.ar_verf = _null_auth; in libc_hidden_nolink_sunrpc() 174 msg.acpted_rply.ar_results.where = resultsp; in libc_hidden_nolink_sunrpc() 175 msg.acpted_rply.ar_results.proc = xresults; in libc_hidden_nolink_sunrpc() 176 if (!xdr_replymsg (xdrs, &msg)) in libc_hidden_nolink_sunrpc() 178 _seterr_reply (&msg, &error); in libc_hidden_nolink_sunrpc() 183 if (!AUTH_VALIDATE (h->cl_auth, &msg.acpted_rply.ar_verf)) in libc_hidden_nolink_sunrpc() 196 if (!AUTH_VALIDATE (h->cl_auth, &msg.acpted_rply.ar_verf)) in libc_hidden_nolink_sunrpc() 200 if (msg.acpted_rply.ar_verf.oa_base != NULL) in libc_hidden_nolink_sunrpc() [all …]
|
A D | svc_unix.c | 331 struct msghdr msg; in __msgread() local 337 msg.msg_iov = &iov; in __msgread() 338 msg.msg_iovlen = 1; in __msgread() 339 msg.msg_name = NULL; in __msgread() 340 msg.msg_namelen = 0; in __msgread() 345 msg.msg_flags = 0; in __msgread() 378 struct msghdr msg; in __msgwrite() 398 msg.msg_iov = &iov; in __msgwrite() 399 msg.msg_iovlen = 1; in __msgwrite() 400 msg.msg_name = NULL; in __msgwrite() [all …]
|
A D | pmap_rmt.c | 235 struct rpc_msg msg; in clnt_broadcast() local 264 msg.rm_xid = xid = _create_xid (); in clnt_broadcast() 266 msg.rm_direction = CALL; in clnt_broadcast() 267 msg.rm_call.cb_rpcvers = RPC_MSG_VERSION; in clnt_broadcast() 268 msg.rm_call.cb_prog = PMAPPROG; in clnt_broadcast() 269 msg.rm_call.cb_vers = PMAPVERS; in clnt_broadcast() 270 msg.rm_call.cb_proc = PMAPPROC_CALLIT; in clnt_broadcast() 271 msg.rm_call.cb_cred = unix_auth->ah_cred; in clnt_broadcast() 282 if ((!xdr_callmsg (xdrs, &msg)) in clnt_broadcast() 352 if (xdr_replymsg (xdrs, &msg)) in clnt_broadcast() [all …]
|
A D | clnt_perr.c | 54 clnt_sperror (CLIENT * rpch, const char *msg) in clnt_sperror() argument 80 res = __asprintf (&str, "%s: %s\n", msg, errstr); in clnt_sperror() 86 msg, errstr, __strerror_r (e.re_errno, in clnt_sperror() 93 msg, errstr, e.re_vers.low, e.re_vers.high); in clnt_sperror() 103 msg, errstr, (int) e.re_why); in clnt_sperror() 109 msg, errstr, e.re_vers.low, e.re_vers.high); in clnt_sperror() 114 msg, errstr, e.re_lb.s1, e.re_lb.s2); in clnt_sperror() 130 clnt_perror (CLIENT * rpch, const char *msg) in libc_hidden_nolink_sunrpc() 132 (void) __fxprintf (NULL, "%s", clnt_sperror (rpch, msg)); in libc_hidden_nolink_sunrpc() 278 clnt_spcreateerror (const char *msg) in libc_hidden_def() [all …]
|
A D | svc_authux.c | 48 _svcauth_unix (struct svc_req *rqst, struct rpc_msg *msg) in _svcauth_unix() argument 69 auth_len = (u_int) msg->rm_call.cb_cred.oa_length; in _svcauth_unix() 70 xdrmem_create (&xdrs, msg->rm_call.cb_cred.oa_base, auth_len, XDR_DECODE); in _svcauth_unix() 117 if ((u_int)msg->rm_call.cb_verf.oa_length) in _svcauth_unix() 120 msg->rm_call.cb_verf.oa_flavor; in _svcauth_unix() 122 msg->rm_call.cb_verf.oa_base; in _svcauth_unix() 124 msg->rm_call.cb_verf.oa_length; in _svcauth_unix() 144 _svcauth_short (struct svc_req *rqst, struct rpc_msg *msg) in _svcauth_short() argument
|
A D | rpc_prot.c | 232 _seterr_reply (struct rpc_msg *msg, in _seterr_reply() argument 236 switch (msg->rm_reply.rp_stat) in _seterr_reply() 239 if (msg->acpted_rply.ar_stat == SUCCESS) in _seterr_reply() 244 accepted (msg->acpted_rply.ar_stat, error); in _seterr_reply() 248 rejected (msg->rjcted_rply.rj_stat, error); in _seterr_reply() 253 error->re_lb.s1 = (long) (msg->rm_reply.rp_stat); in _seterr_reply() 260 error->re_vers.low = msg->rjcted_rply.rj_vers.low; in _seterr_reply() 261 error->re_vers.high = msg->rjcted_rply.rj_vers.high; in _seterr_reply() 265 error->re_why = msg->rjcted_rply.rj_why; in _seterr_reply() 269 error->re_vers.low = msg->acpted_rply.ar_vers.low; in _seterr_reply() [all …]
|
A D | svc_auth.c | 96 _authenticate (register struct svc_req *rqst, struct rpc_msg *msg) in _authenticate() argument 100 rqst->rq_cred = msg->rm_call.cb_cred; in _authenticate() 105 return (*(svcauthsw[cred_flavor].authenticator)) (rqst, msg); in _authenticate() 112 _svcauth_null (struct svc_req *rqst, struct rpc_msg *msg) in libc_hidden_nolink_sunrpc()
|
A D | clnt_unix.c | 439 struct msghdr msg; in __msgread() local 448 msg.msg_iov = &iov; in __msgread() 449 msg.msg_iovlen = 1; in __msgread() 450 msg.msg_name = NULL; in __msgread() 451 msg.msg_namelen = 0; in __msgread() 456 msg.msg_flags = 0; in __msgread() 489 struct msghdr msg; in __msgwrite() 509 msg.msg_iov = &iov; in __msgwrite() 510 msg.msg_iovlen = 1; in __msgwrite() 511 msg.msg_name = NULL; in __msgwrite() [all …]
|
A D | svc_raw.c | 97 svcraw_recv (SVCXPRT *xprt, struct rpc_msg *msg) in svcraw_recv() argument 107 if (!xdr_callmsg (xdrs, msg)) in svcraw_recv() 113 svcraw_reply (SVCXPRT *xprt, struct rpc_msg *msg) in svcraw_reply() argument 123 if (!xdr_replymsg (xdrs, msg)) in svcraw_reply()
|
A D | svcauth_des.c | 59 #define debug(msg) /*printf("svcauth_des: %s\n", msg) */ argument 105 _svcauth_des (register struct svc_req *rqst, register struct rpc_msg *msg) in _svcauth_des() argument 137 if (msg->rm_call.cb_cred.oa_length <= 0 || in _svcauth_des() 138 msg->rm_call.cb_cred.oa_length > MAX_AUTH_BYTES) in _svcauth_des() 141 ixdr = (uint32_t *) msg->rm_call.cb_cred.oa_base; in _svcauth_des() 169 if (msg->rm_call.cb_verf.oa_length <= 0 || in _svcauth_des() 170 msg->rm_call.cb_verf.oa_length > MAX_AUTH_BYTES) in _svcauth_des() 173 ixdr = (uint32_t *) msg->rm_call.cb_verf.oa_base; in _svcauth_des() 339 ixdr = (uint32_t *) msg->rm_call.cb_verf.oa_base; in _svcauth_des() 345 rqst->rq_xprt->xp_verf.oa_base = msg->rm_call.cb_verf.oa_base; in _svcauth_des() [all …]
|
A D | clnt_udp.c | 413 struct msghdr msg; in clntudp_call() local 429 msg.msg_name = (void *) &err_addr; in clntudp_call() 430 msg.msg_namelen = sizeof (err_addr); in clntudp_call() 431 msg.msg_iov = &iov; in clntudp_call() 432 msg.msg_iovlen = 1; in clntudp_call() 433 msg.msg_flags = 0; in clntudp_call() 434 msg.msg_control = cbuf; in clntudp_call() 435 msg.msg_controllen = 256; in clntudp_call() 439 && (msg.msg_flags & MSG_ERRQUEUE) in clntudp_call() 440 && ((msg.msg_namelen == 0 in clntudp_call() [all …]
|
A D | svc_udp.c | 225 svcudp_recv (SVCXPRT *xprt, struct rpc_msg *msg) in svcudp_recv() argument 302 if (!xdr_callmsg (xdrs, msg)) in svcudp_recv() 304 su->su_xid = msg->rm_xid; in svcudp_recv() 327 svcudp_reply (SVCXPRT *xprt, struct rpc_msg *msg) in svcudp_reply() argument 340 msg->rm_xid = su->su_xid; in svcudp_reply() 341 if (xdr_replymsg (xdrs, msg)) in svcudp_reply() 410 #define CACHE_PERROR(msg) \ argument 411 (void) __fxprintf(NULL, "%s\n", msg) 615 uc->uc_proc = msg->rm_call.cb_proc; in cache_get() 616 uc->uc_vers = msg->rm_call.cb_vers; in cache_get() [all …]
|
A D | svc.c | 460 struct rpc_msg msg; in libc_hidden_def() local 463 msg.rm_call.cb_cred.oa_base = cred_area; in libc_hidden_def() 464 msg.rm_call.cb_verf.oa_base = &(cred_area[MAX_AUTH_BYTES]); in libc_hidden_def() 474 if (SVC_RECV (xprt, &msg)) in libc_hidden_def() 486 r.rq_prog = msg.rm_call.cb_prog; in libc_hidden_def() 487 r.rq_vers = msg.rm_call.cb_vers; in libc_hidden_def() 488 r.rq_proc = msg.rm_call.cb_proc; in libc_hidden_def() 489 r.rq_cred = msg.rm_call.cb_cred; in libc_hidden_def() 494 if (msg.rm_call.cb_cred.oa_flavor == AUTH_NULL) in libc_hidden_def() 499 else if ((why = _authenticate (&r, &msg)) != AUTH_OK) in libc_hidden_def()
|
A D | svc_tcp.c | 392 svctcp_recv (SVCXPRT *xprt, struct rpc_msg *msg) in svctcp_recv() argument 399 if (xdr_callmsg (xdrs, msg)) in svctcp_recv() 401 cd->x_id = msg->rm_xid; in svctcp_recv() 425 svctcp_reply (SVCXPRT *xprt, struct rpc_msg *msg) in svctcp_reply() argument 432 msg->rm_xid = cd->x_id; in svctcp_reply() 433 stat = xdr_replymsg (xdrs, msg); in svctcp_reply()
|
A D | auth_des.c | 55 #define debug(msg) /* printf("%s\n", msg) */ argument
|
A D | key_call.c | 57 #define debug(msg) /* turn off debugging */ argument
|
/sunrpc/rpc/ |
A D | svc.h | 130 #define SVC_RECV(xprt, msg) \ argument 131 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 132 #define svc_recv(xprt, msg) \ argument 133 (*(xprt)->xp_ops->xp_recv)((xprt), (msg)) 145 #define SVC_REPLY(xprt, msg) \ argument 146 (*(xprt)->xp_ops->xp_reply) ((xprt), (msg)) 147 #define svc_reply(xprt, msg) \ argument 148 (*(xprt)->xp_ops->xp_reply) ((xprt), (msg))
|