Home | History | Annotate | Download | only in rpc

Lines Matching defs:xprt

47  * There are two sets of procedures here.  The xprt routines are
121 static void __xprt_do_unregister(SVCXPRT *xprt, bool_t dolock);
171 xprt_register(SVCXPRT *xprt)
175 _DIAGASSERT(xprt != NULL);
178 sock = xprt->xp_fd;
183 __svc_xports[sock] = xprt;
197 xprt_unregister(SVCXPRT *xprt)
199 __xprt_do_unregister(xprt, TRUE);
203 __xprt_unregister_unlocked(SVCXPRT *xprt)
205 __xprt_do_unregister(xprt, FALSE);
212 __xprt_do_unregister(SVCXPRT *xprt, bool_t dolock)
216 _DIAGASSERT(xprt != NULL);
221 sock = xprt->xp_fd;
222 if (sock >= __svc_maxxports || __svc_xports[sock] != xprt)
248 svc_reg(SVCXPRT *xprt, const rpcprog_t prog, const rpcvers_t vers,
259 _DIAGASSERT(xprt != NULL);
264 if (xprt->xp_netid) {
265 netid = strdup(xprt->xp_netid);
270 } else if ((tnconf = __rpcgettp(xprt->xp_fd)) != NULL) {
296 if ((xprt->xp_netid == NULL) && (flag == 1) && netid)
297 if ((((SVCXPRT *) xprt)->xp_netid = strdup(netid)) == NULL) {
316 &((SVCXPRT *) xprt)->xp_ltaddr);
357 svc_register(SVCXPRT *xprt, u_long prog, u_long vers,
363 _DIAGASSERT(xprt != NULL);
384 return (pmap_set(prog, vers, protocol, xprt->xp_port));
443 svc_sendreply(SVCXPRT *xprt, xdrproc_t xdr_results, const char *xdr_location)
447 _DIAGASSERT(xprt != NULL);
451 rply.acpted_rply.ar_verf = xprt->xp_verf;
455 return (SVC_REPLY(xprt, &rply));
462 svcerr_noproc(SVCXPRT *xprt)
466 _DIAGASSERT(xprt != NULL);
470 rply.acpted_rply.ar_verf = xprt->xp_verf;
472 SVC_REPLY(xprt, &rply);
479 svcerr_decode(SVCXPRT *xprt)
483 _DIAGASSERT(xprt != NULL);
487 rply.acpted_rply.ar_verf = xprt->xp_verf;
489 SVC_REPLY(xprt, &rply);
496 svcerr_systemerr(SVCXPRT *xprt)
500 _DIAGASSERT(xprt != NULL);
504 rply.acpted_rply.ar_verf = xprt->xp_verf;
506 SVC_REPLY(xprt, &rply);
517 __svc_versquiet_on(SVCXPRT *xprt)
521 _DIAGASSERT(xprt != NULL);
523 tmp = ((u_long) xprt->xp_p3) | SVC_VERSQUIET;
524 xprt->xp_p3 = (caddr_t) tmp;
528 __svc_versquiet_off(SVCXPRT *xprt)
532 _DIAGASSERT(xprt != NULL);
534 tmp = ((u_long) xprt->xp_p3) & ~SVC_VERSQUIET;
535 xprt->xp_p3 = (caddr_t) tmp;
539 svc_versquiet(SVCXPRT *xprt)
541 __svc_versquiet_on(xprt);
545 __svc_versquiet_get(SVCXPRT *xprt)
548 _DIAGASSERT(xprt != NULL);
550 return ((int) xprt->xp_p3) & SVC_VERSQUIET;
558 svcerr_auth(SVCXPRT *xprt, enum auth_stat why)
562 _DIAGASSERT(xprt != NULL);
568 SVC_REPLY(xprt, &rply);
575 svcerr_weakauth(SVCXPRT *xprt)
578 _DIAGASSERT(xprt != NULL);
580 svcerr_auth(xprt, AUTH_TOOWEAK);
587 svcerr_noprog(SVCXPRT *xprt)
591 _DIAGASSERT(xprt != NULL);
595 rply.acpted_rply.ar_verf = xprt->xp_verf;
597 SVC_REPLY(xprt, &rply);
604 svcerr_progvers(SVCXPRT *xprt, rpcvers_t low_vers, rpcvers_t high_vers)
608 _DIAGASSERT(xprt != NULL);
612 rply.acpted_rply.ar_verf = xprt->xp_verf;
616 SVC_REPLY(xprt, &rply);
677 SVCXPRT *xprt;
691 xprt
693 if (xprt == NULL)
698 if (SVC_RECV(xprt, &msg)) {
704 r.rq_xprt = xprt;
711 svcerr_auth(xprt, why);
721 (*s->sc_dispatch)(&r, xprt);
736 svcerr_progvers(xprt, low_vers, high_vers);
738 svcerr_noprog(xprt);
742 * Check if the xprt has been disconnected in a
747 if (xprt != __svc_xports[fd]) {
753 if ((stat = SVC_STAT(xprt)) == XPRT_DIED){
754 SVC_DESTROY(xprt);