]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - mapfile.c
Improve partition table code.
[thirdparty/mdadm.git] / mapfile.c
index 3a26c6d0afeaad99bb1667e8bb2e22d7f09118c4..366ebe332299c92fceaa4d3c9fa2e8c644b27801 100644 (file)
--- a/mapfile.c
+++ b/mapfile.c
  * We read from the first one that exists and write to the first
  * one that we can.
  */
-#include "mdadm.h"
+#include       "mdadm.h"
+#include       <sys/file.h>
+#include       <ctype.h>
 
-#define mapnames(base) { #base, #base ".new", #base ".lock"}
+#define mapnames(base) { base, base ".new", base ".lock"}
 char *mapname[3][3] = {
-       mapnames(/var/run/mdadm/map),
-       mapnames(/var/run/mdadm.map),
-       mapnames(/dev/.mdadm.map)
+       mapnames(VAR_RUN "/map"),
+       mapnames("/var/run/mdadm.map"),
+       mapnames(ALT_RUN "/map")
 };
 
 int mapmode[3] = { O_RDONLY, O_RDWR|O_CREAT, O_RDWR|O_CREAT | O_TRUNC };
@@ -114,7 +116,7 @@ int map_lock(struct map_ent **melp)
                lf = open_map(2, &lwhich);
                if (lf == NULL)
                        return -1;
-               if (lockf(fileno(lf), F_LOCK, 0) != 0) {
+               if (flock(fileno(lf), LOCK_EX) != 0) {
                        fclose(lf);
                        lf = NULL;
                        return -1;
@@ -128,8 +130,10 @@ int map_lock(struct map_ent **melp)
 
 void map_unlock(struct map_ent **melp)
 {
-       if (lf)
+       if (lf) {
+               flock(fileno(lf), LOCK_UN);
                fclose(lf);
+       }
        unlink(mapname[lwhich][2]);
        lf = NULL;
 }
@@ -296,12 +300,53 @@ struct map_ent *map_by_name(struct map_ent **map, char *name)
        return NULL;
 }
 
+/* sets the proper subarray and container_dev according to the metadata
+ * version super_by_fd does this automatically, this routine is meant as
+ * a supplement for guess_super()
+ */
+static void set_member_info(struct supertype *st, struct mdstat_ent *ent)
+{
+
+       st->subarray[0] = '\0';
+
+       if (ent->metadata_version == NULL ||
+           strncmp(ent->metadata_version, "external:", 9) != 0)
+               return;
+
+       if (is_subarray(&ent->metadata_version[9])) {
+               char version[strlen(ent->metadata_version)+1];
+               char *subarray;
+               char *name = &version[10];
+
+               strcpy(version, ent->metadata_version);
+               subarray = strrchr(version, '/');
+               name = &version[10];
+
+               if (!subarray)
+                       return;
+               *subarray++ = '\0';
+
+               st->container_dev = devname2devnum(name);
+               strncpy(st->subarray, subarray, sizeof(st->subarray));
+       }
+}
+
 void RebuildMap(void)
 {
        struct mdstat_ent *mdstat = mdstat_read(0, 0);
        struct mdstat_ent *md;
        struct map_ent *map = NULL;
        int mdp = get_mdp_major();
+       int require_homehost;
+       char sys_hostname[256];
+       char *homehost = conf_get_homehost(&require_homehost);
+
+       if (homehost == NULL || strcmp(homehost, "<system>")==0) {
+               if (gethostname(sys_hostname, sizeof(sys_hostname)) == 0) {
+                       sys_hostname[sizeof(sys_hostname)-1] = 0;
+                       homehost = sys_hostname;
+               }
+       }
 
        for (md = mdstat ; md ; md = md->next) {
                struct mdinfo *sra = sysfs_read(-1, md->devnum, GET_DEVS|SKIP_GONE_DEVS);
@@ -311,6 +356,7 @@ void RebuildMap(void)
                        continue;
 
                for (sd = sra->devs ; sd ; sd = sd->next) {
+                       char namebuf[100];
                        char dn[30];
                        int dfd;
                        int ok;
@@ -325,16 +371,89 @@ void RebuildMap(void)
                        st = guess_super(dfd);
                        if ( st == NULL)
                                ok = -1;
-                       else
+                       else {
+                               set_member_info(st, md);
                                ok = st->ss->load_super(st, dfd, NULL);
+                       }
                        close(dfd);
                        if (ok != 0)
                                continue;
                        st->ss->getinfo_super(st, &info);
-                       if (md->devnum > 0)
+                       if (md->devnum >= 0)
                                path = map_dev(MD_MAJOR, md->devnum, 0);
                        else
                                path = map_dev(mdp, (-1-md->devnum)<< 6, 0);
+                       if (path == NULL ||
+                           strncmp(path, "/dev/md/", 8) != 0) {
+                               /* We would really like a name that provides
+                                * an MD_DEVNAME for udev.
+                                * The name needs to be unique both in /dev/md/
+                                * and in this mapfile.
+                                * It needs to match watch -I or -As would come
+                                * up with.
+                                * That means:
+                                *   Check if array is in mdadm.conf 
+                                *        - if so use that.
+                                *   determine trustworthy from homehost etc
+                                *   find a unique name based on metadata name.
+                                *   
+                                */
+                               struct mddev_ident_s *match = conf_match(&info, st);
+                               struct stat stb;
+                               if (match && match->devname && match->devname[0] == '/') {
+                                       path = match->devname;
+                                       if (path[0] != '/') {
+                                               strcpy(namebuf, "/dev/md/");
+                                               strcat(namebuf, path);
+                                               path = namebuf;
+                                       }
+                               } else {
+                                       int unum = 0;
+                                       char *sep = "_";
+                                       const char *name;
+                                       int conflict = 1;
+                                       if ((homehost == NULL ||
+                                            st->ss->match_home(st, homehost) != 1) &&
+                                           st->ss->match_home(st, "any") != 1 &&
+                                           (require_homehost
+                                            || ! conf_name_is_free(info.name)))
+                                               /* require a numeric suffix */
+                                               unum = 0;
+                                       else
+                                               /* allow name to be used as-is if no conflict */
+                                               unum = -1;
+                                       name = info.name;
+                                       if (!*name) {
+                                               name = st->ss->name;
+                                               if (!isdigit(name[strlen(name)-1]) &&
+                                                   unum == -1) {
+                                                       unum = 0;
+                                                       sep = "";
+                                               }
+                                       }
+                                       if (strchr(name, ':'))
+                                               /* probably a uniquifying
+                                                * hostname prefix.  Allow
+                                                * without a suffix
+                                                */
+                                               unum = -1;
+
+                                       while (conflict) {
+                                               if (unum >= 0)
+                                                       sprintf(namebuf, "/dev/md/%s%s%d",
+                                                               name, sep, unum);
+                                               else
+                                                       sprintf(namebuf, "/dev/md/%s",
+                                                               name);
+                                               unum++;
+                                               if (lstat(namebuf, &stb) != 0 &&
+                                                   (map == NULL ||
+                                                    !map_by_name(&map, namebuf+8)))
+                                                       conflict = 0;
+                                       }
+                                       path = namebuf;
+                               }
+                       }
                        map_add(&map, md->devnum,
                                info.text_version,
                                info.uuid, path);