Whamcloud - gitweb
LU-5141 hsm: Only regular files should be archived
[fs/lustre-release.git] / lustre / utils / lustre_cfg.c
index e709115..7a6790b 100644 (file)
 #include <ctype.h>
 #include <glob.h>
 
-#ifndef __KERNEL__
-#include <liblustre.h>
-#endif
-#include <lustre_lib.h>
+#include <libcfs/libcfs.h>
+#include <lnet/nidstr.h>
 #include <lustre_cfg.h>
 #include <lustre/lustre_idl.h>
-#include <lustre_dlm.h>
-#include <obd.h>          /* for struct lov_stripe_md */
-#include <obd_lov.h>
 #include <lustre/lustre_build_version.h>
 
 #include <unistd.h>
@@ -134,24 +129,15 @@ int jt_lcfg_attach(int argc, char **argv)
         lustre_cfg_bufs_set_string(&bufs, 2, argv[3]);
 
         lcfg = lustre_cfg_new(LCFG_ATTACH, &bufs);
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0) {
                 fprintf(stderr, "error: %s: LCFG_ATTACH %s\n",
                         jt_cmdname(argv[0]), strerror(rc = errno));
-        } else if (argc == 3) {
-                char name[1024];
-
-                lcfg_set_devname(argv[2]);
-                if (strlen(argv[2]) > 128) {
-                        printf("Name too long to set environment\n");
-                        return -EINVAL;
-                }
-                snprintf(name, 512, "LUSTRE_DEV_%s", argv[2]);
-                rc = setenv(name, argv[1], 1);
-                if (rc) {
-                        printf("error setting env variable %s\n", name);
-                }
         } else {
                 lcfg_set_devname(argv[2]);
         }
@@ -183,8 +169,12 @@ int jt_lcfg_setup(int argc, char **argv)
         }
 
         lcfg = lustre_cfg_new(LCFG_SETUP, &bufs);
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0)
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -211,8 +201,12 @@ int jt_obd_detach(int argc, char **argv)
                 return CMD_HELP;
 
         lcfg = lustre_cfg_new(LCFG_DETACH, &bufs);
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0)
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -250,19 +244,23 @@ int jt_obd_cleanup(int argc, char **argv)
                         flags[flag_cnt++] = force;
                 } else if (strcmp(argv[n], "failover") == 0) {
                         flags[flag_cnt++] = failover;
-                } else {
-                        fprintf(stderr, "unknown option: %s", argv[n]);
-                        return CMD_HELP;
-                }
-        }
+               } else {
+                       fprintf(stderr, "unknown option: %s\n", argv[n]);
+                       return CMD_HELP;
+               }
+       }
 
         if (flag_cnt) {
                 lustre_cfg_bufs_set_string(&bufs, 1, flags);
         }
 
         lcfg = lustre_cfg_new(LCFG_CLEANUP, &bufs);
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0)
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -273,34 +271,33 @@ int jt_obd_cleanup(int argc, char **argv)
 static
 int do_add_uuid(char * func, char *uuid, lnet_nid_t nid)
 {
-        int rc;
-        struct lustre_cfg_bufs bufs;
-        struct lustre_cfg *lcfg;
+       int rc;
+       struct lustre_cfg_bufs bufs;
+       struct lustre_cfg *lcfg;
 
-        lustre_cfg_bufs_reset(&bufs, lcfg_devname);
-        if (uuid)
-                lustre_cfg_bufs_set_string(&bufs, 1, uuid);
+       lustre_cfg_bufs_reset(&bufs, lcfg_devname);
+       if (uuid != NULL)
+               lustre_cfg_bufs_set_string(&bufs, 1, uuid);
 
         lcfg = lustre_cfg_new(LCFG_ADD_UUID, &bufs);
-        lcfg->lcfg_nid = nid;
-        /* Poison NAL -- pre 1.4.6 will LASSERT on 0 NAL, this way it
-           doesn't work without crashing (bz 10130) */
-        lcfg->lcfg_nal = 0x5a;
-
-#if 0
-        fprintf(stderr, "adding\tnid: %d\tuuid: %s\n",
-               lcfg->lcfg_nid, uuid);
-#endif
-        rc = lcfg_ioctl(func, OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               lcfg->lcfg_nid = nid;
+
+               rc = lcfg_ioctl(func, OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc) {
                 fprintf(stderr, "IOC_PORTAL_ADD_UUID failed: %s\n",
                         strerror(errno));
                 return -1;
         }
 
-        printf ("Added uuid %s: %s\n", uuid, libcfs_nid2str(nid));
-        return 0;
+       if (uuid != NULL)
+               printf("Added uuid %s: %s\n", uuid, libcfs_nid2str(nid));
+
+       return 0;
 }
 
 int jt_lcfg_add_uuid(int argc, char **argv)
@@ -320,11 +317,6 @@ int jt_lcfg_add_uuid(int argc, char **argv)
         return do_add_uuid(argv[0], argv[1], nid);
 }
 
