Whamcloud - gitweb
- Added lctl.c which is basically ptlctl/obdctl/debugctl all
[fs/lustre-release.git] / lustre / utils / obdctl.c
index 07d93f2..25666c3 100644 (file)
@@ -50,6 +50,8 @@
 #include <errno.h>
 #include <string.h>
 
+#include <asm/page.h>   /* needed for PAGE_SIZE - rread*/ 
+
 #define __KERNEL__
 #include <linux/list.h>
 #undef __KERNEL__
@@ -267,6 +269,7 @@ static int xml_command(char *cmd, ...) {
         return Parser_execarg(i, cmds, cmdlist);
 }
 
+#if 0
 static network_t *xml_network(xmlDocPtr doc, xmlNodePtr root) {
         xmlNodePtr cur = root->xmlChildrenNode;
         network_t *net;
@@ -301,9 +304,10 @@ static network_t *xml_network(xmlDocPtr doc, xmlNodePtr root) {
         
         return net;
 }
+#endif
 
 static int xml_mds(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
+                   char *serv_name, char *serv_uuid) {
         xmlNodePtr cur = root->xmlChildrenNode;
         char *fstype = NULL, *device = NULL;
         int rc;
@@ -316,6 +320,14 @@ static int xml_mds(xmlDocPtr doc, xmlNodePtr root,
                 if (!xmlStrcmp(cur->name, "device"))
                         device = xmlNodeGetContent(cur);
  
+                /* FIXME: Parse the network bits
+                 * if (!xmlStrcmp(cur->name, "network")) {
+                 *       net = xml_network(doc, cur);
+                 *       if (net == NULL)
+                 *               return -1;
+                 * }
+                 * free(net);
+                 */
                 cur = cur->next;
         } 
 
@@ -327,7 +339,7 @@ static int xml_mds(xmlDocPtr doc, xmlNodePtr root,
         if ((rc = xml_command("newdev", NULL)) != 0)
                 return rc;
 
-        if ((rc = xml_command("attach", "mds", "MDSDEV", NULL)) != 0)
+        if ((rc = xml_command("attach","mds",serv_name,serv_uuid,NULL)) != 0)
                 return rc;
 
         if ((rc = xml_command("setup", device, fstype, NULL)) != 0)
@@ -337,9 +349,9 @@ static int xml_mds(xmlDocPtr doc, xmlNodePtr root,
 }
         
 static int xml_obd(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
-        xmlNodePtr cur = root->xmlChildrenNode;
+                   char *serv_name, char *serv_uuid) {
         char *obdtype, *format = NULL, *fstype = NULL, *device = NULL;
+        xmlNodePtr cur = root->xmlChildrenNode;
         int rc;
 
         obdtype = xmlGetProp(root, "type");
@@ -359,7 +371,8 @@ static int xml_obd(xmlDocPtr doc, xmlNodePtr root,
         } 
 
         if ((obdtype == NULL) || (fstype == NULL) || (device == NULL)) {
-                printf("error: 'type' attrib and <fstype> and <device> tags required\n");
+                printf("error: 'type' attrib and <fstype> "
+                       "and <device> tags required\n");
                 return -1;
         }
 
@@ -371,7 +384,8 @@ static int xml_obd(xmlDocPtr doc, xmlNodePtr root,
         if ((rc = xml_command("newdev", NULL)) != 0)
                 return rc;
 
-        if ((rc = xml_command("attach", obdtype, "OBDDEV", NULL)) != 0)
+        if ((rc = xml_command("attach", obdtype,
+            serv_name,serv_uuid, NULL)) != 0)
                 return rc;
 
         if ((rc = xml_command("setup", device, fstype, NULL)) != 0)
@@ -381,125 +395,136 @@ static int xml_obd(xmlDocPtr doc, xmlNodePtr root,
 }
 
 static int xml_ost(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
-        int rc;
+                   char *serv_name, char *serv_uuid) {
+        char *server_name = NULL, *server_uuid = NULL;
+        char *failover_name = NULL, *failover_uuid = NULL;
+        xmlNodePtr cur = root->xmlChildrenNode;
+        int server_num, failover_num, rc;
 
         printf("--- Setting up OST ---\n");
+        while (cur != NULL) {
+                if (!xmlStrcmp(cur->name, "server_id")) {
+                        server_num = atoi(xmlGetProp(cur, "num"));
+                        server_name = xmlGetProp(cur, "name");
+                        server_uuid = xmlGetProp(cur, "uuid");
+                }
+
+                /* FIXME: Properly handle multiple failover servers */
+                if (!xmlStrcmp(cur->name, "failover_id")) {
+                        failover_num = atoi(xmlGetProp(cur, "num"));
+                        failover_name = xmlGetProp(cur, "name");
+                        failover_uuid = xmlGetProp(cur, "uuid");
+                }
+
+                cur = cur->next;
+        } 
+
+        if ((server_name == NULL) || (server_uuid == NULL)) {
+                printf("error: atleast the <server_id> tag is required\n");
+                return -1;
+        }
+        
         if ((rc = xml_command("newdev", NULL)) != 0)
                 return rc;
 
-        if ((rc = xml_command("attach", "ost", "OSTDEV", NULL)) != 0)
+        if ((rc = xml_command("attach","ost",serv_name,serv_uuid,NULL)) != 0)
                 return rc;
 
-        if ((rc = xml_command("setup", "$OBDDEV", NULL)) != 0)
+        if ((rc = xml_command("setup", server_name, NULL)) != 0)
                 return rc;
 
         return 0;
 }
 
 static int xml_osc(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
+                   char *serv_name, char *serv_uuid) {
+        char *ost_name = NULL, *ost_uuid = NULL;
         xmlNodePtr cur = root->xmlChildrenNode;
-        network_t *net = NULL;
-        int rc = 0;
+        int ost_num, rc = 0;
 
         printf("--- Setting up OSC ---\n");
         while (cur != NULL) {
-                if (!xmlStrcmp(cur->name, "network")) {
-                        net = xml_network(doc, cur);
-                        if (net == NULL)
-                                return -1;
+                if (!xmlStrcmp(cur->name, "service_id")) {
+                        ost_num = atoi(xmlGetProp(cur, "num"));
+                        ost_name = xmlGetProp(cur, "name");
+                        ost_uuid = xmlGetProp(cur, "uuid");
                 }
+
                 cur = cur->next;
         } 
 
-        if (net == NULL) {
-                printf("error: <network> tag required\n");
+        if ((ost_name == NULL) || (ost_uuid == NULL)) {
+                printf("error: atleast the <service_id> tag is required\n");
                 return -1;
         }
 
-        if ((rc = xml_command("newdev", NULL)) != 0) {
-                rc = -1;
-                goto xml_osc_error;
-        }
+        if ((rc = xml_command("newdev", NULL)) != 0)
+                return rc;
 
-        if ((rc = xml_command("attach", "osc", "OSCDEV", NULL)) != 0) {
-                rc = -1;
-                goto xml_osc_error;
-        }
+        if ((rc = xml_command("attach","osc",serv_name,serv_uuid,NULL)) != 0)
+                return rc;
 
-        if ((rc = xml_command("setup", "OSTDEV", net->server, NULL)) != 0) {
-                rc = -1;
-                goto xml_osc_error;
-        }
+        if ((rc = xml_command("setup", ost_uuid, "localhost", NULL)) != 0)
+                return rc;
 
-xml_osc_error:
-        free(net);
-        return rc;
+        return 0;
 }
 
 static int xml_mdc(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
+                   char *serv_name, char *serv_uuid) {
+        char *mds_name = NULL, *mds_uuid = NULL;
         xmlNodePtr cur = root->xmlChildrenNode;
-        network_t *net = NULL;
-        int rc = 0;
+        int mds_num, rc = 0;
 
         printf("--- Setting up MDC ---\n");
         while (cur != NULL) {
-                if (!xmlStrcmp(cur->name, "network")) {
-                        net = xml_network(doc, cur);
-                        if (net == NULL)
-                                return -1;
+                if (!xmlStrcmp(cur->name, "service_id")) {
+                        mds_num = atoi(xmlGetProp(cur, "num"));
+                        mds_name = xmlGetProp(cur, "name");
+                        mds_uuid = xmlGetProp(cur, "uuid");
                 }
+
                 cur = cur->next;
         } 
 
-        if (net == NULL) {
-                printf("error: <network> tag required\n");
+        if ((mds_name == NULL) || (mds_uuid == NULL)) {
+                printf("error: atleast the <service_id> tag is required\n");
                 return -1;
         }
 
-        if ((rc = xml_command("newdev", NULL)) != 0) {
-                rc = -1;
-                goto xml_mdc_error;
-        }
-
-        if ((rc = xml_command("attach", "mdc", "MDCDEV", NULL)) != 0) {
-                rc = -1;
-                goto xml_mdc_error;
-        }
+        if ((rc = xml_command("newdev", NULL)) != 0) 
+                return rc;
 
-        if ((rc = xml_command("setup", "MDSDEV", net->server, NULL)) != 0) {
-                rc = -1;
-                goto xml_mdc_error;
-        }
+        if ((rc = xml_command("attach","mdc",serv_name,serv_uuid,NULL)) != 0)
+                return rc;
 
-xml_mdc_error:
-        free(net);
-        return rc;
+        if ((rc = xml_command("setup", mds_uuid, "localhost", NULL)) != 0)
+                return rc;
+                
+        return 0;
 }
 
 static int xml_lov(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
+                   char *serv_name, char *serv_uuid) {
         printf("--- Setting up LOV ---\n");
         return 0;
 }
 
 static int xml_router(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
+                   char *serv_name, char *serv_uuid) {
         printf("--- Setting up ROUTER ---\n");
         return 0;
 }
 
 static int xml_ldlm(xmlDocPtr doc, xmlNodePtr root, 
-                   char *serv_id, char *serv_uuid) {
+                   char *serv_name, char *serv_uuid) {
         int rc;
 
         printf("--- Setting up LDLM ---\n");
         if ((rc = xml_command("newdev", NULL)) != 0)
                 return rc;
 
-        if ((rc = xml_command("attach", "ldlm", "LDLMDEV", NULL)) != 0)
+        if ((rc = xml_command("attach","ldlm",serv_name,serv_uuid,NULL)) != 0)
                 return rc;
 
         if ((rc = xml_command("setup", NULL)) != 0)
@@ -509,59 +534,59 @@ static int xml_ldlm(xmlDocPtr doc, xmlNodePtr root,
 }
 
 static int xml_service(xmlDocPtr doc, xmlNodePtr root, 
-                       int serv_num, char *serv_id, char *serv_uuid) {
+                       int serv_num, char *serv_name, char *serv_uuid) {
         xmlNodePtr cur = root;
-        char *id, *uuid;
+        char *name, *uuid;
 
         while (cur != NULL) {
-                id = xmlGetProp(cur, "id");
+                name = xmlGetProp(cur, "name");
                 uuid = xmlGetProp(cur, "uuid");
 
-                if (xmlStrcmp(id, serv_id) ||
+                if (xmlStrcmp(name, serv_name) ||
                     xmlStrcmp(uuid, serv_uuid)) {
                         cur = cur->next;
                         continue;
                 }
 
                 if (!xmlStrcmp(cur->name, "mds"))
-                        return xml_mds(doc, cur, serv_id, serv_uuid);
+                        return xml_mds(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "obd"))
-                        return xml_obd(doc, cur, serv_id, serv_uuid);
+                        return xml_obd(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "ost"))
-                        return xml_ost(doc, cur, serv_id, serv_uuid);
+                        return xml_ost(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "osc"))
-                        return xml_osc(doc, cur, serv_id, serv_uuid);
+                        return xml_osc(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "mdc"))
-                        return xml_mdc(doc, cur, serv_id, serv_uuid);
+                        return xml_mdc(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "lov"))
-                        return xml_lov(doc, cur, serv_id, serv_uuid);
+                        return xml_lov(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "router"))
-                        return xml_router(doc, cur, serv_id, serv_uuid);
+                        return xml_router(doc, cur, name, uuid);
                 else if (!xmlStrcmp(cur->name, "ldlm"))
-                        return xml_ldlm(doc, cur, serv_id, serv_uuid);
+                        return xml_ldlm(doc, cur, name, uuid);
                 else
                         return -1;        
 
                 cur = cur->next;
         }
 
-        printf("error: No XML config branch for id=%s uuid=%s\n",
-                serv_id, serv_uuid); 
+        printf("error: No XML config branch for name=%s uuid=%s\n",
+                serv_name, serv_uuid); 
         return -1; 
 }
 
 static int xml_profile(xmlDocPtr doc, xmlNodePtr root, 
-                       int prof_num, char *prof_id, char *prof_uuid) {
+                       int prof_num, char *prof_name, char *prof_uuid) {
         xmlNodePtr parent, cur = root;
-        char *id, *uuid, *srv_id, *srv_uuid;
+        char *name, *uuid, *srv_name, *srv_uuid;
         int rc = 0, num;
 
         while (cur != NULL) {
-                id = xmlGetProp(cur, "id");
+                name = xmlGetProp(cur, "name");
                 uuid = xmlGetProp(cur, "uuid");
 
                 if (xmlStrcmp(cur->name, "profile") || 
-                    xmlStrcmp(id, prof_id)          ||
+                    xmlStrcmp(name, prof_name)          ||
                     xmlStrcmp(uuid, prof_uuid)) {
                         cur = cur->next;
                         continue;
@@ -581,7 +606,7 @@ static int xml_profile(xmlDocPtr doc, xmlNodePtr root,
                         if (!xmlStrcmp(cur->name, "service_id")) {
                                 num = atoi(xmlGetProp(cur, "num"));
                                 rc = xml_service(doc, root, num,
-                                        srv_id = xmlGetProp(cur, "id"),
+                                        srv_name = xmlGetProp(cur, "name"),
                                         srv_uuid = xmlGetProp(cur, "uuid"));
                                 if (rc != 0) {
                                         printf("error: service config\n");
@@ -600,7 +625,7 @@ static int xml_profile(xmlDocPtr doc, xmlNodePtr root,
 
 static int xml_node(xmlDocPtr doc, xmlNodePtr root) {
         xmlNodePtr parent, cur = root;
-        char *id, *uuid;
+        char *name, *uuid;
         int rc = 0, num;
         
         /* Walk the node tags looking for ours */
@@ -610,15 +635,15 @@ static int xml_node(xmlDocPtr doc, xmlNodePtr root) {
                         continue;
                 }
 
-                id = xmlGetProp(cur, "id");
-                if (id == NULL)
+                name = xmlGetProp(cur, "name");
+                if (name == NULL)
                         return -1;
 
                 uuid = xmlGetProp(cur, "uuid");
                 if (uuid == NULL)
                         return -1;
 
-                /* FIXME: Verify our ID and UUID against /etc/lustre/id
+                /* FIXME: Verify our NAME and UUID against /etc/lustre/id
                  *        so we're sure we are who we think we are.
                  */
 
@@ -632,7 +657,7 @@ static int xml_node(xmlDocPtr doc, xmlNodePtr root) {
                         if (!xmlStrcmp(cur->name, "profile_id")) {
                                 num = atoi(xmlGetProp(cur, "num"));
                                 rc = xml_profile(doc, root, num,
-                                                 xmlGetProp(cur, "id"),
+                                                 xmlGetProp(cur, "name"),
                                                  xmlGetProp(cur, "uuid"));
                                 if (rc != 0)
                                         return rc;
@@ -1397,6 +1422,71 @@ static int jt_test_brw(int argc, char **argv)
         return rc;
 }
 
+static int jt_lov_config(int argc, char **argv)
+{
+        struct obd_ioctl_data data;
+        struct lov_desc desc; 
+        uuid_t *uuidarray;
+        int size, i;
+        IOCINIT(data);
+
+        if (argc <= 5 ){
+                Parser_printhelp("lovconfig"); 
+                return -1;
+        }
+
+        if (strlen(argv[1]) > sizeof(uuid_t) - 1) { 
+                fprintf(stderr, "lov_config: no %dB memory for uuid's\n", 
+                        size);
+                return -ENOMEM;
+        }
+            
+        memset(&desc, 0, sizeof(desc)); 
+        strcpy(desc.ld_uuid, argv[1]); 
+        desc.ld_default_stripecount = strtoul(argv[2], NULL, 0); 
+        desc.ld_default_stripesize = strtoul(argv[3], NULL, 0); 
+        desc.ld_pattern = strtoul(argv[4], NULL, 0); 
+        desc.ld_tgt_count = argc - 5;
+
+
+        size = sizeof(uuid_t) * desc.ld_tgt_count;
+        uuidarray = malloc(size);
+        if (!uuidarray) { 
+                fprintf(stderr, "lov_config: no %dB memory for uuid's\n", 
+                        size);
+                return -ENOMEM;
+        }
+        memset(uuidarray, 0, size); 
+        for (i=5 ; i < argc ; i++) { 
+                char *buf = (char *) (uuidarray + i -5 );
+                if (strlen(argv[i]) >= sizeof(uuid_t)) { 
+                        fprintf(stderr, "lov_config: arg %d (%s) too long\n",  
+                                i, argv[i]);
+                        free(uuidarray);
+                        return -EINVAL;
+                }
+                strcpy(buf, argv[i]); 
+        }
+
+        data.ioc_inllen1 = sizeof(desc); 
+        data.ioc_inlbuf1 = (char *)&desc;
+        data.ioc_inllen2 = size;
+        data.ioc_inlbuf2 = (char *)uuidarray;
+
+        if (obd_ioctl_pack(&data, &buf, max)) {
+                fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
+                return -EINVAL;
+        }
+
+        rc = ioctl(fd, OBD_IOC_LOV_CONFIG , buf);
+        if (rc < 0)
+                fprintf(stderr, "lov_config: error: %s: %s\n", 
+                        cmdname(argv[0]),strerror(rc = errno));
+        free(uuidarray);
+        return rc;
+}
+
+
 static int jt_test_ldlm(int argc, char **argv)
 {
         struct obd_ioctl_data data;
@@ -1447,6 +1537,8 @@ command_t cmdlist[] = {
                 "--threads <threads> <devno> <command [args ...]>"},
 
         /* Device configuration commands */
+        {"lovconfig", jt_lov_config, 0, "configure lov data on MDS "
+         "(usage: lov-uuid stripecount, stripesize, pattern, UUID1, [UUID2, ...])"}, 
         {"list", jt_list, 0, "list the devices (no args)"},
         {"newdev", jt_newdev, 0, "set device to a new unused obd (no args)"},
         {"device", jt_device, 0, "set current device (args device_no name)"},