Cross Reference: /illumos-gate/usr/src/uts/common/rpc/svc.c

Lines Matching refs:clone_xprt
1105 svc_sendreply(const SVCXPRT *clone_xprt, const xdrproc_t xdr_results,
1112 	rply.acpted_rply.ar_verf = clone_xprt->xp_verf;
1117 	return (SVC_REPLY((SVCXPRT *)clone_xprt, &rply));
1129 svcerr_noproc(const SVCXPRT *clone_xprt)
1135 	rply.acpted_rply.ar_verf = clone_xprt->xp_verf;
1137 	SVC_FREERES((SVCXPRT *)clone_xprt);
1138 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1150 svcerr_decode(const SVCXPRT *clone_xprt)
1156 	rply.acpted_rply.ar_verf = clone_xprt->xp_verf;
1158 	SVC_FREERES((SVCXPRT *)clone_xprt);
1159 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1166 svcerr_systemerr(const SVCXPRT *clone_xprt)
1172 	rply.acpted_rply.ar_verf = clone_xprt->xp_verf;
1174 	SVC_FREERES((SVCXPRT *)clone_xprt);
1175 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1182 svcerr_auth(const SVCXPRT *clone_xprt, const enum auth_stat why)
1190 	SVC_FREERES((SVCXPRT *)clone_xprt);
1191 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1198 svcerr_weakauth(const SVCXPRT *clone_xprt)
1200 	svcerr_auth((SVCXPRT *)clone_xprt, AUTH_TOOWEAK);
1207 svcerr_badcred(const SVCXPRT *clone_xprt)
1215 	SVC_FREERES((SVCXPRT *)clone_xprt);
1216 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1228 svcerr_noprog(const SVCXPRT *clone_xprt)
1234 	rply.acpted_rply.ar_verf = clone_xprt->xp_verf;
1236 	SVC_FREERES((SVCXPRT *)clone_xprt);
1237 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1249 svcerr_progvers(const SVCXPRT *clone_xprt,
1256 	rply.acpted_rply.ar_verf = clone_xprt->xp_verf;
1260 	SVC_FREERES((SVCXPRT *)clone_xprt);
1261 	SVC_REPLY((SVCXPRT *)clone_xprt, &rply);
1288 	SVCXPRT *clone_xprt,	/* clone transport handle */
1298 	ASSERT(clone_xprt->xp_master != NULL);
1342 	if (SVC_RECV(clone_xprt, mp, &msg)) {
1353 		r.rq_xprt = clone_xprt;
1367 			svcerr_auth(clone_xprt, why);
1371 			(void) SVC_FREEARGS(clone_xprt, NULL, NULL);
1377 			(void) SVC_FREEARGS(clone_xprt, NULL, NULL);
1382 			dispatchroutine = svc_callout_find(clone_xprt,
1386 				(*dispatchroutine) (&r, clone_xprt);
1393 				    version_keepquiet(clone_xprt))
1394 					svcerr_noprog(clone_xprt);
1396 					svcerr_progvers(clone_xprt, vers_min,
1403 				(void) SVC_FREEARGS(clone_xprt, NULL, NULL);
1420 				rpc_gss_cleanup(clone_xprt);
1443 	SVCXPRT *clone_xprt;
1445 	clone_xprt = kmem_zalloc(sizeof (SVCXPRT), KM_SLEEP);
1446 	clone_xprt->xp_cred = crget();
1447 	return (clone_xprt);
1454 svc_clone_free(SVCXPRT *clone_xprt)
1457 	if (clone_xprt->xp_cred)
1458 		crfree(clone_xprt->xp_cred);
1459 	kmem_free(clone_xprt, sizeof (SVCXPRT));
1469 svc_clone_link(SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt, SVCXPRT *clone_xprt2)
1471 	cred_t *cred = clone_xprt->xp_cred;
1485 	bzero(clone_xprt, sizeof (SVCXPRT));
1488 	clone_xprt->xp_master = xprt;
1491 	clone_xprt->xp_xpc = xprt->xp_xpc;
1494 	clone_xprt->xp_cred = cred;
1497 		SVC_CLONE_XPRT(clone_xprt2, clone_xprt);
1510 svc_clone_unlink(SVCXPRT *clone_xprt)
1512 	SVCMASTERXPRT *xprt = clone_xprt->xp_master;
1515 	ASSERT(!clone_xprt->xp_detached);
1529 	SVC_CLONE_DESTROY(clone_xprt);
1532 	clone_xprt->xp_master = NULL;
1545 svc_clone_unlinkdetached(SVCXPRT *clone_xprt)
1547 	SVCMASTERXPRT *xprt = clone_xprt->xp_master;
1550 	ASSERT(clone_xprt->xp_detached);
1565 	SVC_CLONE_DESTROY(clone_xprt);
1568 	clone_xprt->xp_master = NULL;
1584 svc_thread_exit(SVCPOOL *pool, SVCXPRT *clone_xprt)
1586 	if (clone_xprt->xp_master)
1587 		svc_clone_unlink(clone_xprt);
1588 	svc_clone_free(clone_xprt);
1611 svc_thread_exitdetached(SVCPOOL *pool, SVCXPRT *clone_xprt)
1614 	ASSERT(clone_xprt->xp_master);
1615 	ASSERT(clone_xprt->xp_detached);
1618 	svc_clone_unlinkdetached(clone_xprt);
1619 	svc_clone_free(clone_xprt);
1842 svc_poll(SVCPOOL *pool, SVCMASTERXPRT *xprt, SVCXPRT *clone_xprt)
1872 		    clone_xprt->xp_same_xprt++ < pool->p_max_same_xprt)) {
1878 		clone_xprt->xp_same_xprt = 0;
2221 	SVCXPRT *clone_xprt;	/* clone for this thread    */
2225 	clone_xprt = svc_clone_init();
2245 			svc_thread_exit(pool, clone_xprt);
2250 		next = svc_poll(pool, xprt, clone_xprt);
2266 			svc_clone_unlink(clone_xprt);
2273 			svc_thread_exit(pool, clone_xprt);
2282 			svc_thread_exit(pool, clone_xprt);
2321 				svc_clone_unlink(clone_xprt);
2322 			svc_clone_link(next, clone_xprt, NULL);
2368 		svc_getreq(clone_xprt, mp);
2371 		ASSERT(!clone_xprt->xp_reserved);
2378 		if (clone_xprt->xp_detached) {
2379 			svc_thread_exitdetached(pool, clone_xprt);
2392 		(*RELE_PROC(xprt)) (clone_xprt->xp_wq, NULL, enable);
2638 svc_reserve_thread(SVCXPRT *clone_xprt)
2640 	SVCPOOL *pool = clone_xprt->xp_master->xp_pool;
2643 	ASSERT(!clone_xprt->xp_reserved);
2644 	ASSERT(!clone_xprt->xp_detached);
2657 	clone_xprt->xp_reserved = TRUE;
2668 svc_unreserve_thread(SVCXPRT *clone_xprt)
2670 	SVCPOOL *pool = clone_xprt->xp_master->xp_pool;
2673 	ASSERT(clone_xprt->xp_reserved);
2674 	ASSERT(!clone_xprt->xp_detached);
2682 	clone_xprt->xp_reserved = FALSE;
2705 svc_detach_thread(SVCXPRT *clone_xprt)
2707 	SVCMASTERXPRT *xprt = clone_xprt->xp_master;
2712 	ASSERT(clone_xprt->xp_reserved);
2713 	ASSERT(!clone_xprt->xp_detached);
2734 	(*RELE_PROC(xprt)) (clone_xprt->xp_wq, NULL, enable);
2737 	clone_xprt->xp_reserved = FALSE;
2738 	clone_xprt->xp_detached = TRUE;