Lines Matching refs:xprt
68 return xprt_get(x->xprt); in rpc_sysfs_xprt_kobj_get_xprt()
93 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); in rpc_sysfs_xprt_dstaddr_show() local
96 if (!xprt) in rpc_sysfs_xprt_dstaddr_show()
98 ret = sprintf(buf, "%s\n", xprt->address_strings[RPC_DISPLAY_ADDR]); in rpc_sysfs_xprt_dstaddr_show()
99 xprt_put(xprt); in rpc_sysfs_xprt_dstaddr_show()
107 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); in rpc_sysfs_xprt_srcaddr_show() local
112 if (!xprt || !xprt_connected(xprt)) { in rpc_sysfs_xprt_srcaddr_show()
113 xprt_put(xprt); in rpc_sysfs_xprt_srcaddr_show()
117 sock = container_of(xprt, struct sock_xprt, xprt); in rpc_sysfs_xprt_srcaddr_show()
123 xprt_put(xprt); in rpc_sysfs_xprt_srcaddr_show()
131 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); in rpc_sysfs_xprt_info_show() local
134 if (!xprt || !xprt_connected(xprt)) { in rpc_sysfs_xprt_info_show()
135 xprt_put(xprt); in rpc_sysfs_xprt_info_show()
144 xprt->last_used, xprt->cong, xprt->cwnd, xprt->max_reqs, in rpc_sysfs_xprt_info_show()
145 xprt->min_reqs, xprt->num_reqs, xprt->binding.qlen, in rpc_sysfs_xprt_info_show()
146 xprt->sending.qlen, xprt->pending.qlen, in rpc_sysfs_xprt_info_show()
147 xprt->backlog.qlen, xprt->main, in rpc_sysfs_xprt_info_show()
148 (xprt->xprt_class->ident == XPRT_TRANSPORT_TCP) ? in rpc_sysfs_xprt_info_show()
149 get_srcport(xprt) : 0, in rpc_sysfs_xprt_info_show()
150 atomic_long_read(&xprt->queuelen), in rpc_sysfs_xprt_info_show()
151 (xprt->xprt_class->ident == XPRT_TRANSPORT_TCP) ? in rpc_sysfs_xprt_info_show()
152 xprt->address_strings[RPC_DISPLAY_PORT] : "0"); in rpc_sysfs_xprt_info_show()
153 xprt_put(xprt); in rpc_sysfs_xprt_info_show()
161 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); in rpc_sysfs_xprt_state_show() local
166 if (!xprt) in rpc_sysfs_xprt_state_show()
169 if (!xprt->state) { in rpc_sysfs_xprt_state_show()
172 locked = test_bit(XPRT_LOCKED, &xprt->state); in rpc_sysfs_xprt_state_show()
173 connected = test_bit(XPRT_CONNECTED, &xprt->state); in rpc_sysfs_xprt_state_show()
174 connecting = test_bit(XPRT_CONNECTING, &xprt->state); in rpc_sysfs_xprt_state_show()
175 close_wait = test_bit(XPRT_CLOSE_WAIT, &xprt->state); in rpc_sysfs_xprt_state_show()
176 bound = test_bit(XPRT_BOUND, &xprt->state); in rpc_sysfs_xprt_state_show()
177 binding = test_bit(XPRT_BINDING, &xprt->state); in rpc_sysfs_xprt_state_show()
178 closing = test_bit(XPRT_CLOSING, &xprt->state); in rpc_sysfs_xprt_state_show()
179 congested = test_bit(XPRT_CONGESTED, &xprt->state); in rpc_sysfs_xprt_state_show()
180 cwnd_wait = test_bit(XPRT_CWND_WAIT, &xprt->state); in rpc_sysfs_xprt_state_show()
181 write_space = test_bit(XPRT_WRITE_SPACE, &xprt->state); in rpc_sysfs_xprt_state_show()
182 offline = test_bit(XPRT_OFFLINE, &xprt->state); in rpc_sysfs_xprt_state_show()
183 remove = test_bit(XPRT_REMOVE, &xprt->state); in rpc_sysfs_xprt_state_show()
200 xprt_put(xprt); in rpc_sysfs_xprt_state_show()
227 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); in rpc_sysfs_xprt_dstaddr_store() local
234 if (!xprt) in rpc_sysfs_xprt_dstaddr_store()
236 if (!(xprt->xprt_class->ident == XPRT_TRANSPORT_TCP || in rpc_sysfs_xprt_dstaddr_store()
237 xprt->xprt_class->ident == XPRT_TRANSPORT_RDMA)) { in rpc_sysfs_xprt_dstaddr_store()
238 xprt_put(xprt); in rpc_sysfs_xprt_dstaddr_store()
242 if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) { in rpc_sysfs_xprt_dstaddr_store()
246 saddr = (struct sockaddr *)&xprt->addr; in rpc_sysfs_xprt_dstaddr_store()
261 rcu_dereference_raw(xprt->address_strings[RPC_DISPLAY_ADDR]); in rpc_sysfs_xprt_dstaddr_store()
262 rcu_assign_pointer(xprt->address_strings[RPC_DISPLAY_ADDR], dst_addr); in rpc_sysfs_xprt_dstaddr_store()
264 xprt->addrlen = rpc_pton(xprt->xprt_net, buf, buf_len, saddr, in rpc_sysfs_xprt_dstaddr_store()
268 xprt_force_disconnect(xprt); in rpc_sysfs_xprt_dstaddr_store()
270 xprt_release_write(xprt, NULL); in rpc_sysfs_xprt_dstaddr_store()
272 xprt_put(xprt); in rpc_sysfs_xprt_dstaddr_store()
285 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); in rpc_sysfs_xprt_state_change() local
289 if (!xprt) in rpc_sysfs_xprt_state_change()
301 if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) { in rpc_sysfs_xprt_state_change()
305 if (xprt->main) { in rpc_sysfs_xprt_state_change()
310 set_bit(XPRT_OFFLINE, &xprt->state); in rpc_sysfs_xprt_state_change()
315 clear_bit(XPRT_OFFLINE, &xprt->state); in rpc_sysfs_xprt_state_change()
320 if (test_bit(XPRT_OFFLINE, &xprt->state)) { in rpc_sysfs_xprt_state_change()
321 set_bit(XPRT_REMOVE, &xprt->state); in rpc_sysfs_xprt_state_change()
322 xprt_force_disconnect(xprt); in rpc_sysfs_xprt_state_change()
323 if (test_bit(XPRT_CONNECTED, &xprt->state)) { in rpc_sysfs_xprt_state_change()
324 if (!xprt->sending.qlen && in rpc_sysfs_xprt_state_change()
325 !xprt->pending.qlen && in rpc_sysfs_xprt_state_change()
326 !xprt->backlog.qlen && in rpc_sysfs_xprt_state_change()
327 !atomic_long_read(&xprt->queuelen)) in rpc_sysfs_xprt_state_change()
328 rpc_xprt_switch_remove_xprt(xps, xprt); in rpc_sysfs_xprt_state_change()
336 xprt_release_write(xprt, NULL); in rpc_sysfs_xprt_state_change()
338 xprt_put(xprt); in rpc_sysfs_xprt_state_change()
384 struct rpc_sysfs_xprt *xprt; in rpc_sysfs_xprt_release() local
386 xprt = container_of(kobj, struct rpc_sysfs_xprt, kobject); in rpc_sysfs_xprt_release()
387 kfree(xprt); in rpc_sysfs_xprt_release()
403 kobject)->xprt->xprt_net; in rpc_sysfs_xprt_namespace()
502 struct rpc_xprt *xprt, in rpc_sysfs_xprt_alloc() argument
512 parent, "xprt-%d-%s", xprt->id, in rpc_sysfs_xprt_alloc()
513 xprt->address_strings[RPC_DISPLAY_PROTO]) == 0) in rpc_sysfs_xprt_alloc()
547 struct rpc_xprt *xprt, in rpc_sysfs_xprt_switch_setup() argument
556 net = xprt->xprt_net; in rpc_sysfs_xprt_switch_setup()
563 rpc_xprt_switch->xprt = xprt; in rpc_sysfs_xprt_switch_setup()
569 struct rpc_xprt *xprt, in rpc_sysfs_xprt_setup() argument
576 rpc_xprt = rpc_sysfs_xprt_alloc(&switch_obj->kobject, xprt, gfp_flags); in rpc_sysfs_xprt_setup()
578 xprt->xprt_sysfs = rpc_xprt; in rpc_sysfs_xprt_setup()
579 rpc_xprt->xprt = xprt; in rpc_sysfs_xprt_setup()
612 void rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt) in rpc_sysfs_xprt_destroy() argument
614 struct rpc_sysfs_xprt *rpc_xprt = xprt->xprt_sysfs; in rpc_sysfs_xprt_destroy()
620 xprt->xprt_sysfs = NULL; in rpc_sysfs_xprt_destroy()