vos: Add the -config option
[openafs.git] / src / volser / vos.c
index 90a5ab5..adddb07 100644 (file)
 # pragma GCC diagnostic warning "-Wimplicit-function-declaration"
 #endif
 
-#include <sys/types.h>
-#include <string.h>
-#ifdef HAVE_STDINT_H
-# include <stdint.h>
-#endif
 #ifdef AFS_NT40_ENV
-#include <fcntl.h>
-#include <io.h>
-#include <winsock2.h>
 #include <WINNT/afsreg.h>
-#else
-#include <sys/time.h>
-#include <sys/file.h>
-#include <netdb.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
 #endif
-#include <sys/stat.h>
+
 #ifdef AFS_AIX_ENV
 #include <sys/statfs.h>
 #endif
-#include <errno.h>
 
 #include <lock.h>
 #include <afs/stds.h>
@@ -62,9 +47,6 @@
 #include "dump.h"
 #include "lockdata.h"
 
-#ifdef AFS_AIX32_ENV
-#include <signal.h>
-#endif
 #include "volser_internal.h"
 #include "volser_prototypes.h"
 #include "vsutils_prototypes.h"
@@ -96,6 +78,7 @@ cmd_AddParm(ts, "-localauth",CMD_FLAG,CMD_OPTIONAL,"use server tickets");\
 cmd_AddParm(ts, "-verbose", CMD_FLAG, CMD_OPTIONAL, "verbose");\
 cmd_AddParm(ts, "-encrypt", CMD_FLAG, CMD_OPTIONAL, "encrypt commands");\
 cmd_AddParm(ts, "-noresolve", CMD_FLAG, CMD_OPTIONAL, "don't resolve addresses"); \
+cmd_AddParm(ts, "-config", CMD_SINGLE, CMD_OPTIONAL, "config location"); \
 
 #define ERROR_EXIT(code) do { \
     error = (code); \
