Lines Matching refs:xps

358 		struct rpc_xprt_switch *xps,  in rpc_new_client()  argument
413 xprt_iter_init(&clnt->cl_xpi, xps); in rpc_new_client()
414 xprt_switch_put(xps); in rpc_new_client()
445 xprt_switch_put(xps); in rpc_new_client()
455 struct rpc_xprt_switch *xps; in rpc_create_xprt() local
459 xps = args->bc_xprt->xpt_bc_xps; in rpc_create_xprt()
460 xprt_switch_get(xps); in rpc_create_xprt()
462 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_create_xprt()
463 if (xps == NULL) { in rpc_create_xprt()
468 xprt_switch_get(xps); in rpc_create_xprt()
469 xprt->bc_xprt->xpt_bc_xps = xps; in rpc_create_xprt()
472 clnt = rpc_new_client(args, xps, xprt, NULL); in rpc_create_xprt()
613 struct rpc_xprt_switch *xps; in __rpc_clone_client() local
621 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in __rpc_clone_client()
623 if (xprt == NULL || xps == NULL) { in __rpc_clone_client()
625 xprt_switch_put(xps); in __rpc_clone_client()
631 new = rpc_new_client(args, xps, xprt, clnt); in __rpc_clone_client()
713 struct rpc_xprt_switch *xps, *oldxps; in rpc_switch_client_transport() local
722 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_switch_client_transport()
723 if (xps == NULL) { in rpc_switch_client_transport()
732 oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps); in rpc_switch_client_transport()
764 xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps); in rpc_switch_client_transport()
768 xprt_switch_put(xps); in rpc_switch_client_transport()
778 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_iter_init() local
781 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_xprt_iter_init()
783 if (xps == NULL) in rpc_clnt_xprt_iter_init()
785 xprt_iter_init_listall(xpi, xps); in rpc_clnt_xprt_iter_init()
786 xprt_switch_put(xps); in rpc_clnt_xprt_iter_init()
987 struct rpc_xprt_switch *xps; in rpc_task_get_xprt() local
992 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_get_xprt()
993 atomic_long_inc(&xps->xps_queuelen); in rpc_task_get_xprt()
1003 struct rpc_xprt_switch *xps; in rpc_task_release_xprt() local
1007 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_release_xprt()
1008 atomic_long_dec(&xps->xps_queuelen); in rpc_task_release_xprt()
2717 struct rpc_xprt_switch *xps; member
2726 rpc_xprt_switch_add_xprt(data->xps, data->xprt); in rpc_cb_add_xprt_done()
2734 xprt_switch_put(data->xps); in rpc_cb_add_xprt_release()
2751 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, in rpc_clnt_test_and_add_xprt() argument
2760 data->xps = xprt_switch_get(xps); in rpc_clnt_test_and_add_xprt()
2762 if (rpc_xprt_switch_has_addr(data->xps, (struct sockaddr *)&xprt->addr)) { in rpc_clnt_test_and_add_xprt()
2795 struct rpc_xprt_switch *xps, in rpc_clnt_setup_test_and_add_xprt() argument
2804 xprt_switch_get(xps); in rpc_clnt_setup_test_and_add_xprt()
2806 if (rpc_xprt_switch_has_addr(xps, (struct sockaddr *)&xprt->addr)) in rpc_clnt_setup_test_and_add_xprt()
2825 xprt_switch_put(xps); in rpc_clnt_setup_test_and_add_xprt()
2831 xprt_switch_put(xps); in rpc_clnt_setup_test_and_add_xprt()
2859 struct rpc_xprt_switch *xps; in rpc_clnt_add_xprt() local
2867 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_add_xprt()
2869 if (xps == NULL || xprt == NULL) { in rpc_clnt_add_xprt()
2871 xprt_switch_put(xps); in rpc_clnt_add_xprt()
2892 rpc_xprt_switch_set_roundrobin(xps); in rpc_clnt_add_xprt()
2894 ret = setup(clnt, xps, xprt, data); in rpc_clnt_add_xprt()
2898 rpc_xprt_switch_add_xprt(xps, xprt); in rpc_clnt_add_xprt()
2902 xprt_switch_put(xps); in rpc_clnt_add_xprt()
2961 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_switch_has_addr() local
2965 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_switch_has_addr()
2966 ret = rpc_xprt_switch_has_addr(xps, sap); in rpc_clnt_xprt_switch_has_addr()