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), 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 ceph_mdsc_free_path(path, pathlen); 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 ceph_mdsc_free_path(path, pathlen); 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_cb(struct inode *inode, struct ceph_cap *cap, void *p) 128 { 129 struct seq_file *s = p; 130 131 seq_printf(s, "0x%-17lx%-17s%-17s\n", inode->i_ino, 132 ceph_cap_string(cap->issued), 133 ceph_cap_string(cap->implemented)); 134 return 0; 135 } 136 137 static int caps_show(struct seq_file *s, void *p) 138 { 139 struct ceph_fs_client *fsc = s->private; 140 struct ceph_mds_client *mdsc = fsc->mdsc; 141 int total, avail, used, reserved, min, i; 142 143 ceph_reservation_status(fsc, &total, &avail, &used, &reserved, &min); 144 seq_printf(s, "total\t\t%d\n" 145 "avail\t\t%d\n" 146 "used\t\t%d\n" 147 "reserved\t%d\n" 148 "min\t\t%d\n\n", 149 total, avail, used, reserved, min); 150 seq_printf(s, "ino issued implemented\n"); 151 seq_printf(s, "-----------------------------------------------\n"); 152 153 mutex_lock(&mdsc->mutex); 154 for (i = 0; i < mdsc->max_sessions; i++) { 155 struct ceph_mds_session *session; 156 157 session = __ceph_lookup_mds_session(mdsc, i); 158 if (!session) 159 continue; 160 mutex_unlock(&mdsc->mutex); 161 mutex_lock(&session->s_mutex); 162 ceph_iterate_session_caps(session, caps_show_cb, s); 163 mutex_unlock(&session->s_mutex); 164 ceph_put_mds_session(session); 165 mutex_lock(&mdsc->mutex); 166 } 167 mutex_unlock(&mdsc->mutex); 168 169 return 0; 170 } 171 172 static int mds_sessions_show(struct seq_file *s, void *ptr) 173 { 174 struct ceph_fs_client *fsc = s->private; 175 struct ceph_mds_client *mdsc = fsc->mdsc; 176 struct ceph_auth_client *ac = fsc->client->monc.auth; 177 struct ceph_options *opt = fsc->client->options; 178 int mds = -1; 179 180 mutex_lock(&mdsc->mutex); 181 182 /* The 'num' portion of an 'entity name' */ 183 seq_printf(s, "global_id %llu\n", ac->global_id); 184 185 /* The -o name mount argument */ 186 seq_printf(s, "name \"%s\"\n", opt->name ? opt->name : ""); 187 188 /* The list of MDS session rank+state */ 189 for (mds = 0; mds < mdsc->max_sessions; mds++) { 190 struct ceph_mds_session *session = 191 __ceph_lookup_mds_session(mdsc, mds); 192 if (!session) { 193 continue; 194 } 195 mutex_unlock(&mdsc->mutex); 196 seq_printf(s, "mds.%d %s\n", 197 session->s_mds, 198 ceph_session_state_name(session->s_state)); 199 200 ceph_put_mds_session(session); 201 mutex_lock(&mdsc->mutex); 202 } 203 mutex_unlock(&mdsc->mutex); 204 205 return 0; 206 } 207 208 CEPH_DEFINE_SHOW_FUNC(mdsmap_show) 209 CEPH_DEFINE_SHOW_FUNC(mdsc_show) 210 CEPH_DEFINE_SHOW_FUNC(caps_show) 211 CEPH_DEFINE_SHOW_FUNC(mds_sessions_show) 212 213 214 /* 215 * debugfs 216 */ 217 static int congestion_kb_set(void *data, u64 val) 218 { 219 struct ceph_fs_client *fsc = (struct ceph_fs_client *)data; 220 221 fsc->mount_options->congestion_kb = (int)val; 222 return 0; 223 } 224 225 static int congestion_kb_get(void *data, u64 *val) 226 { 227 struct ceph_fs_client *fsc = (struct ceph_fs_client *)data; 228 229 *val = (u64)fsc->mount_options->congestion_kb; 230 return 0; 231 } 232 233 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops, congestion_kb_get, 234 congestion_kb_set, "%llu\n"); 235 236 237 void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc) 238 { 239 dout("ceph_fs_debugfs_cleanup\n"); 240 debugfs_remove(fsc->debugfs_bdi); 241 debugfs_remove(fsc->debugfs_congestion_kb); 242 debugfs_remove(fsc->debugfs_mdsmap); 243 debugfs_remove(fsc->debugfs_mds_sessions); 244 debugfs_remove(fsc->debugfs_caps); 245 debugfs_remove(fsc->debugfs_mdsc); 246 } 247 248 int ceph_fs_debugfs_init(struct ceph_fs_client *fsc) 249 { 250 char name[100]; 251 int err = -ENOMEM; 252 253 dout("ceph_fs_debugfs_init\n"); 254 BUG_ON(!fsc->client->debugfs_dir); 255 fsc->debugfs_congestion_kb = 256 debugfs_create_file("writeback_congestion_kb", 257 0600, 258 fsc->client->debugfs_dir, 259 fsc, 260 &congestion_kb_fops); 261 if (!fsc->debugfs_congestion_kb) 262 goto out; 263 264 snprintf(name, sizeof(name), "../../bdi/%s", 265 dev_name(fsc->sb->s_bdi->dev)); 266 fsc->debugfs_bdi = 267 debugfs_create_symlink("bdi", 268 fsc->client->debugfs_dir, 269 name); 270 if (!fsc->debugfs_bdi) 271 goto out; 272 273 fsc->debugfs_mdsmap = debugfs_create_file("mdsmap", 274 0400, 275 fsc->client->debugfs_dir, 276 fsc, 277 &mdsmap_show_fops); 278 if (!fsc->debugfs_mdsmap) 279 goto out; 280 281 fsc->debugfs_mds_sessions = debugfs_create_file("mds_sessions", 282 0400, 283 fsc->client->debugfs_dir, 284 fsc, 285 &mds_sessions_show_fops); 286 if (!fsc->debugfs_mds_sessions) 287 goto out; 288 289 fsc->debugfs_mdsc = debugfs_create_file("mdsc", 290 0400, 291 fsc->client->debugfs_dir, 292 fsc, 293 &mdsc_show_fops); 294 if (!fsc->debugfs_mdsc) 295 goto out; 296 297 fsc->debugfs_caps = debugfs_create_file("caps", 298 0400, 299 fsc->client->debugfs_dir, 300 fsc, 301 &caps_show_fops); 302 if (!fsc->debugfs_caps) 303 goto out; 304 305 return 0; 306 307 out: 308 ceph_fs_debugfs_cleanup(fsc); 309 return err; 310 } 311 312 313 #else /* CONFIG_DEBUG_FS */ 314 315 int ceph_fs_debugfs_init(struct ceph_fs_client *fsc) 316 { 317 return 0; 318 } 319 320 void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc) 321 { 322 } 323 324 #endif /* CONFIG_DEBUG_FS */ 325