vos: Add missing -partition requires -server checks
[openafs.git] / src / volser / vos.c
index f12312e..da09a32 100644 (file)
@@ -80,6 +80,7 @@ enum {
     COMMONPARM_OFFSET_ENCRYPT   = 29,
     COMMONPARM_OFFSET_NORESOLVE = 30,
     COMMONPARM_OFFSET_CONFIG    = 31,
+    COMMONPARM_OFFSET_RXGK      = 32,
 };
 
 #define COMMONPARMS \
@@ -98,6 +99,8 @@ cmd_AddParmAtOffset(ts, COMMONPARM_OFFSET_NORESOLVE, \
     "-noresolve", CMD_FLAG, CMD_OPTIONAL, "don't resolve addresses"); \
 cmd_AddParmAtOffset(ts, COMMONPARM_OFFSET_CONFIG, \
     "-config", CMD_SINGLE, CMD_OPTIONAL, "config location"); \
+cmd_AddParmAtOffset(ts, COMMONPARM_OFFSET_RXGK, \
+    "-rxgk", CMD_SINGLE, CMD_OPTIONAL, "rxgk security level to use"); \
 
 #define ERROR_EXIT(code) do { \
     error = (code); \
@@ -2068,32 +2071,6 @@ CreateVolume(struct cmd_syndesc *as, void *arock)
     return 0;
 }
 
