1 /*- 2 * Copyright (c) 2005 Chris Jones 3 * All rights reserved. 4 * 5 * This software was developed for the FreeBSD Project by Chris Jones 6 * thanks to the support of Google's Summer of Code program and 7 * mentoring by Lukas Ertl. 8 * 9 * Redistribution and use in source and binary forms, with or without 10 * modification, are permitted provided that the following conditions 11 * are met: 12 * 1. Redistributions of source code must retain the above copyright 13 * notice, this list of conditions and the following disclaimer. 14 * 2. Redistributions in binary form must reproduce the above copyright 15 * notice, this list of conditions and the following disclaimer in the 16 * documentation and/or other materials provided with the distribution. 17 * 18 * THIS SOFTWARE IS PROVIDED BY AUTHOR AND CONTRIBUTORS ``AS IS'' AND 19 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 20 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 21 * ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE 22 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 23 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 24 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 25 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 26 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 27 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 28 * SUCH DAMAGE. 29 * 30 */ 31 32 #include <sys/cdefs.h> 33 __FBSDID("$FreeBSD$"); 34 35 #include <sys/param.h> 36 #include <sys/libkern.h> 37 #include <sys/kernel.h> 38 #include <sys/malloc.h> 39 40 #include <geom/geom.h> 41 #include <geom/vinum/geom_vinum_var.h> 42 #include <geom/vinum/geom_vinum.h> 43 #include <geom/vinum/geom_vinum_share.h> 44 45 static int gv_move_sd(struct gv_softc *, struct gctl_req *, 46 struct gv_sd *, char *, int); 47 48 void 49 gv_move(struct g_geom *gp, struct gctl_req *req) 50 { 51 struct gv_softc *sc; 52 struct gv_sd *s; 53 char buf[20], *destination, *object; 54 int *argc, err, *flags, i, type; 55 56 sc = gp->softc; 57 58 argc = gctl_get_paraml(req, "argc", sizeof(*argc)); 59 flags = gctl_get_paraml(req, "flags", sizeof(*flags)); 60 destination = gctl_get_param(req, "destination", NULL); 61 if (destination == NULL) { 62 gctl_error(req, "no destination given"); 63 return; 64 } 65 if (gv_object_type(sc, destination) != GV_TYPE_DRIVE) { 66 gctl_error(req, "destination '%s' is not a drive", destination); 67 return; 68 } 69 70 /* 71 * We start with 1 here, because argv[0] on the command line is the 72 * destination drive. 73 */ 74 for (i = 1; i < *argc; i++) { 75 snprintf(buf, sizeof(buf), "argv%d", i); 76 object = gctl_get_param(req, buf, NULL); 77 if (object == NULL) 78 continue; 79 80 type = gv_object_type(sc, object); 81 if (type != GV_TYPE_SD) { 82 gctl_error(req, "you can only move subdisks; " 83 "'%s' isn't one", object); 84 return; 85 } 86 87 s = gv_find_sd(sc, object); 88 if (s == NULL) { 89 gctl_error(req, "unknown subdisk '%s'", object); 90 return; 91 } 92 err = gv_move_sd(sc, req, s, destination, *flags); 93 if (err) 94 return; 95 } 96 97 gv_save_config_all(sc); 98 } 99 100 /* Move a subdisk. */ 101 static int 102 gv_move_sd(struct gv_softc *sc, struct gctl_req *req, struct gv_sd *cursd, char *destination, int flags) 103 { 104 struct gv_drive *d; 105 struct gv_sd *newsd, *s, *s2; 106 struct gv_plex *p; 107 struct g_consumer *cp; 108 char errstr[ERRBUFSIZ]; 109 int err; 110 111 g_topology_assert(); 112 KASSERT(cursd != NULL, ("gv_move_sd: NULL cursd")); 113 114 cp = cursd->consumer; 115 116 if (cp->acr || cp->acw || cp->ace) { 117 gctl_error(req, "subdisk '%s' is busy", cursd->name); 118 return (-1); 119 } 120 121 if (!(flags && GV_FLAG_F)) { 122 gctl_error(req, "-f flag not passed; move would be " 123 "destructive"); 124 return (-1); 125 } 126 127 d = gv_find_drive(sc, destination); 128 if (d == NULL) { 129 gctl_error(req, "destination drive '%s' not found", 130 destination); 131 return (-1); 132 } 133 134 if (d == cursd->drive_sc) { 135 gctl_error(req, "subdisk '%s' already on drive '%s'", 136 cursd->name, destination); 137 return (-1); 138 } 139 140 /* XXX: Does it have to be part of a plex? */ 141 p = gv_find_plex(sc, cursd->plex); 142 if (p == NULL) { 143 gctl_error(req, "subdisk '%s' is not part of a plex", 144 cursd->name); 145 return (-1); 146 } 147 148 /* Stale the old subdisk. */ 149 err = gv_set_sd_state(cursd, GV_SD_STALE, 150 GV_SETSTATE_FORCE | GV_SETSTATE_CONFIG); 151 if (err) { 152 gctl_error(req, "could not set the subdisk '%s' to state " 153 "'stale'", cursd->name); 154 return (err); 155 } 156 157 /* 158 * Create new subdisk. Ideally, we'd use gv_new_sd, but that requires 159 * us to create a string for it to parse, which is silly. 160 * TODO: maybe refactor gv_new_sd such that this is no longer the case. 161 */ 162 newsd = g_malloc(sizeof(struct gv_sd), M_WAITOK | M_ZERO); 163 newsd->plex_offset = cursd->plex_offset; 164 newsd->size = cursd->size; 165 newsd->drive_offset = -1; 166 strncpy(newsd->name, cursd->name, GV_MAXSDNAME); 167 strncpy(newsd->drive, destination, GV_MAXDRIVENAME); 168 strncpy(newsd->plex, cursd->plex, GV_MAXPLEXNAME); 169 newsd->state = GV_SD_STALE; 170 newsd->vinumconf = cursd->vinumconf; 171 172 err = gv_sd_to_drive(sc, d, newsd, errstr, ERRBUFSIZ); 173 if (err) { 174 /* XXX not enough free space? */ 175 gctl_error(req, errstr); 176 g_free(newsd); 177 return (err); 178 } 179 180 /* Replace the old sd by the new one. */ 181 g_detach(cp); 182 LIST_FOREACH_SAFE(s, &p->subdisks, in_plex, s2) { 183 if (s == cursd) { 184 p->sdcount--; 185 p->size -= s->size; 186 err = gv_rm_sd(sc, req, s, 0); 187 if (err) 188 return (err); 189 190 } 191 } 192 193 gv_sd_to_plex(p, newsd, 1); 194 195 /* Creates the new providers.... */ 196 gv_drive_modify(d); 197 198 /* And reconnect the consumer ... */ 199 newsd->consumer = cp; 200 err = g_attach(cp, newsd->provider); 201 if (err) { 202 g_destroy_consumer(cp); 203 gctl_error(req, "proposed move would create a loop in GEOM " 204 "config"); 205 return (err); 206 } 207 208 LIST_INSERT_HEAD(&sc->subdisks, newsd, sd); 209 210 gv_save_config_all(sc); 211 212 return (0); 213 } 214