Lines Matching refs:xprt

268 		struct rpc_xprt *xprt,  in rpc_clnt_set_transport()  argument
277 if (!xprt_bound(xprt)) in rpc_clnt_set_transport()
281 rcu_assign_pointer(clnt->cl_xprt, xprt); in rpc_clnt_set_transport()
363 struct rpc_xprt *xprt, in rpc_new_client() argument
375 program->name, args->servername, xprt); in rpc_new_client()
413 timeout = xprt->timeout; in rpc_new_client()
420 rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_new_client()
452 xprt_put(xprt); in rpc_new_client()
457 struct rpc_xprt *xprt) in rpc_create_xprt() argument
467 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_create_xprt()
469 xprt_put(xprt); in rpc_create_xprt()
472 if (xprt->bc_xprt) { 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()
520 struct rpc_xprt *xprt; in rpc_create() local
536 xprt = args->bc_xprt->xpt_bc_xprt; in rpc_create()
537 if (xprt) { in rpc_create()
538 xprt_get(xprt); in rpc_create()
539 return rpc_create_xprt(args, xprt); in rpc_create()
581 xprt = xprt_create_transport(&xprtargs); in rpc_create()
582 if (IS_ERR(xprt)) in rpc_create()
583 return (struct rpc_clnt *)xprt; in rpc_create()
591 xprt->resvport = 1; in rpc_create()
593 xprt->resvport = 0; in rpc_create()
595 clnt = rpc_create_xprt(args, xprt); in rpc_create()
616 struct rpc_xprt *xprt; in __rpc_clone_client() local
622 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in __rpc_clone_client()
625 if (xprt == NULL || xps == NULL) { in __rpc_clone_client()
626 xprt_put(xprt); in __rpc_clone_client()
630 args->servername = xprt->servername; in __rpc_clone_client()
633 new = rpc_new_client(args, xps, xprt, clnt); in __rpc_clone_client()
718 struct rpc_xprt *xprt, *old; in rpc_switch_client_transport() local
722 xprt = xprt_create_transport(args); in rpc_switch_client_transport()
723 if (IS_ERR(xprt)) { in rpc_switch_client_transport()
726 return PTR_ERR(xprt); in rpc_switch_client_transport()
729 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_switch_client_transport()
731 xprt_put(xprt); in rpc_switch_client_transport()
738 old = rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_switch_client_transport()
776 xprt_put(xprt); in rpc_switch_client_transport()
819 struct rpc_xprt *xprt = xprt_iter_get_next(&xpi); in rpc_clnt_iterate_for_each_xprt() local
821 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
823 ret = fn(clnt, xprt, data); in rpc_clnt_iterate_for_each_xprt()
824 xprt_put(xprt); in rpc_clnt_iterate_for_each_xprt()
982 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_get_xprt() argument
986 if (!xprt) in rpc_task_get_xprt()
992 atomic_long_inc(&xprt->queuelen); in rpc_task_get_xprt()
994 return xprt; in rpc_task_get_xprt()
998 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_release_xprt() argument
1002 atomic_long_dec(&xprt->queuelen); in rpc_task_release_xprt()
1008 xprt_put(xprt); in rpc_task_release_xprt()
1013 struct rpc_xprt *xprt = task->tk_xprt; in rpc_task_release_transport() local
1015 if (xprt) { in rpc_task_release_transport()
1018 rpc_task_release_xprt(task->tk_client, xprt); in rpc_task_release_transport()
1020 xprt_put(xprt); in rpc_task_release_transport()
1044 struct rpc_xprt *xprt; in rpc_task_get_first_xprt() local
1047 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpc_task_get_first_xprt()
1049 return rpc_task_get_xprt(clnt, xprt); in rpc_task_get_first_xprt()
1275 struct rpc_xprt *xprt; in rpc_peeraddr() local
1278 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr()
1280 bytes = xprt->addrlen; in rpc_peeraddr()
1283 memcpy(buf, &xprt->addr, bytes); in rpc_peeraddr()
1302 struct rpc_xprt *xprt; in rpc_peeraddr2str() local
1304 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr2str()
1306 if (xprt->address_strings[format] != NULL) in rpc_peeraddr2str()
1307 return xprt->address_strings[format]; in rpc_peeraddr2str()
1441 struct rpc_xprt *xprt; in rpc_localaddr() local
1447 xprt = rcu_dereference(clnt->cl_xprt); in rpc_localaddr()
1448 salen = xprt->addrlen; in rpc_localaddr()
1449 memcpy(sap, &xprt->addr, salen); in rpc_localaddr()
1450 net = get_net(xprt->xprt_net); in rpc_localaddr()
1466 struct rpc_xprt *xprt; in rpc_setbufsize() local
1469 xprt = rcu_dereference(clnt->cl_xprt); in rpc_setbufsize()
1470 if (xprt->ops->set_buffer_size) in rpc_setbufsize()
1471 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1518 struct rpc_xprt *xprt; in rpc_max_bc_payload() local
1522 xprt = rcu_dereference(clnt->cl_xprt); in rpc_max_bc_payload()
1523 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1531 struct rpc_xprt *xprt; in rpc_num_bc_slots() local
1535 xprt = rcu_dereference(clnt->cl_xprt); in rpc_num_bc_slots()
1536 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
1789 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate() local
1823 status = xprt->ops->buf_alloc(task); in call_allocate()
1824 xprt_inject_disconnect(xprt); in call_allocate()
1949 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind() local
1956 if (xprt_bound(xprt)) { in call_bind()
1967 xprt->ops->rpcbind(task); in call_bind()
1976 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status() local
1988 if (xprt_bound(xprt)) { in call_bind_status()
2068 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect() local
2075 if (xprt_connected(xprt)) { in call_connect()
2081 task->tk_pid, xprt, in call_connect()
2082 (xprt_connected(xprt) ? "is" : "is not")); in call_connect()
2102 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status() local
2118 if (xprt_connected(xprt)) { in call_connect_status()
2733 struct rpc_xprt *xprt, struct rpc_cred *cred, int flags, in rpc_call_null_helper() argument
2741 .rpc_xprt = xprt, in rpc_call_null_helper()
2760 struct rpc_xprt *xprt; member
2768 rpc_xprt_switch_add_xprt(data->xps, data->xprt); in rpc_cb_add_xprt_done()
2775 xprt_put(data->xprt); in rpc_cb_add_xprt_release()
2793 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, in rpc_clnt_test_and_add_xprt() argument
2803 data->xprt = xprt_get(xprt); in rpc_clnt_test_and_add_xprt()
2804 if (rpc_xprt_switch_has_addr(data->xps, (struct sockaddr *)&xprt->addr)) { in rpc_clnt_test_and_add_xprt()
2809 task = rpc_call_null_helper(clnt, xprt, NULL, in rpc_clnt_test_and_add_xprt()
2840 struct rpc_xprt *xprt, in rpc_clnt_setup_test_and_add_xprt() argument
2847 xprt = xprt_get(xprt); in rpc_clnt_setup_test_and_add_xprt()
2850 if (rpc_xprt_switch_has_addr(xps, (struct sockaddr *)&xprt->addr)) in rpc_clnt_setup_test_and_add_xprt()
2854 task = rpc_call_null_helper(clnt, xprt, NULL, in rpc_clnt_setup_test_and_add_xprt()
2868 xtest->add_xprt_test(clnt, xprt, xtest->data); in rpc_clnt_setup_test_and_add_xprt()
2870 xprt_put(xprt); in rpc_clnt_setup_test_and_add_xprt()
2876 xprt_put(xprt); in rpc_clnt_setup_test_and_add_xprt()
2879 status, xprt->address_strings[RPC_DISPLAY_ADDR]); in rpc_clnt_setup_test_and_add_xprt()
2906 struct rpc_xprt *xprt; in rpc_clnt_add_xprt() local
2914 xprt = xprt_iter_xprt(&clnt->cl_xpi); in rpc_clnt_add_xprt()
2915 if (xps == NULL || xprt == NULL) { in rpc_clnt_add_xprt()
2920 resvport = xprt->resvport; in rpc_clnt_add_xprt()
2921 connect_timeout = xprt->connect_timeout; in rpc_clnt_add_xprt()
2922 reconnect_timeout = xprt->max_reconnect_timeout; in rpc_clnt_add_xprt()
2925 xprt = xprt_create_transport(xprtargs); in rpc_clnt_add_xprt()
2926 if (IS_ERR(xprt)) { in rpc_clnt_add_xprt()
2927 ret = PTR_ERR(xprt); in rpc_clnt_add_xprt()
2930 xprt->resvport = resvport; in rpc_clnt_add_xprt()
2931 if (xprt->ops->set_connect_timeout != NULL) in rpc_clnt_add_xprt()
2932 xprt->ops->set_connect_timeout(xprt, in rpc_clnt_add_xprt()
2938 ret = setup(clnt, xps, xprt, data); in rpc_clnt_add_xprt()
2942 rpc_xprt_switch_add_xprt(xps, xprt); in rpc_clnt_add_xprt()
2944 xprt_put(xprt); in rpc_clnt_add_xprt()
2958 struct rpc_xprt *xprt, in rpc_xprt_set_connect_timeout() argument
2963 if (xprt->ops->set_connect_timeout) in rpc_xprt_set_connect_timeout()
2964 xprt->ops->set_connect_timeout(xprt, in rpc_xprt_set_connect_timeout()
2993 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_switch_add_xprt() argument
2997 xprt); in rpc_clnt_xprt_switch_add_xprt()
3064 struct rpc_xprt *xprt, in rpc_clnt_swap_activate_callback() argument
3067 return xprt_enable_swap(xprt); in rpc_clnt_swap_activate_callback()
3082 struct rpc_xprt *xprt, in rpc_clnt_swap_deactivate_callback() argument
3085 xprt_disable_swap(xprt); in rpc_clnt_swap_deactivate_callback()