1 // SPDX-License-Identifier: GPL-2.0 2 #include <linux/ceph/ceph_debug.h> 3 4 #include <linux/device.h> 5 #include <linux/slab.h> 6 #include <linux/module.h> 7 #include <linux/ctype.h> 8 #include <linux/debugfs.h> 9 #include <linux/seq_file.h> 10 11 #include <linux/ceph/libceph.h> 12 #include <linux/ceph/mon_client.h> 13 #include <linux/ceph/auth.h> 14 #include <linux/ceph/debugfs.h> 15 16 #include "super.h" 17 18 #ifdef CONFIG_DEBUG_FS 19 20 #include "mds_client.h" 21 22 static int mdsmap_show(struct seq_file *s, void *p) 23 { 24 int i; 25 struct ceph_fs_client *fsc = s->private; 26 struct ceph_mdsmap *mdsmap; 27 28 if (!fsc->mdsc || !fsc->mdsc->mdsmap) 29 return 0; 30 mdsmap = fsc->mdsc->mdsmap; 31 seq_printf(s, "epoch %d\n", mdsmap->m_epoch); 32 seq_printf(s, "root %d\n", mdsmap->m_root); 33 seq_printf(s, "max_mds %d\n", mdsmap->m_max_mds); 34 seq_printf(s, "session_timeout %d\n", mdsmap->m_session_timeout); 35 seq_printf(s, "session_autoclose %d\n", mdsmap->m_session_autoclose); 36 for (i = 0; i < mdsmap->m_num_mds; i++) { 37 struct ceph_entity_addr *addr = &mdsmap->m_info[i].addr; 38 int state = mdsmap->m_info[i].state; 39 seq_printf(s, "\tmds%d\t%s\t(%s)\n", i, 40 ceph_pr_addr(&addr->in_addr), 41 ceph_mds_state_name(state)); 42 } 43 return 0; 44 } 45 46 /* 47 * mdsc debugfs 48 */ 49 static int mdsc_show(struct seq_file *s, void *p) 50 { 51 struct ceph_fs_client *fsc = s->private; 52 struct ceph_mds_client *mdsc = fsc->mdsc; 53 struct ceph_mds_request *req; 54 struct rb_node *rp; 55 int pathlen; 56 u64 pathbase; 57 char *path; 58 59 mutex_lock(&mdsc->mutex); 60 for (rp = rb_first(&mdsc->request_tree); rp; rp = rb_next(rp)) { 61 req = rb_entry(rp, struct ceph_mds_request, r_node); 62 63 if (req->r_request && req->r_session) 64 seq_printf(s, "%lld\tmds%d\t", req->r_tid, 65 req->r_session->s_mds); 66 else if (!req->r_request) 67 seq_printf(s, "%lld\t(no request)\t", req->r_tid); 68 else 69 seq_printf(s, "%lld\t(no session)\t", req->r_tid); 70 71 seq_printf(s, "%s", ceph_mds_op_name(req->r_op)); 72 73 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags)) 74 seq_puts(s, "\t(unsafe)"); 75 else 76 seq_puts(s, "\t"); 77 78 if (req->r_inode) { 79 seq_printf(s, " #%llx", ceph_ino(req->r_inode)); 80 } else if (req->r_dentry) { 81 path = ceph_mdsc_build_path(req->r_dentry, &pathlen, 82 &pathbase, 0); 83 if (IS_ERR(path)) 84 path = NULL; 85 spin_lock(&req->r_dentry->d_lock); 86 seq_printf(s, " #%llx/%pd (%s)", 87 ceph_ino(d_inode(req->r_dentry->d_parent)), 88 req->r_dentry, 89 path ? path : ""); 90 spin_unlock(&req->r_dentry->d_lock); 91 kfree(path); 92 } else if (req->r_path1) { 93 seq_printf(s, " #%llx/%s", req->r_ino1.ino, 94 req->r_path1); 95 } else { 96 seq_printf(s, " #%llx", req->r_ino1.ino); 97 } 98 99 if (req->r_old_dentry) { 100 path = ceph_mdsc_build_path(req->r_old_dentry, &pathlen, 101 &pathbase, 0); 102 if (IS_ERR(path)) 103 path = NULL; 104 spin_lock(&req->r_old_dentry->d_lock); 105 seq_printf(s, " #%llx/%pd (%s)", 106 req->r_old_dentry_dir ? 107 ceph_ino(req->r_old_dentry_dir) : 0, 108 req->r_old_dentry, 109 path ? path : ""); 110 spin_unlock(&req->r_old_dentry->d_lock); 111 kfree(path); 112 } else if (req->r_path2 && req->r_op != CEPH_MDS_OP_SYMLINK) { 113 if (req->r_ino2.ino) 114 seq_printf(s, " #%llx/%s", req->r_ino2.ino, 115 req->r_path2); 116 else 117 seq_printf(s, " %s", req->r_path2); 118 } 119 120 seq_puts(s, "\n"); 121 } 122 mutex_unlock(&mdsc->mutex); 123 124 return 0; 125 } 126 127 static int caps_show(struct seq_file *s, void *p) 128 { 129 struct ceph_fs_client *fsc = s->private; 130 int total, avail, used, reserved, min; 131 132 ceph_reservation_status(fsc, &total, &avail, &used, &reserved, &min); 133 seq_printf(s, "total\t\t%d\n" 134 "avail\t\t%d\n" 135 "used\t\t%d\n" 136 "reserved\t%d\n" 137 "min\t%d\n", 138 total, avail, used, reserved, min); 139 return 0; 140 } 141 142 static int mds_sessions_show(struct seq_file *s, void *ptr) 143 { 144 struct ceph_fs_client *fsc = s->private; 145 struct ceph_mds_client *mdsc = fsc->mdsc; 146 struct ceph_auth_client *ac = fsc->client->monc.auth; 147 struct ceph_options *opt = fsc->client->options; 148 int mds = -1; 149 150 mutex_lock(&mdsc->mutex); 151 152 /* The 'num' portion of an 'entity name' */ 153 seq_printf(s, "global_id %llu\n", ac->global_id); 154 155 /* The -o name mount argument */ 156 seq_printf(s, "name \"%s\"\n", opt->name ? opt->name : ""); 157 158 /* The list of MDS session rank+state */ 159 for (mds = 0; mds < mdsc->max_sessions; mds++) { 160 struct ceph_mds_session *session = 161 __ceph_lookup_mds_session(mdsc, mds); 162 if (!session) { 163 continue; 164 } 165 mutex_unlock(&mdsc->mutex); 166 seq_printf(s, "mds.%d %s\n", 167 session->s_mds, 168 ceph_session_state_name(session->s_state)); 169 170 ceph_put_mds_session(session); 171 mutex_lock(&mdsc->mutex); 172 } 173 mutex_unlock(&mdsc->mutex); 174 175 return 0; 176 } 177 178 CEPH_DEFINE_SHOW_FUNC(mdsmap_show) 179 CEPH_DEFINE_SHOW_FUNC(mdsc_show) 180 CEPH_DEFINE_SHOW_FUNC(caps_show) 181 CEPH_DEFINE_SHOW_FUNC(mds_sessions_show) 182 183 184 /* 185 * debugfs 186 */ 187 static int congestion_kb_set(void *data, u64 val) 188 { 189 struct ceph_fs_client *fsc = (struct ceph_fs_client *)data; 190 191 fsc->mount_options->congestion_kb = (int)val; 192 return 0; 193 } 194 195 static int congestion_kb_get(void *data, u64 *val) 196 { 197 struct ceph_fs_client *fsc = (struct ceph_fs_client *)data; 198 199 *val = (u64)fsc->mount_options->congestion_kb; 200 return 0; 201 } 202 203 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops, congestion_kb_get, 204 congestion_kb_set, "%llu\n"); 205 206 207 void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc) 208 { 209 dout("ceph_fs_debugfs_cleanup\n"); 210 debugfs_remove(fsc->debugfs_bdi); 211 debugfs_remove(fsc->debugfs_congestion_kb); 212 debugfs_remove(fsc->debugfs_mdsmap); 213 debugfs_remove(fsc->debugfs_mds_sessions); 214 debugfs_remove(fsc->debugfs_caps); 215 debugfs_remove(fsc->debugfs_mdsc); 216 } 217 218 int ceph_fs_debugfs_init(struct ceph_fs_client *fsc) 219 { 220 char name[100]; 221 int err = -ENOMEM; 222 223 dout("ceph_fs_debugfs_init\n"); 224 BUG_ON(!fsc->client->debugfs_dir); 225 fsc->debugfs_congestion_kb = 226 debugfs_create_file("writeback_congestion_kb", 227 0600, 228 fsc->client->debugfs_dir, 229 fsc, 230 &congestion_kb_fops); 231 if (!fsc->debugfs_congestion_kb) 232 goto out; 233 234 snprintf(name, sizeof(name), "../../bdi/%s", 235 dev_name(fsc->sb->s_bdi->dev)); 236 fsc->debugfs_bdi = 237 debugfs_create_symlink("bdi", 238 fsc->client->debugfs_dir, 239 name); 240 if (!fsc->debugfs_bdi) 241 goto out; 242 243 fsc->debugfs_mdsmap = debugfs_create_file("mdsmap", 244 0400, 245 fsc->client->debugfs_dir, 246 fsc, 247 &mdsmap_show_fops); 248 if (!fsc->debugfs_mdsmap) 249 goto out; 250 251 fsc->debugfs_mds_sessions = debugfs_create_file("mds_sessions", 252 0400, 253 fsc->client->debugfs_dir, 254 fsc, 255 &mds_sessions_show_fops); 256 if (!fsc->debugfs_mds_sessions) 257 goto out; 258 259 fsc->debugfs_mdsc = debugfs_create_file("mdsc", 260 0400, 261 fsc->client->debugfs_dir, 262 fsc, 263 &mdsc_show_fops); 264 if (!fsc->debugfs_mdsc) 265 goto out; 266 267 fsc->debugfs_caps = debugfs_create_file("caps", 268 0400, 269 fsc->client->debugfs_dir, 270 fsc, 271 &caps_show_fops); 272 if (!fsc->debugfs_caps) 273 goto out; 274 275 return 0; 276 277 out: 278 ceph_fs_debugfs_cleanup(fsc); 279 return err; 280 } 281 282 283 #else /* CONFIG_DEBUG_FS */ 284 285 int ceph_fs_debugfs_init(struct ceph_fs_client *fsc) 286 { 287 return 0; 288 } 289 290 void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc) 291 { 292 } 293 294 #endif /* CONFIG_DEBUG_FS */ 295