Lines Matching refs:xps
361 struct rpc_xprt_switch *xps, in rpc_new_client() argument
417 xprt_iter_init(&clnt->cl_xpi, xps); in rpc_new_client()
418 xprt_switch_put(xps); in rpc_new_client()
430 rpc_sysfs_client_setup(clnt, xps, rpc_net_ns(clnt)); in rpc_new_client()
450 xprt_switch_put(xps); in rpc_new_client()
460 struct rpc_xprt_switch *xps; in rpc_create_xprt() local
464 xps = args->bc_xprt->xpt_bc_xps; in rpc_create_xprt()
465 xprt_switch_get(xps); in rpc_create_xprt()
467 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_create_xprt()
468 if (xps == NULL) { in rpc_create_xprt()
473 xprt_switch_get(xps); in rpc_create_xprt()
474 xprt->bc_xprt->xpt_bc_xps = xps; in rpc_create_xprt()
477 clnt = rpc_new_client(args, xps, xprt, NULL); in rpc_create_xprt()
624 struct rpc_xprt_switch *xps; in __rpc_clone_client() local
632 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in __rpc_clone_client()
634 if (xprt == NULL || xps == NULL) { in __rpc_clone_client()
636 xprt_switch_put(xps); in __rpc_clone_client()
642 new = rpc_new_client(args, xps, xprt, clnt); in __rpc_clone_client()
725 struct rpc_xprt_switch *xps, *oldxps; in rpc_switch_client_transport() local
734 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_switch_client_transport()
735 if (xps == NULL) { in rpc_switch_client_transport()
744 oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps); in rpc_switch_client_transport()
777 xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps); in rpc_switch_client_transport()
781 xprt_switch_put(xps); in rpc_switch_client_transport()
790 void func(struct rpc_xprt_iter *xpi, struct rpc_xprt_switch *xps)) in _rpc_clnt_xprt_iter_init() argument
792 struct rpc_xprt_switch *xps; in _rpc_clnt_xprt_iter_init() local
795 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in _rpc_clnt_xprt_iter_init()
797 if (xps == NULL) in _rpc_clnt_xprt_iter_init()
799 func(xpi, xps); in _rpc_clnt_xprt_iter_init()
800 xprt_switch_put(xps); in _rpc_clnt_xprt_iter_init()
1064 struct rpc_xprt_switch *xps; in rpc_task_get_xprt() local
1069 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_get_xprt()
1070 atomic_long_inc(&xps->xps_queuelen); in rpc_task_get_xprt()
1080 struct rpc_xprt_switch *xps; in rpc_task_release_xprt() local
1084 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_release_xprt()
1085 atomic_long_dec(&xps->xps_queuelen); in rpc_task_release_xprt()
2193 struct rpc_xprt_switch *xps; in call_connect_status() local
2196 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in call_connect_status()
2198 if (xps->xps_nxprts > 1) { in call_connect_status()
2204 rpc_xprt_switch_remove_xprt(xps, saved, in call_connect_status()
2210 xprt_switch_put(xps); in call_connect_status()
2863 struct rpc_xprt_switch *xps; member
2872 rpc_xprt_switch_add_xprt(data->xps, data->xprt); in rpc_cb_add_xprt_done()
2880 xprt_switch_put(data->xps); in rpc_cb_add_xprt_release()
2898 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, in rpc_clnt_test_and_add_xprt() argument
2904 if (xps->xps_nunique_destaddr_xprts + 1 > clnt->cl_max_connect) { in rpc_clnt_test_and_add_xprt()
2916 data->xps = xprt_switch_get(xps); in rpc_clnt_test_and_add_xprt()
2918 if (rpc_xprt_switch_has_addr(data->xps, (struct sockaddr *)&xprt->addr)) { in rpc_clnt_test_and_add_xprt()
2928 data->xps->xps_nunique_destaddr_xprts++; in rpc_clnt_test_and_add_xprt()
2978 struct rpc_xprt_switch *xps, in rpc_clnt_setup_test_and_add_xprt() argument
2985 xprt_switch_get(xps); in rpc_clnt_setup_test_and_add_xprt()
2987 if (rpc_xprt_switch_has_addr(xps, (struct sockaddr *)&xprt->addr)) in rpc_clnt_setup_test_and_add_xprt()
2997 xprt_switch_put(xps); in rpc_clnt_setup_test_and_add_xprt()
3028 struct rpc_xprt_switch *xps; in rpc_clnt_add_xprt() local
3036 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_add_xprt()
3038 if (xps == NULL || xprt == NULL) { in rpc_clnt_add_xprt()
3040 xprt_switch_put(xps); in rpc_clnt_add_xprt()
3064 rpc_xprt_switch_set_roundrobin(xps); in rpc_clnt_add_xprt()
3066 ret = setup(clnt, xps, xprt, data); in rpc_clnt_add_xprt()
3070 rpc_xprt_switch_add_xprt(xps, xprt); in rpc_clnt_add_xprt()
3074 xprt_switch_put(xps); in rpc_clnt_add_xprt()
3083 struct rpc_xprt_switch *xps; in rpc_xprt_probe_trunked() local
3091 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_xprt_probe_trunked()
3102 xprt_switch_put(xps); in rpc_xprt_probe_trunked()
3142 struct rpc_xprt_switch *xps; in rpc_xprt_offline() local
3149 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_xprt_offline()
3161 xprt_set_offline_locked(xprt, xps); in rpc_xprt_offline()
3166 xprt_switch_put(xps); in rpc_xprt_offline()
3227 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_set_online() local
3230 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_set_online()
3232 xprt_set_online_locked(xprt, xps); in rpc_clnt_xprt_set_online()
3250 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_switch_remove_xprt() local
3253 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_switch_remove_xprt()
3256 xps->xps_nunique_destaddr_xprts--; in rpc_clnt_xprt_switch_remove_xprt()
3264 struct rpc_xprt_switch *xps; in rpc_clnt_xprt_switch_has_addr() local
3268 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_switch_has_addr()
3269 ret = rpc_xprt_switch_has_addr(xps, sap); in rpc_clnt_xprt_switch_has_addr()