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 112*17f09d3fSAnna Schumaker if (!xprt || !xprt_connected(xprt)) { 113*17f09d3fSAnna Schumaker xprt_put(xprt); 114*17f09d3fSAnna Schumaker return -ENOTCONN; 115*17f09d3fSAnna 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 134*17f09d3fSAnna Schumaker if (!xprt || !xprt_connected(xprt)) { 135*17f09d3fSAnna Schumaker xprt_put(xprt); 136*17f09d3fSAnna Schumaker return -ENOTCONN; 137*17f09d3fSAnna 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 }; 425587bc725SOlga Kornievskaia 4260e559035SOlga Kornievskaia static struct kobj_attribute rpc_sysfs_xprt_switch_info = 4270e559035SOlga Kornievskaia __ATTR(xprt_switch_info, 0444, rpc_sysfs_xprt_switch_info_show, NULL); 4280e559035SOlga Kornievskaia 4290e559035SOlga Kornievskaia static struct attribute *rpc_sysfs_xprt_switch_attrs[] = { 4300e559035SOlga Kornievskaia &rpc_sysfs_xprt_switch_info.attr, 4310e559035SOlga Kornievskaia NULL, 4320e559035SOlga Kornievskaia }; 4330e559035SOlga Kornievskaia 434c5a382ebSOlga Kornievskaia static struct kobj_type rpc_sysfs_client_type = { 435c5a382ebSOlga Kornievskaia .release = rpc_sysfs_client_release, 436c5a382ebSOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 437c5a382ebSOlga Kornievskaia .namespace = rpc_sysfs_client_namespace, 438c5a382ebSOlga Kornievskaia }; 439c5a382ebSOlga Kornievskaia 440baea9944SOlga Kornievskaia static struct kobj_type rpc_sysfs_xprt_switch_type = { 441baea9944SOlga Kornievskaia .release = rpc_sysfs_xprt_switch_release, 4420e559035SOlga Kornievskaia .default_attrs = rpc_sysfs_xprt_switch_attrs, 443baea9944SOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 444baea9944SOlga Kornievskaia .namespace = rpc_sysfs_xprt_switch_namespace, 445baea9944SOlga Kornievskaia }; 446baea9944SOlga Kornievskaia 447d408ebe0SOlga Kornievskaia static struct kobj_type rpc_sysfs_xprt_type = { 448d408ebe0SOlga Kornievskaia .release = rpc_sysfs_xprt_release, 449587bc725SOlga Kornievskaia .default_attrs = rpc_sysfs_xprt_attrs, 450d408ebe0SOlga Kornievskaia .sysfs_ops = &kobj_sysfs_ops, 451d408ebe0SOlga Kornievskaia .namespace = rpc_sysfs_xprt_namespace, 452d408ebe0SOlga Kornievskaia }; 453d408ebe0SOlga Kornievskaia 45474678748SOlga Kornievskaia void rpc_sysfs_exit(void) 45574678748SOlga Kornievskaia { 456c441f125SOlga Kornievskaia kobject_put(rpc_sunrpc_client_kobj); 457baea9944SOlga Kornievskaia kobject_put(rpc_sunrpc_xprt_switch_kobj); 45874678748SOlga Kornievskaia kset_unregister(rpc_sunrpc_kset); 45974678748SOlga Kornievskaia } 460c5a382ebSOlga Kornievskaia 461c5a382ebSOlga Kornievskaia static struct rpc_sysfs_client *rpc_sysfs_client_alloc(struct kobject *parent, 462c5a382ebSOlga Kornievskaia struct net *net, 463c5a382ebSOlga Kornievskaia int clid) 464c5a382ebSOlga Kornievskaia { 465c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *p; 466c5a382ebSOlga Kornievskaia 467c5a382ebSOlga Kornievskaia p = kzalloc(sizeof(*p), GFP_KERNEL); 468c5a382ebSOlga Kornievskaia if (p) { 469c5a382ebSOlga Kornievskaia p->net = net; 470c5a382ebSOlga Kornievskaia p->kobject.kset = rpc_sunrpc_kset; 471c5a382ebSOlga Kornievskaia if (kobject_init_and_add(&p->kobject, &rpc_sysfs_client_type, 472c5a382ebSOlga Kornievskaia parent, "clnt-%d", clid) == 0) 473c5a382ebSOlga Kornievskaia return p; 474c5a382ebSOlga Kornievskaia kobject_put(&p->kobject); 475c5a382ebSOlga Kornievskaia } 476c5a382ebSOlga Kornievskaia return NULL; 477c5a382ebSOlga Kornievskaia } 478c5a382ebSOlga Kornievskaia 479baea9944SOlga Kornievskaia static struct rpc_sysfs_xprt_switch * 480baea9944SOlga Kornievskaia rpc_sysfs_xprt_switch_alloc(struct kobject *parent, 481baea9944SOlga Kornievskaia struct rpc_xprt_switch *xprt_switch, 482baea9944SOlga Kornievskaia struct net *net, 483baea9944SOlga Kornievskaia gfp_t gfp_flags) 484baea9944SOlga Kornievskaia { 485baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *p; 486baea9944SOlga Kornievskaia 487baea9944SOlga Kornievskaia p = kzalloc(sizeof(*p), gfp_flags); 488baea9944SOlga Kornievskaia if (p) { 489baea9944SOlga Kornievskaia p->net = net; 490baea9944SOlga Kornievskaia p->kobject.kset = rpc_sunrpc_kset; 491baea9944SOlga Kornievskaia if (kobject_init_and_add(&p->kobject, 492baea9944SOlga Kornievskaia &rpc_sysfs_xprt_switch_type, 493baea9944SOlga Kornievskaia parent, "switch-%d", 494baea9944SOlga Kornievskaia xprt_switch->xps_id) == 0) 495baea9944SOlga Kornievskaia return p; 496baea9944SOlga Kornievskaia kobject_put(&p->kobject); 497baea9944SOlga Kornievskaia } 498baea9944SOlga Kornievskaia return NULL; 499baea9944SOlga Kornievskaia } 500baea9944SOlga Kornievskaia 501d408ebe0SOlga Kornievskaia static struct rpc_sysfs_xprt *rpc_sysfs_xprt_alloc(struct kobject *parent, 502d408ebe0SOlga Kornievskaia struct rpc_xprt *xprt, 503d408ebe0SOlga Kornievskaia gfp_t gfp_flags) 504d408ebe0SOlga Kornievskaia { 505d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *p; 506d408ebe0SOlga Kornievskaia 507d408ebe0SOlga Kornievskaia p = kzalloc(sizeof(*p), gfp_flags); 508d408ebe0SOlga Kornievskaia if (!p) 509d408ebe0SOlga Kornievskaia goto out; 510d408ebe0SOlga Kornievskaia p->kobject.kset = rpc_sunrpc_kset; 511d408ebe0SOlga Kornievskaia if (kobject_init_and_add(&p->kobject, &rpc_sysfs_xprt_type, 512d408ebe0SOlga Kornievskaia parent, "xprt-%d-%s", xprt->id, 513d408ebe0SOlga Kornievskaia xprt->address_strings[RPC_DISPLAY_PROTO]) == 0) 514d408ebe0SOlga Kornievskaia return p; 515d408ebe0SOlga Kornievskaia kobject_put(&p->kobject); 516d408ebe0SOlga Kornievskaia out: 517d408ebe0SOlga Kornievskaia return NULL; 518d408ebe0SOlga Kornievskaia } 519d408ebe0SOlga Kornievskaia 5202a338a54SOlga Kornievskaia void rpc_sysfs_client_setup(struct rpc_clnt *clnt, 5212a338a54SOlga Kornievskaia struct rpc_xprt_switch *xprt_switch, 5222a338a54SOlga Kornievskaia struct net *net) 523c5a382ebSOlga Kornievskaia { 524c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *rpc_client; 525c5a382ebSOlga Kornievskaia 5262a338a54SOlga Kornievskaia rpc_client = rpc_sysfs_client_alloc(rpc_sunrpc_client_kobj, 5272a338a54SOlga Kornievskaia net, clnt->cl_clid); 528c5a382ebSOlga Kornievskaia if (rpc_client) { 5292a338a54SOlga Kornievskaia char name[] = "switch"; 5302a338a54SOlga Kornievskaia struct rpc_sysfs_xprt_switch *xswitch = 5312a338a54SOlga Kornievskaia (struct rpc_sysfs_xprt_switch *)xprt_switch->xps_sysfs; 5322a338a54SOlga Kornievskaia int ret; 5332a338a54SOlga Kornievskaia 534c5a382ebSOlga Kornievskaia clnt->cl_sysfs = rpc_client; 5352a338a54SOlga Kornievskaia rpc_client->clnt = clnt; 5362a338a54SOlga Kornievskaia rpc_client->xprt_switch = xprt_switch; 537c5a382ebSOlga Kornievskaia kobject_uevent(&rpc_client->kobject, KOBJ_ADD); 5382a338a54SOlga Kornievskaia ret = sysfs_create_link_nowarn(&rpc_client->kobject, 5392a338a54SOlga Kornievskaia &xswitch->kobject, name); 5402a338a54SOlga Kornievskaia if (ret) 5412a338a54SOlga Kornievskaia pr_warn("can't create link to %s in sysfs (%d)\n", 5422a338a54SOlga Kornievskaia name, ret); 543c5a382ebSOlga Kornievskaia } 544c5a382ebSOlga Kornievskaia } 545c5a382ebSOlga Kornievskaia 546baea9944SOlga Kornievskaia void rpc_sysfs_xprt_switch_setup(struct rpc_xprt_switch *xprt_switch, 547baea9944SOlga Kornievskaia struct rpc_xprt *xprt, 548baea9944SOlga Kornievskaia gfp_t gfp_flags) 549baea9944SOlga Kornievskaia { 550baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *rpc_xprt_switch; 551baea9944SOlga Kornievskaia struct net *net; 552baea9944SOlga Kornievskaia 553baea9944SOlga Kornievskaia if (xprt_switch->xps_net) 554baea9944SOlga Kornievskaia net = xprt_switch->xps_net; 555baea9944SOlga Kornievskaia else 556baea9944SOlga Kornievskaia net = xprt->xprt_net; 557baea9944SOlga Kornievskaia rpc_xprt_switch = 558baea9944SOlga Kornievskaia rpc_sysfs_xprt_switch_alloc(rpc_sunrpc_xprt_switch_kobj, 559baea9944SOlga Kornievskaia xprt_switch, net, gfp_flags); 560baea9944SOlga Kornievskaia if (rpc_xprt_switch) { 561baea9944SOlga Kornievskaia xprt_switch->xps_sysfs = rpc_xprt_switch; 562baea9944SOlga Kornievskaia rpc_xprt_switch->xprt_switch = xprt_switch; 563baea9944SOlga Kornievskaia rpc_xprt_switch->xprt = xprt; 564baea9944SOlga Kornievskaia kobject_uevent(&rpc_xprt_switch->kobject, KOBJ_ADD); 565baea9944SOlga Kornievskaia } 566baea9944SOlga Kornievskaia } 567baea9944SOlga Kornievskaia 568d408ebe0SOlga Kornievskaia void rpc_sysfs_xprt_setup(struct rpc_xprt_switch *xprt_switch, 569d408ebe0SOlga Kornievskaia struct rpc_xprt *xprt, 570d408ebe0SOlga Kornievskaia gfp_t gfp_flags) 571d408ebe0SOlga Kornievskaia { 572d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *rpc_xprt; 573d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt_switch *switch_obj = 574d408ebe0SOlga Kornievskaia (struct rpc_sysfs_xprt_switch *)xprt_switch->xps_sysfs; 575d408ebe0SOlga Kornievskaia 576d408ebe0SOlga Kornievskaia rpc_xprt = rpc_sysfs_xprt_alloc(&switch_obj->kobject, xprt, gfp_flags); 577d408ebe0SOlga Kornievskaia if (rpc_xprt) { 578d408ebe0SOlga Kornievskaia xprt->xprt_sysfs = rpc_xprt; 579d408ebe0SOlga Kornievskaia rpc_xprt->xprt = xprt; 5805b7eb784SOlga Kornievskaia rpc_xprt->xprt_switch = xprt_switch; 581d408ebe0SOlga Kornievskaia kobject_uevent(&rpc_xprt->kobject, KOBJ_ADD); 582d408ebe0SOlga Kornievskaia } 583d408ebe0SOlga Kornievskaia } 584d408ebe0SOlga Kornievskaia 585c5a382ebSOlga Kornievskaia void rpc_sysfs_client_destroy(struct rpc_clnt *clnt) 586c5a382ebSOlga Kornievskaia { 587c5a382ebSOlga Kornievskaia struct rpc_sysfs_client *rpc_client = clnt->cl_sysfs; 588c5a382ebSOlga Kornievskaia 589c5a382ebSOlga Kornievskaia if (rpc_client) { 5902a338a54SOlga Kornievskaia char name[] = "switch"; 5912a338a54SOlga Kornievskaia 5922a338a54SOlga Kornievskaia sysfs_remove_link(&rpc_client->kobject, name); 593c5a382ebSOlga Kornievskaia kobject_uevent(&rpc_client->kobject, KOBJ_REMOVE); 594c5a382ebSOlga Kornievskaia kobject_del(&rpc_client->kobject); 595c5a382ebSOlga Kornievskaia kobject_put(&rpc_client->kobject); 596c5a382ebSOlga Kornievskaia clnt->cl_sysfs = NULL; 597c5a382ebSOlga Kornievskaia } 598c5a382ebSOlga Kornievskaia } 599baea9944SOlga Kornievskaia 600baea9944SOlga Kornievskaia void rpc_sysfs_xprt_switch_destroy(struct rpc_xprt_switch *xprt_switch) 601baea9944SOlga Kornievskaia { 602baea9944SOlga Kornievskaia struct rpc_sysfs_xprt_switch *rpc_xprt_switch = xprt_switch->xps_sysfs; 603baea9944SOlga Kornievskaia 604baea9944SOlga Kornievskaia if (rpc_xprt_switch) { 605baea9944SOlga Kornievskaia kobject_uevent(&rpc_xprt_switch->kobject, KOBJ_REMOVE); 606baea9944SOlga Kornievskaia kobject_del(&rpc_xprt_switch->kobject); 607baea9944SOlga Kornievskaia kobject_put(&rpc_xprt_switch->kobject); 608baea9944SOlga Kornievskaia xprt_switch->xps_sysfs = NULL; 609baea9944SOlga Kornievskaia } 610baea9944SOlga Kornievskaia } 611d408ebe0SOlga Kornievskaia 612d408ebe0SOlga Kornievskaia void rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt) 613d408ebe0SOlga Kornievskaia { 614d408ebe0SOlga Kornievskaia struct rpc_sysfs_xprt *rpc_xprt = xprt->xprt_sysfs; 615d408ebe0SOlga Kornievskaia 616d408ebe0SOlga Kornievskaia if (rpc_xprt) { 617d408ebe0SOlga Kornievskaia kobject_uevent(&rpc_xprt->kobject, KOBJ_REMOVE); 618d408ebe0SOlga Kornievskaia kobject_del(&rpc_xprt->kobject); 619d408ebe0SOlga Kornievskaia kobject_put(&rpc_xprt->kobject); 620d408ebe0SOlga Kornievskaia xprt->xprt_sysfs = NULL; 621d408ebe0SOlga Kornievskaia } 622d408ebe0SOlga Kornievskaia } 623