src/proc_self_mountinfo.c

   1 #include "common.h"
   2
   3 // ----------------------------------------------------------------------------
   4 // taken from gnulib/mountlist.c
   5
   6 #ifndef ME_REMOTE
   7 /* A file system is "remote" if its Fs_name contains a ':'
   8    or if (it is of type (smbfs or cifs) and its Fs_name starts with '//')
   9    or Fs_name is equal to "-hosts" (used by autofs to mount remote fs).  */
  10 # define ME_REMOTE(Fs_name, Fs_type)            \
  11     (strchr (Fs_name, ':') != NULL              \
  12      || ((Fs_name)[0] == '/'                    \
  13          && (Fs_name)[1] == '/'                 \
  14          && (strcmp (Fs_type, "smbfs") == 0     \
  15              || strcmp (Fs_type, "cifs") == 0)) \
  16      || (strcmp("-hosts", Fs_name) == 0))
  17 #endif
  18
  19 #define ME_DUMMY_0(Fs_name, Fs_type)            \
  20   (strcmp (Fs_type, "autofs") == 0              \
  21    || strcmp (Fs_type, "proc") == 0             \
  22    || strcmp (Fs_type, "subfs") == 0            \
  23    /* for Linux 2.6/3.x */                      \
  24    || strcmp (Fs_type, "debugfs") == 0          \
  25    || strcmp (Fs_type, "devpts") == 0           \
  26    || strcmp (Fs_type, "fusectl") == 0          \
  27    || strcmp (Fs_type, "mqueue") == 0           \
  28    || strcmp (Fs_type, "rpc_pipefs") == 0       \
  29    || strcmp (Fs_type, "sysfs") == 0            \
  30    /* FreeBSD, Linux 2.4 */                     \
  31    || strcmp (Fs_type, "devfs") == 0            \
  32    /* for NetBSD 3.0 */                         \
  33    || strcmp (Fs_type, "kernfs") == 0           \
  34    /* for Irix 6.5 */                           \
  35    || strcmp (Fs_type, "ignore") == 0)
  36
  37 /* Historically, we have marked as "dummy" any file system of type "none",
  38    but now that programs like du need to know about bind-mounted directories,
  39    we grant an exception to any with "bind" in its list of mount options.
  40    I.e., those are *not* dummy entries.  */
  41 # define ME_DUMMY(Fs_name, Fs_type)             \
  42   (ME_DUMMY_0 (Fs_name, Fs_type) || strcmp (Fs_type, "none") == 0)
  43
  44 // ----------------------------------------------------------------------------
  45
  46 // find the mount info with the given major:minor
  47 // in the supplied linked list of mountinfo structures
  48 struct mountinfo *mountinfo_find(struct mountinfo *root, unsigned long major, unsigned long minor) {
  49     struct mountinfo *mi;
  50
  51     for(mi = root; mi ; mi = mi->next)
  52         if(mi->major == major && mi->minor == minor)
  53             return mi;
  54
  55     return NULL;
  56 }
  57
  58 // find the mount info with the given filesystem and mount_source
  59 // in the supplied linked list of mountinfo structures
  60 struct mountinfo *mountinfo_find_by_filesystem_mount_source(struct mountinfo *root, const char *filesystem, const char *mount_source) {
  61     struct mountinfo *mi;
  62     uint32_t filesystem_hash = simple_hash(filesystem), mount_source_hash = simple_hash(mount_source);
  63
  64     for(mi = root; mi ; mi = mi->next)
  65         if(mi->filesystem
  66                 && mi->mount_source
  67                 && mi->filesystem_hash == filesystem_hash
  68                 && mi->mount_source_hash == mount_source_hash
  69                 && !strcmp(mi->filesystem, filesystem)
  70                 && !strcmp(mi->mount_source, mount_source))
  71             return mi;
  72
  73     return NULL;
  74 }
  75
  76 struct mountinfo *mountinfo_find_by_filesystem_super_option(struct mountinfo *root, const char *filesystem, const char *super_options) {
  77     struct mountinfo *mi;
  78     uint32_t filesystem_hash = simple_hash(filesystem);
  79
  80     size_t solen = strlen(super_options);
  81
  82     for(mi = root; mi ; mi = mi->next)
  83         if(mi->filesystem
  84                 && mi->super_options
  85                 && mi->filesystem_hash == filesystem_hash
  86                 && !strcmp(mi->filesystem, filesystem)) {
  87
  88             // super_options is a comma separated list
  89             char *s = mi->super_options, *e;
  90             while(*s) {
  91                 e = s + 1;
  92                 while(*e && *e != ',') e++;
  93
  94                 size_t len = e - s;
  95                 if(len == solen && !strncmp(s, super_options, len))
  96                     return mi;
  97
  98                 if(*e == ',') s = ++e;
  99                 else s = e;
 100             }
 101         }
 102
 103     return NULL;
 104 }
 105
 106
 107 // free a linked list of mountinfo structures
 108 void mountinfo_free(struct mountinfo *mi) {
 109     if(unlikely(!mi))
 110         return;
 111
 112     if(likely(mi->next))
 113         mountinfo_free(mi->next);
 114
 115     freez(mi->root);
 116     freez(mi->mount_point);
 117     freez(mi->mount_options);
 118     freez(mi->persistent_id);
 119
 120 /*
 121     if(mi->optional_fields_count) {
 122         int i;
 123         for(i = 0; i < mi->optional_fields_count ; i++)
 124             free(*mi->optional_fields[i]);
 125     }
 126     free(mi->optional_fields);
 127 */
 128     freez(mi->filesystem);
 129     freez(mi->mount_source);
 130     freez(mi->super_options);
 131     freez(mi);
 132 }
 133
 134 static char *strdupz_decoding_octal(const char *string) {
 135     char *buffer = strdupz(string);
 136
 137     char *d = buffer;
 138     const char *s = string;
 139
 140     while(*s) {
 141         if(unlikely(*s == '\\')) {
 142             s++;
 143             if(likely(isdigit(*s) && isdigit(s[1]) && isdigit(s[2]))) {
 144                 char c = *s++ - '0';
 145                 c <<= 3;
 146                 c |= *s++ - '0';
 147                 c <<= 3;
 148                 c |= *s++ - '0';
 149                 *d++ = c;
 150             }
 151             else *d++ = '_';
 152         }
 153         else *d++ = *s++;
 154     }
 155     *d = '\0';
 156
 157     return buffer;
 158 }
 159
 160 // read the whole mountinfo into a linked list
 161 struct mountinfo *mountinfo_read() {
 162     procfile *ff = NULL;
 163
 164     char filename[FILENAME_MAX + 1];
 165     snprintfz(filename, FILENAME_MAX, "%s/proc/self/mountinfo", global_host_prefix);
 166     ff = procfile_open(filename, " \t", PROCFILE_FLAG_DEFAULT);
 167     if(!ff) {
 168         snprintfz(filename, FILENAME_MAX, "%s/proc/1/mountinfo", global_host_prefix);
 169         ff = procfile_open(filename, " \t", PROCFILE_FLAG_DEFAULT);
 170         if(!ff) return NULL;
 171     }
 172
 173     ff = procfile_readall(ff);
 174     if(!ff) return NULL;
 175
 176     struct mountinfo *root = NULL, *last = NULL, *mi = NULL;
 177
 178     unsigned long l, lines = procfile_lines(ff);
 179     for(l = 0; l < lines ;l++) {
 180         if(procfile_linewords(ff, l) < 5)
 181             continue;
 182
 183         mi = mallocz(sizeof(struct mountinfo));
 184
 185         unsigned long w = 0;
 186         mi->id = strtoul(procfile_lineword(ff, l, w), NULL, 10); w++;
 187         mi->parentid = strtoul(procfile_lineword(ff, l, w), NULL, 10); w++;
 188
 189         char *major = procfile_lineword(ff, l, w), *minor; w++;
 190         for(minor = major; *minor && *minor != ':' ;minor++) ;
 191
 192         if(!*minor) {
 193             error("Cannot parse major:minor on '%s' at line %lu of '%s'", major, l + 1, filename);
 194             freez(mi);
 195             continue;
 196         }
 197
 198         *minor = '\0';
 199         minor++;
 200
 201         mi->flags = 0;
 202
 203         mi->major = strtoul(major, NULL, 10);
 204         mi->minor = strtoul(minor, NULL, 10);
 205
 206         mi->root = strdupz(procfile_lineword(ff, l, w)); w++;
 207         mi->root_hash = simple_hash(mi->root);
 208
 209         mi->mount_point = strdupz_decoding_octal(procfile_lineword(ff, l, w)); w++;
 210         mi->mount_point_hash = simple_hash(mi->mount_point);
 211
 212         mi->persistent_id = strdupz(mi->mount_point);
 213         netdata_fix_chart_id(mi->persistent_id);
 214         mi->persistent_id_hash = simple_hash(mi->persistent_id);
 215
 216         mi->mount_options = strdupz(procfile_lineword(ff, l, w)); w++;
 217
 218         // count the optional fields
 219 /*
 220         unsigned long wo = w;
 221 */
 222         mi->optional_fields_count = 0;
 223         char *s = procfile_lineword(ff, l, w);
 224         while(*s && *s != '-') {
 225             w++;
 226             s = procfile_lineword(ff, l, w);
 227             mi->optional_fields_count++;
 228         }
 229
 230 /*
 231         if(unlikely(mi->optional_fields_count)) {
 232             // we have some optional fields
 233             // read them into a new array of pointers;
 234
 235             mi->optional_fields = malloc(mi->optional_fields_count * sizeof(char *));
 236             if(unlikely(!mi->optional_fields))
 237                 fatal("Cannot allocate memory for %d mountinfo optional fields", mi->optional_fields_count);
 238
 239             int i;
 240             for(i = 0; i < mi->optional_fields_count ; i++) {
 241                 *mi->optional_fields[wo] = strdup(procfile_lineword(ff, l, w));
 242                 if(!mi->optional_fields[wo]) fatal("Cannot allocate memory");
 243                 wo++;
 244             }
 245         }
 246         else
 247             mi->optional_fields = NULL;
 248 */
 249
 250         if(likely(*s == '-')) {
 251             w++;
 252
 253             mi->filesystem = strdupz(procfile_lineword(ff, l, w)); w++;
 254             mi->filesystem_hash = simple_hash(mi->filesystem);
 255
 256             mi->mount_source = strdupz(procfile_lineword(ff, l, w)); w++;
 257             mi->mount_source_hash = simple_hash(mi->mount_source);
 258
 259             mi->super_options = strdupz(procfile_lineword(ff, l, w)); w++;
 260
 261             if(ME_DUMMY(mi->mount_source, mi->filesystem))
 262                 mi->flags |= MOUNTINFO_IS_DUMMY;
 263
 264             if(ME_REMOTE(mi->mount_source, mi->filesystem))
 265                 mi->flags |= MOUNTINFO_IS_REMOTE;
 266
 267             // mark as BIND the duplicates (i.e. same filesystem + same source)
 268             {
 269                 struct stat buf;
 270                 if(unlikely(stat(mi->mount_point, &buf) == -1)) {
 271                     mi->st_dev = 0;
 272                     mi->flags |= MOUNTINFO_NO_STAT;
 273                 }
 274                 else {
 275                     mi->st_dev = buf.st_dev;
 276
 277                     struct mountinfo *mt;
 278                     for(mt = root; mt; mt = mt->next) {
 279                         if(unlikely(mt->st_dev == mi->st_dev && !(mi->flags & MOUNTINFO_NO_STAT))) {
 280                             if(strlen(mi->mount_point) < strlen(mt->mount_point))
 281                                 mt->flags |= MOUNTINFO_IS_SAME_DEV;
 282                             else
 283                                 mi->flags |= MOUNTINFO_IS_SAME_DEV;
 284                         }
 285                     }
 286                 }
 287             }
 288         }
 289         else {
 290             mi->filesystem = NULL;
 291             mi->filesystem_hash = 0;
 292
 293             mi->mount_source = NULL;
 294             mi->mount_source_hash = 0;
 295
 296             mi->super_options = NULL;
 297
 298             mi->st_dev = 0;
 299         }
 300
 301         // check if it has size
 302         {
 303             struct statvfs buff_statvfs;
 304             if(statvfs(mi->mount_point, &buff_statvfs) < 0) {
 305                 mi->flags |= MOUNTINFO_NO_STAT;
 306             }
 307             else if(!buff_statvfs.f_blocks /* || !buff_statvfs.f_files */) {
 308                 mi->flags |= MOUNTINFO_NO_SIZE;
 309             }
 310         }
 311
 312         // link it
 313         if(unlikely(!root))
 314             root = mi;
 315         else
 316             last->next = mi;
 317
 318         last = mi;
 319         mi->next = NULL;
 320
 321 /*
 322 #ifdef NETDATA_INTERNAL_CHECKS
 323         fprintf(stderr, "MOUNTINFO: %ld %ld %lu:%lu root '%s', persistent id '%s', mount point '%s', mount options '%s', filesystem '%s', mount source '%s', super options '%s'%s%s%s%s%s%s\n",
 324              mi->id,
 325              mi->parentid,
 326              mi->major,
 327              mi->minor,
 328              mi->root,
 329              mi->persistent_id,
 330                 (mi->mount_point)?mi->mount_point:"",
 331                 (mi->mount_options)?mi->mount_options:"",
 332                 (mi->filesystem)?mi->filesystem:"",
 333                 (mi->mount_source)?mi->mount_source:"",
 334                 (mi->super_options)?mi->super_options:"",
 335                 (mi->flags & MOUNTINFO_IS_DUMMY)?" DUMMY":"",
 336                 (mi->flags & MOUNTINFO_IS_BIND)?" BIND":"",
 337                 (mi->flags & MOUNTINFO_IS_REMOTE)?" REMOTE":"",
 338                 (mi->flags & MOUNTINFO_NO_STAT)?" NOSTAT":"",
 339                 (mi->flags & MOUNTINFO_NO_SIZE)?" NOSIZE":"",
 340                 (mi->flags & MOUNTINFO_IS_SAME_DEV)?" SAMEDEV":""
 341         );
 342 #endif
 343 */
 344     }
 345
 346 /* find if the mount options have "bind" in them
 347     {
 348         FILE *fp = setmntent(MOUNTED, "r");
 349         if (fp != NULL) {
 350             struct mntent mntbuf;
 351             struct mntent *mnt;
 352             char buf[4096 + 1];
 353
 354             while ((mnt = getmntent_r(fp, &mntbuf, buf, 4096))) {
 355                 char *bind = hasmntopt(mnt, "bind");
 356                 if(bind) {
 357                     struct mountinfo *mi;
 358                     for(mi = root; mi ; mi = mi->next) {
 359                         if(strcmp(mnt->mnt_dir, mi->mount_point) == 0) {
 360                             fprintf(stderr, "Mount point '%s' is BIND\n", mi->mount_point);
 361                             mi->flags |= MOUNTINFO_IS_BIND;
 362                             break;
 363                         }
 364                     }
 365
 366 #ifdef NETDATA_INTERNAL_CHECKS
 367                     if(!mi) {
 368                         error("Mount point '%s' not found in /proc/self/mountinfo", mnt->mnt_dir);
 369                     }
 370 #endif
 371                 }
 372             }
 373             endmntent(fp);
 374         }
 375     }
 376 */
 377
 378     procfile_close(ff);
 379     return root;
 380 }