lustre/llite/lproc_llite.c

   1 /*
   2  * GPL HEADER START
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License version 2 only,
   8  * as published by the Free Software Foundation.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License version 2 for more details (a copy is included
  14  * in the LICENSE file that accompanied this code).
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * version 2 along with this program; If not, see
  18  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
  19  *
  20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  21  * CA 95054 USA or visit www.sun.com if you need additional information or
  22  * have any questions.
  23  *
  24  * GPL HEADER END
  25  */
  26 /*
  27  * Copyright (c) 2002, 2010, Oracle and/or its affiliates. All rights reserved.
  28  * Use is subject to license terms.
  29  *
  30  * Copyright (c) 2012, 2014, Intel Corporation.
  31  */
  32 /*
  33  * This file is part of Lustre, http://www.lustre.org/
  34  * Lustre is a trademark of Sun Microsystems, Inc.
  35  */
  36 #define DEBUG_SUBSYSTEM S_LLITE
  37
  38 #include <linux/version.h>
  39 #include <linux/user_namespace.h>
  40 #ifdef HAVE_UIDGID_HEADER
  41 # include <linux/uidgid.h>
  42 #endif
  43 #include <lustre_param.h>
  44 #include <lprocfs_status.h>
  45 #include <obd_support.h>
  46
  47 #include "llite_internal.h"
  48 #include "vvp_internal.h"
  49
  50 struct proc_dir_entry *proc_lustre_fs_root;
  51
  52 #ifdef CONFIG_PROC_FS
  53 /* /proc/lustre/llite mount point registration */
  54 static const struct file_operations ll_rw_extents_stats_fops;
  55 static const struct file_operations ll_rw_extents_stats_pp_fops;
  56 static const struct file_operations ll_rw_offset_stats_fops;
  57
  58 static int ll_blksize_seq_show(struct seq_file *m, void *v)
  59 {
  60         struct super_block *sb = m->private;
  61         struct obd_statfs osfs;
  62         int rc;
  63
  64         LASSERT(sb != NULL);
  65         rc = ll_statfs_internal(sb, &osfs,
  66                                 cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS),
  67                                 OBD_STATFS_NODELAY);
  68         if (!rc)
  69                 rc = seq_printf(m, "%u\n", osfs.os_bsize);
  70         return rc;
  71 }
  72 LPROC_SEQ_FOPS_RO(ll_blksize);
  73
  74 static int ll_kbytestotal_seq_show(struct seq_file *m, void *v)
  75 {
  76         struct super_block *sb = m->private;
  77         struct obd_statfs osfs;
  78         int rc;
  79
  80         LASSERT(sb != NULL);
  81         rc = ll_statfs_internal(sb, &osfs,
  82                                 cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS),
  83                                 OBD_STATFS_NODELAY);
  84         if (!rc) {
  85                 __u32 blk_size = osfs.os_bsize >> 10;
  86                 __u64 result = osfs.os_blocks;
  87
  88                 while (blk_size >>= 1)
  89                         result <<= 1;
  90
  91                 rc = seq_printf(m, LPU64"\n", result);
  92         }
  93         return rc;
  94 }
  95 LPROC_SEQ_FOPS_RO(ll_kbytestotal);
  96
  97 static int ll_kbytesfree_seq_show(struct seq_file *m, void *v)
  98 {
  99         struct super_block *sb = m->private;
 100         struct obd_statfs osfs;
 101         int rc;
 102
 103         LASSERT(sb != NULL);
 104         rc = ll_statfs_internal(sb, &osfs,
 105                                 cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS),
 106                                 OBD_STATFS_NODELAY);
 107         if (!rc) {
 108                 __u32 blk_size = osfs.os_bsize >> 10;
 109                 __u64 result = osfs.os_bfree;
 110
 111                 while (blk_size >>= 1)
 112                         result <<= 1;
 113
 114                 rc = seq_printf(m, LPU64"\n", result);
 115         }
 116         return rc;
 117 }
 118 LPROC_SEQ_FOPS_RO(ll_kbytesfree);
 119
 120 static int ll_kbytesavail_seq_show(struct seq_file *m, void *v)
 121 {
 122         struct super_block *sb = m->private;
 123         struct obd_statfs osfs;
 124         int rc;
 125
 126         LASSERT(sb != NULL);
 127         rc = ll_statfs_internal(sb, &osfs,
 128                                 cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS),
 129                                 OBD_STATFS_NODELAY);
 130         if (!rc) {
 131                 __u32 blk_size = osfs.os_bsize >> 10;
 132                 __u64 result = osfs.os_bavail;
 133
 134                 while (blk_size >>= 1)
 135                         result <<= 1;
 136
 137                 rc = seq_printf(m, LPU64"\n", result);
 138         }
 139         return rc;
 140 }
 141 LPROC_SEQ_FOPS_RO(ll_kbytesavail);
 142
 143 static int ll_filestotal_seq_show(struct seq_file *m, void *v)
 144 {
 145         struct super_block *sb = m->private;
 146         struct obd_statfs osfs;
 147         int rc;
 148
 149         LASSERT(sb != NULL);
 150         rc = ll_statfs_internal(sb, &osfs,
 151                                 cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS),
 152                                 OBD_STATFS_NODELAY);
 153         if (!rc)
 154                 rc = seq_printf(m, LPU64"\n", osfs.os_files);
 155         return rc;
 156 }
 157 LPROC_SEQ_FOPS_RO(ll_filestotal);
 158
 159 static int ll_filesfree_seq_show(struct seq_file *m, void *v)
 160 {
 161         struct super_block *sb = m->private;
 162         struct obd_statfs osfs;
 163         int rc;
 164
 165         LASSERT(sb != NULL);
 166         rc = ll_statfs_internal(sb, &osfs,
 167                                 cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS),
 168                                 OBD_STATFS_NODELAY);
 169         if (!rc)
 170                 rc = seq_printf(m, LPU64"\n", osfs.os_ffree);
 171         return rc;
 172 }
 173 LPROC_SEQ_FOPS_RO(ll_filesfree);
 174
 175 static int ll_client_type_seq_show(struct seq_file *m, void *v)
 176 {
 177         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 178         int rc;
 179
 180         LASSERT(sbi != NULL);
 181
 182         if (sbi->ll_flags & LL_SBI_RMT_CLIENT)
 183                 rc = seq_printf(m, "remote client\n");
 184         else
 185                 rc = seq_printf(m, "local client\n");
 186         return rc;
 187 }
 188 LPROC_SEQ_FOPS_RO(ll_client_type);
 189
 190 static int ll_fstype_seq_show(struct seq_file *m, void *v)
 191 {
 192         struct super_block *sb = m->private;
 193
 194         LASSERT(sb != NULL);
 195         return seq_printf(m, "%s\n", sb->s_type->name);
 196 }
 197 LPROC_SEQ_FOPS_RO(ll_fstype);
 198
 199 static int ll_sb_uuid_seq_show(struct seq_file *m, void *v)
 200 {
 201         struct super_block *sb = m->private;
 202
 203         LASSERT(sb != NULL);
 204         return seq_printf(m, "%s\n", ll_s2sbi(sb)->ll_sb_uuid.uuid);
 205 }
 206 LPROC_SEQ_FOPS_RO(ll_sb_uuid);
 207
 208 static int ll_xattr_cache_seq_show(struct seq_file *m, void *v)
 209 {
 210         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 211
 212         return seq_printf(m, "%u\n", sbi->ll_xattr_cache_enabled);
 213 }
 214
 215 static ssize_t ll_xattr_cache_seq_write(struct file *file,
 216                                         const char __user *buffer,
 217                                         size_t count, loff_t *off)
 218 {
 219         struct seq_file *m = file->private_data;
 220         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 221         int val, rc;
 222
 223         rc = lprocfs_write_helper(buffer, count, &val);
 224         if (rc)
 225                 return rc;
 226
 227         if (val != 0 && val != 1)
 228                 return -ERANGE;
 229
 230         if (val == 1 && !(sbi->ll_flags & LL_SBI_XATTR_CACHE))
 231                 return -ENOTSUPP;
 232
 233         sbi->ll_xattr_cache_enabled = val;
 234
 235         return count;
 236 }
 237 LPROC_SEQ_FOPS(ll_xattr_cache);
 238
 239 static int ll_site_stats_seq_show(struct seq_file *m, void *v)
 240 {
 241         struct super_block *sb = m->private;
 242
 243         /*
 244          * See description of statistical counters in struct cl_site, and
 245          * struct lu_site.
 246          */
 247         return cl_site_stats_print(lu2cl_site(ll_s2sbi(sb)->ll_site), m);
 248 }
 249 LPROC_SEQ_FOPS_RO(ll_site_stats);
 250
 251 static int ll_max_readahead_mb_seq_show(struct seq_file *m, void *v)
 252 {
 253         struct super_block *sb = m->private;
 254         struct ll_sb_info *sbi = ll_s2sbi(sb);
 255         long pages_number;
 256         int mult;
 257
 258         spin_lock(&sbi->ll_lock);
 259         pages_number = sbi->ll_ra_info.ra_max_pages;
 260         spin_unlock(&sbi->ll_lock);
 261
 262         mult = 1 << (20 - PAGE_CACHE_SHIFT);
 263         return lprocfs_seq_read_frac_helper(m, pages_number, mult);
 264 }
 265
 266 static ssize_t
 267 ll_max_readahead_mb_seq_write(struct file *file, const char __user *buffer,
 268                               size_t count, loff_t *off)
 269 {
 270         struct seq_file *m = file->private_data;
 271         struct super_block *sb = m->private;
 272         struct ll_sb_info *sbi = ll_s2sbi(sb);
 273         __u64 val;
 274         long pages_number;
 275         int pages_shift;
 276         int rc;
 277
 278         pages_shift = 20 - PAGE_CACHE_SHIFT;
 279         rc = lprocfs_write_frac_u64_helper(buffer, count, &val,
 280                                            1 << pages_shift);
 281         if (rc)
 282                 return rc;
 283
 284         if (val > LONG_MAX)
 285                 return -ERANGE;
 286         pages_number = (long)val;
 287
 288         if (pages_number < 0 || pages_number > totalram_pages / 2) {
 289                 /* 1/2 of RAM */
 290                 CERROR("%s: can't set max_readahead_mb=%lu > %luMB\n",
 291                        ll_get_fsname(sb, NULL, 0), pages_number >> pages_shift,
 292                        totalram_pages >> (pages_shift + 1));
 293                 return -ERANGE;
 294         }
 295
 296         spin_lock(&sbi->ll_lock);
 297         sbi->ll_ra_info.ra_max_pages = pages_number;
 298         spin_unlock(&sbi->ll_lock);
 299         return count;
 300 }
 301 LPROC_SEQ_FOPS(ll_max_readahead_mb);
 302
 303 static int ll_max_readahead_per_file_mb_seq_show(struct seq_file *m, void *v)
 304 {
 305         struct super_block *sb = m->private;
 306         struct ll_sb_info *sbi = ll_s2sbi(sb);
 307         long pages_number;
 308         int mult;
 309
 310         spin_lock(&sbi->ll_lock);
 311         pages_number = sbi->ll_ra_info.ra_max_pages_per_file;
 312         spin_unlock(&sbi->ll_lock);
 313
 314         mult = 1 << (20 - PAGE_CACHE_SHIFT);
 315         return lprocfs_seq_read_frac_helper(m, pages_number, mult);
 316 }
 317
 318 static ssize_t
 319 ll_max_readahead_per_file_mb_seq_write(struct file *file,
 320                                        const char __user *buffer,
 321                                        size_t count, loff_t *off)
 322 {
 323         struct seq_file *m = file->private_data;
 324         struct super_block *sb = m->private;
 325         struct ll_sb_info *sbi = ll_s2sbi(sb);
 326         int pages_shift, rc, pages_number;
 327
 328         pages_shift = 20 - PAGE_CACHE_SHIFT;
 329         rc = lprocfs_write_frac_helper(buffer, count, &pages_number,
 330                                        1 << pages_shift);
 331         if (rc)
 332                 return rc;
 333
 334         if (pages_number < 0 || pages_number > sbi->ll_ra_info.ra_max_pages) {
 335                 CERROR("%s: can't set max_readahead_per_file_mb=%u > "
 336                        "max_read_ahead_mb=%lu\n", ll_get_fsname(sb, NULL, 0),
 337                        pages_number >> pages_shift,
 338                        sbi->ll_ra_info.ra_max_pages >> pages_shift);
 339                 return -ERANGE;
 340         }
 341
 342         spin_lock(&sbi->ll_lock);
 343         sbi->ll_ra_info.ra_max_pages_per_file = pages_number;
 344         spin_unlock(&sbi->ll_lock);
 345         return count;
 346 }
 347 LPROC_SEQ_FOPS(ll_max_readahead_per_file_mb);
 348
 349 static int ll_max_read_ahead_whole_mb_seq_show(struct seq_file *m, void *v)
 350 {
 351         struct super_block *sb = m->private;
 352         struct ll_sb_info *sbi = ll_s2sbi(sb);
 353         long pages_number;
 354         int mult;
 355
 356         spin_lock(&sbi->ll_lock);
 357         pages_number = sbi->ll_ra_info.ra_max_read_ahead_whole_pages;
 358         spin_unlock(&sbi->ll_lock);
 359
 360         mult = 1 << (20 - PAGE_CACHE_SHIFT);
 361         return lprocfs_seq_read_frac_helper(m, pages_number, mult);
 362 }
 363
 364 static ssize_t
 365 ll_max_read_ahead_whole_mb_seq_write(struct file *file,
 366                                      const char __user *buffer,
 367                                      size_t count, loff_t *off)
 368 {
 369         struct seq_file *m = file->private_data;
 370         struct super_block *sb = m->private;
 371         struct ll_sb_info *sbi = ll_s2sbi(sb);
 372         int pages_shift, rc, pages_number;
 373
 374         pages_shift = 20 - PAGE_CACHE_SHIFT;
 375         rc = lprocfs_write_frac_helper(buffer, count, &pages_number,
 376                                        1 << pages_shift);
 377         if (rc)
 378                 return rc;
 379
 380         /* Cap this at the current max readahead window size, the readahead
 381          * algorithm does this anyway so it's pointless to set it larger. */
 382         if (pages_number < 0 ||
 383             pages_number > sbi->ll_ra_info.ra_max_pages_per_file) {
 384                 CERROR("%s: can't set max_read_ahead_whole_mb=%u > "
 385                        "max_read_ahead_per_file_mb=%lu\n",
 386                        ll_get_fsname(sb, NULL, 0),
 387                        pages_number >> pages_shift,
 388                        sbi->ll_ra_info.ra_max_pages_per_file >> pages_shift);
 389                 return -ERANGE;
 390         }
 391
 392         spin_lock(&sbi->ll_lock);
 393         sbi->ll_ra_info.ra_max_read_ahead_whole_pages = pages_number;
 394         spin_unlock(&sbi->ll_lock);
 395         return count;
 396 }
 397 LPROC_SEQ_FOPS(ll_max_read_ahead_whole_mb);
 398
 399 static int ll_max_cached_mb_seq_show(struct seq_file *m, void *v)
 400 {
 401         struct super_block     *sb    = m->private;
 402         struct ll_sb_info      *sbi   = ll_s2sbi(sb);
 403         struct cl_client_cache *cache = sbi->ll_cache;
 404         int shift = 20 - PAGE_CACHE_SHIFT;
 405         long max_cached_mb;
 406         long unused_mb;
 407
 408         max_cached_mb = cache->ccc_lru_max >> shift;
 409         unused_mb = atomic_long_read(&cache->ccc_lru_left) >> shift;
 410         return seq_printf(m,
 411                         "users: %d\n"
 412                         "max_cached_mb: %ld\n"
 413                         "used_mb: %ld\n"
 414                         "unused_mb: %ld\n"
 415                         "reclaim_count: %u\n",
 416                         atomic_read(&cache->ccc_users),
 417                         max_cached_mb,
 418                         max_cached_mb - unused_mb,
 419                         unused_mb,
 420                         cache->ccc_lru_shrinkers);
 421 }
 422
 423 static ssize_t
 424 ll_max_cached_mb_seq_write(struct file *file, const char __user *buffer,
 425                            size_t count, loff_t *off)
 426 {
 427         struct seq_file *m = file->private_data;
 428         struct super_block *sb = m->private;
 429         struct ll_sb_info *sbi = ll_s2sbi(sb);
 430         struct cl_client_cache *cache = sbi->ll_cache;
 431         struct lu_env *env;
 432         __u64 val;
 433         long diff = 0;
 434         long nrpages = 0;
 435         long pages_number;
 436         int refcheck;
 437         int mult;
 438         long rc;
 439         char kernbuf[128];
 440         ENTRY;
 441
 442         if (count >= sizeof(kernbuf))
 443                 RETURN(-EINVAL);
 444
 445         if (copy_from_user(kernbuf, buffer, count))
 446                 RETURN(-EFAULT);
 447         kernbuf[count] = 0;
 448
 449         mult = 1 << (20 - PAGE_CACHE_SHIFT);
 450         buffer += lprocfs_find_named_value(kernbuf, "max_cached_mb:", &count) -
 451                   kernbuf;
 452         rc = lprocfs_write_frac_u64_helper(buffer, count, &val, mult);
 453         if (rc)
 454                 RETURN(rc);
 455
 456         if (val > LONG_MAX)
 457                 return -ERANGE;
 458         pages_number = (long)val;
 459
 460         if (pages_number < 0 || pages_number > totalram_pages) {
 461                 CERROR("%s: can't set max cache more than %lu MB\n",
 462                        ll_get_fsname(sb, NULL, 0),
 463                        totalram_pages >> (20 - PAGE_CACHE_SHIFT));
 464                 RETURN(-ERANGE);
 465         }
 466         /* Allow enough cache so clients can make well-formed RPCs */
 467         pages_number = max_t(long, pages_number, PTLRPC_MAX_BRW_PAGES);
 468
 469         spin_lock(&sbi->ll_lock);
 470         diff = pages_number - cache->ccc_lru_max;
 471         spin_unlock(&sbi->ll_lock);
 472
 473         /* easy - add more LRU slots. */
 474         if (diff >= 0) {
 475                 atomic_long_add(diff, &cache->ccc_lru_left);
 476                 GOTO(out, rc = 0);
 477         }
 478
 479         env = cl_env_get(&refcheck);
 480         if (IS_ERR(env))
 481                 RETURN(rc);
 482
 483         diff = -diff;
 484         while (diff > 0) {
 485                 long tmp;
 486
 487                 /* reduce LRU budget from free slots. */
 488                 do {
 489                         long ov, nv;
 490
 491                         ov = atomic_long_read(&cache->ccc_lru_left);
 492                         if (ov == 0)
 493                                 break;
 494
 495                         nv = ov > diff ? ov - diff : 0;
 496                         rc = atomic_long_cmpxchg(&cache->ccc_lru_left, ov, nv);
 497                         if (likely(ov == rc)) {
 498                                 diff -= ov - nv;
 499                                 nrpages += ov - nv;
 500                                 break;
 501                         }
 502                 } while (1);
 503
 504                 if (diff <= 0)
 505                         break;
 506
 507                 if (sbi->ll_dt_exp == NULL) { /* being initialized */
 508                         rc = -ENODEV;
 509                         break;
 510                 }
 511
 512                 /* difficult - have to ask OSCs to drop LRU slots. */
 513                 tmp = diff << 1;
 514                 rc = obd_set_info_async(env, sbi->ll_dt_exp,
 515                                 sizeof(KEY_CACHE_LRU_SHRINK),
 516                                 KEY_CACHE_LRU_SHRINK,
 517                                 sizeof(tmp), &tmp, NULL);
 518                 if (rc < 0)
 519                         break;
 520         }
 521         cl_env_put(env, &refcheck);
 522
 523 out:
 524         if (rc >= 0) {
 525                 spin_lock(&sbi->ll_lock);
 526                 cache->ccc_lru_max = pages_number;
 527                 spin_unlock(&sbi->ll_lock);
 528                 rc = count;
 529         } else {
 530                 atomic_long_add(nrpages, &cache->ccc_lru_left);
 531         }
 532         return rc;
 533 }
 534 LPROC_SEQ_FOPS(ll_max_cached_mb);
 535
 536 static int ll_checksum_seq_show(struct seq_file *m, void *v)
 537 {
 538         struct super_block *sb = m->private;
 539         struct ll_sb_info *sbi = ll_s2sbi(sb);
 540
 541         return seq_printf(m, "%u\n", (sbi->ll_flags & LL_SBI_CHECKSUM) ? 1 : 0);
 542 }
 543
 544 static ssize_t ll_checksum_seq_write(struct file *file,
 545                                      const char __user *buffer,
 546                                      size_t count, loff_t *off)
 547 {
 548         struct seq_file *m = file->private_data;
 549         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 550         int val, rc;
 551
 552         if (!sbi->ll_dt_exp)
 553                 /* Not set up yet */
 554                 return -EAGAIN;
 555
 556         rc = lprocfs_write_helper(buffer, count, &val);
 557         if (rc)
 558                 return rc;
 559         if (val)
 560                 sbi->ll_flags |= LL_SBI_CHECKSUM;
 561         else
 562                 sbi->ll_flags &= ~LL_SBI_CHECKSUM;
 563
 564         rc = obd_set_info_async(NULL, sbi->ll_dt_exp, sizeof(KEY_CHECKSUM),
 565                                 KEY_CHECKSUM, sizeof(val), &val, NULL);
 566         if (rc)
 567                 CWARN("Failed to set OSC checksum flags: %d\n", rc);
 568
 569         return count;
 570 }
 571 LPROC_SEQ_FOPS(ll_checksum);
 572
 573 static int ll_max_rw_chunk_seq_show(struct seq_file *m, void *v)
 574 {
 575         struct super_block *sb = m->private;
 576
 577         return seq_printf(m, "%lu\n", ll_s2sbi(sb)->ll_max_rw_chunk);
 578 }
 579
 580 static ssize_t ll_max_rw_chunk_seq_write(struct file *file,
 581                                          const char __user *buffer,
 582                                          size_t count, loff_t *off)
 583 {
 584         struct seq_file *m = file->private_data;
 585         struct super_block *sb = m->private;
 586         int rc, val;
 587
 588         rc = lprocfs_write_helper(buffer, count, &val);
 589         if (rc)
 590                 return rc;
 591         ll_s2sbi(sb)->ll_max_rw_chunk = val;
 592         return count;
 593 }
 594 LPROC_SEQ_FOPS(ll_max_rw_chunk);
 595
 596 static int ll_rd_track_id(struct seq_file *m, enum stats_track_type type)
 597 {
 598         struct super_block *sb = m->private;
 599
 600         if (ll_s2sbi(sb)->ll_stats_track_type == type) {
 601                 return seq_printf(m, "%d\n",
 602                                   ll_s2sbi(sb)->ll_stats_track_id);
 603         } else if (ll_s2sbi(sb)->ll_stats_track_type == STATS_TRACK_ALL) {
 604                 return seq_printf(m, "0 (all)\n");
 605         } else {
 606                 return seq_printf(m, "untracked\n");
 607         }
 608 }
 609
 610 static int ll_wr_track_id(const char __user *buffer, unsigned long count,
 611                           void *data, enum stats_track_type type)
 612 {
 613         struct super_block *sb = data;
 614         int rc, pid;
 615
 616         rc = lprocfs_write_helper(buffer, count, &pid);
 617         if (rc)
 618                 return rc;
 619         ll_s2sbi(sb)->ll_stats_track_id = pid;
 620         if (pid == 0)
 621                 ll_s2sbi(sb)->ll_stats_track_type = STATS_TRACK_ALL;
 622         else
 623                 ll_s2sbi(sb)->ll_stats_track_type = type;
 624         lprocfs_clear_stats(ll_s2sbi(sb)->ll_stats);
 625         return count;
 626 }
 627
 628 static int ll_track_pid_seq_show(struct seq_file *m, void *v)
 629 {
 630         return ll_rd_track_id(m, STATS_TRACK_PID);
 631 }
 632
 633 static ssize_t ll_track_pid_seq_write(struct file *file,
 634                                       const char __user *buffer,
 635                                       size_t count, loff_t *off)
 636 {
 637         struct seq_file *seq = file->private_data;
 638         return ll_wr_track_id(buffer, count, seq->private, STATS_TRACK_PID);
 639 }
 640 LPROC_SEQ_FOPS(ll_track_pid);
 641
 642 static int ll_track_ppid_seq_show(struct seq_file *m, void *v)
 643 {
 644         return ll_rd_track_id(m, STATS_TRACK_PPID);
 645 }
 646
 647 static ssize_t ll_track_ppid_seq_write(struct file *file,
 648                                        const char __user *buffer,
 649                                        size_t count, loff_t *off)
 650 {
 651         struct seq_file *seq = file->private_data;
 652         return ll_wr_track_id(buffer, count, seq->private, STATS_TRACK_PPID);
 653 }
 654 LPROC_SEQ_FOPS(ll_track_ppid);
 655
 656 static int ll_track_gid_seq_show(struct seq_file *m, void *v)
 657 {
 658         return ll_rd_track_id(m, STATS_TRACK_GID);
 659 }
 660
 661 static ssize_t ll_track_gid_seq_write(struct file *file,
 662                                       const char __user *buffer,
 663                                       size_t count, loff_t *off)
 664 {
 665         struct seq_file *seq = file->private_data;
 666         return ll_wr_track_id(buffer, count, seq->private, STATS_TRACK_GID);
 667 }
 668 LPROC_SEQ_FOPS(ll_track_gid);
 669
 670 static int ll_statahead_max_seq_show(struct seq_file *m, void *v)
 671 {
 672         struct super_block *sb = m->private;
 673         struct ll_sb_info *sbi = ll_s2sbi(sb);
 674
 675         return seq_printf(m, "%u\n", sbi->ll_sa_max);
 676 }
 677
 678 static ssize_t ll_statahead_max_seq_write(struct file *file,
 679                                           const char __user *buffer,
 680                                           size_t count, loff_t *off)
 681 {
 682         struct seq_file *m = file->private_data;
 683         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 684         int val, rc;
 685
 686         rc = lprocfs_write_helper(buffer, count, &val);
 687         if (rc)
 688                 return rc;
 689
 690         if (val >= 0 && val <= LL_SA_RPC_MAX)
 691                 sbi->ll_sa_max = val;
 692         else
 693                 CERROR("Bad statahead_max value %d. Valid values are in the "
 694                        "range [0, %d]\n", val, LL_SA_RPC_MAX);
 695
 696         return count;
 697 }
 698 LPROC_SEQ_FOPS(ll_statahead_max);
 699
 700 static int ll_statahead_agl_seq_show(struct seq_file *m, void *v)
 701 {
 702         struct super_block *sb = m->private;
 703         struct ll_sb_info *sbi = ll_s2sbi(sb);
 704
 705         return seq_printf(m, "%u\n",
 706                           sbi->ll_flags & LL_SBI_AGL_ENABLED ? 1 : 0);
 707 }
 708
 709 static ssize_t ll_statahead_agl_seq_write(struct file *file,
 710                                           const char __user *buffer,
 711                                           size_t count, loff_t *off)
 712 {
 713         struct seq_file *m = file->private_data;
 714         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 715         int val, rc;
 716
 717         rc = lprocfs_write_helper(buffer, count, &val);
 718         if (rc)
 719                 return rc;
 720
 721         if (val)
 722                 sbi->ll_flags |= LL_SBI_AGL_ENABLED;
 723         else
 724                 sbi->ll_flags &= ~LL_SBI_AGL_ENABLED;
 725
 726         return count;
 727 }
 728 LPROC_SEQ_FOPS(ll_statahead_agl);
 729
 730 static int ll_statahead_stats_seq_show(struct seq_file *m, void *v)
 731 {
 732         struct super_block *sb = m->private;
 733         struct ll_sb_info *sbi = ll_s2sbi(sb);
 734
 735         return seq_printf(m,
 736                         "statahead total: %u\n"
 737                         "statahead wrong: %u\n"
 738                         "agl total: %u\n",
 739                         atomic_read(&sbi->ll_sa_total),
 740                         atomic_read(&sbi->ll_sa_wrong),
 741                         atomic_read(&sbi->ll_agl_total));
 742 }
 743 LPROC_SEQ_FOPS_RO(ll_statahead_stats);
 744
 745 static int ll_lazystatfs_seq_show(struct seq_file *m, void *v)
 746 {
 747         struct super_block *sb = m->private;
 748         struct ll_sb_info *sbi = ll_s2sbi(sb);
 749
 750         return seq_printf(m, "%u\n",
 751                           (sbi->ll_flags & LL_SBI_LAZYSTATFS) ? 1 : 0);
 752 }
 753
 754 static ssize_t ll_lazystatfs_seq_write(struct file *file,
 755                                        const char __user *buffer,
 756                                         size_t count, loff_t *off)
 757 {
 758         struct seq_file *m = file->private_data;
 759         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)m->private);
 760         int val, rc;
 761
 762         rc = lprocfs_write_helper(buffer, count, &val);
 763         if (rc)
 764                 return rc;
 765
 766         if (val)
 767                 sbi->ll_flags |= LL_SBI_LAZYSTATFS;
 768         else
 769                 sbi->ll_flags &= ~LL_SBI_LAZYSTATFS;
 770
 771         return count;
 772 }
 773 LPROC_SEQ_FOPS(ll_lazystatfs);
 774
 775 static int ll_max_easize_seq_show(struct seq_file *m, void *v)
 776 {
 777         struct super_block *sb = m->private;
 778         struct ll_sb_info *sbi = ll_s2sbi(sb);
 779         unsigned int ealen;
 780         int rc;
 781
 782         rc = ll_get_max_mdsize(sbi, &ealen);
 783         if (rc)
 784                 return rc;
 785
 786         return seq_printf(m, "%u\n", ealen);
 787 }
 788 LPROC_SEQ_FOPS_RO(ll_max_easize);
 789
 790 /**
 791  * Get default_easize.
 792  *
 793  * \see client_obd::cl_default_mds_easize
 794  *
 795  * \param[in] m         seq_file handle
 796  * \param[in] v         unused for single entry
 797  *
 798  * \retval 0            on success
 799  * \retval negative     negated errno on failure
 800  */
 801 static int ll_default_easize_seq_show(struct seq_file *m, void *v)
 802 {
 803         struct super_block *sb = m->private;
 804         struct ll_sb_info *sbi = ll_s2sbi(sb);
 805         unsigned int ealen;
 806         int rc;
 807
 808         rc = ll_get_default_mdsize(sbi, &ealen);
 809         if (rc)
 810                 return rc;
 811
 812         return seq_printf(m, "%u\n", ealen);
 813 }
 814
 815 /**
 816  * Set default_easize.
 817  *
 818  * Range checking on the passed value is handled by
 819  * ll_set_default_mdsize().
 820  *
 821  * \see client_obd::cl_default_mds_easize
 822  *
 823  * \param[in] file      proc file
 824  * \param[in] buffer    string passed from user space
 825  * \param[in] count     \a buffer length
 826  * \param[in] off       unused for single entry
 827  *
 828  * \retval positive     \a count on success
 829  * \retval negative     negated errno on failure
 830  */
 831 static ssize_t ll_default_easize_seq_write(struct file *file,
 832                                            const char __user *buffer,
 833                                            size_t count, loff_t *unused)
 834 {
 835         struct seq_file         *seq = file->private_data;
 836         struct super_block      *sb = (struct super_block *)seq->private;
 837         struct ll_sb_info       *sbi = ll_s2sbi(sb);
 838         int                      val;
 839         int                      rc;
 840
 841         if (count == 0)
 842                 return 0;
 843
 844         rc = lprocfs_write_helper(buffer, count, &val);
 845         if (rc < 0)
 846                 return rc;
 847
 848         rc = ll_set_default_mdsize(sbi, val);
 849         if (rc)
 850                 return rc;
 851
 852         return count;
 853 }
 854 LPROC_SEQ_FOPS(ll_default_easize);
 855
 856 static int ll_sbi_flags_seq_show(struct seq_file *m, void *v)
 857 {
 858         const char *str[] = LL_SBI_FLAGS;
 859         struct super_block *sb = m->private;
 860         int flags = ll_s2sbi(sb)->ll_flags;
 861         int i = 0;
 862
 863         while (flags != 0) {
 864                 if (ARRAY_SIZE(str) <= i) {
 865                         CERROR("%s: Revise array LL_SBI_FLAGS to match sbi "
 866                                 "flags please.\n", ll_get_fsname(sb, NULL, 0));
 867                         return -EINVAL;
 868                 }
 869
 870                 if (flags & 0x1)
 871                         seq_printf(m, "%s ", str[i]);
 872                 flags >>= 1;
 873                 ++i;
 874         }
 875         seq_printf(m, "\b\n");
 876         return 0;
 877 }
 878 LPROC_SEQ_FOPS_RO(ll_sbi_flags);
 879
 880 static int ll_unstable_stats_seq_show(struct seq_file *m, void *v)
 881 {
 882         struct super_block      *sb    = m->private;
 883         struct ll_sb_info       *sbi   = ll_s2sbi(sb);
 884         struct cl_client_cache  *cache = sbi->ll_cache;
 885         long pages;
 886         int mb;
 887
 888         pages = atomic_long_read(&cache->ccc_unstable_nr);
 889         mb    = (pages * PAGE_CACHE_SIZE) >> 20;
 890
 891         return seq_printf(m, "unstable_check:     %8d\n"
 892                              "unstable_pages: %12ld\n"
 893                              "unstable_mb:        %8d\n",
 894                           cache->ccc_unstable_check, pages, mb);
 895 }
 896
 897 static ssize_t ll_unstable_stats_seq_write(struct file *file,
 898                                            const char __user *buffer,
 899                                            size_t count, loff_t *unused)
 900 {
 901         struct seq_file *seq = file->private_data;
 902         struct ll_sb_info *sbi = ll_s2sbi((struct super_block *)seq->private);
 903         char kernbuf[128];
 904         int val, rc;
 905
 906         if (count == 0)
 907                 return 0;
 908         if (count >= sizeof(kernbuf))
 909                 return -EINVAL;
 910
 911         if (copy_from_user(kernbuf, buffer, count))
 912                 return -EFAULT;
 913         kernbuf[count] = 0;
 914
 915         buffer += lprocfs_find_named_value(kernbuf, "unstable_check:", &count) -
 916                   kernbuf;
 917         rc = lprocfs_write_helper(buffer, count, &val);
 918         if (rc < 0)
 919                 return rc;
 920
 921         /* borrow lru lock to set the value */
 922         spin_lock(&sbi->ll_cache->ccc_lru_lock);
 923         sbi->ll_cache->ccc_unstable_check = !!val;
 924         spin_unlock(&sbi->ll_cache->ccc_lru_lock);
 925
 926         return count;
 927 }
 928 LPROC_SEQ_FOPS(ll_unstable_stats);
 929
 930 static int ll_root_squash_seq_show(struct seq_file *m, void *v)
 931 {
 932         struct super_block *sb = m->private;
 933         struct ll_sb_info *sbi = ll_s2sbi(sb);
 934         struct root_squash_info *squash = &sbi->ll_squash;
 935
 936         return seq_printf(m, "%u:%u\n", squash->rsi_uid, squash->rsi_gid);
 937 }
 938
 939 static ssize_t ll_root_squash_seq_write(struct file *file,
 940                                         const char __user *buffer,
 941                                         size_t count, loff_t *off)
 942 {
 943         struct seq_file *m = file->private_data;
 944         struct super_block *sb = m->private;
 945         struct ll_sb_info *sbi = ll_s2sbi(sb);
 946         struct root_squash_info *squash = &sbi->ll_squash;
 947
 948         return lprocfs_wr_root_squash(buffer, count, squash,
 949                                       ll_get_fsname(sb, NULL, 0));
 950 }
 951 LPROC_SEQ_FOPS(ll_root_squash);
 952
 953 static int ll_nosquash_nids_seq_show(struct seq_file *m, void *v)
 954 {
 955         struct super_block *sb = m->private;
 956         struct ll_sb_info *sbi = ll_s2sbi(sb);
 957         struct root_squash_info *squash = &sbi->ll_squash;
 958         int len, rc;
 959
 960         down_read(&squash->rsi_sem);
 961         if (!list_empty(&squash->rsi_nosquash_nids)) {
 962                 len = cfs_print_nidlist(m->buf + m->count, m->size - m->count,
 963                                         &squash->rsi_nosquash_nids);
 964                 m->count += len;
 965                 rc = seq_printf(m, "\n");
 966         } else {
 967                 rc = seq_printf(m, "NONE\n");
 968         }
 969         up_read(&squash->rsi_sem);
 970
 971         return rc;
 972 }
 973
 974 static ssize_t ll_nosquash_nids_seq_write(struct file *file,
 975                                           const char __user *buffer,
 976                                           size_t count, loff_t *off)
 977 {
 978         struct seq_file *m = file->private_data;
 979         struct super_block *sb = m->private;
 980         struct ll_sb_info *sbi = ll_s2sbi(sb);
 981         struct root_squash_info *squash = &sbi->ll_squash;
 982         int rc;
 983
 984         rc = lprocfs_wr_nosquash_nids(buffer, count, squash,
 985                                       ll_get_fsname(sb, NULL, 0));
 986         if (rc < 0)
 987                 return rc;
 988
 989         ll_compute_rootsquash_state(sbi);
 990
 991         return rc;
 992 }
 993 LPROC_SEQ_FOPS(ll_nosquash_nids);
 994
 995 struct lprocfs_vars lprocfs_llite_obd_vars[] = {
 996         { .name =       "uuid",
 997           .fops =       &ll_sb_uuid_fops                        },
 998         { .name =       "fstype",
 999           .fops =       &ll_fstype_fops                         },
1000         { .name =       "site",
1001           .fops =       &ll_site_stats_fops                     },
1002         { .name =       "blocksize",
1003           .fops =       &ll_blksize_fops                        },
1004         { .name =       "kbytestotal",
1005           .fops =       &ll_kbytestotal_fops                    },
1006         { .name =       "kbytesfree",
1007           .fops =       &ll_kbytesfree_fops                     },
1008         { .name =       "kbytesavail",
1009           .fops =       &ll_kbytesavail_fops                    },
1010         { .name =       "filestotal",
1011           .fops =       &ll_filestotal_fops                     },
1012         { .name =       "filesfree",
1013           .fops =       &ll_filesfree_fops                      },
1014         { .name =       "client_type",
1015           .fops =       &ll_client_type_fops                    },
1016         { .name =       "max_read_ahead_mb",
1017           .fops =       &ll_max_readahead_mb_fops               },
1018         { .name =       "max_read_ahead_per_file_mb",
1019           .fops =       &ll_max_readahead_per_file_mb_fops      },
1020         { .name =       "max_read_ahead_whole_mb",
1021           .fops =       &ll_max_read_ahead_whole_mb_fops        },
1022         { .name =       "max_cached_mb",
1023           .fops =       &ll_max_cached_mb_fops                  },
1024         { .name =       "checksum_pages",
1025           .fops =       &ll_checksum_fops                       },
1026         { .name =       "max_rw_chunk",
1027           .fops =       &ll_max_rw_chunk_fops                   },
1028         { .name =       "stats_track_pid",
1029           .fops =       &ll_track_pid_fops                      },
1030         { .name =       "stats_track_ppid",
1031           .fops =       &ll_track_ppid_fops                     },
1032         { .name =       "stats_track_gid",
1033           .fops =       &ll_track_gid_fops                      },
1034         { .name =       "statahead_max",
1035           .fops =       &ll_statahead_max_fops                  },
1036         { .name =       "statahead_agl",
1037           .fops =       &ll_statahead_agl_fops                  },
1038         { .name =       "statahead_stats",
1039           .fops =       &ll_statahead_stats_fops                },
1040         { .name =       "lazystatfs",
1041           .fops =       &ll_lazystatfs_fops                     },
1042         { .name =       "max_easize",
1043           .fops =       &ll_max_easize_fops                     },
1044         { .name =       "default_easize",
1045           .fops =       &ll_default_easize_fops                 },
1046         { .name =       "sbi_flags",
1047           .fops =       &ll_sbi_flags_fops                      },
1048         { .name =       "xattr_cache",
1049           .fops =       &ll_xattr_cache_fops                    },
1050         { .name =       "unstable_stats",
1051           .fops =       &ll_unstable_stats_fops                 },
1052         { .name =       "root_squash",
1053           .fops =       &ll_root_squash_fops                    },
1054         { .name =       "nosquash_nids",
1055           .fops =       &ll_nosquash_nids_fops                  },
1056         { NULL }
1057 };
1058
1059 #define MAX_STRING_SIZE 128
1060
1061 static const struct llite_file_opcode {
1062         __u32       opcode;
1063         __u32       type;
1064         const char *opname;
1065 } llite_opcode_table[LPROC_LL_FILE_OPCODES] = {
1066         /* file operation */
1067         { LPROC_LL_DIRTY_HITS,     LPROCFS_TYPE_REGS, "dirty_pages_hits" },
1068         { LPROC_LL_DIRTY_MISSES,   LPROCFS_TYPE_REGS, "dirty_pages_misses" },
1069         { LPROC_LL_READ_BYTES,     LPROCFS_CNTR_AVGMINMAX|LPROCFS_TYPE_BYTES,
1070                                    "read_bytes" },
1071         { LPROC_LL_WRITE_BYTES,    LPROCFS_CNTR_AVGMINMAX|LPROCFS_TYPE_BYTES,
1072                                    "write_bytes" },
1073         { LPROC_LL_BRW_READ,       LPROCFS_CNTR_AVGMINMAX|LPROCFS_TYPE_PAGES,
1074                                    "brw_read" },
1075         { LPROC_LL_BRW_WRITE,      LPROCFS_CNTR_AVGMINMAX|LPROCFS_TYPE_PAGES,
1076                                    "brw_write" },
1077         { LPROC_LL_OSC_READ,       LPROCFS_CNTR_AVGMINMAX|LPROCFS_TYPE_BYTES,
1078                                    "osc_read" },
1079         { LPROC_LL_OSC_WRITE,      LPROCFS_CNTR_AVGMINMAX|LPROCFS_TYPE_BYTES,
1080                                    "osc_write" },
1081         { LPROC_LL_IOCTL,          LPROCFS_TYPE_REGS, "ioctl" },
1082         { LPROC_LL_OPEN,           LPROCFS_TYPE_REGS, "open" },
1083         { LPROC_LL_RELEASE,        LPROCFS_TYPE_REGS, "close" },
1084         { LPROC_LL_MAP,            LPROCFS_TYPE_REGS, "mmap" },
1085         { LPROC_LL_LLSEEK,         LPROCFS_TYPE_REGS, "seek" },
1086         { LPROC_LL_FSYNC,          LPROCFS_TYPE_REGS, "fsync" },
1087         { LPROC_LL_READDIR,        LPROCFS_TYPE_REGS, "readdir" },
1088         /* inode operation */
1089         { LPROC_LL_SETATTR,        LPROCFS_TYPE_REGS, "setattr" },
1090         { LPROC_LL_TRUNC,          LPROCFS_TYPE_REGS, "truncate" },
1091         { LPROC_LL_FLOCK,          LPROCFS_TYPE_REGS, "flock" },
1092         { LPROC_LL_GETATTR,        LPROCFS_TYPE_REGS, "getattr" },
1093         /* dir inode operation */
1094         { LPROC_LL_CREATE,         LPROCFS_TYPE_REGS, "create" },
1095         { LPROC_LL_LINK,           LPROCFS_TYPE_REGS, "link" },
1096         { LPROC_LL_UNLINK,         LPROCFS_TYPE_REGS, "unlink" },
1097         { LPROC_LL_SYMLINK,        LPROCFS_TYPE_REGS, "symlink" },
1098         { LPROC_LL_MKDIR,          LPROCFS_TYPE_REGS, "mkdir" },
1099         { LPROC_LL_RMDIR,          LPROCFS_TYPE_REGS, "rmdir" },
1100         { LPROC_LL_MKNOD,          LPROCFS_TYPE_REGS, "mknod" },
1101         { LPROC_LL_RENAME,         LPROCFS_TYPE_REGS, "rename" },
1102         /* special inode operation */
1103         { LPROC_LL_STAFS,          LPROCFS_TYPE_REGS, "statfs" },
1104         { LPROC_LL_ALLOC_INODE,    LPROCFS_TYPE_REGS, "alloc_inode" },
1105         { LPROC_LL_SETXATTR,       LPROCFS_TYPE_REGS, "setxattr" },
1106         { LPROC_LL_GETXATTR,       LPROCFS_TYPE_REGS, "getxattr" },
1107         { LPROC_LL_GETXATTR_HITS,  LPROCFS_TYPE_REGS, "getxattr_hits" },
1108         { LPROC_LL_LISTXATTR,      LPROCFS_TYPE_REGS, "listxattr" },
1109         { LPROC_LL_REMOVEXATTR,    LPROCFS_TYPE_REGS, "removexattr" },
1110         { LPROC_LL_INODE_PERM,     LPROCFS_TYPE_REGS, "inode_permission" },
1111 };
1112
1113 void ll_stats_ops_tally(struct ll_sb_info *sbi, int op, int count)
1114 {
1115         if (!sbi->ll_stats)
1116                 return;
1117         if (sbi->ll_stats_track_type == STATS_TRACK_ALL)
1118                 lprocfs_counter_add(sbi->ll_stats, op, count);
1119         else if (sbi->ll_stats_track_type == STATS_TRACK_PID &&
1120                  sbi->ll_stats_track_id == current->pid)
1121                 lprocfs_counter_add(sbi->ll_stats, op, count);
1122         else if (sbi->ll_stats_track_type == STATS_TRACK_PPID &&
1123                  sbi->ll_stats_track_id == current->parent->pid)
1124                 lprocfs_counter_add(sbi->ll_stats, op, count);
1125         else if (sbi->ll_stats_track_type == STATS_TRACK_GID &&
1126                  sbi->ll_stats_track_id ==
1127                         from_kgid(&init_user_ns, current_gid()))
1128                 lprocfs_counter_add(sbi->ll_stats, op, count);
1129 }
1130 EXPORT_SYMBOL(ll_stats_ops_tally);
1131
1132 static const char *ra_stat_string[] = {
1133         [RA_STAT_HIT] = "hits",
1134         [RA_STAT_MISS] = "misses",
1135         [RA_STAT_DISTANT_READPAGE] = "readpage not consecutive",
1136         [RA_STAT_MISS_IN_WINDOW] = "miss inside window",
1137         [RA_STAT_FAILED_GRAB_PAGE] = "failed grab_cache_page",
1138         [RA_STAT_FAILED_MATCH] = "failed lock match",
1139         [RA_STAT_DISCARDED] = "read but discarded",
1140         [RA_STAT_ZERO_LEN] = "zero length file",
1141         [RA_STAT_ZERO_WINDOW] = "zero size window",
1142         [RA_STAT_EOF] = "read-ahead to EOF",
1143         [RA_STAT_MAX_IN_FLIGHT] = "hit max r-a issue",
1144         [RA_STAT_WRONG_GRAB_PAGE] = "wrong page from grab_cache_page",
1145         [RA_STAT_FAILED_REACH_END] = "failed to reach end"
1146 };
1147
1148 LPROC_SEQ_FOPS_RO_TYPE(llite, name);
1149 LPROC_SEQ_FOPS_RO_TYPE(llite, uuid);
1150
1151 int lprocfs_register_mountpoint(struct proc_dir_entry *parent,
1152                                 struct super_block *sb, char *osc, char *mdc)
1153 {
1154         struct lprocfs_vars lvars[2];
1155         struct lustre_sb_info *lsi = s2lsi(sb);
1156         struct ll_sb_info *sbi = ll_s2sbi(sb);
1157         struct obd_device *obd;
1158         struct proc_dir_entry *dir;
1159         char name[MAX_STRING_SIZE + 1], *ptr;
1160         int err, id, len, rc;
1161         ENTRY;
1162
1163         memset(lvars, 0, sizeof(lvars));
1164
1165         name[MAX_STRING_SIZE] = '\0';
1166         lvars[0].name = name;
1167
1168         LASSERT(sbi != NULL);
1169         LASSERT(mdc != NULL);
1170         LASSERT(osc != NULL);
1171
1172         /* Get fsname */
1173         len = strlen(lsi->lsi_lmd->lmd_profile);
1174         ptr = strrchr(lsi->lsi_lmd->lmd_profile, '-');
1175         if (ptr && (strcmp(ptr, "-client") == 0))
1176                 len -= 7;
1177
1178         /* Mount info */
1179         snprintf(name, MAX_STRING_SIZE, "%.*s-%p", len,
1180                  lsi->lsi_lmd->lmd_profile, sb);
1181
1182         sbi->ll_proc_root = lprocfs_register(name, parent, NULL, NULL);
1183         if (IS_ERR(sbi->ll_proc_root)) {
1184                 err = PTR_ERR(sbi->ll_proc_root);
1185                 sbi->ll_proc_root = NULL;
1186                 RETURN(err);
1187         }
1188
1189         rc = lprocfs_seq_create(sbi->ll_proc_root, "dump_page_cache", 0444,
1190                                 &vvp_dump_pgcache_file_ops, sbi);
1191         if (rc)
1192                 CWARN("Error adding the dump_page_cache file\n");
1193
1194         rc = lprocfs_seq_create(sbi->ll_proc_root, "extents_stats", 0644,
1195                                 &ll_rw_extents_stats_fops, sbi);
1196         if (rc)
1197                 CWARN("Error adding the extent_stats file\n");
1198
1199         rc = lprocfs_seq_create(sbi->ll_proc_root, "extents_stats_per_process",
1200                                 0644, &ll_rw_extents_stats_pp_fops, sbi);
1201         if (rc)
1202                 CWARN("Error adding the extents_stats_per_process file\n");
1203
1204         rc = lprocfs_seq_create(sbi->ll_proc_root, "offset_stats", 0644,
1205                                 &ll_rw_offset_stats_fops, sbi);
1206         if (rc)
1207                 CWARN("Error adding the offset_stats file\n");
1208
1209         /* File operations stats */
1210         sbi->ll_stats = lprocfs_alloc_stats(LPROC_LL_FILE_OPCODES,
1211                                             LPROCFS_STATS_FLAG_NONE);
1212         if (sbi->ll_stats == NULL)
1213                 GOTO(out, err = -ENOMEM);
1214         /* do counter init */
1215         for (id = 0; id < LPROC_LL_FILE_OPCODES; id++) {
1216                 __u32 type = llite_opcode_table[id].type;
1217                 void *ptr = NULL;
1218                 if (type & LPROCFS_TYPE_REGS)
1219                         ptr = "regs";
1220                 else if (type & LPROCFS_TYPE_BYTES)
1221                         ptr = "bytes";
1222                 else if (type & LPROCFS_TYPE_PAGES)
1223                         ptr = "pages";
1224                 lprocfs_counter_init(sbi->ll_stats,
1225                                      llite_opcode_table[id].opcode,
1226                                      (type & LPROCFS_CNTR_AVGMINMAX),
1227                                      llite_opcode_table[id].opname, ptr);
1228         }
1229         err = lprocfs_register_stats(sbi->ll_proc_root, "stats", sbi->ll_stats);
1230         if (err)
1231                 GOTO(out, err);
1232
1233         sbi->ll_ra_stats = lprocfs_alloc_stats(ARRAY_SIZE(ra_stat_string),
1234                                                LPROCFS_STATS_FLAG_NONE);
1235         if (sbi->ll_ra_stats == NULL)
1236                 GOTO(out, err = -ENOMEM);
1237
1238         for (id = 0; id < ARRAY_SIZE(ra_stat_string); id++)
1239                 lprocfs_counter_init(sbi->ll_ra_stats, id, 0,
1240                                      ra_stat_string[id], "pages");
1241         err = lprocfs_register_stats(sbi->ll_proc_root, "read_ahead_stats",
1242                                      sbi->ll_ra_stats);
1243         if (err)
1244                 GOTO(out, err);
1245
1246
1247         err = lprocfs_add_vars(sbi->ll_proc_root, lprocfs_llite_obd_vars, sb);
1248         if (err)
1249                 GOTO(out, err);
1250
1251         /* MDC info */
1252         obd = class_name2obd(mdc);
1253
1254         LASSERT(obd != NULL);
1255         LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);
1256         LASSERT(obd->obd_type->typ_name != NULL);
1257
1258         dir = proc_mkdir(obd->obd_type->typ_name, sbi->ll_proc_root);
1259         if (dir == NULL)
1260                 GOTO(out, err = -ENOMEM);
1261
1262         snprintf(name, MAX_STRING_SIZE, "common_name");
1263         lvars[0].fops = &llite_name_fops;
1264         err = lprocfs_add_vars(dir, lvars, obd);
1265         if (err)
1266                 GOTO(out, err);
1267
1268         snprintf(name, MAX_STRING_SIZE, "uuid");
1269         lvars[0].fops = &llite_uuid_fops;
1270         err = lprocfs_add_vars(dir, lvars, obd);
1271         if (err)
1272                 GOTO(out, err);
1273
1274         /* OSC */
1275         obd = class_name2obd(osc);
1276
1277         LASSERT(obd != NULL);
1278         LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);
1279         LASSERT(obd->obd_type->typ_name != NULL);
1280
1281         dir = proc_mkdir(obd->obd_type->typ_name, sbi->ll_proc_root);
1282         if (dir == NULL)
1283                 GOTO(out, err = -ENOMEM);
1284
1285         snprintf(name, MAX_STRING_SIZE, "common_name");
1286         lvars[0].fops = &llite_name_fops;
1287         err = lprocfs_add_vars(dir, lvars, obd);
1288         if (err)
1289                 GOTO(out, err);
1290
1291         snprintf(name, MAX_STRING_SIZE, "uuid");
1292         lvars[0].fops = &llite_uuid_fops;
1293         err = lprocfs_add_vars(dir, lvars, obd);
1294 out:
1295         if (err) {
1296                 lprocfs_remove(&sbi->ll_proc_root);
1297                 lprocfs_free_stats(&sbi->ll_ra_stats);
1298                 lprocfs_free_stats(&sbi->ll_stats);
1299         }
1300         RETURN(err);
1301 }
1302
1303 void lprocfs_unregister_mountpoint(struct ll_sb_info *sbi)
1304 {
1305         if (sbi->ll_proc_root) {
1306                 lprocfs_remove(&sbi->ll_proc_root);
1307                 lprocfs_free_stats(&sbi->ll_ra_stats);
1308                 lprocfs_free_stats(&sbi->ll_stats);
1309         }
1310 }
1311 #undef MAX_STRING_SIZE
1312
1313 #define pct(a,b) (b ? a * 100 / b : 0)
1314
1315 static void ll_display_extents_info(struct ll_rw_extents_info *io_extents,
1316                                    struct seq_file *seq, int which)
1317 {
1318         unsigned long read_tot = 0, write_tot = 0, read_cum, write_cum;
1319         unsigned long start, end, r, w;
1320         char *unitp = "KMGTPEZY";
1321         int i, units = 10;
1322         struct per_process_info *pp_info = &io_extents->pp_extents[which];
1323
1324         read_cum = 0;
1325         write_cum = 0;
1326         start = 0;
1327
1328         for(i = 0; i < LL_HIST_MAX; i++) {
1329                 read_tot += pp_info->pp_r_hist.oh_buckets[i];
1330                 write_tot += pp_info->pp_w_hist.oh_buckets[i];
1331         }
1332
1333         for(i = 0; i < LL_HIST_MAX; i++) {
1334                 r = pp_info->pp_r_hist.oh_buckets[i];
1335                 w = pp_info->pp_w_hist.oh_buckets[i];
1336                 read_cum += r;
1337                 write_cum += w;
1338                 end = 1 << (i + LL_HIST_START - units);
1339                 seq_printf(seq, "%4lu%c - %4lu%c%c: %14lu %4lu %4lu  | "
1340                            "%14lu %4lu %4lu\n", start, *unitp, end, *unitp,
1341                            (i == LL_HIST_MAX - 1) ? '+' : ' ',
1342                            r, pct(r, read_tot), pct(read_cum, read_tot),
1343                            w, pct(w, write_tot), pct(write_cum, write_tot));
1344                 start = end;
1345                 if (start == 1<<10) {
1346                         start = 1;
1347                         units += 10;
1348                         unitp++;
1349                 }
1350                 if (read_cum == read_tot && write_cum == write_tot)
1351                         break;
1352         }
1353 }
1354
1355 static int ll_rw_extents_stats_pp_seq_show(struct seq_file *seq, void *v)
1356 {
1357         struct timeval now;
1358         struct ll_sb_info *sbi = seq->private;
1359         struct ll_rw_extents_info *io_extents = &sbi->ll_rw_extents_info;
1360         int k;
1361
1362         do_gettimeofday(&now);
1363
1364         if (!sbi->ll_rw_stats_on) {
1365                 seq_printf(seq, "disabled\n"
1366                                 "write anything in this file to activate, "
1367                                 "then 0 or \"[D/d]isabled\" to deactivate\n");
1368                 return 0;
1369         }
1370         seq_printf(seq, "snapshot_time:         %lu.%lu (secs.usecs)\n",
1371                    now.tv_sec, now.tv_usec);
1372         seq_printf(seq, "%15s %19s       | %20s\n", " ", "read", "write");
1373         seq_printf(seq, "%13s   %14s %4s %4s  | %14s %4s %4s\n",
1374                    "extents", "calls", "%", "cum%",
1375                    "calls", "%", "cum%");
1376         spin_lock(&sbi->ll_pp_extent_lock);
1377         for (k = 0; k < LL_PROCESS_HIST_MAX; k++) {
1378                 if (io_extents->pp_extents[k].pid != 0) {
1379                         seq_printf(seq, "\nPID: %d\n",
1380                                    io_extents->pp_extents[k].pid);
1381                         ll_display_extents_info(io_extents, seq, k);
1382                 }
1383         }
1384         spin_unlock(&sbi->ll_pp_extent_lock);
1385         return 0;
1386 }
1387
1388 static ssize_t ll_rw_extents_stats_pp_seq_write(struct file *file,
1389                                                 const char __user *buf,
1390                                                 size_t len,
1391                                                 loff_t *off)
1392 {
1393         struct seq_file *seq = file->private_data;
1394         struct ll_sb_info *sbi = seq->private;
1395         struct ll_rw_extents_info *io_extents = &sbi->ll_rw_extents_info;
1396         int i;
1397         int value = 1, rc = 0;
1398
1399         if (len == 0)
1400                 return -EINVAL;
1401
1402         rc = lprocfs_write_helper(buf, len, &value);
1403         if (rc < 0 && len < 16) {
1404                 char kernbuf[16];
1405
1406                 if (copy_from_user(kernbuf, buf, len))
1407                         return -EFAULT;
1408                 kernbuf[len] = 0;
1409
1410                 if (kernbuf[len - 1] == '\n')
1411                         kernbuf[len - 1] = 0;
1412
1413                 if (strcmp(kernbuf, "disabled") == 0 ||
1414                     strcmp(kernbuf, "Disabled") == 0)
1415                         value = 0;
1416         }
1417
1418         if (value == 0)
1419                 sbi->ll_rw_stats_on = 0;
1420         else
1421                 sbi->ll_rw_stats_on = 1;
1422
1423         spin_lock(&sbi->ll_pp_extent_lock);
1424         for (i = 0; i < LL_PROCESS_HIST_MAX; i++) {
1425                 io_extents->pp_extents[i].pid = 0;
1426                 lprocfs_oh_clear(&io_extents->pp_extents[i].pp_r_hist);
1427                 lprocfs_oh_clear(&io_extents->pp_extents[i].pp_w_hist);
1428         }
1429         spin_unlock(&sbi->ll_pp_extent_lock);
1430         return len;
1431 }
1432
1433 LPROC_SEQ_FOPS(ll_rw_extents_stats_pp);
1434
1435 static int ll_rw_extents_stats_seq_show(struct seq_file *seq, void *v)
1436 {
1437         struct timeval now;
1438         struct ll_sb_info *sbi = seq->private;
1439         struct ll_rw_extents_info *io_extents = &sbi->ll_rw_extents_info;
1440
1441         do_gettimeofday(&now);
1442
1443         if (!sbi->ll_rw_stats_on) {
1444                 seq_printf(seq, "disabled\n"
1445                                 "write anything in this file to activate, "
1446                                 "then 0 or \"[D/d]isabled\" to deactivate\n");
1447                 return 0;
1448         }
1449         seq_printf(seq, "snapshot_time:         %lu.%lu (secs.usecs)\n",
1450                    now.tv_sec, now.tv_usec);
1451
1452         seq_printf(seq, "%15s %19s       | %20s\n", " ", "read", "write");
1453         seq_printf(seq, "%13s   %14s %4s %4s  | %14s %4s %4s\n",
1454                    "extents", "calls", "%", "cum%",
1455                    "calls", "%", "cum%");
1456         spin_lock(&sbi->ll_lock);
1457         ll_display_extents_info(io_extents, seq, LL_PROCESS_HIST_MAX);
1458         spin_unlock(&sbi->ll_lock);
1459
1460         return 0;
1461 }
1462
1463 static ssize_t ll_rw_extents_stats_seq_write(struct file *file,
1464                                              const char __user *buf,
1465                                              size_t len, loff_t *off)
1466 {
1467         struct seq_file *seq = file->private_data;
1468         struct ll_sb_info *sbi = seq->private;
1469         struct ll_rw_extents_info *io_extents = &sbi->ll_rw_extents_info;
1470         int i;
1471         int value = 1, rc = 0;
1472
1473         if (len == 0)
1474                 return -EINVAL;
1475
1476         rc = lprocfs_write_helper(buf, len, &value);
1477         if (rc < 0 && len < 16) {
1478                 char kernbuf[16];
1479
1480                 if (copy_from_user(kernbuf, buf, len))
1481                         return -EFAULT;
1482                 kernbuf[len] = 0;
1483
1484                 if (kernbuf[len - 1] == '\n')
1485                         kernbuf[len - 1] = 0;
1486
1487                 if (strcmp(kernbuf, "disabled") == 0 ||
1488                     strcmp(kernbuf, "Disabled") == 0)
1489                         value = 0;
1490         }
1491
1492         if (value == 0)
1493                 sbi->ll_rw_stats_on = 0;
1494         else
1495                 sbi->ll_rw_stats_on = 1;
1496
1497         spin_lock(&sbi->ll_pp_extent_lock);
1498         for (i = 0; i <= LL_PROCESS_HIST_MAX; i++) {
1499                 io_extents->pp_extents[i].pid = 0;
1500                 lprocfs_oh_clear(&io_extents->pp_extents[i].pp_r_hist);
1501                 lprocfs_oh_clear(&io_extents->pp_extents[i].pp_w_hist);
1502         }
1503         spin_unlock(&sbi->ll_pp_extent_lock);
1504
1505         return len;
1506 }
1507 LPROC_SEQ_FOPS(ll_rw_extents_stats);
1508
1509 void ll_rw_stats_tally(struct ll_sb_info *sbi, pid_t pid,
1510                        struct ll_file_data *file, loff_t pos,
1511                        size_t count, int rw)
1512 {
1513         int i, cur = -1;
1514         struct ll_rw_process_info *process;
1515         struct ll_rw_process_info *offset;
1516         int *off_count = &sbi->ll_rw_offset_entry_count;
1517         int *process_count = &sbi->ll_offset_process_count;
1518         struct ll_rw_extents_info *io_extents = &sbi->ll_rw_extents_info;
1519
1520         if(!sbi->ll_rw_stats_on)
1521                 return;
1522         process = sbi->ll_rw_process_info;
1523         offset = sbi->ll_rw_offset_info;
1524
1525         spin_lock(&sbi->ll_pp_extent_lock);
1526         /* Extent statistics */
1527         for(i = 0; i < LL_PROCESS_HIST_MAX; i++) {
1528                 if(io_extents->pp_extents[i].pid == pid) {
1529                         cur = i;
1530                         break;
1531                 }
1532         }
1533
1534         if (cur == -1) {
1535                 /* new process */
1536                 sbi->ll_extent_process_count =
1537                         (sbi->ll_extent_process_count + 1) % LL_PROCESS_HIST_MAX;
1538                 cur = sbi->ll_extent_process_count;
1539                 io_extents->pp_extents[cur].pid = pid;
1540                 lprocfs_oh_clear(&io_extents->pp_extents[cur].pp_r_hist);
1541                 lprocfs_oh_clear(&io_extents->pp_extents[cur].pp_w_hist);
1542         }
1543
1544         for(i = 0; (count >= (1 << LL_HIST_START << i)) &&
1545              (i < (LL_HIST_MAX - 1)); i++);
1546         if (rw == 0) {
1547                 io_extents->pp_extents[cur].pp_r_hist.oh_buckets[i]++;
1548                 io_extents->pp_extents[LL_PROCESS_HIST_MAX].pp_r_hist.oh_buckets[i]++;
1549         } else {
1550                 io_extents->pp_extents[cur].pp_w_hist.oh_buckets[i]++;
1551                 io_extents->pp_extents[LL_PROCESS_HIST_MAX].pp_w_hist.oh_buckets[i]++;
1552         }
1553         spin_unlock(&sbi->ll_pp_extent_lock);
1554
1555         spin_lock(&sbi->ll_process_lock);
1556         /* Offset statistics */
1557         for (i = 0; i < LL_PROCESS_HIST_MAX; i++) {
1558                 if (process[i].rw_pid == pid) {
1559                         if (process[i].rw_last_file != file) {
1560                                 process[i].rw_range_start = pos;
1561                                 process[i].rw_last_file_pos = pos + count;
1562                                 process[i].rw_smallest_extent = count;
1563                                 process[i].rw_largest_extent = count;
1564                                 process[i].rw_offset = 0;
1565                                 process[i].rw_last_file = file;
1566                                 spin_unlock(&sbi->ll_process_lock);
1567                                 return;
1568                         }
1569                         if (process[i].rw_last_file_pos != pos) {
1570                                 *off_count =
1571                                     (*off_count + 1) % LL_OFFSET_HIST_MAX;
1572                                 offset[*off_count].rw_op = process[i].rw_op;
1573                                 offset[*off_count].rw_pid = pid;
1574                                 offset[*off_count].rw_range_start =
1575                                         process[i].rw_range_start;
1576                                 offset[*off_count].rw_range_end =
1577                                         process[i].rw_last_file_pos;
1578                                 offset[*off_count].rw_smallest_extent =
1579                                         process[i].rw_smallest_extent;
1580                                 offset[*off_count].rw_largest_extent =
1581                                         process[i].rw_largest_extent;
1582                                 offset[*off_count].rw_offset =
1583                                         process[i].rw_offset;
1584                                 process[i].rw_op = rw;
1585                                 process[i].rw_range_start = pos;
1586                                 process[i].rw_smallest_extent = count;
1587                                 process[i].rw_largest_extent = count;
1588                                 process[i].rw_offset = pos -
1589                                         process[i].rw_last_file_pos;
1590                         }
1591                         if(process[i].rw_smallest_extent > count)
1592                                 process[i].rw_smallest_extent = count;
1593                         if(process[i].rw_largest_extent < count)
1594                                 process[i].rw_largest_extent = count;
1595                         process[i].rw_last_file_pos = pos + count;
1596                         spin_unlock(&sbi->ll_process_lock);
1597                         return;
1598                 }
1599         }
1600         *process_count = (*process_count + 1) % LL_PROCESS_HIST_MAX;
1601         process[*process_count].rw_pid = pid;
1602         process[*process_count].rw_op = rw;
1603         process[*process_count].rw_range_start = pos;
1604         process[*process_count].rw_last_file_pos = pos + count;
1605         process[*process_count].rw_smallest_extent = count;
1606         process[*process_count].rw_largest_extent = count;
1607         process[*process_count].rw_offset = 0;
1608         process[*process_count].rw_last_file = file;
1609         spin_unlock(&sbi->ll_process_lock);
1610 }
1611
1612 static int ll_rw_offset_stats_seq_show(struct seq_file *seq, void *v)
1613 {
1614         struct timeval now;
1615         struct ll_sb_info *sbi = seq->private;
1616         struct ll_rw_process_info *offset = sbi->ll_rw_offset_info;
1617         struct ll_rw_process_info *process = sbi->ll_rw_process_info;
1618         int i;
1619
1620         do_gettimeofday(&now);
1621
1622         if (!sbi->ll_rw_stats_on) {
1623                 seq_printf(seq, "disabled\n"
1624                                 "write anything in this file to activate, "
1625                                 "then 0 or \"[D/d]isabled\" to deactivate\n");
1626                 return 0;
1627         }
1628         spin_lock(&sbi->ll_process_lock);
1629
1630         seq_printf(seq, "snapshot_time:         %lu.%lu (secs.usecs)\n",
1631                    now.tv_sec, now.tv_usec);
1632         seq_printf(seq, "%3s %10s %14s %14s %17s %17s %14s\n",
1633                    "R/W", "PID", "RANGE START", "RANGE END",
1634                    "SMALLEST EXTENT", "LARGEST EXTENT", "OFFSET");
1635
1636         /* We stored the discontiguous offsets here; print them first */
1637         for (i = 0; i < LL_OFFSET_HIST_MAX; i++) {
1638                 if (offset[i].rw_pid != 0)
1639                         seq_printf(seq,
1640                                    "%3c %10d %14Lu %14Lu %17lu %17lu %14Lu",
1641                                    offset[i].rw_op == READ ? 'R' : 'W',
1642                                    offset[i].rw_pid,
1643                                    offset[i].rw_range_start,
1644                                    offset[i].rw_range_end,
1645                                    (unsigned long)offset[i].rw_smallest_extent,
1646                                    (unsigned long)offset[i].rw_largest_extent,
1647                                    offset[i].rw_offset);
1648         }
1649
1650         /* Then print the current offsets for each process */
1651         for (i = 0; i < LL_PROCESS_HIST_MAX; i++) {
1652                 if (process[i].rw_pid != 0)
1653                         seq_printf(seq,
1654                                    "%3c %10d %14Lu %14Lu %17lu %17lu %14Lu",
1655                                    process[i].rw_op == READ ? 'R' : 'W',
1656                                    process[i].rw_pid,
1657                                    process[i].rw_range_start,
1658                                    process[i].rw_last_file_pos,
1659                                    (unsigned long)process[i].rw_smallest_extent,
1660                                    (unsigned long)process[i].rw_largest_extent,
1661                                    process[i].rw_offset);
1662         }
1663         spin_unlock(&sbi->ll_process_lock);
1664
1665         return 0;
1666 }
1667
1668 static ssize_t ll_rw_offset_stats_seq_write(struct file *file,
1669                                             const char __user *buf,
1670                                             size_t len, loff_t *off)
1671 {
1672         struct seq_file *seq = file->private_data;
1673         struct ll_sb_info *sbi = seq->private;
1674         struct ll_rw_process_info *process_info = sbi->ll_rw_process_info;
1675         struct ll_rw_process_info *offset_info = sbi->ll_rw_offset_info;
1676         int value = 1, rc = 0;
1677
1678         if (len == 0)
1679                 return -EINVAL;
1680
1681         rc = lprocfs_write_helper(buf, len, &value);
1682
1683         if (rc < 0 && len < 16) {
1684                 char kernbuf[16];
1685
1686                 if (copy_from_user(kernbuf, buf, len))
1687                         return -EFAULT;
1688                 kernbuf[len] = 0;
1689
1690                 if (kernbuf[len - 1] == '\n')
1691                         kernbuf[len - 1] = 0;
1692
1693                 if (strcmp(kernbuf, "disabled") == 0 ||
1694                     strcmp(kernbuf, "Disabled") == 0)
1695                         value = 0;
1696         }
1697
1698         if (value == 0)
1699                 sbi->ll_rw_stats_on = 0;
1700         else
1701                 sbi->ll_rw_stats_on = 1;
1702
1703         spin_lock(&sbi->ll_process_lock);
1704         sbi->ll_offset_process_count = 0;
1705         sbi->ll_rw_offset_entry_count = 0;
1706         memset(process_info, 0, sizeof(struct ll_rw_process_info) *
1707                LL_PROCESS_HIST_MAX);
1708         memset(offset_info, 0, sizeof(struct ll_rw_process_info) *
1709                LL_OFFSET_HIST_MAX);
1710         spin_unlock(&sbi->ll_process_lock);
1711
1712         return len;
1713 }
1714
1715 LPROC_SEQ_FOPS(ll_rw_offset_stats);
1716 #endif /* CONFIG_PROC_FS */