Lines Matching defs:xps
364 struct rpc_xprt_switch *xps,
421 xprt_iter_init(&clnt->cl_xpi, xps);
422 xprt_switch_put(xps);
434 rpc_sysfs_client_setup(clnt, xps, rpc_net_ns(clnt));
454 xprt_switch_put(xps);
464 struct rpc_xprt_switch *xps;
468 xps = args->bc_xprt->xpt_bc_xps;
469 xprt_switch_get(xps);
471 xps = xprt_switch_alloc(xprt, GFP_KERNEL);
472 if (xps == NULL) {
477 xprt_switch_get(xps);
478 xprt->bc_xprt->xpt_bc_xps = xps;
481 clnt = rpc_new_client(args, xps, xprt, NULL);
635 struct rpc_xprt_switch *xps;
643 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));
645 if (xprt == NULL || xps == NULL) {
647 xprt_switch_put(xps);
653 new = rpc_new_client(args, xps, xprt, clnt);
736 struct rpc_xprt_switch *xps, *oldxps;
746 xps = xprt_switch_alloc(xprt, GFP_KERNEL);
747 if (xps == NULL) {
756 oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps);
789 xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps);
793 xprt_switch_put(xps);
802 void func(struct rpc_xprt_iter *xpi, struct rpc_xprt_switch *xps))
804 struct rpc_xprt_switch *xps;
807 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));
809 if (xps == NULL)
811 func(xpi, xps);
812 xprt_switch_put(xps);
1076 struct rpc_xprt_switch *xps;
1081 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);
1082 atomic_long_inc(&xps->xps_queuelen);
1092 struct rpc_xprt_switch *xps;
1096 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);
1097 atomic_long_dec(&xps->xps_queuelen);
2207 struct rpc_xprt_switch *xps;
2210 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));
2212 if (xps->xps_nxprts > 1) {
2218 rpc_xprt_switch_remove_xprt(xps, saved,
2224 xprt_switch_put(xps);
2889 struct rpc_xprt_switch *xps;
2898 rpc_xprt_switch_add_xprt(data->xps, data->xprt);
2906 xprt_switch_put(data->xps);
2919 * @xps: pointer to struct rpc_xprt_switch,
2924 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt,
2933 if (xps->xps_nunique_destaddr_xprts + 1 > max_connect) {
2945 data->xps = xprt_switch_get(xps);
2947 if (rpc_xprt_switch_has_addr(data->xps, (struct sockaddr *)&xprt->addr)) {
2957 data->xps->xps_nunique_destaddr_xprts++;
3001 * @xps: the rpc_xprt_switch to hold the new transport
3007 struct rpc_xprt_switch *xps,
3014 xprt_switch_get(xps);
3016 if (rpc_xprt_switch_has_addr(xps, (struct sockaddr *)&xprt->addr))
3026 xprt_switch_put(xps);
3057 struct rpc_xprt_switch *xps;
3065 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));
3067 if (xps == NULL || xprt == NULL) {
3069 xprt_switch_put(xps);
3099 rpc_xprt_switch_set_roundrobin(xps);
3101 ret = setup(clnt, xps, xprt, data);
3105 rpc_xprt_switch_add_xprt(xps, xprt);
3109 xprt_switch_put(xps);
3118 struct rpc_xprt_switch *xps;
3126 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));
3137 xprt_switch_put(xps);
3177 struct rpc_xprt_switch *xps;
3184 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));
3196 xprt_set_offline_locked(xprt, xps);
3201 xprt_switch_put(xps);
3262 struct rpc_xprt_switch *xps;
3265 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);
3267 xprt_set_online_locked(xprt, xps);
3285 struct rpc_xprt_switch *xps;
3288 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);
3291 xps->xps_nunique_destaddr_xprts--;
3299 struct rpc_xprt_switch *xps;
3303 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);
3304 ret = rpc_xprt_switch_has_addr(xps, sap);