@@ -152,7 +135,7 @@ FileExists(char *filename)
 {
     usd_handle_t ufd;
     int code;
-    afs_hyper_t size;
+    afs_int64 size;
 
     code = usd_Open(filename, USD_OPEN_RDONLY, 0, &ufd);
     if (code) {
@@ -170,7 +153,7 @@ FileExists(char *filename)
 static int
 VolNameOK(char *name)
 {
-    int total;
+    size_t total;
 
 
     total = strlen(name);
@@ -187,7 +170,8 @@ VolNameOK(char *name)
 static int
 IsNumeric(char *name)
 {
-    int result, len, i;
+    int result, i;
+    size_t len;
     char *ptr;
 
     result = 1;
@@ -348,7 +332,7 @@ WriteData(struct rx_call *call, void *rock)
     long blksize;
     afs_int32 error, code;
     int ufdIsOpen = 0;
-    afs_hyper_t filesize, currOffset;
+    afs_int64 currOffset;
     afs_uint32 buffer;
     afs_uint32 got;
 
@@ -371,19 +355,15 @@ WriteData(struct rx_call *call, void *rock)
            goto wfail;
        }
        /* test if we have a valid dump */
-       hset64(filesize, 0, 0);
-       USD_SEEK(ufd, filesize, SEEK_END, &currOffset);
-       hset64(filesize, hgethi(currOffset), hgetlo(currOffset)-sizeof(afs_uint32));
-       USD_SEEK(ufd, filesize, SEEK_SET, &currOffset);
+       USD_SEEK(ufd, 0, SEEK_END, &currOffset);
+       USD_SEEK(ufd, currOffset - sizeof(afs_uint32), SEEK_SET, &currOffset);
        USD_READ(ufd, (char *)&buffer, sizeof(afs_uint32), &got);
        if ((got != sizeof(afs_uint32)) || (ntohl(buffer) != DUMPENDMAGIC)) {
            fprintf(STDERR, "Signature missing from end of file '%s'\n", filename);
            error = VOLSERBADOP;
            goto wfail;
        }
-       /* rewind, we are done */
-       hset64(filesize, 0, 0);
-       USD_SEEK(ufd, filesize, SEEK_SET, &currOffset);
+       USD_SEEK(ufd, 0, SEEK_SET, &currOffset);
     }
     code = SendFile(ufd, call, blksize);
     if (code) {
@@ -455,7 +435,7 @@ DumpFunction(struct rx_call *call, void *rock)
     char *filename = (char *)rock;
     usd_handle_t ufd;          /* default is to stdout */
     afs_int32 error = 0, code;
-    afs_hyper_t size;
+    afs_int64 size;
     long blksize;
     int ufdIsOpen = 0;
 
@@ -469,7 +449,7 @@ DumpFunction(struct rx_call *call, void *rock)
            usd_Open(filename, USD_OPEN_CREATE | USD_OPEN_RDWR, 0666, &ufd);
        if (code == 0) {
            ufdIsOpen = 1;
-           hzero(size);
+           size = 0;
            code = USD_IOCTL(ufd, USD_IOCTL_SETSIZE, &size);
        }
        if (code == 0) {
@@ -4291,7 +4271,8 @@ DeleteEntry(struct cmd_syndesc *as, void *arock)
                            itp->data);
                continue;
            }
-           if (as->parms[4].items) {   /* -noexecute */
+           if (as->parms[4].items || as->parms[5].items) {
+               /* -noexecute (hidden) or -dryrun */
                fprintf(STDOUT, "Would have deleted VLDB entry for %s \n",
                        itp->data);
                fflush(STDOUT);
@@ -4401,7 +4382,8 @@ DeleteEntry(struct cmd_syndesc *as, void *arock)
            }
        }
 
-       if (as->parms[4].items) {       /* -noexecute */
+       if (as->parms[4].items || as->parms[5].items) {
+           /* -noexecute (hidden) or -dryrun */
            fprintf(STDOUT, "Would have deleted VLDB entry for %s \n",
                    vllist->name);
            fflush(STDOUT);
@@ -5274,14 +5256,8 @@ static void
 print_addrs(const bulkaddrs * addrs, afsUUID * m_uuid, int nentries,
            int print)
 {
-    afs_int32 vcode, m_uniq=0;
-    afs_int32 i, j;
+    int i;
     afs_uint32 *addrp;
-    bulkaddrs m_addrs;
-    ListAddrByAttributes m_attrs;
-    afs_int32 m_nentries;
-    afs_uint32 *m_addrp;
-    afs_int32 base, index;
     char buf[1024];
 
     if (print) {
@@ -5292,56 +5268,6 @@ print_addrs(const bulkaddrs * addrs, afsUUID * m_uuid, int nentries,
     /* print out the list of all the server */
     addrp = (afs_uint32 *) addrs->bulkaddrs_val;
     for (i = 0; i < nentries; i++, addrp++) {
-       /* If it is a multihomed address, then we will need to
-        * get the addresses for this multihomed server from
-        * the vlserver and print them.
-        */
-       if (((*addrp & 0xff000000) == 0xff000000) && ((*addrp) & 0xffff)) {
-           /* Get the list of multihomed fileservers */
-           base = (*addrp >> 16) & 0xff;
-           index = (*addrp) & 0xffff;
-
-           if ((base >= 0) && (base <= VL_MAX_ADDREXTBLKS) && (index >= 1)
-               && (index <= VL_MHSRV_PERBLK)) {
-               m_attrs.Mask = VLADDR_INDEX;
-               m_attrs.index = (base * VL_MHSRV_PERBLK) + index;
-               m_nentries = 0;
-               m_addrs.bulkaddrs_val = 0;
-               m_addrs.bulkaddrs_len = 0;
-               vcode =
-                   ubik_VL_GetAddrsU(cstruct, 0, &m_attrs, m_uuid,
-                                     &m_uniq, &m_nentries,
-                                     &m_addrs);
-               if (vcode) {
-                   fprintf(STDERR,
-                           "vos: could not list the multi-homed server addresses\n");
-                   PrintError("", vcode);
-               }
-
-               /* Print the list */
-               m_addrp = (afs_uint32 *) m_addrs.bulkaddrs_val;
-               for (j = 0; j < m_nentries; j++, m_addrp++) {
-                   *m_addrp = htonl(*m_addrp);
-                   if (noresolve) {
-                       char hoststr[16];
-                       printf("%s ", afs_inet_ntoa_r(*m_addrp, hoststr));
-                   } else {
-                       printf("%s ", hostutil_GetNameByINet(*m_addrp));
-                   }
-               }
-               if (j == 0) {
-                   printf("<unknown>\n");
-               } else {
-                   printf("\n");
-               }
-
-               continue;
-           }
-       }
-
-       /* Otherwise, it is a non-multihomed entry and contains
-        * the IP address of the server - print it.
-        */
        *addrp = htonl(*addrp);
        if (noresolve) {
            char hoststr[16];
@@ -5372,7 +5298,6 @@ ListAddrs(struct cmd_syndesc *as, void *arock)
     memset(&m_attrs, 0, sizeof(struct ListAddrByAttributes));
     m_attrs.Mask = VLADDR_INDEX;
 
-    memset(&m_addrs, 0, sizeof(bulkaddrs));
     memset(&askuuid, 0, sizeof(afsUUID));
     if (as->parms[0].items) {
        /* -uuid */
@@ -5402,8 +5327,8 @@ ListAddrs(struct cmd_syndesc *as, void *arock)
        printuuid = 1;
     }
 
-    m_addrs.bulkaddrs_val = 0;
-    m_addrs.bulkaddrs_len = 0;
+    memset(&m_addrs, 0, sizeof(bulkaddrs));
+    memset(&vlcb, 0, sizeof(struct VLCallBack));
 
     vcode =
        ubik_VL_GetAddrs(cstruct, UBIK_CALL_NEW, 0, 0, &vlcb, &nentries,
@@ -5411,16 +5336,15 @@ ListAddrs(struct cmd_syndesc *as, void *arock)
     if (vcode) {
        fprintf(STDERR, "vos: could not list the server addresses\n");
        PrintError("", vcode);
-       return (vcode);
+       goto out;
     }
 
     m_nentries = 0;
-    m_addrs.bulkaddrs_val = 0;
-    m_addrs.bulkaddrs_len = 0;
     i = 1;
     while (1) {
        m_attrs.index = i;
 
+       xdr_free((xdrproc_t)xdr_bulkaddrs, &m_addrs); /* reset addr list */
        vcode =
            ubik_VL_GetAddrsU(cstruct, UBIK_CALL_NEW, &m_attrs, &m_uuid,
                              &m_uniq, &m_nentries, &m_addrs);
@@ -5442,23 +5366,26 @@ ListAddrs(struct cmd_syndesc *as, void *arock)
        }
 
        if (vcode == VL_INDEXERANGE) {
-           break;
+           vcode = 0; /* not an error, just means we're done */
+           goto out;
        }
 
        if (vcode) {
            fprintf(STDERR, "vos: could not list the server addresses\n");
            PrintError("", vcode);
-           return (vcode);
+           goto out;
        }
 
        print_addrs(&m_addrs, &m_uuid, m_nentries, printuuid);
        i++;
 
        if ((as->parms[1].items) || (as->parms[0].items) || (i > nentries))
-           break;
+           goto out;
     }
 
-    return 0;
+out:
+    xdr_free((xdrproc_t)xdr_bulkaddrs, &m_addrs);
+    return vcode;
 }
 
 
@@ -5896,6 +5823,10 @@ MyBeforeProc(struct cmd_syndesc *as, void *arock)
 #endif /* AFS_NT40_ENV */
          )
        vsu_SetCrypt(1);
+
+    if (as->parms[18].items)   /* -config flag set */
+       confdir = as->parms[18].items->data;
+
     if ((code =
         vsu_ClientInit((as->parms[13].items != 0), confdir, tcell, sauth,
                        &cstruct, UV_SetSecurity))) {
@@ -5912,6 +5843,7 @@ MyBeforeProc(struct cmd_syndesc *as, void *arock)
        noresolve = 1;
     else
        noresolve = 0;
+
     return 0;
 }
 
@@ -6139,14 +6071,14 @@ main(int argc, char **argv)
     cmd_AddParm(ts, "-server", CMD_SINGLE, CMD_OPTIONAL, "machine name");
     cmd_AddParm(ts, "-partition", CMD_SINGLE, CMD_OPTIONAL, "partition name");
     cmd_AddParm(ts, "-volume", CMD_SINGLE, CMD_OPTIONAL, "volume name or ID");
-    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL, "report without updating");
+    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL, "list what would be done, don't do it");
     COMMONPARMS;
 
     ts = cmd_CreateSyntax("syncserv", SyncServer, NULL,
                          "synchronize server with VLDB");
     cmd_AddParm(ts, "-server", CMD_SINGLE, 0, "machine name");
     cmd_AddParm(ts, "-partition", CMD_SINGLE, CMD_OPTIONAL, "partition name");
-    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL, "report without updating");
+    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL, "list what would be done, don't do it");
     COMMONPARMS;
 
     ts = cmd_CreateSyntax("examine", ExamineVolume, NULL,
@@ -6223,7 +6155,7 @@ main(int argc, char **argv)
                "exclude common prefix volumes");
     cmd_AddParm(ts, "-xprefix", CMD_LIST, CMD_OPTIONAL,
                "negative prefix on volume(s)");
-    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL, "no action");
+    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL, "list what would be done, don't do it");
     COMMONPARMS;
 
     ts = cmd_CreateSyntax("delentry", DeleteEntry, NULL,
@@ -6233,8 +6165,9 @@ main(int argc, char **argv)
                "prefix of the volume whose VLDB entry is to be deleted");
     cmd_AddParm(ts, "-server", CMD_SINGLE, CMD_OPTIONAL, "machine name");
     cmd_AddParm(ts, "-partition", CMD_SINGLE, CMD_OPTIONAL, "partition name");
-    cmd_AddParm(ts, "-noexecute", CMD_FLAG, CMD_OPTIONAL,
-               "no execute");
+    cmd_AddParm(ts, "-noexecute", CMD_FLAG, CMD_OPTIONAL|CMD_HIDDEN, "");
+    cmd_AddParm(ts, "-dryrun", CMD_FLAG, CMD_OPTIONAL,
+               "list what would be done, don't do it");
     COMMONPARMS;
 
     ts = cmd_CreateSyntax("partinfo", PartitionInfo, NULL,