Lines Matching refs:xprt
265 struct rpc_xprt *xprt, in rpc_clnt_set_transport() argument
274 if (!xprt_bound(xprt)) in rpc_clnt_set_transport()
278 rcu_assign_pointer(clnt->cl_xprt, xprt); in rpc_clnt_set_transport()
361 struct rpc_xprt *xprt, in rpc_new_client() argument
407 timeout = xprt->timeout; in rpc_new_client()
414 rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_new_client()
415 xprt->main = true; in rpc_new_client()
436 trace_rpc_clnt_new(clnt, xprt, program->name, args->servername); in rpc_new_client()
450 xprt_put(xprt); in rpc_new_client()
456 struct rpc_xprt *xprt) in rpc_create_xprt() argument
466 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_create_xprt()
468 xprt_put(xprt); in rpc_create_xprt()
471 if (xprt->bc_xprt) { 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()
519 struct rpc_xprt *xprt; in rpc_create() local
535 xprt = args->bc_xprt->xpt_bc_xprt; in rpc_create()
536 if (xprt) { in rpc_create()
537 xprt_get(xprt); in rpc_create()
538 return rpc_create_xprt(args, xprt); in rpc_create()
580 xprt = xprt_create_transport(&xprtargs); in rpc_create()
581 if (IS_ERR(xprt)) in rpc_create()
582 return (struct rpc_clnt *)xprt; in rpc_create()
590 xprt->resvport = 1; in rpc_create()
592 xprt->resvport = 0; in rpc_create()
593 xprt->reuseport = 0; in rpc_create()
595 xprt->reuseport = 1; in rpc_create()
597 clnt = rpc_create_xprt(args, xprt); in rpc_create()
618 struct rpc_xprt *xprt; in __rpc_clone_client() local
624 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in __rpc_clone_client()
627 if (xprt == NULL || xps == NULL) { in __rpc_clone_client()
628 xprt_put(xprt); in __rpc_clone_client()
632 args->servername = xprt->servername; in __rpc_clone_client()
635 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()
724 return PTR_ERR(xprt); in rpc_switch_client_transport()
726 xps = xprt_switch_alloc(xprt, GFP_KERNEL); in rpc_switch_client_transport()
728 xprt_put(xprt); in rpc_switch_client_transport()
735 old = rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_switch_client_transport()
774 xprt_put(xprt); in rpc_switch_client_transport()
817 struct rpc_xprt *xprt = xprt_iter_get_next(&xpi); in rpc_clnt_iterate_for_each_xprt() local
819 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
821 ret = fn(clnt, xprt, data); in rpc_clnt_iterate_for_each_xprt()
822 xprt_put(xprt); in rpc_clnt_iterate_for_each_xprt()
989 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_get_xprt() argument
993 if (!xprt) in rpc_task_get_xprt()
999 atomic_long_inc(&xprt->queuelen); in rpc_task_get_xprt()
1001 return xprt; in rpc_task_get_xprt()
1005 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_release_xprt() argument
1009 atomic_long_dec(&xprt->queuelen); in rpc_task_release_xprt()
1015 xprt_put(xprt); in rpc_task_release_xprt()
1020 struct rpc_xprt *xprt = task->tk_xprt; in rpc_task_release_transport() local
1022 if (xprt) { in rpc_task_release_transport()
1025 rpc_task_release_xprt(task->tk_client, xprt); in rpc_task_release_transport()
1027 xprt_put(xprt); in rpc_task_release_transport()
1051 struct rpc_xprt *xprt; in rpc_task_get_first_xprt() local
1054 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpc_task_get_first_xprt()
1056 return rpc_task_get_xprt(clnt, xprt); in rpc_task_get_first_xprt()
1280 struct rpc_xprt *xprt; in rpc_peeraddr() local
1283 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr()
1285 bytes = xprt->addrlen; in rpc_peeraddr()
1288 memcpy(buf, &xprt->addr, bytes); in rpc_peeraddr()
1307 struct rpc_xprt *xprt; in rpc_peeraddr2str() local
1309 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr2str()
1311 if (xprt->address_strings[format] != NULL) in rpc_peeraddr2str()
1312 return xprt->address_strings[format]; in rpc_peeraddr2str()
1446 struct rpc_xprt *xprt; in rpc_localaddr() local
1452 xprt = rcu_dereference(clnt->cl_xprt); in rpc_localaddr()
1453 salen = xprt->addrlen; in rpc_localaddr()
1454 memcpy(sap, &xprt->addr, salen); in rpc_localaddr()
1455 net = get_net(xprt->xprt_net); in rpc_localaddr()
1471 struct rpc_xprt *xprt; in rpc_setbufsize() local
1474 xprt = rcu_dereference(clnt->cl_xprt); in rpc_setbufsize()
1475 if (xprt->ops->set_buffer_size) in rpc_setbufsize()
1476 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1523 struct rpc_xprt *xprt; in rpc_max_bc_payload() local
1527 xprt = rcu_dereference(clnt->cl_xprt); in rpc_max_bc_payload()
1528 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1536 struct rpc_xprt *xprt; in rpc_num_bc_slots() local
1540 xprt = rcu_dereference(clnt->cl_xprt); in rpc_num_bc_slots()
1541 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
1762 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate() local
1794 status = xprt->ops->buf_alloc(task); in call_allocate()
1917 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind() local
1924 if (xprt_bound(xprt)) { in call_bind()
1933 xprt->ops->rpcbind(task); in call_bind()
1942 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status() local
1952 if (xprt_bound(xprt)) { in call_bind_status()
2025 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect() local
2032 if (xprt_connected(xprt)) { in call_connect()
2055 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status() local
2070 if (xprt_connected(xprt)) { in call_connect_status()
2106 test_bit(XPRT_REMOVE, &xprt->state)) { in call_connect_status()
2117 value = atomic_long_dec_return(&xprt->queuelen); in call_connect_status()
2706 struct rpc_xprt *xprt, struct rpc_cred *cred, int flags, in rpc_call_null_helper() argument
2714 .rpc_xprt = xprt, in rpc_call_null_helper()
2747 struct rpc_xprt *xprt; member
2755 rpc_xprt_switch_add_xprt(data->xps, data->xprt); in rpc_cb_add_xprt_done()
2762 xprt_put(data->xprt); in rpc_cb_add_xprt_release()
2781 struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, in rpc_clnt_test_and_add_xprt() argument
2800 data->xprt = xprt_get(xprt); 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()
2806 task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC, in rpc_clnt_test_and_add_xprt()
2835 struct rpc_xprt *xprt, in rpc_clnt_setup_test_and_add_xprt() argument
2842 xprt = xprt_get(xprt); 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()
2849 task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL); in rpc_clnt_setup_test_and_add_xprt()
2861 xtest->add_xprt_test(clnt, xprt, xtest->data); in rpc_clnt_setup_test_and_add_xprt()
2863 xprt_put(xprt); in rpc_clnt_setup_test_and_add_xprt()
2869 xprt_put(xprt); in rpc_clnt_setup_test_and_add_xprt()
2872 status, xprt->address_strings[RPC_DISPLAY_ADDR]); in rpc_clnt_setup_test_and_add_xprt()
2899 struct rpc_xprt *xprt; in rpc_clnt_add_xprt() local
2907 xprt = xprt_iter_xprt(&clnt->cl_xpi); in rpc_clnt_add_xprt()
2908 if (xps == NULL || xprt == NULL) { in rpc_clnt_add_xprt()
2913 resvport = xprt->resvport; in rpc_clnt_add_xprt()
2914 reuseport = xprt->reuseport; in rpc_clnt_add_xprt()
2915 connect_timeout = xprt->connect_timeout; in rpc_clnt_add_xprt()
2916 reconnect_timeout = xprt->max_reconnect_timeout; in rpc_clnt_add_xprt()
2919 xprt = xprt_create_transport(xprtargs); in rpc_clnt_add_xprt()
2920 if (IS_ERR(xprt)) { in rpc_clnt_add_xprt()
2921 ret = PTR_ERR(xprt); in rpc_clnt_add_xprt()
2924 xprt->resvport = resvport; in rpc_clnt_add_xprt()
2925 xprt->reuseport = reuseport; in rpc_clnt_add_xprt()
2926 if (xprt->ops->set_connect_timeout != NULL) in rpc_clnt_add_xprt()
2927 xprt->ops->set_connect_timeout(xprt, 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()
2939 xprt_put(xprt); in rpc_clnt_add_xprt()
2953 struct rpc_xprt *xprt, in rpc_xprt_set_connect_timeout() argument
2958 if (xprt->ops->set_connect_timeout) in rpc_xprt_set_connect_timeout()
2959 xprt->ops->set_connect_timeout(xprt, in rpc_xprt_set_connect_timeout()
2988 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_switch_add_xprt() argument
2992 xprt); in rpc_clnt_xprt_switch_add_xprt()
3059 struct rpc_xprt *xprt, in rpc_clnt_swap_activate_callback() argument
3062 return xprt_enable_swap(xprt); in rpc_clnt_swap_activate_callback()
3077 struct rpc_xprt *xprt, in rpc_clnt_swap_deactivate_callback() argument
3080 xprt_disable_swap(xprt); in rpc_clnt_swap_deactivate_callback()