Lines Matching refs:xps
360 struct rpc_xprt_switch *xps, in rpc_new_client() argument
416 xprt_iter_init(&clnt->cl_xpi, xps); in rpc_new_client()
417 xprt_switch_put(xps); in rpc_new_client()
429 rpc_sysfs_client_setup(clnt, xps, rpc_net_ns(clnt)); in rpc_new_client()
449 xprt_switch_put(xps); in rpc_new_client()
459 struct rpc_xprt_switch *xps; in rpc_create_xprt() local
463 xps = args->bc_xprt->xpt_bc_xps; in rpc_create_xprt()
464 xprt_switch_get(xps); in rpc_create_xprt()
466 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_create_xprt()
467 if (xps == NULL) { in rpc_create_xprt()
472 xprt_switch_get(xps); in rpc_create_xprt()
473 xprt->bc_xprt->xpt_bc_xps = xps; in rpc_create_xprt()
476 clnt = rpc_new_client(args, xps, xprt, NULL); in rpc_create_xprt()
617 struct rpc_xprt_switch *xps; in __rpc_clone_client() local
625 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in __rpc_clone_client()
627 if (xprt == NULL || xps == NULL) { in __rpc_clone_client()
629 xprt_switch_put(xps); in __rpc_clone_client()
635 new = rpc_new_client(args, xps, xprt, clnt); in __rpc_clone_client()
717 struct rpc_xprt_switch *xps, *oldxps; in rpc_switch_client_transport() local
726 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_switch_client_transport()
727 if (xps == NULL) { in rpc_switch_client_transport()
736 oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps); in rpc_switch_client_transport()
769 xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps); in rpc_switch_client_transport()
773 xprt_switch_put(xps); in rpc_switch_client_transport()
783 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_iter_init() local
786 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_xprt_iter_init()
788 if (xps == NULL) in rpc_clnt_xprt_iter_init()
790 xprt_iter_init_listall(xpi, xps); in rpc_clnt_xprt_iter_init()
791 xprt_switch_put(xps); in rpc_clnt_xprt_iter_init()
991 struct rpc_xprt_switch *xps; in rpc_task_get_xprt() local
996 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_get_xprt()
997 atomic_long_inc(&xps->xps_queuelen); in rpc_task_get_xprt()
1007 struct rpc_xprt_switch *xps; in rpc_task_release_xprt() local
1011 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_release_xprt()
1012 atomic_long_dec(&xps->xps_queuelen); in rpc_task_release_xprt()
2108 struct rpc_xprt_switch *xps; in call_connect_status() local
2111 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in call_connect_status()
2113 if (xps->xps_nxprts > 1) { in call_connect_status()
2119 rpc_xprt_switch_remove_xprt(xps, saved); in call_connect_status()
2124 xprt_switch_put(xps); in call_connect_status()
2746 struct rpc_xprt_switch *xps; member
2755 rpc_xprt_switch_add_xprt(data->xps, data->xprt); in rpc_cb_add_xprt_done()
2763 xprt_switch_put(data->xps); in rpc_cb_add_xprt_release()
2781 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, in rpc_clnt_test_and_add_xprt() argument
2787 if (xps->xps_nunique_destaddr_xprts + 1 > clnt->cl_max_connect) { in rpc_clnt_test_and_add_xprt()
2799 data->xps = xprt_switch_get(xps); in rpc_clnt_test_and_add_xprt()
2801 if (rpc_xprt_switch_has_addr(data->xps, (struct sockaddr *)&xprt->addr)) { in rpc_clnt_test_and_add_xprt()
2808 data->xps->xps_nunique_destaddr_xprts++; in rpc_clnt_test_and_add_xprt()
2834 struct rpc_xprt_switch *xps, in rpc_clnt_setup_test_and_add_xprt() argument
2843 xprt_switch_get(xps); in rpc_clnt_setup_test_and_add_xprt()
2845 if (rpc_xprt_switch_has_addr(xps, (struct sockaddr *)&xprt->addr)) in rpc_clnt_setup_test_and_add_xprt()
2864 xprt_switch_put(xps); in rpc_clnt_setup_test_and_add_xprt()
2870 xprt_switch_put(xps); in rpc_clnt_setup_test_and_add_xprt()
2898 struct rpc_xprt_switch *xps; in rpc_clnt_add_xprt() local
2906 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_add_xprt()
2908 if (xps == NULL || xprt == NULL) { in rpc_clnt_add_xprt()
2910 xprt_switch_put(xps); in rpc_clnt_add_xprt()
2931 rpc_xprt_switch_set_roundrobin(xps); in rpc_clnt_add_xprt()
2933 ret = setup(clnt, xps, xprt, data); in rpc_clnt_add_xprt()
2937 rpc_xprt_switch_add_xprt(xps, xprt); in rpc_clnt_add_xprt()
2941 xprt_switch_put(xps); in rpc_clnt_add_xprt()
3000 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_switch_has_addr() local
3004 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_switch_has_addr()
3005 ret = rpc_xprt_switch_has_addr(xps, sap); in rpc_clnt_xprt_switch_has_addr()