-int obd_add_uuid(char *uuid, lnet_nid_t nid)
-{
-        return do_add_uuid("obd_add_uuid", uuid, nid);
-}
-
 int jt_lcfg_del_uuid(int argc, char **argv)
 {
         int rc;
@@ -341,8 +333,12 @@ int jt_lcfg_del_uuid(int argc, char **argv)
                 lustre_cfg_bufs_set_string(&bufs, 1, argv[1]);
 
         lcfg = lustre_cfg_new(LCFG_DEL_UUID, &bufs);
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc) {
                 fprintf(stderr, "IOC_PORTAL_DEL_UUID failed: %s\n",
                         strerror(errno));
@@ -366,8 +362,12 @@ int jt_lcfg_del_mount_option(int argc, char **argv)
         lustre_cfg_bufs_set_string(&bufs, 1, argv[1]);
 
         lcfg = lustre_cfg_new(LCFG_DEL_MOUNTOPT, &bufs);
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0) {
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -392,12 +392,14 @@ int jt_lcfg_set_timeout(int argc, char **argv)
 
         lustre_cfg_bufs_reset(&bufs, lcfg_devname);
         lcfg = lustre_cfg_new(LCFG_SET_TIMEOUT, &bufs);
-        lcfg->lcfg_num = atoi(argv[1]);
-
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        //rc = lcfg_mgs_ioctl(argv[0], OBD_DEV_ID, lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               lcfg->lcfg_num = atoi(argv[1]);
 
-        lustre_cfg_free(lcfg);
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0) {
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -431,10 +433,14 @@ int jt_lcfg_add_conn(int argc, char **argv)
         lustre_cfg_bufs_set_string(&bufs, 1, argv[1]);
 
         lcfg = lustre_cfg_new(LCFG_ADD_CONN, &bufs);
-        lcfg->lcfg_num = priority;
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               lcfg->lcfg_num = priority;
 
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free (lcfg);
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0) {
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -465,9 +471,12 @@ int jt_lcfg_del_conn(int argc, char **argv)
         lustre_cfg_bufs_set_string(&bufs, 1, argv[1]);
 
         lcfg = lustre_cfg_new(LCFG_DEL_MOUNTOPT, &bufs);
-
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0) {
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -493,9 +502,12 @@ int jt_lcfg_param(int argc, char **argv)
         }
 
         lcfg = lustre_cfg_new(LCFG_PARAM, &bufs);
-
-        rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (rc < 0) {
                 fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
                         strerror(rc = errno));
@@ -558,16 +570,16 @@ static int jt_lcfg_mgsparam2(int argc, char **argv, struct param_opts *popt)
                lustre_cfg_bufs_set_string(&bufs, 1, buf);
 
                lcfg = lustre_cfg_new(LCFG_SET_PARAM, &bufs);
-               if (IS_ERR(lcfg)) {
+               if (lcfg == NULL) {
                        fprintf(stderr, "error: allocating lcfg for %s: %s\n",
-                               jt_cmdname(argv[0]), strerror(PTR_ERR(lcfg)));
+                               jt_cmdname(argv[0]), strerror(-ENOMEM));
                        if (rc == 0)
-                                rc = PTR_ERR(lcfg);
+                               rc = -ENOMEM;
                } else {
                        int rc2 = lcfg_mgs_ioctl(argv[0], OBD_DEV_ID, lcfg);
                        if (rc2 != 0) {
                                fprintf(stderr, "error: executing %s: %s\n",
-                                       jt_cmdname(argv[0]), strerror(rc2));
+                                       jt_cmdname(argv[0]), strerror(errno));
                                if (rc == 0)
                                        rc = rc2;
                        }
