174678748SOlga Kornievskaia // SPDX-License-Identifier: GPL-2.0 274678748SOlga Kornievskaia /* 374678748SOlga Kornievskaia * Copyright (c) 2020 Anna Schumaker <Anna.Schumaker@Netapp.com> 474678748SOlga Kornievskaia */ 5c441f125SOlga Kornievskaia #include <linux/sunrpc/clnt.h> 674678748SOlga Kornievskaia #include <linux/kobject.h> 7587bc725SOlga Kornievskaia #include <linux/sunrpc/addr.h> 8c1830a63SOlga Kornievskaia #include <linux/sunrpc/xprtsock.h> 9587bc725SOlga Kornievskaia 10c5a382ebSOlga Kornievskaia #include "sysfs.h" 1174678748SOlga Kornievskaia 12587bc725SOlga Kornievskaia struct xprt_addr { 13587bc725SOlga Kornievskaia const char *addr; 14587bc725SOlga Kornievskaia struct rcu_head rcu; 15587bc725SOlga Kornievskaia }; 16587bc725SOlga Kornievskaia 17587bc725SOlga Kornievskaia static void free_xprt_addr(struct rcu_head *head) 18587bc725SOlga Kornievskaia { 19587bc725SOlga Kornievskaia struct xprt_addr *addr = container_of(head, struct xprt_addr, rcu); 20587bc725SOlga Kornievskaia 21587bc725SOlga Kornievskaia kfree(addr->addr); 22587bc725SOlga Kornievskaia kfree(addr); 23587bc725SOlga Kornievskaia } 24587bc725SOlga Kornievskaia 2574678748SOlga Kornievskaia static struct kset *rpc_sunrpc_kset; 26baea9944SOlga Kornievskaia static struct kobject *rpc_sunrpc_client_kobj, *rpc_sunrpc_xprt_switch_kobj; 27c441f125SOlga Kornievskaia 28c441f125SOlga Kornievskaia static void rpc_sysfs_object_release(struct kobject *kobj) 29c441f125SOlga Kornievskaia { 30c441f125SOlga Kornievskaia kfree(kobj); 31c441f125SOlga Kornievskaia } 32c441f125SOlga Kornievskaia 33c441f125SOlga Kornievskaia static const struct kobj_ns_type_operations * 34c441f125SOlga Kornievskaia rpc_sysfs_object_child_ns_type(struct kobject *kobj) 35c441f125SOlga Kornievskaia { 36c441f125SOlga Kornievskaia return &net_ns_type_operations; 37c441f125SOlga Kornievskaia } 38c441f125SOlga Kornievskaia 39c441f125SOlga Kornievskaia static struct kobj_type rpc_sysfs_object_type = { 40c441f125SOlga Kornievskaia .release = rpc_sysfs_object_release, 41c441f125SOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 42c441f125SOlga Kornievskaia .child_ns_type = rpc_sysfs_object_child_ns_type, 43c441f125SOlga Kornievskaia }; 44c441f125SOlga Kornievskaia 45c441f125SOlga Kornievskaia static struct kobject *rpc_sysfs_object_alloc(const char *name, 46c441f125SOlga Kornievskaia struct kset *kset, 47c441f125SOlga Kornievskaia struct kobject *parent) 48c441f125SOlga Kornievskaia { 49c441f125SOlga Kornievskaia struct kobject *kobj; 50c441f125SOlga Kornievskaia 51c441f125SOlga Kornievskaia kobj = kzalloc(sizeof(*kobj), GFP_KERNEL); 52c441f125SOlga Kornievskaia if (kobj) { 53c441f125SOlga Kornievskaia kobj->kset = kset; 54c441f125SOlga Kornievskaia if (kobject_init_and_add(kobj, &rpc_sysfs_object_type, 55c441f125SOlga Kornievskaia parent, "%s", name) == 0) 56c441f125SOlga Kornievskaia return kobj; 57c441f125SOlga Kornievskaia kobject_put(kobj); 58c441f125SOlga Kornievskaia } 59c441f125SOlga Kornievskaia return NULL; 60c441f125SOlga Kornievskaia } 6174678748SOlga Kornievskaia 62587bc725SOlga Kornievskaia static inline struct rpc_xprt * 63587bc725SOlga Kornievskaia rpc_sysfs_xprt_kobj_get_xprt(struct kobject *kobj) 64587bc725SOlga Kornievskaia { 65587bc725SOlga Kornievskaia struct rpc_sysfs_xprt *x = container_of(kobj, 66587bc725SOlga Kornievskaia struct rpc_sysfs_xprt, kobject); 67587bc725SOlga Kornievskaia 68587bc725SOlga Kornievskaia return xprt_get(x->xprt); 69587bc725SOlga Kornievskaia } 70587bc725SOlga Kornievskaia 710e559035SOlga Kornievskaia static inline struct rpc_xprt_switch * 725b7eb784SOlga Kornievskaia rpc_sysfs_xprt_kobj_get_xprt_switch(struct kobject *kobj) 735b7eb784SOlga Kornievskaia { 745b7eb784SOlga Kornievskaia struct rpc_sysfs_xprt *x = container_of(kobj, 755b7eb784SOlga Kornievskaia struct rpc_sysfs_xprt, kobject); 765b7eb784SOlga Kornievskaia 775b7eb784SOlga Kornievskaia return xprt_switch_get(x->xprt_switch); 785b7eb784SOlga Kornievskaia } 795b7eb784SOlga Kornievskaia 805b7eb784SOlga Kornievskaia static inline struct rpc_xprt_switch * 810e559035SOlga Kornievskaia rpc_sysfs_xprt_switch_kobj_get_xprt(struct kobject *kobj) 820e559035SOlga Kornievskaia { 830e559035SOlga Kornievskaia struct rpc_sysfs_xprt_switch *x = container_of(kobj, 840e559035SOlga Kornievskaia struct rpc_sysfs_xprt_switch, kobject); 850e559035SOlga Kornievskaia 860e559035SOlga Kornievskaia return xprt_switch_get(x->xprt_switch); 870e559035SOlga Kornievskaia } 880e559035SOlga Kornievskaia 89587bc725SOlga Kornievskaia static ssize_t rpc_sysfs_xprt_dstaddr_show(struct kobject *kobj, 90587bc725SOlga Kornievskaia struct kobj_attribute *attr, 91587bc725SOlga Kornievskaia char *buf) 92587bc725SOlga Kornievskaia { 93587bc725SOlga Kornievskaia struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); 94587bc725SOlga Kornievskaia ssize_t ret; 95587bc725SOlga Kornievskaia 96587bc725SOlga Kornievskaia if (!xprt) 97587bc725SOlga Kornievskaia return 0; 98587bc725SOlga Kornievskaia ret = sprintf(buf, "%s\n", xprt->address_strings[RPC_DISPLAY_ADDR]); 99587bc725SOlga Kornievskaia xprt_put(xprt); 100587bc725SOlga Kornievskaia return ret + 1; 101587bc725SOlga Kornievskaia } 102587bc725SOlga Kornievskaia 103e44773daSAnna Schumaker static ssize_t rpc_sysfs_xprt_srcaddr_show(struct kobject *kobj, 104e44773daSAnna Schumaker struct kobj_attribute *attr, 105e44773daSAnna Schumaker char *buf) 106e44773daSAnna Schumaker { 107e44773daSAnna Schumaker struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); 108e44773daSAnna Schumaker struct sockaddr_storage saddr; 109e44773daSAnna Schumaker struct sock_xprt *sock; 110e44773daSAnna Schumaker ssize_t ret = -1; 111e44773daSAnna Schumaker 11217f09d3fSAnna Schumaker if (!xprt || !xprt_connected(xprt)) { 11317f09d3fSAnna Schumaker xprt_put(xprt); 11417f09d3fSAnna Schumaker return -ENOTCONN; 11517f09d3fSAnna Schumaker } 116e44773daSAnna Schumaker 117e44773daSAnna Schumaker sock = container_of(xprt, struct sock_xprt, xprt); 118e44773daSAnna Schumaker if (kernel_getsockname(sock->sock, (struct sockaddr *)&saddr) < 0) 119e44773daSAnna Schumaker goto out; 120e44773daSAnna Schumaker 121e44773daSAnna Schumaker ret = sprintf(buf, "%pISc\n", &saddr); 122e44773daSAnna Schumaker out: 123e44773daSAnna Schumaker xprt_put(xprt); 124e44773daSAnna Schumaker return ret + 1; 125e44773daSAnna Schumaker } 126e44773daSAnna Schumaker 1274a09651aSOlga Kornievskaia static ssize_t rpc_sysfs_xprt_info_show(struct kobject *kobj, 1284a09651aSOlga Kornievskaia struct kobj_attribute *attr, 1294a09651aSOlga Kornievskaia char *buf) 1304a09651aSOlga Kornievskaia { 1314a09651aSOlga Kornievskaia struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); 1324a09651aSOlga Kornievskaia ssize_t ret; 1334a09651aSOlga Kornievskaia 13417f09d3fSAnna Schumaker if (!xprt || !xprt_connected(xprt)) { 13517f09d3fSAnna Schumaker xprt_put(xprt); 13617f09d3fSAnna Schumaker return -ENOTCONN; 13717f09d3fSAnna Schumaker } 1384a09651aSOlga Kornievskaia 1394a09651aSOlga Kornievskaia ret = sprintf(buf, "last_used=%lu\ncur_cong=%lu\ncong_win=%lu\n" 1404a09651aSOlga Kornievskaia "max_num_slots=%u\nmin_num_slots=%u\nnum_reqs=%u\n" 1414a09651aSOlga Kornievskaia "binding_q_len=%u\nsending_q_len=%u\npending_q_len=%u\n" 1426a284059SOlga Kornievskaia "backlog_q_len=%u\nmain_xprt=%d\nsrc_port=%u\n" 14369f2cd6dSAnna Schumaker "tasks_queuelen=%ld\ndst_port=%s\n", 144c1830a63SOlga Kornievskaia xprt->last_used, xprt->cong, xprt->cwnd, xprt->max_reqs, 145c1830a63SOlga Kornievskaia xprt->min_reqs, xprt->num_reqs, xprt->binding.qlen, 146c1830a63SOlga Kornievskaia xprt->sending.qlen, xprt->pending.qlen, 147c1830a63SOlga Kornievskaia xprt->backlog.qlen, xprt->main, 148c1830a63SOlga Kornievskaia (xprt->xprt_class->ident == XPRT_TRANSPORT_TCP) ? 1496a284059SOlga Kornievskaia get_srcport(xprt) : 0, 15069f2cd6dSAnna Schumaker atomic_long_read(&xprt->queuelen), 15169f2cd6dSAnna Schumaker (xprt->xprt_class->ident == XPRT_TRANSPORT_TCP) ? 15269f2cd6dSAnna Schumaker xprt->address_strings[RPC_DISPLAY_PORT] : "0"); 1534a09651aSOlga Kornievskaia xprt_put(xprt); 1544a09651aSOlga Kornievskaia return ret + 1; 1554a09651aSOlga Kornievskaia } 1564a09651aSOlga Kornievskaia 157681d5699SOlga Kornievskaia static ssize_t rpc_sysfs_xprt_state_show(struct kobject *kobj, 158681d5699SOlga Kornievskaia struct kobj_attribute *attr, 159681d5699SOlga Kornievskaia char *buf) 160681d5699SOlga Kornievskaia { 161681d5699SOlga Kornievskaia struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); 162681d5699SOlga Kornievskaia ssize_t ret; 163681d5699SOlga Kornievskaia int locked, connected, connecting, close_wait, bound, binding, 1646f081693SOlga Kornievskaia closing, congested, cwnd_wait, write_space, offline, remove; 165681d5699SOlga Kornievskaia 166681d5699SOlga Kornievskaia if (!xprt) 167681d5699SOlga Kornievskaia return 0; 168681d5699SOlga Kornievskaia 169681d5699SOlga Kornievskaia if (!xprt->state) { 170681d5699SOlga Kornievskaia ret = sprintf(buf, "state=CLOSED\n"); 171681d5699SOlga Kornievskaia } else { 172681d5699SOlga Kornievskaia locked = test_bit(XPRT_LOCKED, &xprt->state); 173681d5699SOlga Kornievskaia connected = test_bit(XPRT_CONNECTED, &xprt->state); 174681d5699SOlga Kornievskaia connecting = test_bit(XPRT_CONNECTING, &xprt->state); 175681d5699SOlga Kornievskaia close_wait = test_bit(XPRT_CLOSE_WAIT, &xprt->state); 176681d5699SOlga Kornievskaia bound = test_bit(XPRT_BOUND, &xprt->state); 177681d5699SOlga Kornievskaia binding = test_bit(XPRT_BINDING, &xprt->state); 178681d5699SOlga Kornievskaia closing = test_bit(XPRT_CLOSING, &xprt->state); 179681d5699SOlga Kornievskaia congested = test_bit(XPRT_CONGESTED, &xprt->state); 180681d5699SOlga Kornievskaia cwnd_wait = test_bit(XPRT_CWND_WAIT, &xprt->state); 181681d5699SOlga Kornievskaia write_space = test_bit(XPRT_WRITE_SPACE, &xprt->state); 1825b7eb784SOlga Kornievskaia offline = test_bit(XPRT_OFFLINE, &xprt->state); 1836f081693SOlga Kornievskaia remove = test_bit(XPRT_REMOVE, &xprt->state); 184681d5699SOlga Kornievskaia 1856f081693SOlga Kornievskaia ret = sprintf(buf, "state=%s %s %s %s %s %s %s %s %s %s %s %s\n", 186681d5699SOlga Kornievskaia locked ? "LOCKED" : "", 187681d5699SOlga Kornievskaia connected ? "CONNECTED" : "", 188681d5699SOlga Kornievskaia connecting ? "CONNECTING" : "", 189681d5699SOlga Kornievskaia close_wait ? "CLOSE_WAIT" : "", 190681d5699SOlga Kornievskaia bound ? "BOUND" : "", 191681d5699SOlga Kornievskaia binding ? "BOUNDING" : "", 192681d5699SOlga Kornievskaia closing ? "CLOSING" : "", 193681d5699SOlga Kornievskaia congested ? "CONGESTED" : "", 194681d5699SOlga Kornievskaia cwnd_wait ? "CWND_WAIT" : "", 1955b7eb784SOlga Kornievskaia write_space ? "WRITE_SPACE" : "", 1966f081693SOlga Kornievskaia offline ? "OFFLINE" : "", 1976f081693SOlga Kornievskaia remove ? "REMOVE" : ""); 198681d5699SOlga Kornievskaia } 199681d5699SOlga Kornievskaia 200681d5699SOlga Kornievskaia xprt_put(xprt); 201681d5699SOlga Kornievskaia return ret + 1; 202681d5699SOlga Kornievskaia } 203681d5699SOlga Kornievskaia 2040e559035SOlga Kornievskaia static ssize_t rpc_sysfs_xprt_switch_info_show(struct kobject *kobj, 2050e559035SOlga Kornievskaia struct kobj_attribute *attr, 2060e559035SOlga Kornievskaia char *buf) 2070e559035SOlga Kornievskaia { 2080e559035SOlga Kornievskaia struct rpc_xprt_switch *xprt_switch = 2090e559035SOlga Kornievskaia rpc_sysfs_xprt_switch_kobj_get_xprt(kobj); 2100e559035SOlga Kornievskaia ssize_t ret; 2110e559035SOlga Kornievskaia 2120e559035SOlga Kornievskaia if (!xprt_switch) 2130e559035SOlga Kornievskaia return 0; 214df205d0aSOlga Kornievskaia ret = sprintf(buf, "num_xprts=%u\nnum_active=%u\n" 215df205d0aSOlga Kornievskaia "num_unique_destaddr=%u\nqueue_len=%ld\n", 2160e559035SOlga Kornievskaia xprt_switch->xps_nxprts, xprt_switch->xps_nactive, 217df205d0aSOlga Kornievskaia xprt_switch->xps_nunique_destaddr_xprts, 2180e559035SOlga Kornievskaia atomic_long_read(&xprt_switch->xps_queuelen)); 2190e559035SOlga Kornievskaia xprt_switch_put(xprt_switch); 2200e559035SOlga Kornievskaia return ret + 1; 2210e559035SOlga Kornievskaia } 2220e559035SOlga Kornievskaia 223587bc725SOlga Kornievskaia static ssize_t rpc_sysfs_xprt_dstaddr_store(struct kobject *kobj, 224587bc725SOlga Kornievskaia struct kobj_attribute *attr, 225587bc725SOlga Kornievskaia const char *buf, size_t count) 226587bc725SOlga Kornievskaia { 227587bc725SOlga Kornievskaia struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); 228587bc725SOlga Kornievskaia struct sockaddr *saddr; 229587bc725SOlga Kornievskaia char *dst_addr; 230587bc725SOlga Kornievskaia int port; 231587bc725SOlga Kornievskaia struct xprt_addr *saved_addr; 232587bc725SOlga Kornievskaia size_t buf_len; 233587bc725SOlga Kornievskaia 234587bc725SOlga Kornievskaia if (!xprt) 235587bc725SOlga Kornievskaia return 0; 236587bc725SOlga Kornievskaia if (!(xprt->xprt_class->ident == XPRT_TRANSPORT_TCP || 237587bc725SOlga Kornievskaia xprt->xprt_class->ident == XPRT_TRANSPORT_RDMA)) { 238587bc725SOlga Kornievskaia xprt_put(xprt); 239587bc725SOlga Kornievskaia return -EOPNOTSUPP; 240587bc725SOlga Kornievskaia } 241587bc725SOlga Kornievskaia 242587bc725SOlga Kornievskaia if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) { 243587bc725SOlga Kornievskaia count = -EINTR; 244587bc725SOlga Kornievskaia goto out_put; 245587bc725SOlga Kornievskaia } 246587bc725SOlga Kornievskaia saddr = (struct sockaddr *)&xprt->addr; 247587bc725SOlga Kornievskaia port = rpc_get_port(saddr); 248587bc725SOlga Kornievskaia 249587bc725SOlga Kornievskaia /* buf_len is the len until the first occurence of either 250587bc725SOlga Kornievskaia * '\n' or '\0' 251587bc725SOlga Kornievskaia */ 252587bc725SOlga Kornievskaia buf_len = strcspn(buf, "\n"); 253587bc725SOlga Kornievskaia 254587bc725SOlga Kornievskaia dst_addr = kstrndup(buf, buf_len, GFP_KERNEL); 255587bc725SOlga Kornievskaia if (!dst_addr) 256587bc725SOlga Kornievskaia goto out_err; 257587bc725SOlga Kornievskaia saved_addr = kzalloc(sizeof(*saved_addr), GFP_KERNEL); 258587bc725SOlga Kornievskaia if (!saved_addr) 259587bc725SOlga Kornievskaia goto out_err_free; 260587bc725SOlga Kornievskaia saved_addr->addr = 261587bc725SOlga Kornievskaia rcu_dereference_raw(xprt->address_strings[RPC_DISPLAY_ADDR]); 262587bc725SOlga Kornievskaia rcu_assign_pointer(xprt->address_strings[RPC_DISPLAY_ADDR], dst_addr); 263587bc725SOlga Kornievskaia call_rcu(&saved_addr->rcu, free_xprt_addr); 264587bc725SOlga Kornievskaia xprt->addrlen = rpc_pton(xprt->xprt_net, buf, buf_len, saddr, 265587bc725SOlga Kornievskaia sizeof(*saddr)); 266587bc725SOlga Kornievskaia rpc_set_port(saddr, port); 267587bc725SOlga Kornievskaia 268587bc725SOlga Kornievskaia xprt_force_disconnect(xprt); 269587bc725SOlga Kornievskaia out: 270587bc725SOlga Kornievskaia xprt_release_write(xprt, NULL); 271587bc725SOlga Kornievskaia out_put: 272587bc725SOlga Kornievskaia xprt_put(xprt); 273587bc725SOlga Kornievskaia return count; 274587bc725SOlga Kornievskaia out_err_free: 275587bc725SOlga Kornievskaia kfree(dst_addr); 276587bc725SOlga Kornievskaia out_err: 277587bc725SOlga Kornievskaia count = -ENOMEM; 278587bc725SOlga Kornievskaia goto out; 279587bc725SOlga Kornievskaia } 280587bc725SOlga Kornievskaia 2815b7eb784SOlga Kornievskaia static ssize_t rpc_sysfs_xprt_state_change(struct kobject *kobj, 2825b7eb784SOlga Kornievskaia struct kobj_attribute *attr, 2835b7eb784SOlga Kornievskaia const char *buf, size_t count) 2845b7eb784SOlga Kornievskaia { 2855b7eb784SOlga Kornievskaia struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); 2866f081693SOlga Kornievskaia int offline = 0, online = 0, remove = 0; 2875b7eb784SOlga Kornievskaia struct rpc_xprt_switch *xps = rpc_sysfs_xprt_kobj_get_xprt_switch(kobj); 2885b7eb784SOlga Kornievskaia 2895b7eb784SOlga Kornievskaia if (!xprt) 2905b7eb784SOlga Kornievskaia return 0; 2915b7eb784SOlga Kornievskaia 2925b7eb784SOlga Kornievskaia if (!strncmp(buf, "offline", 7)) 2935b7eb784SOlga Kornievskaia offline = 1; 2945b7eb784SOlga Kornievskaia else if (!strncmp(buf, "online", 6)) 2955b7eb784SOlga Kornievskaia online = 1; 2966f081693SOlga Kornievskaia else if (!strncmp(buf, "remove", 6)) 2976f081693SOlga Kornievskaia remove = 1; 2985b7eb784SOlga Kornievskaia else 2995b7eb784SOlga Kornievskaia return -EINVAL; 3005b7eb784SOlga Kornievskaia 3015b7eb784SOlga Kornievskaia if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) { 3025b7eb784SOlga Kornievskaia count = -EINTR; 3035b7eb784SOlga Kornievskaia goto out_put; 3045b7eb784SOlga Kornievskaia } 3055b7eb784SOlga Kornievskaia if (xprt->main) { 3065b7eb784SOlga Kornievskaia count = -EINVAL; 3075b7eb784SOlga Kornievskaia goto release_tasks; 3085b7eb784SOlga Kornievskaia } 3095b7eb784SOlga Kornievskaia if (offline) { 3105b7eb784SOlga Kornievskaia set_bit(XPRT_OFFLINE, &xprt->state); 3115b7eb784SOlga Kornievskaia spin_lock(&xps->xps_lock); 3125b7eb784SOlga Kornievskaia xps->xps_nactive--; 3135b7eb784SOlga Kornievskaia spin_unlock(&xps->xps_lock); 3145b7eb784SOlga Kornievskaia } else if (online) { 3155b7eb784SOlga Kornievskaia clear_bit(XPRT_OFFLINE, &xprt->state); 3165b7eb784SOlga Kornievskaia spin_lock(&xps->xps_lock); 3175b7eb784SOlga Kornievskaia xps->xps_nactive++; 3185b7eb784SOlga Kornievskaia spin_unlock(&xps->xps_lock); 3196f081693SOlga Kornievskaia } else if (remove) { 3206f081693SOlga Kornievskaia if (test_bit(XPRT_OFFLINE, &xprt->state)) { 3216f081693SOlga Kornievskaia set_bit(XPRT_REMOVE, &xprt->state); 3226f081693SOlga Kornievskaia xprt_force_disconnect(xprt); 3236f081693SOlga Kornievskaia if (test_bit(XPRT_CONNECTED, &xprt->state)) { 3246f081693SOlga Kornievskaia if (!xprt->sending.qlen && 3256f081693SOlga Kornievskaia !xprt->pending.qlen && 3266f081693SOlga Kornievskaia !xprt->backlog.qlen && 3276f081693SOlga Kornievskaia !atomic_long_read(&xprt->queuelen)) 3286f081693SOlga Kornievskaia rpc_xprt_switch_remove_xprt(xps, xprt); 3296f081693SOlga Kornievskaia } 3306f081693SOlga Kornievskaia } else { 3316f081693SOlga Kornievskaia count = -EINVAL; 3326f081693SOlga Kornievskaia } 3335b7eb784SOlga Kornievskaia } 3345b7eb784SOlga Kornievskaia 3355b7eb784SOlga Kornievskaia release_tasks: 3365b7eb784SOlga Kornievskaia xprt_release_write(xprt, NULL); 3375b7eb784SOlga Kornievskaia out_put: 3385b7eb784SOlga Kornievskaia xprt_put(xprt); 3395b7eb784SOlga Kornievskaia xprt_switch_put(xps); 3405b7eb784SOlga Kornievskaia return count; 3415b7eb784SOlga Kornievskaia } 3425b7eb784SOlga Kornievskaia 34374678748SOlga Kornievskaia int rpc_sysfs_init(void) 34474678748SOlga Kornievskaia { 34574678748SOlga Kornievskaia rpc_sunrpc_kset = kset_create_and_add("sunrpc", NULL, kernel_kobj); 34674678748SOlga Kornievskaia if (!rpc_sunrpc_kset) 34774678748SOlga Kornievskaia return -ENOMEM; 348baea9944SOlga Kornievskaia rpc_sunrpc_client_kobj = 349baea9944SOlga Kornievskaia rpc_sysfs_object_alloc("rpc-clients", rpc_sunrpc_kset, NULL); 350baea9944SOlga Kornievskaia if (!rpc_sunrpc_client_kobj) 351baea9944SOlga Kornievskaia goto err_client; 352baea9944SOlga Kornievskaia rpc_sunrpc_xprt_switch_kobj = 353baea9944SOlga Kornievskaia rpc_sysfs_object_alloc("xprt-switches", rpc_sunrpc_kset, NULL); 354baea9944SOlga Kornievskaia if (!rpc_sunrpc_xprt_switch_kobj) 355baea9944SOlga Kornievskaia goto err_switch; 35674678748SOlga Kornievskaia return 0; 357baea9944SOlga Kornievskaia err_switch: 358baea9944SOlga Kornievskaia kobject_put(rpc_sunrpc_client_kobj); 359baea9944SOlga Kornievskaia rpc_sunrpc_client_kobj = NULL; 360baea9944SOlga Kornievskaia err_client: 361baea9944SOlga Kornievskaia kset_unregister(rpc_sunrpc_kset); 362baea9944SOlga Kornievskaia rpc_sunrpc_kset = NULL; 363baea9944SOlga Kornievskaia return -ENOMEM; 36474678748SOlga Kornievskaia } 36574678748SOlga Kornievskaia 366c5a382ebSOlga Kornievskaia static void rpc_sysfs_client_release(struct kobject *kobj) 367c5a382ebSOlga Kornievskaia { 368c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *c; 369c5a382ebSOlga Kornievskaia 370c5a382ebSOlga Kornievskaia c = container_of(kobj, struct rpc_sysfs_client, kobject); 371c5a382ebSOlga Kornievskaia kfree(c); 372c5a382ebSOlga Kornievskaia } 373c5a382ebSOlga Kornievskaia 374baea9944SOlga Kornievskaia static void rpc_sysfs_xprt_switch_release(struct kobject *kobj) 375baea9944SOlga Kornievskaia { 376baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *xprt_switch; 377baea9944SOlga Kornievskaia 378baea9944SOlga Kornievskaia xprt_switch = container_of(kobj, struct rpc_sysfs_xprt_switch, kobject); 379baea9944SOlga Kornievskaia kfree(xprt_switch); 380baea9944SOlga Kornievskaia } 381baea9944SOlga Kornievskaia 382d408ebe0SOlga Kornievskaia static void rpc_sysfs_xprt_release(struct kobject *kobj) 383d408ebe0SOlga Kornievskaia { 384d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *xprt; 385d408ebe0SOlga Kornievskaia 386d408ebe0SOlga Kornievskaia xprt = container_of(kobj, struct rpc_sysfs_xprt, kobject); 387d408ebe0SOlga Kornievskaia kfree(xprt); 388d408ebe0SOlga Kornievskaia } 389d408ebe0SOlga Kornievskaia 390c5a382ebSOlga Kornievskaia static const void *rpc_sysfs_client_namespace(struct kobject *kobj) 391c5a382ebSOlga Kornievskaia { 392c5a382ebSOlga Kornievskaia return container_of(kobj, struct rpc_sysfs_client, kobject)->net; 393c5a382ebSOlga Kornievskaia } 394c5a382ebSOlga Kornievskaia 395baea9944SOlga Kornievskaia static const void *rpc_sysfs_xprt_switch_namespace(struct kobject *kobj) 396baea9944SOlga Kornievskaia { 397baea9944SOlga Kornievskaia return container_of(kobj, struct rpc_sysfs_xprt_switch, kobject)->net; 398baea9944SOlga Kornievskaia } 399baea9944SOlga Kornievskaia 400d408ebe0SOlga Kornievskaia static const void *rpc_sysfs_xprt_namespace(struct kobject *kobj) 401d408ebe0SOlga Kornievskaia { 402d408ebe0SOlga Kornievskaia return container_of(kobj, struct rpc_sysfs_xprt, 403d408ebe0SOlga Kornievskaia kobject)->xprt->xprt_net; 404d408ebe0SOlga Kornievskaia } 405d408ebe0SOlga Kornievskaia 406587bc725SOlga Kornievskaia static struct kobj_attribute rpc_sysfs_xprt_dstaddr = __ATTR(dstaddr, 407587bc725SOlga Kornievskaia 0644, rpc_sysfs_xprt_dstaddr_show, rpc_sysfs_xprt_dstaddr_store); 408587bc725SOlga Kornievskaia 409e44773daSAnna Schumaker static struct kobj_attribute rpc_sysfs_xprt_srcaddr = __ATTR(srcaddr, 410e44773daSAnna Schumaker 0644, rpc_sysfs_xprt_srcaddr_show, NULL); 411e44773daSAnna Schumaker 4124a09651aSOlga Kornievskaia static struct kobj_attribute rpc_sysfs_xprt_info = __ATTR(xprt_info, 4134a09651aSOlga Kornievskaia 0444, rpc_sysfs_xprt_info_show, NULL); 4144a09651aSOlga Kornievskaia 415681d5699SOlga Kornievskaia static struct kobj_attribute rpc_sysfs_xprt_change_state = __ATTR(xprt_state, 4165b7eb784SOlga Kornievskaia 0644, rpc_sysfs_xprt_state_show, rpc_sysfs_xprt_state_change); 417681d5699SOlga Kornievskaia 418587bc725SOlga Kornievskaia static struct attribute *rpc_sysfs_xprt_attrs[] = { 419587bc725SOlga Kornievskaia &rpc_sysfs_xprt_dstaddr.attr, 420e44773daSAnna Schumaker &rpc_sysfs_xprt_srcaddr.attr, 4214a09651aSOlga Kornievskaia &rpc_sysfs_xprt_info.attr, 422681d5699SOlga Kornievskaia &rpc_sysfs_xprt_change_state.attr, 423587bc725SOlga Kornievskaia NULL, 424587bc725SOlga Kornievskaia }; 425*86439fa2SGreg Kroah-Hartman ATTRIBUTE_GROUPS(rpc_sysfs_xprt); 426587bc725SOlga Kornievskaia 4270e559035SOlga Kornievskaia static struct kobj_attribute rpc_sysfs_xprt_switch_info = 4280e559035SOlga Kornievskaia __ATTR(xprt_switch_info, 0444, rpc_sysfs_xprt_switch_info_show, NULL); 4290e559035SOlga Kornievskaia 4300e559035SOlga Kornievskaia static struct attribute *rpc_sysfs_xprt_switch_attrs[] = { 4310e559035SOlga Kornievskaia &rpc_sysfs_xprt_switch_info.attr, 4320e559035SOlga Kornievskaia NULL, 4330e559035SOlga Kornievskaia }; 434*86439fa2SGreg Kroah-Hartman ATTRIBUTE_GROUPS(rpc_sysfs_xprt_switch); 4350e559035SOlga Kornievskaia 436c5a382ebSOlga Kornievskaia static struct kobj_type rpc_sysfs_client_type = { 437c5a382ebSOlga Kornievskaia .release = rpc_sysfs_client_release, 438c5a382ebSOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 439c5a382ebSOlga Kornievskaia .namespace = rpc_sysfs_client_namespace, 440c5a382ebSOlga Kornievskaia }; 441c5a382ebSOlga Kornievskaia 442baea9944SOlga Kornievskaia static struct kobj_type rpc_sysfs_xprt_switch_type = { 443baea9944SOlga Kornievskaia .release = rpc_sysfs_xprt_switch_release, 444*86439fa2SGreg Kroah-Hartman .default_groups = rpc_sysfs_xprt_switch_groups, 445baea9944SOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 446baea9944SOlga Kornievskaia .namespace = rpc_sysfs_xprt_switch_namespace, 447baea9944SOlga Kornievskaia }; 448baea9944SOlga Kornievskaia 449d408ebe0SOlga Kornievskaia static struct kobj_type rpc_sysfs_xprt_type = { 450d408ebe0SOlga Kornievskaia .release = rpc_sysfs_xprt_release, 451*86439fa2SGreg Kroah-Hartman .default_groups = rpc_sysfs_xprt_groups, 452d408ebe0SOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 453d408ebe0SOlga Kornievskaia .namespace = rpc_sysfs_xprt_namespace, 454d408ebe0SOlga Kornievskaia }; 455d408ebe0SOlga Kornievskaia 45674678748SOlga Kornievskaia void rpc_sysfs_exit(void) 45774678748SOlga Kornievskaia { 458c441f125SOlga Kornievskaia kobject_put(rpc_sunrpc_client_kobj); 459baea9944SOlga Kornievskaia kobject_put(rpc_sunrpc_xprt_switch_kobj); 46074678748SOlga Kornievskaia kset_unregister(rpc_sunrpc_kset); 46174678748SOlga Kornievskaia } 462c5a382ebSOlga Kornievskaia 463c5a382ebSOlga Kornievskaia static struct rpc_sysfs_client *rpc_sysfs_client_alloc(struct kobject *parent, 464c5a382ebSOlga Kornievskaia struct net *net, 465c5a382ebSOlga Kornievskaia int clid) 466c5a382ebSOlga Kornievskaia { 467c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *p; 468c5a382ebSOlga Kornievskaia 469c5a382ebSOlga Kornievskaia p = kzalloc(sizeof(*p), GFP_KERNEL); 470c5a382ebSOlga Kornievskaia if (p) { 471c5a382ebSOlga Kornievskaia p->net = net; 472c5a382ebSOlga Kornievskaia p->kobject.kset = rpc_sunrpc_kset; 473c5a382ebSOlga Kornievskaia if (kobject_init_and_add(&p->kobject, &rpc_sysfs_client_type, 474c5a382ebSOlga Kornievskaia parent, "clnt-%d", clid) == 0) 475c5a382ebSOlga Kornievskaia return p; 476c5a382ebSOlga Kornievskaia kobject_put(&p->kobject); 477c5a382ebSOlga Kornievskaia } 478c5a382ebSOlga Kornievskaia return NULL; 479c5a382ebSOlga Kornievskaia } 480c5a382ebSOlga Kornievskaia 481baea9944SOlga Kornievskaia static struct rpc_sysfs_xprt_switch * 482baea9944SOlga Kornievskaia rpc_sysfs_xprt_switch_alloc(struct kobject *parent, 483baea9944SOlga Kornievskaia struct rpc_xprt_switch *xprt_switch, 484baea9944SOlga Kornievskaia struct net *net, 485baea9944SOlga Kornievskaia gfp_t gfp_flags) 486baea9944SOlga Kornievskaia { 487baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *p; 488baea9944SOlga Kornievskaia 489baea9944SOlga Kornievskaia p = kzalloc(sizeof(*p), gfp_flags); 490baea9944SOlga Kornievskaia if (p) { 491baea9944SOlga Kornievskaia p->net = net; 492baea9944SOlga Kornievskaia p->kobject.kset = rpc_sunrpc_kset; 493baea9944SOlga Kornievskaia if (kobject_init_and_add(&p->kobject, 494baea9944SOlga Kornievskaia &rpc_sysfs_xprt_switch_type, 495baea9944SOlga Kornievskaia parent, "switch-%d", 496baea9944SOlga Kornievskaia xprt_switch->xps_id) == 0) 497baea9944SOlga Kornievskaia return p; 498baea9944SOlga Kornievskaia kobject_put(&p->kobject); 499baea9944SOlga Kornievskaia } 500baea9944SOlga Kornievskaia return NULL; 501baea9944SOlga Kornievskaia } 502baea9944SOlga Kornievskaia 503d408ebe0SOlga Kornievskaia static struct rpc_sysfs_xprt *rpc_sysfs_xprt_alloc(struct kobject *parent, 504d408ebe0SOlga Kornievskaia struct rpc_xprt *xprt, 505d408ebe0SOlga Kornievskaia gfp_t gfp_flags) 506d408ebe0SOlga Kornievskaia { 507d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *p; 508d408ebe0SOlga Kornievskaia 509d408ebe0SOlga Kornievskaia p = kzalloc(sizeof(*p), gfp_flags); 510d408ebe0SOlga Kornievskaia if (!p) 511d408ebe0SOlga Kornievskaia goto out; 512d408ebe0SOlga Kornievskaia p->kobject.kset = rpc_sunrpc_kset; 513d408ebe0SOlga Kornievskaia if (kobject_init_and_add(&p->kobject, &rpc_sysfs_xprt_type, 514d408ebe0SOlga Kornievskaia parent, "xprt-%d-%s", xprt->id, 515d408ebe0SOlga Kornievskaia xprt->address_strings[RPC_DISPLAY_PROTO]) == 0) 516d408ebe0SOlga Kornievskaia return p; 517d408ebe0SOlga Kornievskaia kobject_put(&p->kobject); 518d408ebe0SOlga Kornievskaia out: 519d408ebe0SOlga Kornievskaia return NULL; 520d408ebe0SOlga Kornievskaia } 521d408ebe0SOlga Kornievskaia 5222a338a54SOlga Kornievskaia void rpc_sysfs_client_setup(struct rpc_clnt *clnt, 5232a338a54SOlga Kornievskaia struct rpc_xprt_switch *xprt_switch, 5242a338a54SOlga Kornievskaia struct net *net) 525c5a382ebSOlga Kornievskaia { 526c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *rpc_client; 527c5a382ebSOlga Kornievskaia 5282a338a54SOlga Kornievskaia rpc_client = rpc_sysfs_client_alloc(rpc_sunrpc_client_kobj, 5292a338a54SOlga Kornievskaia net, clnt->cl_clid); 530c5a382ebSOlga Kornievskaia if (rpc_client) { 5312a338a54SOlga Kornievskaia char name[] = "switch"; 5322a338a54SOlga Kornievskaia struct rpc_sysfs_xprt_switch *xswitch = 5332a338a54SOlga Kornievskaia (struct rpc_sysfs_xprt_switch *)xprt_switch->xps_sysfs; 5342a338a54SOlga Kornievskaia int ret; 5352a338a54SOlga Kornievskaia 536c5a382ebSOlga Kornievskaia clnt->cl_sysfs = rpc_client; 5372a338a54SOlga Kornievskaia rpc_client->clnt = clnt; 5382a338a54SOlga Kornievskaia rpc_client->xprt_switch = xprt_switch; 539c5a382ebSOlga Kornievskaia kobject_uevent(&rpc_client->kobject, KOBJ_ADD); 5402a338a54SOlga Kornievskaia ret = sysfs_create_link_nowarn(&rpc_client->kobject, 5412a338a54SOlga Kornievskaia &xswitch->kobject, name); 5422a338a54SOlga Kornievskaia if (ret) 5432a338a54SOlga Kornievskaia pr_warn("can't create link to %s in sysfs (%d)\n", 5442a338a54SOlga Kornievskaia name, ret); 545c5a382ebSOlga Kornievskaia } 546c5a382ebSOlga Kornievskaia } 547c5a382ebSOlga Kornievskaia 548baea9944SOlga Kornievskaia void rpc_sysfs_xprt_switch_setup(struct rpc_xprt_switch *xprt_switch, 549baea9944SOlga Kornievskaia struct rpc_xprt *xprt, 550baea9944SOlga Kornievskaia gfp_t gfp_flags) 551baea9944SOlga Kornievskaia { 552baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *rpc_xprt_switch; 553baea9944SOlga Kornievskaia struct net *net; 554baea9944SOlga Kornievskaia 555baea9944SOlga Kornievskaia if (xprt_switch->xps_net) 556baea9944SOlga Kornievskaia net = xprt_switch->xps_net; 557baea9944SOlga Kornievskaia else 558baea9944SOlga Kornievskaia net = xprt->xprt_net; 559baea9944SOlga Kornievskaia rpc_xprt_switch = 560baea9944SOlga Kornievskaia rpc_sysfs_xprt_switch_alloc(rpc_sunrpc_xprt_switch_kobj, 561baea9944SOlga Kornievskaia xprt_switch, net, gfp_flags); 562baea9944SOlga Kornievskaia if (rpc_xprt_switch) { 563baea9944SOlga Kornievskaia xprt_switch->xps_sysfs = rpc_xprt_switch; 564baea9944SOlga Kornievskaia rpc_xprt_switch->xprt_switch = xprt_switch; 565baea9944SOlga Kornievskaia rpc_xprt_switch->xprt = xprt; 566baea9944SOlga Kornievskaia kobject_uevent(&rpc_xprt_switch->kobject, KOBJ_ADD); 567baea9944SOlga Kornievskaia } 568baea9944SOlga Kornievskaia } 569baea9944SOlga Kornievskaia 570d408ebe0SOlga Kornievskaia void rpc_sysfs_xprt_setup(struct rpc_xprt_switch *xprt_switch, 571d408ebe0SOlga Kornievskaia struct rpc_xprt *xprt, 572d408ebe0SOlga Kornievskaia gfp_t gfp_flags) 573d408ebe0SOlga Kornievskaia { 574d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *rpc_xprt; 575d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt_switch *switch_obj = 576d408ebe0SOlga Kornievskaia (struct rpc_sysfs_xprt_switch *)xprt_switch->xps_sysfs; 577d408ebe0SOlga Kornievskaia 578d408ebe0SOlga Kornievskaia rpc_xprt = rpc_sysfs_xprt_alloc(&switch_obj->kobject, xprt, gfp_flags); 579d408ebe0SOlga Kornievskaia if (rpc_xprt) { 580d408ebe0SOlga Kornievskaia xprt->xprt_sysfs = rpc_xprt; 581d408ebe0SOlga Kornievskaia rpc_xprt->xprt = xprt; 5825b7eb784SOlga Kornievskaia rpc_xprt->xprt_switch = xprt_switch; 583d408ebe0SOlga Kornievskaia kobject_uevent(&rpc_xprt->kobject, KOBJ_ADD); 584d408ebe0SOlga Kornievskaia } 585d408ebe0SOlga Kornievskaia } 586d408ebe0SOlga Kornievskaia 587c5a382ebSOlga Kornievskaia void rpc_sysfs_client_destroy(struct rpc_clnt *clnt) 588c5a382ebSOlga Kornievskaia { 589c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *rpc_client = clnt->cl_sysfs; 590c5a382ebSOlga Kornievskaia 591c5a382ebSOlga Kornievskaia if (rpc_client) { 5922a338a54SOlga Kornievskaia char name[] = "switch"; 5932a338a54SOlga Kornievskaia 5942a338a54SOlga Kornievskaia sysfs_remove_link(&rpc_client->kobject, name); 595c5a382ebSOlga Kornievskaia kobject_uevent(&rpc_client->kobject, KOBJ_REMOVE); 596c5a382ebSOlga Kornievskaia kobject_del(&rpc_client->kobject); 597c5a382ebSOlga Kornievskaia kobject_put(&rpc_client->kobject); 598c5a382ebSOlga Kornievskaia clnt->cl_sysfs = NULL; 599c5a382ebSOlga Kornievskaia } 600c5a382ebSOlga Kornievskaia } 601baea9944SOlga Kornievskaia 602baea9944SOlga Kornievskaia void rpc_sysfs_xprt_switch_destroy(struct rpc_xprt_switch *xprt_switch) 603baea9944SOlga Kornievskaia { 604baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *rpc_xprt_switch = xprt_switch->xps_sysfs; 605baea9944SOlga Kornievskaia 606baea9944SOlga Kornievskaia if (rpc_xprt_switch) { 607baea9944SOlga Kornievskaia kobject_uevent(&rpc_xprt_switch->kobject, KOBJ_REMOVE); 608baea9944SOlga Kornievskaia kobject_del(&rpc_xprt_switch->kobject); 609baea9944SOlga Kornievskaia kobject_put(&rpc_xprt_switch->kobject); 610baea9944SOlga Kornievskaia xprt_switch->xps_sysfs = NULL; 611baea9944SOlga Kornievskaia } 612baea9944SOlga Kornievskaia } 613d408ebe0SOlga Kornievskaia 614d408ebe0SOlga Kornievskaia void rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt) 615d408ebe0SOlga Kornievskaia { 616d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *rpc_xprt = xprt->xprt_sysfs; 617d408ebe0SOlga Kornievskaia 618d408ebe0SOlga Kornievskaia if (rpc_xprt) { 619d408ebe0SOlga Kornievskaia kobject_uevent(&rpc_xprt->kobject, KOBJ_REMOVE); 620d408ebe0SOlga Kornievskaia kobject_del(&rpc_xprt->kobject); 621d408ebe0SOlga Kornievskaia kobject_put(&rpc_xprt->kobject); 622d408ebe0SOlga Kornievskaia xprt->xprt_sysfs = NULL; 623d408ebe0SOlga Kornievskaia } 624d408ebe0SOlga Kornievskaia } 625