-#if 0
-static afs_int32
-DeleteAll(struct nvldbentry *entry)
-{
-    int i;
-    afs_int32 error, code, curserver, curpart;
-    afs_uint32 volid;
-
-    MapHostToNetwork(entry);
-    error = 0;
-    for (i = 0; i < entry->nServers; i++) {
-       curserver = entry->serverNumber[i];
-       curpart = entry->serverPartition[i];
-       if (entry->serverFlags[i] & VLSF_ROVOL) {
-           volid = entry->volumeId[ROVOL];
-       } else {
-           volid = entry->volumeId[RWVOL];
-       }
-       code = UV_DeleteVolume(curserver, curpart, volid);
-       if (code && !error)
-           error = code;
-    }
-    return error;
-}
-#endif
-
 static int
 DeleteVolume(struct cmd_syndesc *as, void *arock)
 {
@@ -2104,6 +2081,11 @@ DeleteVolume(struct cmd_syndesc *as, void *arock)
     char pname[10];
     afs_int32 idx, j;
 
+    if (as->parms[1].items && !as->parms[0].items) {
+       fprintf(STDERR, "vos: The -partition option requires the -server option.\n");
+       return EINVAL;
+    }
+
     if (as->parms[0].items) {
        server = GetServer(as->parms[0].items->data);
        if (!server) {
@@ -2752,18 +2734,6 @@ CloneVolume(struct cmd_syndesc *as, void *arock)
                volname, VOLSER_OLDMAXVOLNAME - 1);
            return E2BIG;
        }
-#if 0
-       /*
-        * In order that you be able to make clones of RO or BK, this
-        * check must be omitted.
-        */
-       if (!VolNameOK(volname)) {
-           fprintf(STDERR,
-               "Illegal volume name %s, should not end in .readonly or .backup\n",
-               volname);
-           return EINVAL;
-       }
-#endif
        if (IsNumeric(volname)) {
            fprintf(STDERR,
                "Illegal volume name %s, should not be a number\n",
@@ -3847,6 +3817,12 @@ SyncVldb(struct cmd_syndesc *as, void *arock)
     afs_uint32 tserver;
 
     tserver = 0;
+
+    if (as->parms[1].items && !as->parms[0].items) {
+       fprintf(STDERR, "vos: The -partition option requires the -server option.\n");
+       exit(1);
+    }
+
     if (as->parms[0].items) {
        tserver = GetServer(as->parms[0].items->data);
        if (!tserver) {
@@ -3873,12 +3849,6 @@ SyncVldb(struct cmd_syndesc *as, void *arock)
            exit(1);
        }
        flags = 1;
-
-       if (!tserver) {
-           fprintf(STDERR,
-                   "The -partition option requires a -server option\n");
-           exit(1);
-       }
     }
 
     if (as->parms[3].items) {
@@ -4130,33 +4100,32 @@ VolserStatus(struct cmd_syndesc *as, void *arock)
        }
        if (pntr->iflags) {
            fprintf(STDOUT, "attachFlags:  ");
-           switch (pntr->iflags) {
-           case ITOffline:
+           if ((pntr->iflags & ITOffline) != 0) {
                fprintf(STDOUT, "offline ");
-               break;
-           case ITBusy:
+           }
+           if ((pntr->iflags & ITBusy) != 0) {
                fprintf(STDOUT, "busy ");
-               break;
-           case ITReadOnly:
+           }
+           if ((pntr->iflags & ITReadOnly) != 0) {
                fprintf(STDOUT, "readonly ");
-               break;
-           case ITCreate:
+           }
+           if ((pntr->iflags & ITCreate) != 0) {
                fprintf(STDOUT, "create ");
-               break;
-           case ITCreateVolID:
+           }
+           if ((pntr->iflags & ITCreateVolID) != 0) {
                fprintf(STDOUT, "create volid ");
-               break;
            }
            fprintf(STDOUT, "\n");
        }
        if (pntr->vflags) {
            fprintf(STDOUT, "volumeStatus: ");
-           switch (pntr->vflags) {
-           case VTDeleteOnSalvage:
+           if ((pntr->vflags & VTDeleteOnSalvage) != 0) {
                fprintf(STDOUT, "deleteOnSalvage ");
-           case VTOutOfService:
+           }
+           if ((pntr->vflags & VTOutOfService) != 0) {
                fprintf(STDOUT, "outOfService ");
-           case VTDeleted:
+           }
+           if ((pntr->vflags & VTDeleted) != 0) {
                fprintf(STDOUT, "deleted ");
            }
            fprintf(STDOUT, "\n");
@@ -4188,25 +4157,39 @@ VolserStatus(struct cmd_syndesc *as, void *arock)
 static int
 RenameVolume(struct cmd_syndesc *as, void *arock)
 {
-    afs_int32 code1, code2, code;
+    afs_int32 code;
     struct nvldbentry entry;
+    struct nvldbentry entry2;
 
-    code1 = VLDB_GetEntryByName(as->parms[0].items->data, &entry);
-    if (code1) {
+    /* Get the entry of the volume to be renamed (-oldname), by name or id. */
+    code = VLDB_GetEntryByName(as->parms[0].items->data, &entry);
+    if (code) {
        fprintf(STDERR, "vos: Could not find entry for volume %s\n",
                as->parms[0].items->data);
+       PrintError("", code);
        exit(1);
     }
-    code2 = VLDB_GetEntryByName(as->parms[1].items->data, &entry);
-    if ((!code1) && (!code2)) {        /*the newname already exists */
-       fprintf(STDERR, "vos: volume %s already exists\n",
+
+    /*
+     * Verify the new name is available before attempting to rename.
+     * Allow renaming of the same volume in order to complete a
+     * previously interrupted rename.
+     */
+    code = VLDB_GetEntryByName(as->parms[1].items->data, &entry2);
+    if (code != 0 && code != VL_NOENT) {
+       fprintf(STDERR, "vos: Could not check entry for volume %s\n",
                as->parms[1].items->data);
+       PrintError("", code);
        exit(1);
     }
-
-    if (code1 && code2) {
-       fprintf(STDERR, "vos: Could not find entry for volume %s or %s\n",
-               as->parms[0].items->data, as->parms[1].items->data);
+    if (code == 0 && entry.volumeId[RWVOL] != entry2.volumeId[RWVOL]) {
+       fprintf(STDERR, "vos: Cannot rename volume %s (%lu) to %s;"
+                       " volume %s (%lu) already exists\n",
+                       as->parms[0].items->data,
+                       (unsigned long)entry.volumeId[RWVOL],
+                       as->parms[1].items->data,
+                       as->parms[1].items->data,
+                       (unsigned long)entry2.volumeId[RWVOL]);
        exit(1);
     }
     if (!VolNameOK(as->parms[0].items->data)) {
@@ -4547,7 +4530,7 @@ ListVLDB(struct cmd_syndesc *as, void *arock)
 
     apart = 0;
 
-    attributes.Mask = 0;
+    memset(&attributes, 0, sizeof(attributes));
     lock = (as->parms[3].items ? 1 : 0);       /* -lock   flag */
     quiet = (as->parms[4].items ? 1 : 0);      /* -quit   flag */
     sort = (as->parms[5].items ? 0 : 1);       /* -nosort flag */
@@ -5050,7 +5033,7 @@ UnlockVLDB(struct cmd_syndesc *as, void *arock)
 
     apart = -1;
     totalE = 0;
-    attributes.Mask = 0;
+    memset(&attributes, 0, sizeof(attributes));
 
     if (as->parms[0].items) {  /* server specified */
        aserver = GetServer(as->parms[0].items->data);
@@ -5069,14 +5052,17 @@ UnlockVLDB(struct cmd_syndesc *as, void *arock)
                    as->parms[1].items->data);
            exit(1);
        }
-       if (!IsPartValid(apart, aserver, &code)) {      /*check for validity of the partition */
-           if (code)
-               PrintError("", code);
-           else
-               fprintf(STDERR,
-                       "vos : partition %s does not exist on the server\n",
-                       as->parms[1].items->data);
-           exit(1);
+       if (aserver) {
+           /* Check for validity of the partition if a server was given. */
+           if (!IsPartValid(apart, aserver, &code)) {
+               if (code)
+                   PrintError("", code);
+               else
+                   fprintf(STDERR,
+                           "vos : partition %s does not exist on the server\n",
+                           as->parms[1].items->data);
+               exit(1);
+           }
        }
        attributes.partition = apart;
        attributes.Mask |= VLLIST_PARTITION;
@@ -5296,12 +5282,11 @@ ChangeAddr(struct cmd_syndesc *as, void *arock)
        afs_int32 m_uniq = 0;
        afsUUID m_uuid;
        ListAddrByAttributes m_attrs;
-       char buffer[128];
+       struct uuid_fmtbuf buffer;
 
        memset(&m_attrs, 0, sizeof(m_attrs));
        memset(&m_uuid, 0, sizeof(m_uuid));
        memset(&m_addrs, 0, sizeof(m_addrs));
-       memset(buffer, 0, sizeof(buffer));
 
        m_attrs.Mask = VLADDR_IPADDR;
        m_attrs.ipaddr = ntohl(ip1);    /* -oldaddr */
@@ -5312,9 +5297,10 @@ ChangeAddr(struct cmd_syndesc *as, void *arock)
        xdr_free((xdrproc_t) xdr_bulkaddrs, &m_addrs);
        switch (vcode) {
        case 0:         /* mh entry detected */
-           afsUUID_to_string(&m_uuid, buffer, sizeof(buffer) - 1);
+           afsUUID_to_string(&m_uuid, &buffer);
            fprintf(STDERR, "vos: Refusing to change address in multi-homed server entry.\n");
-           fprintf(STDERR, "     -oldaddr address is registered to file server UUID %s\n", buffer);
+           fprintf(STDERR, "     -oldaddr address is registered to file server UUID %s\n",
+                           buffer.buffer);
            fprintf(STDERR, "     Please restart the file server or use vos setaddrs.\n");
            return EINVAL;
        case VL_NOENT:
@@ -5363,11 +5349,11 @@ print_addrs(const bulkaddrs * addrs, afsUUID * m_uuid, int nentries,
 {
     int i;
     afs_uint32 addr;
-    char buf[1024];
+    struct uuid_fmtbuf buf;
 
     if (print) {
-       afsUUID_to_string(m_uuid, buf, sizeof(buf));
-       printf("UUID: %s\n", buf);
+       afsUUID_to_string(m_uuid, &buf);
+       printf("UUID: %s\n", buf.buffer);
     }
 
     /* print out the list of all the server */
@@ -5930,6 +5916,7 @@ static int
 MyBeforeProc(struct cmd_syndesc *as, void *arock)
 {
     char *tcell;
+    char *rxgk_seclevel_str = NULL;
     afs_int32 code;
     int secFlags;
 
@@ -5960,6 +5947,23 @@ MyBeforeProc(struct cmd_syndesc *as, void *arock)
     if (as->parms[COMMONPARM_OFFSET_CONFIG].items)   /* -config flag set */
        confdir = as->parms[COMMONPARM_OFFSET_CONFIG].items->data;
 
+    if (cmd_OptionAsString(as, COMMONPARM_OFFSET_RXGK, &rxgk_seclevel_str) == 0) {
+       if (strcmp(rxgk_seclevel_str, "clear") == 0)
+           secFlags |= AFSCONF_SECOPTS_ALWAYSCLEAR;
+       else if (strcmp(rxgk_seclevel_str, "auth") == 0)
+           secFlags |= AFSCONF_SECOPTS_NEVERENCRYPT;
+       else if (strcmp(rxgk_seclevel_str, "crypt") == 0) {
+           /* don't need to set any flags; this is the default for rxgk */
+       } else {
+           fprintf(STDERR, "Invalid argument to -rxgk: %s\n", rxgk_seclevel_str);
+           exit(1);
+       }
+       secFlags |= AFSCONF_SECOPTS_RXGK;
+
+       free(rxgk_seclevel_str);
+       rxgk_seclevel_str = NULL;
+    }
+
     if ((code = vsu_ClientInit(confdir, tcell, secFlags, UV_SetSecurity,
                               &cstruct))) {
        fprintf(STDERR, "could not initialize VLDB library (code=%lu) \n",
@@ -6023,9 +6027,6 @@ main(int argc, char **argv)
                "initial quota (KB)");
     cmd_AddParm(ts, "-id", CMD_SINGLE, CMD_OPTIONAL, "volume ID");
     cmd_AddParm(ts, "-roid", CMD_SINGLE, CMD_OPTIONAL, "readonly volume ID");
-#ifdef notdef
-    cmd_AddParm(ts, "-minquota", CMD_SINGLE, CMD_OPTIONAL, "");
-#endif
     COMMONPARMS;
 
     ts = cmd_CreateSyntax("remove", DeleteVolume, NULL, 0, "delete a volume");