@@ -589,11 +601,16 @@ static int jt_lcfg_mgsparam2(int argc, char **argv, struct param_opts *popt)
  * AT NEXT REBOOT, not immediately. */
 int jt_lcfg_mgsparam(int argc, char **argv)
 {
-        int rc;
-        int del = 0;
-        struct lustre_cfg_bufs bufs;
-        struct lustre_cfg *lcfg;
-        char *buf = NULL;
+       int rc;
+       int del = 0;
+       struct lustre_cfg_bufs bufs;
+       struct lustre_cfg *lcfg;
+       char *buf = NULL;
+
+#if LUSTRE_VERSION_CODE >= OBD_OCD_VERSION(2, 7, 53, 0)
+       fprintf(stderr, "warning: 'lctl conf_param' is deprecated, "
+               "use 'lctl set_param -P' instead\n");
+#endif
 
         /* mgs_setparam processes only lctl buf #1 */
         if ((argc > 3) || (argc <= 1))
@@ -627,9 +644,12 @@ int jt_lcfg_mgsparam(int argc, char **argv)
 
         /* We could put other opcodes here. */
         lcfg = lustre_cfg_new(LCFG_PARAM, &bufs);
-
-        rc = lcfg_mgs_ioctl(argv[0], OBD_DEV_ID, lcfg);
-        lustre_cfg_free(lcfg);
+       if (lcfg == NULL) {
+               rc = -ENOMEM;
+       } else {
+               rc = lcfg_mgs_ioctl(argv[0], OBD_DEV_ID, lcfg);
+               lustre_cfg_free(lcfg);
+       }
         if (buf)
                 free(buf);
         if (rc < 0) {
@@ -740,24 +760,21 @@ static void clean_path(char *path)
  * Path support is deprecated.
  * If a path is supplied it must begin with /proc.  */
 static void lprocfs_param_pattern(const char *cmd, const char *path, char *buf,
-        size_t buf_size)
+                                 size_t buf_size)
 {
-        /* test path to see if it begins with '/proc/' */
-        if (strncmp(path, "/proc/", strlen("/proc/")) == 0) {
-                static int warned;
-                if (!warned) {
-                        fprintf(stderr, "%s: specifying parameters via "
-                                "full paths is deprecated.\n", cmd);
-#if LUSTRE_VERSION_CODE >= OBD_OCD_VERSION(2, 6, 50, 0)
-#warning "remove deprecated full path tunable access"
+#if LUSTRE_VERSION_CODE >= OBD_OCD_VERSION(2, 6, 53, 0)
+       /* test path to see if it begins with '/proc/' */
+       if (strncmp(path, "/proc/", strlen("/proc/")) == 0) {
+               static int warned;
+               if (!warned) {
+                       fprintf(stderr, "%s: specifying parameters via "
+                               "full paths is deprecated.\n", cmd);
+                       warned = 1;
+               }
+               snprintf(buf, buf_size, "%s", path);
+       } else
 #endif
-                        warned = 1;
-                }
-                snprintf(buf, buf_size, "%s", path);
-        } else {
-                snprintf(buf, buf_size, "/proc/{fs,sys}/{lnet,lustre}/%s",
-                        path);
-        }
+       snprintf(buf, buf_size, "/proc/{fs,sys}/{lnet,lustre}/%s", path);
 }
 
 static int listparam_cmdline(int argc, char **argv, struct param_opts *popt)
@@ -908,7 +925,13 @@ static int getparam_display(struct param_opts *popt, char *pattern)
                 /* As listparam_display is used to show param name (with type),
                  * here "if (only_path)" is ignored.*/
                 if (popt->po_show_path) {
-                        strcpy(filename, glob_info.gl_pathv[i]);
+                       if (strlen(glob_info.gl_pathv[i]) >
+                           sizeof(filename)-1) {
+                               free(buf);
+                               return -E2BIG;
+                       }
+                       strncpy(filename, glob_info.gl_pathv[i],
+                               sizeof(filename));
                         valuename = display_name(filename, 0);
                 }
 
@@ -1037,7 +1060,10 @@ static int setparam_display(struct param_opts *popt, char *pattern, char *value)
                char *valuename = NULL;
 
                if (popt->po_show_path) {
-                       strcpy(filename, glob_info.gl_pathv[i]);
+                       if (strlen(glob_info.gl_pathv[i]) > sizeof(filename)-1)
+                               return -E2BIG;
+                       strncpy(filename, glob_info.gl_pathv[i],
+                               sizeof(filename));
                        valuename = display_name(filename, 0);
                        if (valuename)
                                printf("%s=%s\n", valuename, value);
@@ -1087,6 +1113,8 @@ int jt_lcfg_setparam(int argc, char **argv)
                         *value = '\0';
                         value ++;
                         path = argv[i];
+                       if (*value == '\0')
+                               break;
                 } else {
                         /* format: set_param a b */
                         if (path == NULL) {
@@ -1107,6 +1135,9 @@ int jt_lcfg_setparam(int argc, char **argv)
                if (rc2 < 0 && rc == 0)
                        rc = rc2;
        }
+       if (path != NULL && (value == NULL || *value == '\0'))
+               fprintf(stderr, "error: %s: setting %s=: %s\n",
+                       jt_cmdname(argv[0]), path, strerror(rc = EINVAL));
 
        return rc;
 }