Lines Matching refs:xprt
267 struct rpc_xprt *xprt, in rpc_clnt_set_transport() argument
276 if (!xprt_bound(xprt)) in rpc_clnt_set_transport()
280 rcu_assign_pointer(clnt->cl_xprt, xprt); in rpc_clnt_set_transport()
362 struct rpc_xprt *xprt, in rpc_new_client() argument
408 timeout = xprt->timeout; in rpc_new_client()
415 rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_new_client()
435 trace_rpc_clnt_new(clnt, xprt, program->name, args->servername); in rpc_new_client()
449 xprt_put(xprt); in rpc_new_client()
455 struct rpc_xprt *xprt) in rpc_create_xprt() argument
465 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_create_xprt()
467 xprt_put(xprt); in rpc_create_xprt()
470 if (xprt->bc_xprt) { in rpc_create_xprt()
472 xprt->bc_xprt->xpt_bc_xps = xps; in rpc_create_xprt()
475 clnt = rpc_new_client(args, xps, xprt, NULL); in rpc_create_xprt()
518 struct rpc_xprt *xprt; in rpc_create() local
534 xprt = args->bc_xprt->xpt_bc_xprt; in rpc_create()
535 if (xprt) { in rpc_create()
536 xprt_get(xprt); in rpc_create()
537 return rpc_create_xprt(args, xprt); in rpc_create()
579 xprt = xprt_create_transport(&xprtargs); in rpc_create()
580 if (IS_ERR(xprt)) in rpc_create()
581 return (struct rpc_clnt *)xprt; in rpc_create()
589 xprt->resvport = 1; in rpc_create()
591 xprt->resvport = 0; in rpc_create()
592 xprt->reuseport = 0; in rpc_create()
594 xprt->reuseport = 1; in rpc_create()
596 clnt = rpc_create_xprt(args, xprt); in rpc_create()
617 struct rpc_xprt *xprt; in __rpc_clone_client() local
623 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in __rpc_clone_client()
626 if (xprt == NULL || xps == NULL) { in __rpc_clone_client()
627 xprt_put(xprt); in __rpc_clone_client()
631 args->servername = xprt->servername; in __rpc_clone_client()
634 new = rpc_new_client(args, xps, xprt, clnt); in __rpc_clone_client()
717 struct rpc_xprt *xprt, *old; in rpc_switch_client_transport() local
721 xprt = xprt_create_transport(args); in rpc_switch_client_transport()
722 if (IS_ERR(xprt)) in rpc_switch_client_transport()
723 return PTR_ERR(xprt); in rpc_switch_client_transport()
725 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_switch_client_transport()
727 xprt_put(xprt); in rpc_switch_client_transport()
734 old = rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_switch_client_transport()
772 xprt_put(xprt); in rpc_switch_client_transport()
815 struct rpc_xprt *xprt = xprt_iter_get_next(&xpi); in rpc_clnt_iterate_for_each_xprt() local
817 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
819 ret = fn(clnt, xprt, data); in rpc_clnt_iterate_for_each_xprt()
820 xprt_put(xprt); in rpc_clnt_iterate_for_each_xprt()
988 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_get_xprt() argument
992 if (!xprt) in rpc_task_get_xprt()
998 atomic_long_inc(&xprt->queuelen); in rpc_task_get_xprt()
1000 return xprt; in rpc_task_get_xprt()
1004 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_release_xprt() argument
1008 atomic_long_dec(&xprt->queuelen); in rpc_task_release_xprt()
1014 xprt_put(xprt); in rpc_task_release_xprt()
1019 struct rpc_xprt *xprt = task->tk_xprt; in rpc_task_release_transport() local
1021 if (xprt) { in rpc_task_release_transport()
1024 rpc_task_release_xprt(task->tk_client, xprt); in rpc_task_release_transport()
1026 xprt_put(xprt); in rpc_task_release_transport()
1050 struct rpc_xprt *xprt; in rpc_task_get_first_xprt() local
1053 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpc_task_get_first_xprt()
1055 return rpc_task_get_xprt(clnt, xprt); in rpc_task_get_first_xprt()
1285 struct rpc_xprt *xprt; in rpc_peeraddr() local
1288 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr()
1290 bytes = xprt->addrlen; in rpc_peeraddr()
1293 memcpy(buf, &xprt->addr, bytes); in rpc_peeraddr()
1312 struct rpc_xprt *xprt; in rpc_peeraddr2str() local
1314 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr2str()
1316 if (xprt->address_strings[format] != NULL) in rpc_peeraddr2str()
1317 return xprt->address_strings[format]; in rpc_peeraddr2str()
1451 struct rpc_xprt *xprt; in rpc_localaddr() local
1457 xprt = rcu_dereference(clnt->cl_xprt); in rpc_localaddr()
1458 salen = xprt->addrlen; in rpc_localaddr()
1459 memcpy(sap, &xprt->addr, salen); in rpc_localaddr()
1460 net = get_net(xprt->xprt_net); in rpc_localaddr()
1476 struct rpc_xprt *xprt; in rpc_setbufsize() local
1479 xprt = rcu_dereference(clnt->cl_xprt); in rpc_setbufsize()
1480 if (xprt->ops->set_buffer_size) in rpc_setbufsize()
1481 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1528 struct rpc_xprt *xprt; in rpc_max_bc_payload() local
1532 xprt = rcu_dereference(clnt->cl_xprt); in rpc_max_bc_payload()
1533 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1541 struct rpc_xprt *xprt; in rpc_num_bc_slots() local
1545 xprt = rcu_dereference(clnt->cl_xprt); in rpc_num_bc_slots()
1546 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
1767 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate() local
1799 status = xprt->ops->buf_alloc(task); in call_allocate()
1922 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind() local
1929 if (xprt_bound(xprt)) { in call_bind()
1938 xprt->ops->rpcbind(task); in call_bind()
1947 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status() local
1957 if (xprt_bound(xprt)) { in call_bind_status()
2027 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect() local
2034 if (xprt_connected(xprt)) { in call_connect()
2057 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status() local
2072 if (xprt_connected(xprt)) { in call_connect_status()
2690 struct rpc_xprt *xprt, struct rpc_cred *cred, int flags, in rpc_call_null_helper() argument
2698 .rpc_xprt = xprt, in rpc_call_null_helper()
2718 struct rpc_xprt *xprt; member
2726 rpc_xprt_switch_add_xprt(data->xps, data->xprt); in rpc_cb_add_xprt_done()
2733 xprt_put(data->xprt); in rpc_cb_add_xprt_release()
2751 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, in rpc_clnt_test_and_add_xprt() argument
2761 data->xprt = xprt_get(xprt); 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()
2767 task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC, in rpc_clnt_test_and_add_xprt()
2796 struct rpc_xprt *xprt, in rpc_clnt_setup_test_and_add_xprt() argument
2803 xprt = xprt_get(xprt); 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()
2810 task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL); in rpc_clnt_setup_test_and_add_xprt()
2822 xtest->add_xprt_test(clnt, xprt, xtest->data); in rpc_clnt_setup_test_and_add_xprt()
2824 xprt_put(xprt); in rpc_clnt_setup_test_and_add_xprt()
2830 xprt_put(xprt); in rpc_clnt_setup_test_and_add_xprt()
2833 status, xprt->address_strings[RPC_DISPLAY_ADDR]); in rpc_clnt_setup_test_and_add_xprt()
2860 struct rpc_xprt *xprt; in rpc_clnt_add_xprt() local
2868 xprt = xprt_iter_xprt(&clnt->cl_xpi); in rpc_clnt_add_xprt()
2869 if (xps == NULL || xprt == NULL) { in rpc_clnt_add_xprt()
2874 resvport = xprt->resvport; in rpc_clnt_add_xprt()
2875 reuseport = xprt->reuseport; in rpc_clnt_add_xprt()
2876 connect_timeout = xprt->connect_timeout; in rpc_clnt_add_xprt()
2877 reconnect_timeout = xprt->max_reconnect_timeout; in rpc_clnt_add_xprt()
2880 xprt = xprt_create_transport(xprtargs); in rpc_clnt_add_xprt()
2881 if (IS_ERR(xprt)) { in rpc_clnt_add_xprt()
2882 ret = PTR_ERR(xprt); in rpc_clnt_add_xprt()
2885 xprt->resvport = resvport; in rpc_clnt_add_xprt()
2886 xprt->reuseport = reuseport; in rpc_clnt_add_xprt()
2887 if (xprt->ops->set_connect_timeout != NULL) in rpc_clnt_add_xprt()
2888 xprt->ops->set_connect_timeout(xprt, 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()
2900 xprt_put(xprt); in rpc_clnt_add_xprt()
2914 struct rpc_xprt *xprt, in rpc_xprt_set_connect_timeout() argument
2919 if (xprt->ops->set_connect_timeout) in rpc_xprt_set_connect_timeout()
2920 xprt->ops->set_connect_timeout(xprt, in rpc_xprt_set_connect_timeout()
2949 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_switch_add_xprt() argument
2953 xprt); in rpc_clnt_xprt_switch_add_xprt()
3020 struct rpc_xprt *xprt, in rpc_clnt_swap_activate_callback() argument
3023 return xprt_enable_swap(xprt); in rpc_clnt_swap_activate_callback()
3040 struct rpc_xprt *xprt, in rpc_clnt_swap_deactivate_callback() argument
3043 xprt_disable_swap(xprt); in rpc_clnt_swap_deactivate_callback()