net/sunrpc/sysfs.c

68 	return xprt_get(x->xprt);
93 	struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj);
96 	if (!xprt) {
100 	ret = sprintf(buf, "%s\n", xprt->address_strings[RPC_DISPLAY_ADDR]);
101 	xprt_put(xprt);
110 	struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj);
114 	if (!xprt || !xprt_connected(xprt)) {
116 	} else if (xprt->ops->get_srcaddr) {
117 		ret = xprt->ops->get_srcaddr(xprt, buf, buflen);
128 	xprt_put(xprt);
135 	struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj);
140 	if (!xprt || !xprt_connected(xprt)) {
145 	if (xprt->ops->get_srcport)
146 		srcport = xprt->ops->get_srcport(xprt);
154 		       xprt->last_used, xprt->cong, xprt->cwnd, xprt->max_reqs,
155 		       xprt->min_reqs, xprt->num_reqs, xprt->binding.qlen,
156 		       xprt->sending.qlen, xprt->pending.qlen,
157 		       xprt->backlog.qlen, xprt->main, srcport,
158 		       atomic_long_read(&xprt->queuelen),
159 		       xprt->address_strings[RPC_DISPLAY_PORT]);
161 	xprt_put(xprt);
169 	struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj);
174 	if (!(xprt && xprt->state)) {
177 		locked = test_bit(XPRT_LOCKED, &xprt->state);
178 		connected = test_bit(XPRT_CONNECTED, &xprt->state);
179 		connecting = test_bit(XPRT_CONNECTING, &xprt->state);
180 		close_wait = test_bit(XPRT_CLOSE_WAIT, &xprt->state);
181 		bound = test_bit(XPRT_BOUND, &xprt->state);
182 		binding = test_bit(XPRT_BINDING, &xprt->state);
183 		closing = test_bit(XPRT_CLOSING, &xprt->state);
184 		congested = test_bit(XPRT_CONGESTED, &xprt->state);
185 		cwnd_wait = test_bit(XPRT_CWND_WAIT, &xprt->state);
186 		write_space = test_bit(XPRT_WRITE_SPACE, &xprt->state);
187 		offline = test_bit(XPRT_OFFLINE, &xprt->state);
188 		remove = test_bit(XPRT_REMOVE, &xprt->state);
205 	xprt_put(xprt);
232 	struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj);
239 	if (!xprt)
241 	if (!(xprt->xprt_class->ident == XPRT_TRANSPORT_TCP ||
242 	      xprt->xprt_class->ident == XPRT_TRANSPORT_TCP_TLS ||
243 	      xprt->xprt_class->ident == XPRT_TRANSPORT_RDMA)) {
244 		xprt_put(xprt);
248 	if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) {
252 	saddr = (struct sockaddr *)&xprt->addr;
267 		rcu_dereference_raw(xprt->address_strings[RPC_DISPLAY_ADDR]);
268 	rcu_assign_pointer(xprt->address_strings[RPC_DISPLAY_ADDR], dst_addr);
270 	xprt->addrlen = rpc_pton(xprt->xprt_net, buf, buf_len, saddr,
274 	xprt_force_disconnect(xprt);
276 	xprt_release_write(xprt, NULL);
278 	xprt_put(xprt);
291 	struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj);
295 	if (!xprt || !xps) {
311 	if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) {
315 	if (xprt->main) {
320 		xprt_set_offline_locked(xprt, xps);
322 		xprt_set_online_locked(xprt, xps);
324 		if (test_bit(XPRT_OFFLINE, &xprt->state))
325 			xprt_delete_locked(xprt, xps);
331 	xprt_release_write(xprt, NULL);
333 	xprt_put(xprt);
348 		rpc_sysfs_object_alloc("xprt-switches", rpc_sunrpc_kset, NULL);
379 	struct rpc_sysfs_xprt *xprt;
381 	xprt = container_of(kobj, struct rpc_sysfs_xprt, kobject);
382 	kfree(xprt);
398 			    kobject)->xprt->xprt_net;
499 						   struct rpc_xprt *xprt,
509 				 parent, "xprt-%d-%s", xprt->id,
510 				 xprt->address_strings[RPC_DISPLAY_PROTO]) == 0)
547 				 struct rpc_xprt *xprt,
556 		net = xprt->xprt_net;
563 		rpc_xprt_switch->xprt = xprt;
571 			  struct rpc_xprt *xprt,
581 	rpc_xprt = rpc_sysfs_xprt_alloc(&switch_obj->kobject, xprt, gfp_flags);
583 		xprt->xprt_sysfs = rpc_xprt;
584 		rpc_xprt->xprt = xprt;
617 void rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt)
619 	struct rpc_sysfs_xprt *rpc_xprt = xprt->xprt_sysfs;
625 		xprt->xprt_sysfs = NULL;