partman.c revision 1.25 1 1.25 martin /* $NetBSD: partman.c,v 1.25 2018/12/13 12:28:25 martin Exp $ */
2 1.1 martin
3 1.1 martin /*
4 1.1 martin * Copyright 2012 Eugene Lozovoy
5 1.1 martin * All rights reserved.
6 1.1 martin *
7 1.1 martin * Redistribution and use in source and binary forms, with or without
8 1.1 martin * modification, are permitted provided that the following conditions
9 1.1 martin * are met:
10 1.1 martin * 1. Redistributions of source code must retain the above copyright
11 1.1 martin * notice, this list of conditions and the following disclaimer.
12 1.1 martin * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 martin * notice, this list of conditions and the following disclaimer in the
14 1.1 martin * documentation and/or other materials provided with the distribution.
15 1.1 martin * 3. The name of Eugene Lozovoy may not be used to endorse
16 1.1 martin * or promote products derived from this software without specific prior
17 1.1 martin * written permission.
18 1.1 martin *
19 1.1 martin * THIS SOFTWARE IS PROVIDED BY PIERMONT INFORMATION SYSTEMS INC. ``AS IS''
20 1.1 martin * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.1 martin * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.1 martin * ARE DISCLAIMED. IN NO EVENT SHALL PIERMONT INFORMATION SYSTEMS INC. BE
23 1.1 martin * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.1 martin * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.1 martin * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.1 martin * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.1 martin * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.1 martin * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
29 1.1 martin * THE POSSIBILITY OF SUCH DAMAGE.
30 1.1 martin *
31 1.1 martin */
32 1.1 martin
33 1.1 martin /* partman.c - extended partitioning */
34 1.1 martin
35 1.1 martin #include <fcntl.h>
36 1.1 martin #include <errno.h>
37 1.1 martin #include <libgen.h>
38 1.1 martin #include <stdio.h>
39 1.1 martin #include <stdlib.h>
40 1.1 martin #include <unistd.h>
41 1.1 martin #include <util.h>
42 1.1 martin
43 1.1 martin #include "defs.h"
44 1.1 martin #include "msg_defs.h"
45 1.1 martin #include "menu_defs.h"
46 1.1 martin
47 1.4 riz /* flags whether to offer the respective options (depending on helper
48 1.1 martin programs available on install media */
49 1.9 martin int have_raid, have_vnd, have_cgd, have_lvm, have_gpt, have_dk;
50 1.1 martin
51 1.4 riz /* XXX: replace all MAX_* defines with vars that depend on kernel settings */
52 1.1 martin #define MAX_ENTRIES 96
53 1.1 martin
54 1.1 martin #define MAX_RAID 8
55 1.1 martin #define MAX_IN_RAID 48
56 1.1 martin typedef struct raids_t {
57 1.1 martin int enabled;
58 1.1 martin int blocked;
59 1.1 martin int node;
60 1.1 martin char pm_name[MAX_IN_RAID][SSTRSIZE];
61 1.1 martin int pm_part[MAX_IN_RAID];
62 1.1 martin int pm_is_spare[MAX_IN_RAID];
63 1.1 martin int numRow, numCol, numSpare;
64 1.1 martin int sectPerSU, SUsPerParityUnit, SUsPerReconUnit, raid_level;
65 1.1 martin uint total_size;
66 1.1 martin pm_devs_t *pm[MAX_IN_RAID];
67 1.1 martin } raids_t;
68 1.15 christos raids_t *raids;
69 1.1 martin
70 1.1 martin #define MAX_VND 4
71 1.1 martin typedef struct vnds_t {
72 1.1 martin int enabled;
73 1.1 martin int blocked;
74 1.1 martin int node;
75 1.1 martin char filepath[STRSIZE];
76 1.1 martin int size;
77 1.1 martin int readonly;
78 1.1 martin int is_exist;
79 1.1 martin int manual_geom;
80 1.1 martin int secsize, nsectors, ntracks, ncylinders;
81 1.1 martin int pm_part; /* Used only for */
82 1.4 riz pm_devs_t *pm; /* referring device */
83 1.1 martin } vnds_t;
84 1.15 christos vnds_t *vnds;
85 1.1 martin
86 1.1 martin #define MAX_CGD 4
87 1.1 martin typedef struct cgds_t {
88 1.1 martin int enabled;
89 1.1 martin int blocked;
90 1.1 martin int node;
91 1.1 martin pm_devs_t *pm;
92 1.1 martin char pm_name[SSTRSIZE];
93 1.1 martin int pm_part;
94 1.1 martin const char *keygen_type;
95 1.1 martin const char *verify_type;
96 1.1 martin const char *enc_type;
97 1.1 martin const char *iv_type;
98 1.1 martin int key_size;
99 1.1 martin } cgds_t;
100 1.15 christos cgds_t *cgds;
101 1.1 martin
102 1.1 martin #define MAX_LVM_VG 16
103 1.1 martin #define MAX_LVM_PV 255
104 1.1 martin #define MAX_LVM_LV 255
105 1.1 martin typedef struct pv_t {
106 1.1 martin pm_devs_t *pm;
107 1.1 martin char pm_name[SSTRSIZE];
108 1.1 martin int pm_part;
109 1.1 martin int metadatasize;
110 1.1 martin int metadatacopies;
111 1.1 martin int labelsector;
112 1.1 martin int setphysicalvolumesize;
113 1.1 martin } pv_t;
114 1.1 martin typedef struct lv_t {
115 1.1 martin int blocked;
116 1.1 martin int size;
117 1.1 martin char name[SSTRSIZE];
118 1.1 martin int readonly;
119 1.1 martin int contiguous;
120 1.1 martin char extents[SSTRSIZE];
121 1.1 martin int minor;
122 1.1 martin int mirrors;
123 1.1 martin int regionsize;
124 1.1 martin int persistent;
125 1.1 martin int readahead;
126 1.1 martin int stripes;
127 1.1 martin int stripesize;
128 1.1 martin int zero;
129 1.1 martin } lv_t;
130 1.1 martin typedef struct lvms_t {
131 1.1 martin int enabled;
132 1.1 martin int blocked;
133 1.1 martin char name[SSTRSIZE];
134 1.1 martin int maxlogicalvolumes;
135 1.1 martin int maxphysicalvolumes;
136 1.1 martin int physicalextentsize;
137 1.1 martin uint total_size;
138 1.1 martin pv_t pv[MAX_LVM_PV];
139 1.1 martin lv_t lv[MAX_LVM_LV];
140 1.1 martin } lvms_t;
141 1.15 christos lvms_t *lvms;
142 1.1 martin
143 1.1 martin typedef struct structinfo_t {
144 1.1 martin int max;
145 1.1 martin uint entry_size;
146 1.1 martin uint parent_size;
147 1.1 martin void *entry_first;
148 1.1 martin void *entry_enabled;
149 1.1 martin void *entry_blocked;
150 1.1 martin void *entry_node;
151 1.1 martin } structinfo_t;
152 1.1 martin structinfo_t raids_t_info, vnds_t_info, cgds_t_info, lvms_t_info, lv_t_info;
153 1.1 martin
154 1.1 martin typedef struct pm_upddevlist_adv_t {
155 1.1 martin const char *create_msg;
156 1.1 martin int pe_type;
157 1.1 martin structinfo_t *s;
158 1.1 martin int sub_num;
159 1.1 martin struct pm_upddevlist_adv_t *sub;
160 1.1 martin } pm_upddevlist_adv_t;
161 1.1 martin
162 1.1 martin #define MAX_MNTS 48
163 1.1 martin struct {
164 1.1 martin char dev[STRSIZE];
165 1.1 martin const char *mnt_opts, *on;
166 1.15 christos } *mnts;
167 1.1 martin
168 1.4 riz int cursel; /* Number of selected entry in main menu */
169 1.1 martin int changed; /* flag indicating that we have unsaved changes */
170 1.1 martin int raid_curspare; /* XXX: replace by true way */
171 1.1 martin
172 1.1 martin enum { /* RAIDframe menu enum */
173 1.1 martin PMR_MENU_DEVS, PMR_MENU_DEVSSPARE, PMR_MENU_RAIDLEVEL, PMR_MENU_NUMROW,
174 1.1 martin PMR_MENU_NUMCOL, PMR_MENU_NUMSPARE, PMR_MENU_SECTPERSU, PMR_MENU_SUSPERPARITYUNIT,
175 1.1 martin PMR_MENU_SUSPERRECONUNIT, PMR_MENU_REMOVE, PMR_MENU_END
176 1.1 martin };
177 1.1 martin
178 1.1 martin enum { /* VND menu enum */
179 1.1 martin PMV_MENU_FILEPATH, PMV_MENU_EXIST, PMV_MENU_SIZE, PMV_MENU_RO, PMV_MENU_MGEOM,
180 1.1 martin PMV_MENU_SECSIZE, PMV_MENU_NSECTORS, PMV_MENU_NTRACKS, PMV_MENU_NCYLINDERS,
181 1.1 martin PMV_MENU_REMOVE, PMV_MENU_END
182 1.1 martin };
183 1.1 martin
184 1.1 martin enum { /* CGD menu enum */
185 1.1 martin PMC_MENU_DEV, PMC_MENU_ENCTYPE, PMC_MENU_KEYSIZE, PMC_MENU_IVTYPE,
186 1.1 martin PMC_MENU_KEYGENTYPE, PMC_MENU_VERIFYTYPE, PMC_MENU_REMOVE, PMC_MENU_END
187 1.1 martin };
188 1.1 martin
189 1.1 martin enum { /* LVM menu enum */
190 1.1 martin PML_MENU_PV, PML_MENU_NAME, PML_MENU_MAXLOGICALVOLUMES,
191 1.1 martin PML_MENU_MAXPHYSICALVOLUMES, PML_MENU_PHYSICALEXTENTSIZE,
192 1.1 martin PML_MENU_REMOVE, PML_MENU_END
193 1.1 martin };
194 1.1 martin
195 1.1 martin enum { /* LVM submenu (logical volumes) enum */
196 1.1 martin PMLV_MENU_NAME, PMLV_MENU_SIZE, PMLV_MENU_READONLY, PMLV_MENU_CONTIGUOUS,
197 1.1 martin PMLV_MENU_EXTENTS, PMLV_MENU_MINOR, PMLV_MENU_PERSISTENT,
198 1.1 martin PMLV_MENU_MIRRORS, PMLV_MENU_REGIONSIZE, PMLV_MENU_READAHEAD,
199 1.1 martin PMLV_MENU_STRIPES, PMLV_MENU_STRIPESIZE, PMLV_MENU_ZERO,
200 1.1 martin PMLV_MENU_REMOVE, PMLV_MENU_END
201 1.1 martin };
202 1.1 martin
203 1.1 martin part_entry_t pm_dev_list(int);
204 1.1 martin static int pm_raid_disk_add(menudesc *, void *);
205 1.1 martin static int pm_raid_disk_del(menudesc *, void *);
206 1.1 martin static int pm_cgd_disk_set(cgds_t *, part_entry_t *);
207 1.1 martin static int pm_mount(pm_devs_t *, int);
208 1.1 martin static int pm_upddevlist(menudesc *, void *);
209 1.1 martin static void pm_select(pm_devs_t *);
210 1.1 martin
211 1.1 martin /* Universal menu for RAID/VND/CGD/LVM entry edit */
212 1.1 martin static int
213 1.1 martin pm_edit(int menu_entries_count, void (*menu_fmt)(menudesc *, int, void *),
214 1.1 martin int (*action)(menudesc *, void *), int (*check_fun)(void *),
215 1.1 martin void (*entry_init)(void *, void *), void *entry_init_arg,
216 1.1 martin void *dev_ptr, int dev_ptr_delta, structinfo_t *s)
217 1.1 martin {
218 1.1 martin int i, ok = 0;
219 1.1 martin
220 1.1 martin if (dev_ptr == NULL) {
221 1.1 martin /* We should create new device */
222 1.1 martin for (i = 0; i < s->max && !ok; i++)
223 1.1 martin if (*(int*)((char*)s->entry_enabled + dev_ptr_delta + s->entry_size * i) == 0) {
224 1.1 martin dev_ptr = (char*)s->entry_first + dev_ptr_delta + s->entry_size * i;
225 1.1 martin entry_init(dev_ptr, entry_init_arg);
226 1.1 martin ok = 1;
227 1.1 martin }
228 1.1 martin if (!ok) {
229 1.1 martin /* We do not have free device slots */
230 1.22 joerg process_menu(MENU_ok, __UNCONST(MSG_limitcount));
231 1.1 martin return -1;
232 1.1 martin }
233 1.1 martin }
234 1.1 martin
235 1.1 martin menu_ent menu_entries[menu_entries_count];
236 1.1 martin for (i = 0; i < menu_entries_count - 1; i++)
237 1.23 martin menu_entries[i] = (menu_ent) { .opt_menu=OPT_NOMENU,
238 1.23 martin .opt_action=action };
239 1.23 martin menu_entries[i] = (menu_ent) { .opt_name=MSG_fremove,
240 1.23 martin .opt_menu=OPT_NOMENU,
241 1.23 martin .opt_flags=OPT_EXIT,
242 1.23 martin .opt_action=action };
243 1.1 martin
244 1.1 martin int menu_no = -1;
245 1.1 martin menu_no = new_menu(NULL, menu_entries, menu_entries_count,
246 1.1 martin -1, -1, 0, 40, MC_NOCLEAR | MC_SCROLL,
247 1.1 martin NULL, menu_fmt, NULL, NULL, MSG_DONE);
248 1.1 martin
249 1.1 martin process_menu(menu_no, dev_ptr);
250 1.1 martin free_menu(menu_no);
251 1.1 martin
252 1.1 martin return check_fun(dev_ptr);
253 1.1 martin }
254 1.1 martin
255 1.1 martin static void
256 1.1 martin pm_getdevstring(char *buf, int len, pm_devs_t *pm_cur, int num)
257 1.1 martin {
258 1.1 martin int i;
259 1.1 martin
260 1.1 martin if (pm_cur->isspecial)
261 1.1 martin snprintf(buf, len, "%s", pm_cur->diskdev);
262 1.1 martin else if (num + 'a' < 'a' || num + 'a' > 'a' + MAXPARTITIONS)
263 1.1 martin snprintf(buf, len, "%sd", pm_cur->diskdev);
264 1.1 martin else if (pm_cur->gpt) {
265 1.1 martin for (i = 0; i < MAX_WEDGES; i++)
266 1.1 martin if (wedges[i].pm == pm_cur &&
267 1.1 martin wedges[i].ptn == num)
268 1.1 martin snprintf(buf, len, "dk%d", i); // XXX: xxx
269 1.1 martin } else
270 1.1 martin snprintf(buf, len, "%s%c", pm_cur->diskdev, num + 'a');
271 1.1 martin
272 1.1 martin return;
273 1.1 martin }
274 1.1 martin
275 1.1 martin /* Show filtered partitions menu */
276 1.1 martin part_entry_t
277 1.1 martin pm_dev_list(int type)
278 1.1 martin {
279 1.1 martin int dev_num = -1, num_devs = 0;
280 1.1 martin int i, ok;
281 1.1 martin int menu_no;
282 1.1 martin menu_ent menu_entries[MAX_DISKS*MAXPARTITIONS];
283 1.1 martin part_entry_t disk_entries[MAX_DISKS*MAXPARTITIONS];
284 1.1 martin pm_devs_t *pm_i;
285 1.1 martin
286 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
287 1.1 martin for (i = 0; i < MAXPARTITIONS; i++) {
288 1.1 martin ok = 0;
289 1.1 martin switch (type) {
290 1.1 martin case PM_RAID_T:
291 1.1 martin if (pm_i->bsdlabel[i].pi_fstype == FS_RAID)
292 1.1 martin ok = 1;
293 1.1 martin break;
294 1.1 martin case PM_CGD_T:
295 1.1 martin if (pm_i->bsdlabel[i].pi_fstype == FS_CGD)
296 1.1 martin ok = 1;
297 1.1 martin break;
298 1.1 martin case PM_LVM_T:
299 1.1 martin if (pm_i->bsdlabel[i].lvmpv)
300 1.1 martin ok = 1;
301 1.1 martin break;
302 1.1 martin }
303 1.1 martin if (ok && pm_partusage(pm_i, i, 0) == 0) {
304 1.1 martin disk_entries[num_devs].dev_ptr = pm_i;
305 1.1 martin disk_entries[num_devs].dev_num = i;
306 1.1 martin pm_getdevstring(disk_entries[num_devs].fullname, SSTRSIZE, pm_i, i);
307 1.1 martin
308 1.1 martin menu_entries[num_devs] = (struct menu_ent) {
309 1.1 martin .opt_name = disk_entries[num_devs].fullname,
310 1.1 martin .opt_action = set_menu_select,
311 1.1 martin .opt_menu = OPT_NOMENU,
312 1.1 martin .opt_flags = OPT_EXIT,
313 1.1 martin };
314 1.1 martin num_devs++;
315 1.1 martin }
316 1.1 martin }
317 1.1 martin
318 1.1 martin menu_no = new_menu(MSG_avdisks,
319 1.1 martin menu_entries, num_devs, -1, -1, (num_devs+1<3)?3:num_devs+1, 13,
320 1.1 martin MC_SCROLL | MC_NOCLEAR, NULL, NULL, NULL, NULL, NULL);
321 1.1 martin if (menu_no == -1)
322 1.1 martin return (part_entry_t) { .retvalue = -1, };
323 1.1 martin process_menu(menu_no, &dev_num);
324 1.1 martin free_menu(menu_no);
325 1.1 martin
326 1.1 martin if (dev_num < 0 || dev_num >= num_devs)
327 1.1 martin return (part_entry_t) { .retvalue = -1, };
328 1.1 martin
329 1.1 martin disk_entries[dev_num].retvalue = dev_num;
330 1.1 martin return disk_entries[dev_num];
331 1.1 martin }
332 1.1 martin
333 1.1 martin /* Get unused raid*, cgd* or vnd* device */
334 1.1 martin static int
335 1.1 martin pm_manage_getfreenode(void *node, const char *d, structinfo_t *s)
336 1.1 martin {
337 1.1 martin int i, ii, ok;
338 1.1 martin char buf[SSTRSIZE];
339 1.1 martin pm_devs_t *pm_i;
340 1.1 martin
341 1.1 martin *(int*)node = -1;
342 1.1 martin for (i = 0; i < s->max; i++) {
343 1.1 martin ok = 1;
344 1.1 martin /* Check that node is not already reserved */
345 1.1 martin for (ii = 0; ii < s->max; ii++)
346 1.1 martin if (*(int*)((char*)s->entry_node + s->entry_size * ii) == i) {
347 1.1 martin ok = 0;
348 1.1 martin break;
349 1.1 martin }
350 1.1 martin if (! ok)
351 1.1 martin continue;
352 1.1 martin /* Check that node is not in the device list */
353 1.1 martin snprintf(buf, SSTRSIZE, "%s%d", d, i);
354 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
355 1.1 martin if (! strcmp(pm_i->diskdev, buf)) {
356 1.1 martin ok = 0;
357 1.1 martin break;
358 1.1 martin }
359 1.1 martin if (ok) {
360 1.1 martin *(int*)node = i;
361 1.1 martin return i;
362 1.1 martin }
363 1.1 martin }
364 1.22 joerg process_menu(MENU_ok, __UNCONST(MSG_nofreedev));
365 1.1 martin return -1;
366 1.1 martin }
367 1.1 martin
368 1.1 martin /***
369 1.4 riz RAIDs
370 1.4 riz ***/
371 1.1 martin
372 1.1 martin static void
373 1.1 martin pm_raid_menufmt(menudesc *m, int opt, void *arg)
374 1.1 martin {
375 1.1 martin int i, ok = 0;
376 1.1 martin char buf[STRSIZE]; buf[0] = '\0';
377 1.1 martin raids_t *dev_ptr = ((part_entry_t *)arg)[opt].dev_ptr;
378 1.1 martin
379 1.1 martin if (dev_ptr->enabled == 0)
380 1.1 martin return;
381 1.1 martin for (i = 0; i < MAX_IN_RAID; i++)
382 1.1 martin if (dev_ptr->pm[i] != NULL) {
383 1.15 christos strlcat(buf, dev_ptr->pm_name[i], STRSIZE);
384 1.15 christos strlcat(buf, " ", STRSIZE);
385 1.1 martin ok = 1;
386 1.1 martin }
387 1.1 martin if (ok)
388 1.1 martin wprintw(m->mw, msg_string(MSG_raid_menufmt), dev_ptr->node,
389 1.1 martin dev_ptr->raid_level, buf, dev_ptr->total_size);
390 1.1 martin else
391 1.1 martin wprintw(m->mw, "%s", msg_string(MSG_raid_err_menufmt));
392 1.1 martin return;
393 1.1 martin }
394 1.1 martin
395 1.1 martin static void
396 1.1 martin pm_raid_edit_menufmt(menudesc *m, int opt, void *arg)
397 1.1 martin {
398 1.1 martin int i;
399 1.1 martin char buf[STRSIZE]; buf[0] = '\0';
400 1.1 martin raids_t *dev_ptr = arg;
401 1.1 martin
402 1.1 martin switch (opt) {
403 1.1 martin case PMR_MENU_DEVS:
404 1.1 martin for (i = 0; i < MAX_IN_RAID; i++)
405 1.1 martin if (dev_ptr->pm[i] != NULL && dev_ptr->pm_is_spare[i] == 0)
406 1.1 martin snprintf(buf, STRSIZE, "%s %s", buf, dev_ptr->pm_name[i]);
407 1.1 martin wprintw(m->mw, msg_string(MSG_raid_disks_fmt), buf);
408 1.1 martin break;
409 1.1 martin case PMR_MENU_DEVSSPARE:
410 1.1 martin for (i = 0; i < MAX_IN_RAID; i++)
411 1.1 martin if (dev_ptr->pm[i] != NULL && dev_ptr->pm_is_spare[i] != 0)
412 1.1 martin snprintf(buf, STRSIZE, "%s %s", buf, dev_ptr->pm_name[i]);
413 1.1 martin wprintw(m->mw, msg_string(MSG_raid_spares_fmt), buf);
414 1.1 martin break;
415 1.1 martin case PMR_MENU_RAIDLEVEL:
416 1.1 martin wprintw(m->mw, msg_string(MSG_raid_level_fmt), dev_ptr->raid_level);
417 1.1 martin break;
418 1.1 martin case PMR_MENU_NUMROW:
419 1.1 martin wprintw(m->mw, msg_string(MSG_raid_numrow_fmt), dev_ptr->numRow);
420 1.1 martin break;
421 1.1 martin case PMR_MENU_NUMCOL:
422 1.1 martin wprintw(m->mw, msg_string(MSG_raid_numcol_fmt), dev_ptr->numCol);
423 1.1 martin break;
424 1.1 martin case PMR_MENU_NUMSPARE:
425 1.1 martin wprintw(m->mw, msg_string(MSG_raid_numspare_fmt), dev_ptr->numSpare);
426 1.1 martin break;
427 1.1 martin case PMR_MENU_SECTPERSU:
428 1.1 martin wprintw(m->mw, msg_string(MSG_raid_sectpersu_fmt), dev_ptr->sectPerSU);
429 1.1 martin break;
430 1.1 martin case PMR_MENU_SUSPERPARITYUNIT:
431 1.1 martin wprintw(m->mw, msg_string(MSG_raid_superpar_fmt), dev_ptr->SUsPerParityUnit);
432 1.1 martin break;
433 1.1 martin case PMR_MENU_SUSPERRECONUNIT:
434 1.1 martin wprintw(m->mw, msg_string(MSG_raid_superrec_fmt), dev_ptr->SUsPerReconUnit);
435 1.1 martin break;
436 1.1 martin }
437 1.1 martin return;
438 1.1 martin }
439 1.1 martin
440 1.1 martin static int
441 1.1 martin pm_raid_set_value(menudesc *m, void *arg)
442 1.1 martin {
443 1.1 martin int retvalue = -1;
444 1.1 martin int *out_var = NULL;
445 1.1 martin char buf[SSTRSIZE];
446 1.1 martin const char *msg_to_show = NULL;
447 1.1 martin raids_t *dev_ptr = arg;
448 1.1 martin
449 1.1 martin static menu_ent menuent_disk_adddel[] = {
450 1.23 martin { .opt_name=MSG_add, .opt_menu=OPT_NOMENU, .opt_flags=OPT_EXIT,
451 1.23 martin .opt_action=pm_raid_disk_add },
452 1.23 martin { .opt_name=MSG_remove, .opt_menu=OPT_NOMENU, .opt_flags=OPT_EXIT,
453 1.23 martin .opt_action=pm_raid_disk_del }
454 1.1 martin };
455 1.1 martin static int menu_disk_adddel = -1;
456 1.1 martin if (menu_disk_adddel == -1) {
457 1.1 martin menu_disk_adddel = new_menu(NULL, menuent_disk_adddel, nelem(menuent_disk_adddel),
458 1.1 martin -1, -1, 0, 10, MC_NOCLEAR, NULL, NULL, NULL, NULL, NULL);
459 1.1 martin }
460 1.1 martin
461 1.1 martin switch (m->cursel) {
462 1.1 martin case PMR_MENU_DEVS:
463 1.1 martin raid_curspare = 0;
464 1.1 martin process_menu(menu_disk_adddel, dev_ptr);
465 1.1 martin return 0;
466 1.1 martin case PMR_MENU_DEVSSPARE:
467 1.1 martin raid_curspare = 1;
468 1.1 martin process_menu(menu_disk_adddel, dev_ptr);
469 1.1 martin return 0;
470 1.1 martin case PMR_MENU_RAIDLEVEL:
471 1.1 martin process_menu(MENU_raidlevel, &retvalue);
472 1.1 martin if (retvalue >= 0)
473 1.1 martin dev_ptr->raid_level = retvalue;
474 1.1 martin return 0;
475 1.1 martin case PMR_MENU_NUMROW:
476 1.22 joerg process_menu(MENU_ok, __UNCONST(MSG_raid_nomultidim));
477 1.1 martin return 0;
478 1.12 dholland #if 0 /* notyet */
479 1.1 martin msg_to_show = MSG_raid_numrow_ask;
480 1.1 martin out_var = &(dev_ptr->numRow);
481 1.1 martin break;
482 1.12 dholland #endif
483 1.1 martin case PMR_MENU_NUMCOL:
484 1.1 martin msg_to_show = MSG_raid_numcol_ask;
485 1.1 martin out_var = &(dev_ptr->numCol);
486 1.1 martin break;
487 1.1 martin case PMR_MENU_NUMSPARE:
488 1.1 martin msg_to_show = MSG_raid_numspare_ask;
489 1.1 martin out_var = &(dev_ptr->numSpare);
490 1.1 martin break;
491 1.1 martin case PMR_MENU_SECTPERSU:
492 1.1 martin msg_to_show = MSG_raid_sectpersu_ask;
493 1.1 martin out_var = &(dev_ptr->sectPerSU);
494 1.1 martin break;
495 1.1 martin case PMR_MENU_SUSPERPARITYUNIT:
496 1.1 martin msg_to_show = MSG_raid_superpar_ask;
497 1.1 martin out_var = &(dev_ptr->SUsPerParityUnit);
498 1.1 martin break;
499 1.1 martin case PMR_MENU_SUSPERRECONUNIT:
500 1.1 martin msg_to_show = MSG_raid_superrec_ask;
501 1.1 martin out_var = &(dev_ptr->SUsPerReconUnit);
502 1.1 martin break;
503 1.1 martin case PMR_MENU_REMOVE:
504 1.1 martin dev_ptr->enabled = 0;
505 1.1 martin return 0;
506 1.1 martin }
507 1.1 martin if (out_var == NULL || msg_to_show == NULL)
508 1.1 martin return -1;
509 1.1 martin snprintf(buf, SSTRSIZE, "%d", *out_var);
510 1.1 martin msg_prompt_win(msg_to_show, -1, 18, 0, 0, buf, buf, SSTRSIZE);
511 1.1 martin if (atoi(buf) >= 0)
512 1.1 martin *out_var = atoi(buf);
513 1.1 martin return 0;
514 1.1 martin }
515 1.1 martin
516 1.1 martin static void
517 1.1 martin pm_raid_init(void *arg, void *none)
518 1.1 martin {
519 1.1 martin raids_t *dev_ptr = arg;
520 1.1 martin memset(dev_ptr, 0, sizeof(*dev_ptr));
521 1.1 martin *dev_ptr = (struct raids_t) {
522 1.1 martin .enabled = 1,
523 1.1 martin .blocked = 0,
524 1.1 martin .sectPerSU = 32,
525 1.1 martin .SUsPerParityUnit = 1,
526 1.1 martin .SUsPerReconUnit = 1,
527 1.1 martin };
528 1.1 martin return;
529 1.1 martin }
530 1.1 martin
531 1.1 martin static int
532 1.1 martin pm_raid_check(void *arg)
533 1.1 martin {
534 1.1 martin int i, dev_num = 0, min_size = 0, cur_size = 0;
535 1.1 martin raids_t *dev_ptr = arg;
536 1.1 martin
537 1.1 martin if (dev_ptr->blocked)
538 1.1 martin return 0;
539 1.1 martin for (i = 0; i < MAX_IN_RAID; i++)
540 1.1 martin if (dev_ptr->pm[i] != NULL) {
541 1.1 martin cur_size = dev_ptr->pm[i]->bsdlabel[dev_ptr->pm_part[i]].pi_size /
542 1.1 martin (MEG / dev_ptr->pm[i]->sectorsize);
543 1.1 martin if (cur_size < min_size || dev_num == 0)
544 1.1 martin min_size = cur_size;
545 1.1 martin if (!dev_ptr->pm_is_spare[i])
546 1.1 martin dev_num++;
547 1.1 martin }
548 1.4 riz /* Calculate sum of available space */
549 1.1 martin if (dev_num > 0) {
550 1.1 martin switch (dev_ptr->raid_level) {
551 1.1 martin case 0:
552 1.1 martin dev_ptr->total_size = min_size * dev_num;
553 1.1 martin break;
554 1.1 martin case 1:
555 1.1 martin dev_ptr->total_size = min_size;
556 1.1 martin break;
557 1.1 martin case 4:
558 1.1 martin case 5:
559 1.1 martin dev_ptr->total_size = min_size * (dev_num - 1);
560 1.1 martin break;
561 1.1 martin }
562 1.1 martin pm_manage_getfreenode(&(dev_ptr->node), "raid", &raids_t_info);
563 1.1 martin if (dev_ptr->node < 0)
564 1.1 martin dev_ptr->enabled = 0;
565 1.1 martin }
566 1.1 martin else
567 1.1 martin dev_ptr->enabled = 0;
568 1.1 martin return dev_ptr->enabled;
569 1.1 martin }
570 1.1 martin
571 1.1 martin static int
572 1.1 martin pm_raid_disk_add(menudesc *m, void *arg)
573 1.1 martin {
574 1.1 martin int i;
575 1.1 martin raids_t *dev_ptr = arg;
576 1.1 martin part_entry_t disk_entrie = pm_dev_list(PM_RAID_T);
577 1.1 martin if (disk_entrie.retvalue < 0)
578 1.1 martin return disk_entrie.retvalue;
579 1.1 martin
580 1.1 martin for (i = 0; i < MAX_IN_RAID; i++)
581 1.1 martin if (dev_ptr->pm[i] == NULL) {
582 1.1 martin dev_ptr->pm[i] = disk_entrie.dev_ptr;
583 1.1 martin dev_ptr->pm_part[i] = disk_entrie.dev_num;
584 1.1 martin dev_ptr->pm_is_spare[i] = raid_curspare;
585 1.1 martin strlcpy(dev_ptr->pm_name[i], disk_entrie.fullname, SSTRSIZE);
586 1.1 martin if (raid_curspare)
587 1.1 martin dev_ptr->numSpare++;
588 1.1 martin else
589 1.1 martin dev_ptr->numCol++;
590 1.1 martin dev_ptr->numRow = 1;
591 1.1 martin break;
592 1.1 martin }
593 1.1 martin return 0;
594 1.1 martin }
595 1.1 martin
596 1.1 martin static int
597 1.1 martin pm_raid_disk_del(menudesc *m, void *arg)
598 1.1 martin {
599 1.1 martin int retvalue = -1, num_devs = 0;
600 1.1 martin int i, pm_cur;
601 1.1 martin int menu_no;
602 1.1 martin raids_t *dev_ptr = arg;
603 1.1 martin menu_ent menu_entries[MAX_IN_RAID];
604 1.1 martin part_entry_t submenu_args[MAX_IN_RAID];
605 1.1 martin
606 1.1 martin for (i = 0; i < MAX_IN_RAID; i++) {
607 1.1 martin if (dev_ptr->pm[i] == NULL ||
608 1.1 martin dev_ptr->pm_is_spare[i] != raid_curspare)
609 1.1 martin continue;
610 1.1 martin menu_entries[num_devs] = (struct menu_ent) {
611 1.1 martin .opt_name = dev_ptr->pm_name[i],
612 1.1 martin .opt_action = set_menu_select,
613 1.1 martin .opt_menu = OPT_NOMENU,
614 1.1 martin .opt_flags = OPT_EXIT,
615 1.1 martin };
616 1.1 martin submenu_args[num_devs].dev_num = i;
617 1.1 martin num_devs++;
618 1.1 martin }
619 1.1 martin
620 1.1 martin menu_no = new_menu(MSG_raid_disks,
621 1.1 martin menu_entries, num_devs, -1, -1, (num_devs+1<3)?3:num_devs+1, 13,
622 1.1 martin MC_SCROLL | MC_NOCLEAR, NULL, NULL, NULL, NULL, NULL);
623 1.1 martin if (menu_no == -1)
624 1.1 martin return -1;
625 1.1 martin process_menu(menu_no, &retvalue);
626 1.1 martin free_menu(menu_no);
627 1.1 martin
628 1.1 martin if (retvalue < 0 || retvalue >= num_devs)
629 1.1 martin return -1;
630 1.1 martin
631 1.1 martin pm_cur = submenu_args[retvalue].dev_num;
632 1.1 martin
633 1.1 martin if (dev_ptr->pm_is_spare[pm_cur])
634 1.1 martin dev_ptr->numSpare--;
635 1.1 martin else
636 1.1 martin dev_ptr->numCol--;
637 1.1 martin dev_ptr->numRow = (dev_ptr->numCol)?1:0;
638 1.1 martin dev_ptr->pm[pm_cur] = NULL;
639 1.1 martin
640 1.1 martin return 0;
641 1.1 martin }
642 1.1 martin
643 1.1 martin static int
644 1.1 martin pm_raid_commit(void)
645 1.1 martin {
646 1.1 martin int i, ii;
647 1.1 martin FILE *f;
648 1.1 martin char f_name[STRSIZE];
649 1.1 martin
650 1.1 martin for (i = 0; i < MAX_RAID; i++) {
651 1.1 martin if (! pm_raid_check(&raids[i]))
652 1.1 martin continue;
653 1.1 martin
654 1.1 martin /* Generating configure file for our raid */
655 1.1 martin snprintf(f_name, SSTRSIZE, "/tmp/raid.%d.conf", raids[i].node);
656 1.1 martin f = fopen(f_name, "w");
657 1.1 martin if (f == NULL) {
658 1.1 martin endwin();
659 1.1 martin (void)fprintf(stderr, "Could not open %s for writing\n", f_name);
660 1.1 martin if (logfp)
661 1.1 martin (void)fprintf(logfp, "Could not open %s for writing\n", f_name);
662 1.1 martin return 1;
663 1.1 martin }
664 1.1 martin scripting_fprintf(NULL, "cat <<EOF >%s\n", f_name);
665 1.1 martin scripting_fprintf(f, "START array\n%d %d %d\n", raids[i].numRow,
666 1.1 martin raids[i].numCol, raids[i].numSpare);
667 1.1 martin
668 1.1 martin scripting_fprintf(f, "\nSTART disks\n");
669 1.1 martin for (ii = 0; ii < MAX_IN_RAID; ii++)
670 1.1 martin if (raids[i].pm[ii] != NULL && raids[i].pm_is_spare[ii] == 0) {
671 1.1 martin scripting_fprintf(f, "/dev/%s\n", raids[i].pm_name[ii]);
672 1.1 martin }
673 1.1 martin
674 1.1 martin scripting_fprintf(f, "\nSTART spare\n");
675 1.1 martin for (ii = 0; ii < MAX_IN_RAID; ii++)
676 1.1 martin if (raids[i].pm[ii] != NULL && raids[i].pm_is_spare[ii] != 0) {
677 1.1 martin scripting_fprintf(f, "/dev/%s\n", raids[i].pm_name[ii]);
678 1.1 martin }
679 1.1 martin
680 1.1 martin scripting_fprintf(f, "\nSTART layout\n%d %d %d %d\n", raids[i].sectPerSU,
681 1.1 martin raids[i].SUsPerParityUnit, raids[i].SUsPerReconUnit,
682 1.1 martin raids[i].raid_level);
683 1.1 martin
684 1.1 martin scripting_fprintf(f, "\nSTART queue\nfifo 100\n\n");
685 1.1 martin scripting_fprintf(NULL, "EOF\n");
686 1.1 martin fclose (f);
687 1.1 martin fflush(NULL);
688 1.1 martin
689 1.1 martin /* Raid initialization */
690 1.1 martin if (
691 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS, "raidctl -C %s raid%d",
692 1.1 martin f_name, raids[i].node) == 0 &&
693 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS, "raidctl -I %d raid%d",
694 1.1 martin rand(), raids[i].node) == 0 &&
695 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS, "raidctl -vi raid%d",
696 1.1 martin raids[i].node) == 0 &&
697 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS, "raidctl -v -A yes raid%d",
698 1.1 martin raids[i].node) == 0
699 1.1 martin ) {
700 1.1 martin raids[i].blocked = 1; /* RAID creation done, remove it from list to
701 1.7 snj prevent its repeated reinitialization */
702 1.1 martin for (ii = 0; ii < MAX_IN_RAID; ii++)
703 1.1 martin if (raids[i].pm[ii] != NULL)
704 1.1 martin raids[i].pm[ii]->blocked++;
705 1.1 martin }
706 1.1 martin }
707 1.1 martin return 0;
708 1.1 martin }
709 1.1 martin
710 1.1 martin /***
711 1.4 riz VND
712 1.4 riz ***/
713 1.1 martin
714 1.1 martin static void
715 1.1 martin pm_vnd_menufmt(menudesc *m, int opt, void *arg)
716 1.1 martin {
717 1.1 martin vnds_t *dev_ptr = ((part_entry_t *)arg)[opt].dev_ptr;
718 1.1 martin
719 1.1 martin if (dev_ptr->enabled == 0)
720 1.1 martin return;
721 1.1 martin if (strlen(dev_ptr->filepath) < 1)
722 1.1 martin wprintw(m->mw, "%s", msg_string(MSG_vnd_err_menufmt));
723 1.1 martin else if (dev_ptr->is_exist)
724 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_assgn_menufmt),
725 1.1 martin dev_ptr->node, dev_ptr->filepath);
726 1.1 martin else
727 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_menufmt),
728 1.1 martin dev_ptr->node, dev_ptr->filepath, dev_ptr->size);
729 1.1 martin return;
730 1.1 martin }
731 1.1 martin
732 1.1 martin static void
733 1.1 martin pm_vnd_edit_menufmt(menudesc *m, int opt, void *arg)
734 1.1 martin {
735 1.1 martin vnds_t *dev_ptr = arg;
736 1.1 martin char buf[SSTRSIZE];
737 1.1 martin strcpy(buf, "-");
738 1.1 martin
739 1.1 martin switch (opt) {
740 1.1 martin case PMV_MENU_FILEPATH:
741 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_path_fmt), dev_ptr->filepath);
742 1.1 martin break;
743 1.1 martin case PMV_MENU_EXIST:
744 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_assgn_fmt),
745 1.11 martin dev_ptr->is_exist? msg_string(MSG_No) : msg_string(MSG_Yes));
746 1.1 martin break;
747 1.1 martin case PMV_MENU_SIZE:
748 1.1 martin if (!dev_ptr->is_exist)
749 1.1 martin snprintf(buf, SSTRSIZE, "%d", dev_ptr->size);
750 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_size_fmt), buf);
751 1.1 martin break;
752 1.1 martin case PMV_MENU_RO:
753 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_ro_fmt),
754 1.1 martin dev_ptr->readonly? msg_string(MSG_Yes) : msg_string(MSG_No));
755 1.1 martin break;
756 1.1 martin case PMV_MENU_MGEOM:
757 1.1 martin if (!dev_ptr->is_exist)
758 1.1 martin snprintf(buf, SSTRSIZE, "%s",
759 1.1 martin dev_ptr->manual_geom? msg_string(MSG_Yes) : msg_string(MSG_No));
760 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_geom_fmt), buf);
761 1.1 martin break;
762 1.1 martin case PMV_MENU_SECSIZE:
763 1.1 martin if (dev_ptr->manual_geom && !dev_ptr->is_exist)
764 1.1 martin snprintf(buf, SSTRSIZE, "%d", dev_ptr->secsize);
765 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_bps_fmt), buf);
766 1.1 martin break;
767 1.1 martin case PMV_MENU_NSECTORS:
768 1.1 martin if (dev_ptr->manual_geom && !dev_ptr->is_exist)
769 1.1 martin snprintf(buf, SSTRSIZE, "%d", dev_ptr->nsectors);
770 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_spt_fmt), buf);
771 1.1 martin break;
772 1.1 martin case PMV_MENU_NTRACKS:
773 1.1 martin if (dev_ptr->manual_geom && !dev_ptr->is_exist)
774 1.1 martin snprintf(buf, SSTRSIZE, "%d", dev_ptr->ntracks);
775 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_tpc_fmt), buf);
776 1.1 martin break;
777 1.1 martin case PMV_MENU_NCYLINDERS:
778 1.1 martin if (dev_ptr->manual_geom && !dev_ptr->is_exist)
779 1.1 martin snprintf(buf, SSTRSIZE, "%d", dev_ptr->ncylinders);
780 1.1 martin wprintw(m->mw, msg_string(MSG_vnd_cyl_fmt), buf);
781 1.1 martin break;
782 1.1 martin }
783 1.1 martin return;
784 1.1 martin }
785 1.1 martin
786 1.1 martin static int
787 1.1 martin pm_vnd_set_value(menudesc *m, void *arg)
788 1.1 martin {
789 1.1 martin vnds_t *dev_ptr = arg;
790 1.1 martin char buf[STRSIZE];
791 1.1 martin const char *msg_to_show = NULL;
792 1.1 martin int *out_var = NULL;
793 1.1 martin
794 1.1 martin switch (m->cursel) {
795 1.1 martin case PMV_MENU_FILEPATH:
796 1.1 martin msg_prompt_win(MSG_vnd_path_ask, -1, 18, 0, 0, dev_ptr->filepath,
797 1.1 martin dev_ptr->filepath, STRSIZE);
798 1.1 martin if (dev_ptr->filepath[0] != '/') {
799 1.1 martin strlcpy(buf, dev_ptr->filepath, MOUNTLEN);
800 1.1 martin snprintf(dev_ptr->filepath, MOUNTLEN, "/%s", buf);
801 1.1 martin }
802 1.1 martin if (dev_ptr->filepath[strlen(dev_ptr->filepath) - 1] == '/')
803 1.1 martin dev_ptr->filepath[strlen(dev_ptr->filepath) - 1] = '\0';
804 1.1 martin return 0;
805 1.1 martin case PMV_MENU_EXIST:
806 1.1 martin dev_ptr->is_exist = !dev_ptr->is_exist;
807 1.1 martin return 0;
808 1.1 martin case PMV_MENU_SIZE:
809 1.1 martin if (dev_ptr->is_exist)
810 1.1 martin return 0;
811 1.1 martin msg_to_show = MSG_vnd_size_ask;
812 1.1 martin out_var = &(dev_ptr->size);
813 1.1 martin break;
814 1.1 martin case PMV_MENU_RO:
815 1.1 martin dev_ptr->readonly = !dev_ptr->readonly;
816 1.1 martin return 0;
817 1.1 martin case PMV_MENU_MGEOM:
818 1.1 martin if (dev_ptr->is_exist)
819 1.1 martin return 0;
820 1.1 martin dev_ptr->manual_geom = !dev_ptr->manual_geom;
821 1.1 martin return 0;
822 1.1 martin case PMV_MENU_SECSIZE:
823 1.1 martin if (!dev_ptr->manual_geom || dev_ptr->is_exist)
824 1.1 martin return 0;
825 1.1 martin msg_to_show = MSG_vnd_bps_ask;
826 1.1 martin out_var = &(dev_ptr->secsize);
827 1.1 martin break;
828 1.1 martin case PMV_MENU_NSECTORS:
829 1.1 martin if (!dev_ptr->manual_geom || dev_ptr->is_exist)
830 1.1 martin return 0;
831 1.1 martin msg_to_show = MSG_vnd_spt_ask;
832 1.1 martin out_var = &(dev_ptr->nsectors);
833 1.1 martin break;
834 1.1 martin case PMV_MENU_NTRACKS:
835 1.1 martin if (!dev_ptr->manual_geom || dev_ptr->is_exist)
836 1.1 martin return 0;
837 1.1 martin msg_to_show = MSG_vnd_tpc_ask;
838 1.1 martin out_var = &(dev_ptr->ntracks);
839 1.1 martin break;
840 1.1 martin case PMV_MENU_NCYLINDERS:
841 1.1 martin if (!dev_ptr->manual_geom || dev_ptr->is_exist)
842 1.1 martin return 0;
843 1.1 martin msg_to_show = MSG_vnd_cyl_ask;
844 1.1 martin out_var = &(dev_ptr->ncylinders);
845 1.1 martin break;
846 1.1 martin case PMV_MENU_REMOVE:
847 1.1 martin dev_ptr->enabled = 0;
848 1.1 martin return 0;
849 1.1 martin }
850 1.1 martin if (out_var == NULL || msg_to_show == NULL)
851 1.1 martin return -1;
852 1.1 martin snprintf(buf, SSTRSIZE, "%d", *out_var);
853 1.1 martin msg_prompt_win(msg_to_show, -1, 18, 0, 0, buf, buf, SSTRSIZE);
854 1.1 martin if (atoi(buf) >= 0)
855 1.1 martin *out_var = atoi(buf);
856 1.1 martin return 0;
857 1.1 martin }
858 1.1 martin
859 1.1 martin static void
860 1.1 martin pm_vnd_init(void *arg, void *none)
861 1.1 martin {
862 1.1 martin vnds_t *dev_ptr = arg;
863 1.1 martin memset(dev_ptr, 0, sizeof(*dev_ptr));
864 1.1 martin *dev_ptr = (struct vnds_t) {
865 1.1 martin .enabled = 1,
866 1.1 martin .blocked = 0,
867 1.1 martin .filepath[0] = '\0',
868 1.1 martin .is_exist = 0,
869 1.1 martin .size = 1024,
870 1.1 martin .readonly = 0,
871 1.1 martin .manual_geom = 0,
872 1.1 martin .secsize = 512,
873 1.1 martin .nsectors = 18,
874 1.1 martin .ntracks = 2,
875 1.1 martin .ncylinders = 80
876 1.1 martin };
877 1.1 martin return;
878 1.1 martin }
879 1.1 martin
880 1.1 martin static int
881 1.1 martin pm_vnd_check(void *arg)
882 1.1 martin {
883 1.1 martin vnds_t *dev_ptr = arg;
884 1.1 martin
885 1.1 martin if (dev_ptr->blocked)
886 1.1 martin return 0;
887 1.1 martin if (strlen(dev_ptr->filepath) < 1 ||
888 1.1 martin dev_ptr->size < 1)
889 1.1 martin dev_ptr->enabled = 0;
890 1.1 martin else {
891 1.1 martin pm_manage_getfreenode(&(dev_ptr->node), "vnd", &vnds_t_info);
892 1.1 martin if (dev_ptr->node < 0)
893 1.1 martin dev_ptr->enabled = 0;
894 1.1 martin }
895 1.1 martin return dev_ptr->enabled;
896 1.1 martin }
897 1.1 martin
898 1.19 martin /* XXX: vndconfig always return 0? */
899 1.1 martin static int
900 1.1 martin pm_vnd_commit(void)
901 1.1 martin {
902 1.1 martin int i, ii, error, part_suit = -1;
903 1.1 martin char r_o[3], buf[MOUNTLEN+3], resultpath[STRSIZE];
904 1.1 martin pm_devs_t *pm_i, *pm_suit = NULL;
905 1.1 martin
906 1.1 martin for (i = 0; i < MAX_VND; i++) {
907 1.1 martin error = 0;
908 1.1 martin if (! pm_vnd_check(&vnds[i]))
909 1.1 martin continue;
910 1.1 martin
911 1.1 martin /* Trying to assign target device */
912 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
913 1.1 martin for (ii = 0; ii < 6; ii++) {
914 1.1 martin strcpy(buf, pm_i->bsdlabel[ii].pi_mount);
915 1.1 martin if (buf[strlen(buf)-1] != '/')
916 1.25 martin strcat(buf, "/");
917 1.1 martin printf("%s\n",buf);
918 1.1 martin if (strstr(vnds[i].filepath, buf) == vnds[i].filepath)
919 1.1 martin if (part_suit < 0 || pm_suit == NULL ||
920 1.1 martin strlen(buf) > strlen(pm_suit->bsdlabel[part_suit].pi_mount)) {
921 1.1 martin part_suit = ii;
922 1.1 martin pm_suit = pm_i;
923 1.1 martin }
924 1.1 martin }
925 1.1 martin if (part_suit < 0 || pm_suit == NULL ||
926 1.1 martin pm_suit->bsdlabel[part_suit].mnt_opts == NULL ||
927 1.1 martin ! (pm_suit->bsdlabel[part_suit].pi_flags & PIF_MOUNT))
928 1.1 martin continue;
929 1.1 martin
930 1.1 martin /* Mounting assigned partition and try to get real file path*/
931 1.1 martin if (pm_mount(pm_suit, part_suit) != 0)
932 1.1 martin continue;
933 1.1 martin snprintf(resultpath, STRSIZE, "%s/%s",
934 1.1 martin pm_suit->bsdlabel[part_suit].mounted,
935 1.1 martin &(vnds[i].filepath[strlen(pm_suit->bsdlabel[part_suit].pi_mount)]));
936 1.1 martin
937 1.1 martin strcpy(r_o, vnds[i].readonly?"-r":"");
938 1.1 martin /* If this is a new image */
939 1.1 martin if (!vnds[i].is_exist) {
940 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS, "mkdir -p %s ", dirname(resultpath));
941 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
942 1.1 martin "dd if=/dev/zero of=%s bs=1m count=%d progress=100 msgfmt=human",
943 1.1 martin resultpath, vnds[i].size);
944 1.1 martin }
945 1.1 martin if (error)
946 1.1 martin continue;
947 1.1 martin /* If this is a new image with manual geometry */
948 1.1 martin if (!vnds[i].is_exist && vnds[i].manual_geom)
949 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
950 1.19 martin "vndconfig %s vnd%d %s %d %d %d %d", r_o, vnds[i].node,
951 1.1 martin resultpath, vnds[i].secsize, vnds[i].nsectors,
952 1.1 martin vnds[i].ntracks, vnds[i].ncylinders);
953 1.4 riz /* If this is a existing image or image without manual geometry */
954 1.1 martin else
955 1.19 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS, "vndconfig %s vnd%d %s",
956 1.1 martin r_o, vnds[i].node, resultpath);
957 1.1 martin
958 1.1 martin if (! error) {
959 1.1 martin vnds[i].blocked = 1;
960 1.1 martin vnds[i].pm_part = part_suit;
961 1.1 martin vnds[i].pm = pm_suit;
962 1.1 martin vnds[i].pm->blocked++;
963 1.1 martin }
964 1.1 martin }
965 1.1 martin return 0;
966 1.1 martin }
967 1.1 martin
968 1.1 martin /***
969 1.4 riz CGD
970 1.4 riz ***/
971 1.1 martin
972 1.1 martin static void
973 1.1 martin pm_cgd_menufmt(menudesc *m, int opt, void *arg)
974 1.1 martin {
975 1.1 martin cgds_t *dev_ptr = ((part_entry_t *)arg)[opt].dev_ptr;
976 1.1 martin char desc[STRSIZE];
977 1.1 martin
978 1.1 martin if (dev_ptr->enabled == 0)
979 1.1 martin return;
980 1.1 martin if (dev_ptr->pm == NULL)
981 1.1 martin wprintw(m->mw, "%s", msg_string(MSG_cgd_err_menufmt));
982 1.1 martin else {
983 1.1 martin snprintf(desc, STRSIZE, "(%s-%d) on %s", dev_ptr->enc_type,
984 1.1 martin dev_ptr->key_size, dev_ptr->pm_name);
985 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_menufmt), dev_ptr->node, desc,
986 1.1 martin dev_ptr->pm->bsdlabel[dev_ptr->pm_part].pi_size /
987 1.1 martin (MEG / dev_ptr->pm->sectorsize));
988 1.1 martin }
989 1.1 martin return;
990 1.1 martin }
991 1.1 martin
992 1.1 martin static void
993 1.1 martin pm_cgd_edit_menufmt(menudesc *m, int opt, void *arg)
994 1.1 martin {
995 1.1 martin cgds_t *dev_ptr = arg;
996 1.1 martin switch (opt) {
997 1.1 martin case PMC_MENU_DEV:
998 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_dev_fmt), dev_ptr->pm_name);
999 1.1 martin break;
1000 1.1 martin case PMC_MENU_ENCTYPE:
1001 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_enc_fmt), dev_ptr->enc_type);
1002 1.1 martin break;
1003 1.1 martin case PMC_MENU_KEYSIZE:
1004 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_key_fmt), dev_ptr->key_size);
1005 1.1 martin break;
1006 1.1 martin case PMC_MENU_IVTYPE:
1007 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_iv_fmt), dev_ptr->iv_type);
1008 1.1 martin break;
1009 1.1 martin case PMC_MENU_KEYGENTYPE:
1010 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_keygen_fmt), dev_ptr->keygen_type);
1011 1.1 martin break;
1012 1.1 martin case PMC_MENU_VERIFYTYPE:
1013 1.1 martin wprintw(m->mw, msg_string(MSG_cgd_verif_fmt), dev_ptr->verify_type);
1014 1.1 martin break;
1015 1.1 martin }
1016 1.1 martin return;
1017 1.1 martin }
1018 1.1 martin
1019 1.1 martin static int
1020 1.1 martin pm_cgd_set_value(menudesc *m, void *arg)
1021 1.1 martin {
1022 1.1 martin char *retstring;
1023 1.1 martin cgds_t *dev_ptr = arg;
1024 1.1 martin
1025 1.1 martin switch (m->cursel) {
1026 1.1 martin case PMC_MENU_DEV:
1027 1.1 martin pm_cgd_disk_set(dev_ptr, NULL);
1028 1.1 martin return 0;
1029 1.1 martin case PMC_MENU_ENCTYPE:
1030 1.1 martin process_menu(MENU_cgd_enctype, &retstring);
1031 1.1 martin dev_ptr->enc_type = retstring;
1032 1.14 alnsn if (! strcmp(retstring, "aes-xts"))
1033 1.14 alnsn dev_ptr->key_size = 256;
1034 1.14 alnsn if (! strcmp(retstring, "aes-cbc"))
1035 1.14 alnsn dev_ptr->key_size = 192;
1036 1.1 martin if (! strcmp(retstring, "blowfish-cbc"))
1037 1.1 martin dev_ptr->key_size = 128;
1038 1.1 martin if (! strcmp(retstring, "3des-cbc"))
1039 1.1 martin dev_ptr->key_size = 192;
1040 1.1 martin return 0;
1041 1.1 martin case PMC_MENU_KEYSIZE:
1042 1.14 alnsn if (! strcmp(dev_ptr->enc_type, "aes-xts"))
1043 1.14 alnsn dev_ptr->key_size +=
1044 1.14 alnsn (dev_ptr->key_size < 512)? 256 : -256;
1045 1.1 martin if (! strcmp(dev_ptr->enc_type, "aes-cbc"))
1046 1.1 martin dev_ptr->key_size +=
1047 1.1 martin (dev_ptr->key_size < 256)? 64 : -128;
1048 1.1 martin if (! strcmp(dev_ptr->enc_type, "blowfish-cbc"))
1049 1.1 martin dev_ptr->key_size = 128;
1050 1.1 martin if (! strcmp(dev_ptr->enc_type, "3des-cbc"))
1051 1.1 martin dev_ptr->key_size = 192;
1052 1.1 martin return 0;
1053 1.1 martin case PMC_MENU_IVTYPE:
1054 1.1 martin process_menu(MENU_cgd_ivtype, &retstring);
1055 1.1 martin dev_ptr->iv_type = retstring;
1056 1.1 martin return 0;
1057 1.1 martin case PMC_MENU_KEYGENTYPE:
1058 1.1 martin process_menu(MENU_cgd_keygentype, &retstring);
1059 1.1 martin dev_ptr->keygen_type = retstring;
1060 1.1 martin return 0;
1061 1.1 martin case PMC_MENU_VERIFYTYPE:
1062 1.1 martin process_menu(MENU_cgd_verifytype, &retstring);
1063 1.1 martin dev_ptr->verify_type = retstring;
1064 1.1 martin return 0;
1065 1.1 martin case PMC_MENU_REMOVE:
1066 1.1 martin dev_ptr->enabled = 0;
1067 1.1 martin return 0;
1068 1.1 martin }
1069 1.1 martin return -1;
1070 1.1 martin }
1071 1.1 martin
1072 1.1 martin static void
1073 1.1 martin pm_cgd_init(void *arg1, void *arg2)
1074 1.1 martin {
1075 1.1 martin cgds_t *dev_ptr = arg1;
1076 1.1 martin part_entry_t *disk_entrie = arg2;
1077 1.1 martin
1078 1.1 martin memset(dev_ptr, 0, sizeof(*dev_ptr));
1079 1.1 martin *dev_ptr = (struct cgds_t) {
1080 1.1 martin .enabled = 1,
1081 1.1 martin .blocked = 0,
1082 1.1 martin .pm = NULL,
1083 1.1 martin .pm_name[0] = '\0',
1084 1.1 martin .pm_part = 0,
1085 1.1 martin .keygen_type = "pkcs5_pbkdf2/sha1",
1086 1.1 martin .verify_type = "disklabel",
1087 1.14 alnsn .enc_type = "aes-xts",
1088 1.1 martin .iv_type = "encblkno1",
1089 1.14 alnsn .key_size = 256,
1090 1.1 martin };
1091 1.1 martin if (disk_entrie != NULL) {
1092 1.1 martin pm_getdevstring(disk_entrie->fullname, SSTRSIZE,
1093 1.1 martin disk_entrie->dev_ptr, disk_entrie->dev_num);
1094 1.1 martin pm_cgd_disk_set(dev_ptr, disk_entrie);
1095 1.1 martin }
1096 1.1 martin return;
1097 1.1 martin }
1098 1.1 martin
1099 1.1 martin static int
1100 1.1 martin pm_cgd_check(void *arg)
1101 1.1 martin {
1102 1.1 martin cgds_t *dev_ptr = arg;
1103 1.1 martin
1104 1.1 martin if (dev_ptr->blocked)
1105 1.1 martin return 0;
1106 1.1 martin if (dev_ptr->pm == NULL)
1107 1.1 martin dev_ptr->enabled = 0;
1108 1.18 mrg else {
1109 1.1 martin pm_manage_getfreenode(&(dev_ptr->node), "cgd", &cgds_t_info);
1110 1.1 martin if (dev_ptr->node < 0)
1111 1.1 martin dev_ptr->enabled = 0;
1112 1.18 mrg }
1113 1.1 martin return dev_ptr->enabled;
1114 1.1 martin }
1115 1.1 martin
1116 1.1 martin static int
1117 1.1 martin pm_cgd_disk_set(cgds_t *dev_ptr, part_entry_t *disk_entrie)
1118 1.1 martin {
1119 1.1 martin int alloc_disk_entrie = 0;
1120 1.1 martin if (disk_entrie == NULL) {
1121 1.1 martin alloc_disk_entrie = 1;
1122 1.1 martin disk_entrie = malloc (sizeof(part_entry_t));
1123 1.1 martin if (disk_entrie == NULL)
1124 1.1 martin return -2;
1125 1.1 martin *disk_entrie = pm_dev_list(PM_CGD_T);
1126 1.1 martin if (disk_entrie->retvalue < 0) {
1127 1.1 martin free(disk_entrie);
1128 1.1 martin return -1;
1129 1.1 martin }
1130 1.1 martin }
1131 1.1 martin dev_ptr->pm = disk_entrie->dev_ptr;
1132 1.1 martin dev_ptr->pm_part = disk_entrie->dev_num;
1133 1.1 martin strlcpy(dev_ptr->pm_name, disk_entrie->fullname, SSTRSIZE);
1134 1.1 martin
1135 1.1 martin if (alloc_disk_entrie)
1136 1.1 martin free(disk_entrie);
1137 1.1 martin return 0;
1138 1.1 martin }
1139 1.1 martin
1140 1.1 martin int
1141 1.1 martin pm_cgd_edit(void *dev_ptr, part_entry_t *disk_entrie)
1142 1.1 martin {
1143 1.1 martin if (disk_entrie != NULL)
1144 1.1 martin dev_ptr = NULL;
1145 1.1 martin return pm_edit(PMC_MENU_END, pm_cgd_edit_menufmt,
1146 1.1 martin pm_cgd_set_value, pm_cgd_check, pm_cgd_init,
1147 1.1 martin disk_entrie, dev_ptr, 0, &cgds_t_info);
1148 1.1 martin }
1149 1.1 martin
1150 1.1 martin static int
1151 1.1 martin pm_cgd_commit(void)
1152 1.1 martin {
1153 1.1 martin int i, error = 0;
1154 1.1 martin for (i = 0; i < MAX_CGD; i++) {
1155 1.1 martin if (! pm_cgd_check(&cgds[i]))
1156 1.1 martin continue;
1157 1.1 martin if (run_program(RUN_DISPLAY | RUN_PROGRESS,
1158 1.1 martin "cgdconfig -g -i %s -k %s -o /tmp/cgd.%d.conf %s %d",
1159 1.1 martin cgds[i].iv_type, cgds[i].keygen_type, cgds[i].node,
1160 1.1 martin cgds[i].enc_type, cgds[i].key_size) != 0) {
1161 1.1 martin error++;
1162 1.1 martin continue;
1163 1.1 martin }
1164 1.1 martin if (run_program(RUN_DISPLAY | RUN_PROGRESS,
1165 1.1 martin "cgdconfig -V re-enter cgd%d /dev/%s /tmp/cgd.%d.conf",
1166 1.1 martin cgds[i].node, cgds[i].pm_name, cgds[i].node) != 0) {
1167 1.1 martin error++;
1168 1.1 martin continue;
1169 1.1 martin }
1170 1.1 martin cgds[i].pm->blocked++;
1171 1.1 martin cgds[i].blocked = 1;
1172 1.1 martin }
1173 1.1 martin return error;
1174 1.1 martin }
1175 1.1 martin
1176 1.1 martin /***
1177 1.4 riz LVM
1178 1.4 riz ***/
1179 1.1 martin
1180 1.1 martin /* Add lvm logical volumes to pm list */
1181 1.1 martin /* XXX: rewrite */
1182 1.21 kre static void
1183 1.1 martin pm_lvm_find(void)
1184 1.1 martin {
1185 1.1 martin int i, ii, already_found;
1186 1.1 martin char dev[STRSIZE];
1187 1.1 martin pm_devs_t *pm_i;
1188 1.1 martin
1189 1.1 martin for (i = 0; i < MAX_LVM_VG; i++) {
1190 1.1 martin if (! lvms[i].blocked)
1191 1.1 martin continue;
1192 1.1 martin for (ii = 0; ii < MAX_LVM_LV; ii++) {
1193 1.1 martin if (! lvms[i].lv[ii].blocked || lvms[i].lv[ii].size < 1)
1194 1.1 martin continue;
1195 1.1 martin snprintf(dev, STRSIZE, "%s/%s", lvms[i].name, lvms[i].lv[ii].name);
1196 1.1 martin already_found = 0;
1197 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
1198 1.1 martin if (!already_found && strcmp(pm_i->diskdev, dev) == 0) {
1199 1.1 martin pm_i->found = 1;
1200 1.1 martin already_found = 1;
1201 1.1 martin }
1202 1.1 martin if (already_found)
1203 1.1 martin /* We already added this device, skipping */
1204 1.1 martin continue;
1205 1.1 martin pm_new->found = 1;
1206 1.1 martin pm_new->isspecial = 1;
1207 1.1 martin pm_new->refdev = &lvms[i].lv[ii];
1208 1.1 martin pm_new->sectorsize = 1;
1209 1.1 martin pm_new->dlcylsize = MEG;
1210 1.1 martin pm_new->bsdlabel[0].pi_size = MEG * lvms[i].lv[ii].size;
1211 1.1 martin strlcpy(pm_new->diskdev, dev, SSTRSIZE);
1212 1.1 martin strlcpy(pm_new->diskdev_descr, dev, STRSIZE);
1213 1.1 martin
1214 1.1 martin if (SLIST_EMPTY(&pm_head))
1215 1.1 martin SLIST_INSERT_HEAD(&pm_head, pm_new, l);
1216 1.1 martin else
1217 1.1 martin SLIST_INSERT_AFTER(pm_i, pm_new, l);
1218 1.1 martin pm_new = malloc(sizeof (pm_devs_t));
1219 1.1 martin memset(pm_new, 0, sizeof *pm_new);
1220 1.1 martin }
1221 1.1 martin }
1222 1.1 martin }
1223 1.1 martin
1224 1.1 martin static int
1225 1.1 martin pm_lvm_disk_add(menudesc *m, void *arg)
1226 1.1 martin {
1227 1.1 martin int i;
1228 1.1 martin lvms_t *dev_ptr = arg;
1229 1.1 martin part_entry_t disk_entrie = pm_dev_list(PM_LVM_T);
1230 1.1 martin if (disk_entrie.retvalue < 0)
1231 1.1 martin return disk_entrie.retvalue;
1232 1.1 martin
1233 1.1 martin for (i = 0; i < MAX_LVM_PV; i++)
1234 1.1 martin if (dev_ptr->pv[i].pm == NULL) {
1235 1.1 martin dev_ptr->pv[i].pm = disk_entrie.dev_ptr;
1236 1.1 martin dev_ptr->pv[i].pm_part = disk_entrie.dev_num;
1237 1.1 martin strlcpy(dev_ptr->pv[i].pm_name, disk_entrie.fullname, SSTRSIZE);
1238 1.1 martin break;
1239 1.1 martin }
1240 1.1 martin return 0;
1241 1.1 martin }
1242 1.1 martin
1243 1.1 martin static int
1244 1.1 martin pm_lvm_disk_del(menudesc *m, void *arg)
1245 1.1 martin {
1246 1.1 martin int i, retvalue = -1, num_devs = 0;
1247 1.1 martin int menu_no;
1248 1.1 martin lvms_t *dev_ptr = arg;
1249 1.1 martin menu_ent menu_entries[MAX_LVM_PV];
1250 1.1 martin part_entry_t submenu_args[MAX_LVM_PV];
1251 1.1 martin
1252 1.1 martin for (i = 0; i < MAX_LVM_PV; i++) {
1253 1.1 martin if (dev_ptr->pv[i].pm == NULL)
1254 1.1 martin continue;
1255 1.1 martin menu_entries[num_devs] = (struct menu_ent) {
1256 1.1 martin .opt_name = dev_ptr->pv[i].pm_name,
1257 1.1 martin .opt_action = set_menu_select,
1258 1.1 martin .opt_menu = OPT_NOMENU,
1259 1.1 martin .opt_flags = OPT_EXIT,
1260 1.1 martin };
1261 1.1 martin submenu_args[num_devs].dev_num = i;
1262 1.1 martin num_devs++;
1263 1.1 martin }
1264 1.1 martin
1265 1.1 martin menu_no = new_menu(MSG_lvm_disks,
1266 1.1 martin menu_entries, num_devs, -1, -1, (num_devs+1<3)?3:num_devs+1, 13,
1267 1.1 martin MC_SCROLL | MC_NOCLEAR, NULL, NULL, NULL, NULL, NULL);
1268 1.1 martin if (menu_no == -1)
1269 1.1 martin return -1;
1270 1.1 martin process_menu(menu_no, &retvalue);
1271 1.1 martin free_menu(menu_no);
1272 1.1 martin
1273 1.1 martin if (retvalue < 0 || retvalue >= num_devs)
1274 1.1 martin return -1;
1275 1.1 martin
1276 1.1 martin dev_ptr->pv[submenu_args[retvalue].dev_num].pm = NULL;
1277 1.1 martin
1278 1.1 martin return 0;
1279 1.1 martin }
1280 1.1 martin
1281 1.1 martin static void
1282 1.1 martin pm_lvm_menufmt(menudesc *m, int opt, void *arg)
1283 1.1 martin {
1284 1.1 martin int i, ok = 0, used_size = 0;
1285 1.1 martin char buf1[STRSIZE]; buf1[0] = '\0';
1286 1.1 martin char buf2[STRSIZE]; buf2[0] = '\0';
1287 1.1 martin lvms_t *dev_ptr = ((part_entry_t *)arg)[opt].dev_ptr;
1288 1.1 martin
1289 1.1 martin if (dev_ptr->enabled == 0)
1290 1.1 martin return;
1291 1.1 martin snprintf(buf1, STRSIZE, "VG '%s' on ", dev_ptr->name);
1292 1.1 martin for (i = 0; i < MAX_LVM_PV; i++)
1293 1.1 martin if (dev_ptr->pv[i].pm != NULL) {
1294 1.15 christos strlcat(buf1, dev_ptr->pv[i].pm_name, STRSIZE);
1295 1.15 christos strlcat(buf1, " ", STRSIZE);
1296 1.1 martin ok = 1;
1297 1.1 martin }
1298 1.1 martin for (i = 0; i < MAX_LVM_LV; i++)
1299 1.1 martin used_size += dev_ptr->lv[i].size;
1300 1.1 martin if (ok) {
1301 1.1 martin snprintf(buf2, STRSIZE, "%d/%u",
1302 1.1 martin dev_ptr->total_size - used_size, dev_ptr->total_size);
1303 1.1 martin wprintw(m->mw, msg_string(MSG_lvm_menufmt), buf1, buf2);
1304 1.1 martin } else
1305 1.1 martin wprintw(m->mw, "%s", msg_string(MSG_lvm_err_menufmt));
1306 1.1 martin return;
1307 1.1 martin }
1308 1.1 martin
1309 1.1 martin static void
1310 1.1 martin pm_lvm_edit_menufmt(menudesc *m, int opt, void *arg)
1311 1.1 martin {
1312 1.1 martin int i;
1313 1.1 martin char buf[STRSIZE];
1314 1.1 martin lvms_t *dev_ptr = arg;
1315 1.1 martin strlcpy(buf, msg_string(MSG_auto), STRSIZE);
1316 1.1 martin
1317 1.1 martin switch (opt) {
1318 1.1 martin case PML_MENU_PV:
1319 1.1 martin buf[0] = '\0';
1320 1.1 martin for (i = 0; i < MAX_LVM_PV; i++)
1321 1.1 martin if (dev_ptr->pv[i].pm != NULL)
1322 1.1 martin snprintf(buf, STRSIZE, "%s %s", buf, dev_ptr->pv[i].pm_name);
1323 1.1 martin wprintw(m->mw, msg_string(MSG_lvm_disks_fmt), buf);
1324 1.1 martin break;
1325 1.1 martin case PML_MENU_NAME:
1326 1.1 martin wprintw(m->mw, msg_string(MSG_lvm_name_fmt), dev_ptr->name);
1327 1.1 martin break;
1328 1.1 martin case PML_MENU_MAXLOGICALVOLUMES:
1329 1.1 martin if (dev_ptr->maxlogicalvolumes > 0)
1330 1.1 martin snprintf(buf, STRSIZE, "%d", dev_ptr->maxlogicalvolumes);
1331 1.1 martin wprintw(m->mw, msg_string(MSG_lvm_maxlv_fmt), buf);
1332 1.1 martin break;
1333 1.1 martin case PML_MENU_MAXPHYSICALVOLUMES:
1334 1.1 martin if (dev_ptr->maxphysicalvolumes > 0)
1335 1.1 martin snprintf(buf, STRSIZE, "%d", dev_ptr->maxphysicalvolumes);
1336 1.1 martin wprintw(m->mw, msg_string(MSG_lvm_maxpv_fmt), buf);
1337 1.1 martin break;
1338 1.1 martin case PML_MENU_PHYSICALEXTENTSIZE:
1339 1.1 martin if (dev_ptr->physicalextentsize > 0)
1340 1.1 martin snprintf(buf, STRSIZE, "%dM", dev_ptr->physicalextentsize);
1341 1.1 martin wprintw(m->mw, msg_string(MSG_lvm_extsiz_fmt), buf);
1342 1.1 martin break;
1343 1.1 martin }
1344 1.1 martin return;
1345 1.1 martin }
1346 1.1 martin
1347 1.1 martin static int
1348 1.1 martin pm_lvm_set_value(menudesc *m, void *arg)
1349 1.1 martin {
1350 1.1 martin char buf[STRSIZE];
1351 1.1 martin const char *msg_to_show = NULL;
1352 1.1 martin int *out_var = NULL;
1353 1.1 martin lvms_t *dev_ptr = arg;
1354 1.1 martin
1355 1.1 martin static menu_ent menuent_disk_adddel[] = {
1356 1.23 martin { .opt_name=MSG_add, .opt_menu=OPT_NOMENU, .opt_flags=OPT_EXIT,
1357 1.23 martin .opt_action=pm_lvm_disk_add },
1358 1.23 martin { .opt_name=MSG_remove, .opt_menu=OPT_NOMENU, .opt_flags=OPT_EXIT,
1359 1.23 martin .opt_action=pm_lvm_disk_del }
1360 1.1 martin };
1361 1.1 martin static int menu_disk_adddel = -1;
1362 1.1 martin if (menu_disk_adddel == -1) {
1363 1.1 martin menu_disk_adddel = new_menu(NULL, menuent_disk_adddel, nelem(menuent_disk_adddel),
1364 1.1 martin -1, -1, 0, 10, MC_NOCLEAR, NULL, NULL, NULL, NULL, NULL);
1365 1.1 martin }
1366 1.1 martin
1367 1.1 martin switch (m->cursel) {
1368 1.1 martin case PML_MENU_PV:
1369 1.1 martin process_menu(menu_disk_adddel, arg);
1370 1.1 martin return 0;
1371 1.1 martin case PML_MENU_NAME:
1372 1.1 martin msg_prompt_win(MSG_lvm_name_ask, -1, 18, 0, 0, dev_ptr->name, dev_ptr->name, SSTRSIZE);
1373 1.1 martin return 0;
1374 1.1 martin case PML_MENU_MAXLOGICALVOLUMES:
1375 1.1 martin msg_to_show = MSG_lvm_maxlv_ask;
1376 1.1 martin out_var = &(dev_ptr->maxlogicalvolumes);
1377 1.1 martin break;
1378 1.1 martin case PML_MENU_MAXPHYSICALVOLUMES:
1379 1.1 martin msg_to_show = MSG_lvm_maxpv_ask;
1380 1.1 martin out_var = &(dev_ptr->maxphysicalvolumes);
1381 1.1 martin break;
1382 1.1 martin case PML_MENU_PHYSICALEXTENTSIZE:
1383 1.1 martin msg_to_show = MSG_lvm_extsiz_ask;
1384 1.1 martin out_var = &(dev_ptr->physicalextentsize);
1385 1.1 martin break;
1386 1.1 martin case PML_MENU_REMOVE:
1387 1.1 martin dev_ptr->enabled = 0;
1388 1.1 martin return 0;
1389 1.1 martin }
1390 1.1 martin if (out_var == NULL || msg_to_show == NULL)
1391 1.1 martin return -1;
1392 1.1 martin snprintf(buf, SSTRSIZE, "%d", *out_var);
1393 1.1 martin msg_prompt_win(msg_to_show, -1, 18, 0, 0, buf, buf, SSTRSIZE);
1394 1.1 martin if (atoi(buf) >= 0)
1395 1.1 martin *out_var = atoi(buf);
1396 1.1 martin return 0;
1397 1.1 martin }
1398 1.1 martin
1399 1.1 martin static void
1400 1.1 martin pm_lvm_init(void *arg, void* none)
1401 1.1 martin {
1402 1.1 martin lvms_t *dev_ptr = arg;
1403 1.1 martin
1404 1.1 martin memset(dev_ptr, 0, sizeof *dev_ptr);
1405 1.1 martin *dev_ptr = (struct lvms_t) {
1406 1.1 martin .enabled = 1,
1407 1.1 martin .blocked = 0,
1408 1.1 martin .maxlogicalvolumes = MAX_LVM_PV,
1409 1.1 martin .maxphysicalvolumes = MAX_LVM_LV,
1410 1.1 martin .physicalextentsize = -1,
1411 1.1 martin };
1412 1.1 martin sprintf(dev_ptr->name, "vg%.2d", rand()%100);
1413 1.1 martin return;
1414 1.1 martin }
1415 1.1 martin
1416 1.1 martin static int
1417 1.1 martin pm_lvm_check(void *arg)
1418 1.1 martin {
1419 1.1 martin int i, ok = 0;
1420 1.1 martin lvms_t *dev_ptr = arg;
1421 1.1 martin dev_ptr->total_size = 0;
1422 1.1 martin
1423 1.1 martin for (i = 0; i < MAX_LVM_PV; i++)
1424 1.1 martin if (dev_ptr->pv[i].pm != NULL) {
1425 1.1 martin ok = 1;
1426 1.1 martin dev_ptr->total_size += dev_ptr->pv[i].pm->
1427 1.1 martin bsdlabel[dev_ptr->pv[i].pm_part].pi_size /
1428 1.1 martin (MEG / dev_ptr->pv[i].pm->sectorsize);
1429 1.1 martin }
1430 1.1 martin if (! ok)
1431 1.1 martin dev_ptr->enabled = 0;
1432 1.1 martin return dev_ptr->enabled;
1433 1.1 martin }
1434 1.1 martin
1435 1.1 martin static void
1436 1.1 martin pm_lvmlv_menufmt(menudesc *m, int opt, void *arg)
1437 1.1 martin {
1438 1.1 martin char buf[STRSIZE];
1439 1.1 martin lv_t *dev_ptr = ((part_entry_t *)arg)[opt].dev_ptr;
1440 1.1 martin
1441 1.1 martin if (dev_ptr->size > 0) {
1442 1.1 martin snprintf(buf, STRSIZE, "'%s'", dev_ptr->name);
1443 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_menufmt), buf, dev_ptr->size);
1444 1.1 martin }
1445 1.1 martin return;
1446 1.1 martin }
1447 1.1 martin
1448 1.1 martin static void
1449 1.1 martin pm_lvmlv_edit_menufmt(menudesc *m, int opt, void *arg)
1450 1.1 martin {
1451 1.1 martin
1452 1.1 martin lv_t *dev_ptr = arg;
1453 1.1 martin char buf[STRSIZE];
1454 1.1 martin strlcpy(buf, msg_string(MSG_auto), STRSIZE);
1455 1.1 martin
1456 1.1 martin switch (opt) {
1457 1.1 martin case PMLV_MENU_NAME:
1458 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_name_fmt), dev_ptr->name);
1459 1.1 martin break;
1460 1.1 martin case PMLV_MENU_SIZE:
1461 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_size_fmt), dev_ptr->size);
1462 1.1 martin break;
1463 1.1 martin case PMLV_MENU_READONLY:
1464 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_ro_fmt),
1465 1.1 martin dev_ptr->readonly? msg_string(MSG_Yes) : msg_string(MSG_No));
1466 1.1 martin break;
1467 1.1 martin case PMLV_MENU_CONTIGUOUS:
1468 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_cont_fmt),
1469 1.1 martin dev_ptr->contiguous? msg_string(MSG_Yes) : msg_string(MSG_No));
1470 1.1 martin break;
1471 1.1 martin case PMLV_MENU_EXTENTS:
1472 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_extnum_fmt),
1473 1.1 martin (strlen(dev_ptr->extents) > 0)? dev_ptr->extents : msg_string(MSG_auto));
1474 1.1 martin break;
1475 1.1 martin case PMLV_MENU_MINOR:
1476 1.1 martin if (dev_ptr->minor > 0)
1477 1.1 martin snprintf(buf, STRSIZE, "%dK", dev_ptr->minor);
1478 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_minor_fmt), buf);
1479 1.1 martin break;
1480 1.1 martin case PMLV_MENU_MIRRORS:
1481 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_mirrors_fmt), dev_ptr->mirrors);
1482 1.1 martin break;
1483 1.1 martin case PMLV_MENU_REGIONSIZE:
1484 1.1 martin if (dev_ptr->regionsize > 0)
1485 1.1 martin snprintf(buf, STRSIZE, "%dM", dev_ptr->regionsize);
1486 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_regsiz_fmt), buf);
1487 1.1 martin break;
1488 1.1 martin case PMLV_MENU_PERSISTENT:
1489 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_pers_fmt),
1490 1.1 martin dev_ptr->persistent ? msg_string(MSG_Yes) : msg_string(MSG_No));
1491 1.1 martin break;
1492 1.1 martin case PMLV_MENU_READAHEAD:
1493 1.1 martin if (dev_ptr->readahead > 0)
1494 1.1 martin snprintf(buf, STRSIZE, "%d", dev_ptr->readahead);
1495 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_readahsect_fmt), buf);
1496 1.1 martin break;
1497 1.1 martin case PMLV_MENU_STRIPES:
1498 1.1 martin if (dev_ptr->stripes > 0)
1499 1.1 martin snprintf(buf, STRSIZE, "%d", dev_ptr->stripes);
1500 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_stripes_fmt), buf);
1501 1.1 martin break;
1502 1.1 martin case PMLV_MENU_STRIPESIZE:
1503 1.1 martin if (dev_ptr->stripesize > 0)
1504 1.1 martin snprintf(buf, STRSIZE, "%dK", dev_ptr->stripesize);
1505 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_stripesiz_fmt), buf);
1506 1.1 martin break;
1507 1.1 martin case PMLV_MENU_ZERO:
1508 1.1 martin wprintw(m->mw, msg_string(MSG_lvmlv_zero_fmt),
1509 1.1 martin dev_ptr->zero? msg_string(MSG_Yes) : msg_string(MSG_No));
1510 1.1 martin break;
1511 1.1 martin }
1512 1.1 martin return;
1513 1.1 martin }
1514 1.1 martin
1515 1.1 martin static int
1516 1.1 martin pm_lvmlv_set_value(menudesc *m, void *arg)
1517 1.1 martin {
1518 1.1 martin char buf[STRSIZE];
1519 1.1 martin const char *msg_to_show = NULL;
1520 1.1 martin int *out_var = NULL;
1521 1.1 martin lv_t *dev_ptr = arg;
1522 1.1 martin
1523 1.1 martin switch (m->cursel) {
1524 1.1 martin case PMLV_MENU_NAME:
1525 1.1 martin msg_prompt_win(MSG_lvmlv_name_ask, -1, 18, 0, 0, dev_ptr->name, dev_ptr->name,
1526 1.1 martin SSTRSIZE);
1527 1.1 martin return 0;
1528 1.1 martin case PMLV_MENU_SIZE:
1529 1.1 martin msg_to_show = MSG_lvmlv_size_ask;
1530 1.1 martin out_var = &(dev_ptr->size);
1531 1.1 martin break;
1532 1.1 martin case PMLV_MENU_READONLY:
1533 1.1 martin dev_ptr->readonly = !dev_ptr->readonly;
1534 1.1 martin return 0;
1535 1.1 martin case PMLV_MENU_CONTIGUOUS:
1536 1.1 martin dev_ptr->contiguous = !dev_ptr->contiguous;
1537 1.1 martin return 0;
1538 1.1 martin case PMLV_MENU_EXTENTS:
1539 1.1 martin msg_prompt_win(MSG_lvmlv_extnum_ask, -1, 18, 0, 0,
1540 1.1 martin dev_ptr->extents, dev_ptr->extents, SSTRSIZE);
1541 1.1 martin return 0;
1542 1.1 martin case PMLV_MENU_MINOR:
1543 1.1 martin msg_to_show = MSG_lvmlv_minor_ask;
1544 1.1 martin out_var = &(dev_ptr->minor);
1545 1.1 martin break;
1546 1.1 martin case PMLV_MENU_MIRRORS:
1547 1.1 martin msg_to_show = MSG_lvmlv_mirrors_ask;
1548 1.1 martin out_var = &(dev_ptr->mirrors);
1549 1.1 martin break;
1550 1.1 martin case PMLV_MENU_REGIONSIZE:
1551 1.1 martin msg_to_show = MSG_lvmlv_regsiz_ask;
1552 1.1 martin out_var = &(dev_ptr->regionsize);
1553 1.1 martin break;
1554 1.1 martin case PMLV_MENU_PERSISTENT:
1555 1.1 martin dev_ptr->persistent = !dev_ptr->persistent;
1556 1.1 martin return 0;
1557 1.1 martin case PMLV_MENU_READAHEAD:
1558 1.1 martin msg_to_show = MSG_lvmlv_readahsect_ask;
1559 1.1 martin out_var = &(dev_ptr->readahead);
1560 1.1 martin break;
1561 1.1 martin case PMLV_MENU_STRIPES:
1562 1.1 martin msg_to_show = MSG_lvmlv_stripes_ask;
1563 1.1 martin out_var = &(dev_ptr->stripes);
1564 1.1 martin break;
1565 1.1 martin case PMLV_MENU_STRIPESIZE:
1566 1.1 martin if (dev_ptr->stripesize << 1 > 512)
1567 1.1 martin dev_ptr->stripesize = 4;
1568 1.1 martin else
1569 1.1 martin dev_ptr->stripesize <<= 1;
1570 1.1 martin return 0;
1571 1.1 martin case PMLV_MENU_ZERO:
1572 1.1 martin dev_ptr->zero = !dev_ptr->zero;
1573 1.1 martin return 0;
1574 1.1 martin case PMLV_MENU_REMOVE:
1575 1.1 martin dev_ptr->size = 0;
1576 1.1 martin return 0;
1577 1.1 martin }
1578 1.1 martin if (out_var == NULL || msg_to_show == NULL)
1579 1.1 martin return -1;
1580 1.1 martin snprintf(buf, SSTRSIZE, "%d", *out_var);
1581 1.1 martin msg_prompt_win(msg_to_show, -1, 18, 0, 0, buf, buf, SSTRSIZE);
1582 1.1 martin if (atoi(buf) >= 0)
1583 1.1 martin *out_var = atoi(buf);
1584 1.1 martin return 0;
1585 1.1 martin }
1586 1.1 martin
1587 1.1 martin static void
1588 1.1 martin pm_lvmlv_init(void *arg, void *none)
1589 1.1 martin {
1590 1.1 martin lv_t *dev_ptr = arg;
1591 1.1 martin memset(dev_ptr, 0, sizeof *(dev_ptr));
1592 1.1 martin *dev_ptr = (struct lv_t) {
1593 1.1 martin .blocked = 0,
1594 1.1 martin .size = 1024,
1595 1.1 martin .stripesize = 64,
1596 1.1 martin };
1597 1.1 martin sprintf (dev_ptr->name, "lvol%.2d", rand()%100);
1598 1.1 martin return;
1599 1.1 martin }
1600 1.1 martin
1601 1.1 martin static int
1602 1.1 martin pm_lvmlv_check(void *arg)
1603 1.1 martin {
1604 1.1 martin lv_t *dev_ptr = arg;
1605 1.1 martin if (dev_ptr->size > 0 && strlen(dev_ptr->name) > 0)
1606 1.1 martin return 1;
1607 1.1 martin else {
1608 1.1 martin dev_ptr->size = 0;
1609 1.1 martin return 0;
1610 1.1 martin }
1611 1.1 martin }
1612 1.1 martin
1613 1.1 martin static int
1614 1.1 martin pm_lvm_commit(void)
1615 1.1 martin {
1616 1.1 martin int i, ii, error;
1617 1.1 martin uint used_size = 0;
1618 1.1 martin char params[STRSIZE*3];
1619 1.1 martin char devs[STRSIZE*3];
1620 1.1 martin
1621 1.1 martin for (i = 0; i < MAX_LVM_VG; i++) {
1622 1.1 martin /* Stage 0: checks */
1623 1.1 martin if (! pm_lvm_check(&lvms[i]))
1624 1.1 martin continue;
1625 1.1 martin for (ii = 0; ii < MAX_LVM_LV; ii++)
1626 1.1 martin used_size += lvms[i].lv[ii].size;
1627 1.1 martin if (used_size > lvms[i].total_size)
1628 1.1 martin continue;
1629 1.1 martin
1630 1.1 martin params[0] = '\0';
1631 1.1 martin devs[0] = '\0';
1632 1.1 martin error = 0;
1633 1.1 martin /* Stage 1: creating Physical Volumes (PV's) */
1634 1.1 martin for (ii = 0; ii < MAX_LVM_PV && ! error; ii++)
1635 1.1 martin if (lvms[i].pv[ii].pm != NULL) {
1636 1.1 martin run_program(RUN_SILENT | RUN_ERROR_OK,
1637 1.1 martin "lvm pvremove -ffy /dev/r%s",
1638 1.1 martin (char*)lvms[i].pv[ii].pm_name);
1639 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
1640 1.1 martin "lvm pvcreate -ffy /dev/r%s",
1641 1.1 martin (char*)lvms[i].pv[ii].pm_name);
1642 1.1 martin if (error)
1643 1.1 martin break;
1644 1.1 martin snprintf(devs, STRSIZE*3, "%s /dev/r%s", devs, (char*)lvms[i].pv[ii].pm_name);
1645 1.1 martin }
1646 1.1 martin if (error)
1647 1.1 martin continue;
1648 1.1 martin /* Stage 2: creating Volume Groups (VG's) */
1649 1.1 martin if (lvms[i].maxlogicalvolumes > 0)
1650 1.1 martin snprintf(params, STRSIZE*3, "%s -l %d", params, lvms[i].maxlogicalvolumes);
1651 1.1 martin if (lvms[i].maxphysicalvolumes > 0)
1652 1.1 martin snprintf(params, STRSIZE*3, "%s -p %d", params, lvms[i].maxphysicalvolumes);
1653 1.1 martin if (lvms[i].physicalextentsize > 0)
1654 1.1 martin snprintf(params, STRSIZE*3, "%s -s %d", params, lvms[i].physicalextentsize);
1655 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS, "lvm vgcreate %s %s %s",
1656 1.1 martin params, lvms[i].name, devs);
1657 1.1 martin if (error)
1658 1.1 martin continue;
1659 1.1 martin /* Stage 3: creating Logical Volumes (LV's) */
1660 1.1 martin for (ii = 0; ii < MAX_LVM_LV; ii++) {
1661 1.1 martin if (lvms[i].lv[ii].size <= 0)
1662 1.1 martin continue;
1663 1.1 martin
1664 1.1 martin params[0] = '\0';
1665 1.1 martin snprintf(params, STRSIZE*3, "%s -C %c", params, lvms[i].lv[ii].contiguous?'y':'n');
1666 1.1 martin snprintf(params, STRSIZE*3, "%s -M %c", params, lvms[i].lv[ii].persistent?'y':'n');
1667 1.1 martin snprintf(params, STRSIZE*3, "%s -p %s", params, lvms[i].lv[ii].readonly?"r":"rw");
1668 1.1 martin snprintf(params, STRSIZE*3, "%s -Z %c", params, lvms[i].lv[ii].zero?'y':'n');
1669 1.1 martin if (strlen(lvms[i].lv[ii].name) > 0)
1670 1.1 martin snprintf(params, STRSIZE*3, "%s -n %s", params, lvms[i].lv[ii].name);
1671 1.1 martin if (strlen(lvms[i].lv[ii].extents) > 0)
1672 1.1 martin snprintf(params, STRSIZE*3, "%s -l %s", params, lvms[i].lv[ii].extents);
1673 1.1 martin if (lvms[i].lv[ii].minor > 0)
1674 1.1 martin snprintf(params, STRSIZE*3, "%s --minor %d", params, lvms[i].lv[ii].minor);
1675 1.1 martin if (lvms[i].lv[ii].mirrors > 0) {
1676 1.1 martin snprintf(params, STRSIZE*3, "%s -m %d", params, lvms[i].lv[ii].mirrors);
1677 1.1 martin if (lvms[i].lv[ii].regionsize > 0)
1678 1.1 martin snprintf(params, STRSIZE*3, "%s -R %d", params, lvms[i].lv[ii].regionsize);
1679 1.1 martin }
1680 1.1 martin if (lvms[i].lv[ii].readahead > 0)
1681 1.1 martin snprintf(params, STRSIZE*3, "%s -r %d", params, lvms[i].lv[ii].readahead);
1682 1.1 martin if (lvms[i].lv[ii].stripes > 0) {
1683 1.1 martin snprintf(params, STRSIZE*3, "%s -i %d", params, lvms[i].lv[ii].stripes);
1684 1.1 martin if (lvms[i].lv[ii].stripesize > 0)
1685 1.1 martin snprintf(params, STRSIZE*3, "%s -I %d", params, lvms[i].lv[ii].stripesize);
1686 1.1 martin }
1687 1.1 martin snprintf(params, STRSIZE*3, "%s -L %uM", params, lvms[i].lv[ii].size);
1688 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS, "lvm lvcreate %s %s",
1689 1.1 martin params, lvms[i].name);
1690 1.1 martin }
1691 1.1 martin if (! error) {
1692 1.1 martin lvms[i].blocked = 1;
1693 1.1 martin for (ii = 0; ii < MAX_LVM_PV; ii++)
1694 1.1 martin if (lvms[i].pv[ii].pm != NULL)
1695 1.1 martin lvms[i].pv[ii].pm->blocked++;
1696 1.1 martin for (ii = 0; ii < MAX_LVM_LV; ii++)
1697 1.1 martin if (lvms[i].lv[ii].size > 0)
1698 1.1 martin lvms[i].lv[ii].blocked = 1;
1699 1.1 martin }
1700 1.1 martin }
1701 1.1 martin
1702 1.1 martin return 0;
1703 1.1 martin }
1704 1.1 martin
1705 1.1 martin /***
1706 1.4 riz GPT
1707 1.4 riz ***/
1708 1.1 martin
1709 1.1 martin int
1710 1.1 martin pm_gpt_convert(pm_devs_t *pm_cur)
1711 1.1 martin {
1712 1.1 martin int i, error = 0;
1713 1.1 martin
1714 1.1 martin msg_display(MSG_removepartswarn);
1715 1.10 martin if (!ask_noyes(NULL))
1716 1.1 martin return -1;
1717 1.1 martin
1718 1.1 martin if (! pm_cur->gpt)
1719 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "gpt create -f %s",
1720 1.1 martin pm_cur->diskdev);
1721 1.1 martin else {
1722 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "gpt destroy %s",
1723 1.1 martin pm_cur->diskdev);
1724 1.1 martin for (i = 0; i < MAX_WEDGES; i++)
1725 1.1 martin if (wedges[i].pm == pm_cur)
1726 1.1 martin wedges[i].pm = NULL;
1727 1.1 martin }
1728 1.1 martin if (!error) {
1729 1.1 martin pm_cur->gpt = !pm_cur->gpt;
1730 1.1 martin pm_select(pm_cur);
1731 1.1 martin label_read();
1732 1.1 martin }
1733 1.1 martin return error;
1734 1.1 martin }
1735 1.1 martin
1736 1.1 martin static int
1737 1.1 martin pm_wedge_getfree(void)
1738 1.1 martin {
1739 1.1 martin int i;
1740 1.1 martin for (i = 0; i < MAX_WEDGES; i++)
1741 1.1 martin if (! wedges[i].allocated && wedges[i].pm == NULL)
1742 1.1 martin return i;
1743 1.1 martin return -1;
1744 1.1 martin }
1745 1.1 martin
1746 1.1 martin void
1747 1.1 martin pm_wedges_fill(pm_devs_t *pm_cur)
1748 1.1 martin {
1749 1.1 martin int i, current;
1750 1.1 martin
1751 1.1 martin for (i = 0; i < MAX_WEDGES; i++)
1752 1.1 martin if (wedges[i].pm == pm_cur && ! wedges[i].allocated)
1753 1.1 martin wedges[i].pm = NULL;
1754 1.1 martin
1755 1.5 martin for (i = 0; i < min(MAXPARTITIONS,MAX_WEDGES); i++)
1756 1.1 martin if (pm_cur->bsdlabel[i].pi_fstype != FS_UNUSED) {
1757 1.1 martin current = pm_wedge_getfree();
1758 1.1 martin if (current < 0) {
1759 1.22 joerg process_menu(MENU_ok, __UNCONST(MSG_limitcount));
1760 1.1 martin return;
1761 1.1 martin }
1762 1.1 martin wedges[current].pm = pm_cur;
1763 1.1 martin wedges[current].ptn = i;
1764 1.1 martin }
1765 1.1 martin return;
1766 1.1 martin }
1767 1.1 martin
1768 1.1 martin static int
1769 1.1 martin pm_wedge_create(int num, pm_devs_t **pm_dk)
1770 1.1 martin {
1771 1.1 martin int i, ii, hackerr, error;
1772 1.1 martin partinfo *p = &(wedges[num].pm->bsdlabel[wedges[num].ptn]);
1773 1.1 martin
1774 1.1 martin if (num > MAX_WEDGES)
1775 1.1 martin return -1;
1776 1.1 martin
1777 1.4 riz /* There is no ability to use required dkX device, so that's a hack */
1778 1.1 martin for (i = 0; i < num; i++)
1779 1.1 martin if (! wedges[i].allocated) {
1780 1.1 martin hackerr = 1;
1781 1.1 martin for (ii = 0; hackerr && ii < 3; ii++)
1782 1.1 martin hackerr = run_program(RUN_SILENT | RUN_ERROR_OK,
1783 1.1 martin "dkctl %s addwedge HACK%d %d %d unused",
1784 1.1 martin wedges[num].pm->diskdev,
1785 1.1 martin rand()%33, rand()%33, 0);
1786 1.1 martin wedges[i].todel = 1;
1787 1.1 martin }
1788 1.1 martin
1789 1.1 martin run_program(RUN_SILENT | RUN_ERROR_OK,
1790 1.1 martin "dkctl %s listwedges", wedges[num].pm->diskdev);
1791 1.1 martin
1792 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS,
1793 1.1 martin "dkctl %s addwedge dk%d %u %u %s",
1794 1.1 martin wedges[num].pm->diskdev,
1795 1.1 martin num,
1796 1.1 martin p->pi_offset,
1797 1.1 martin p->pi_size,
1798 1.1 martin getfstypename(p->pi_fstype));
1799 1.1 martin if (!error) {
1800 1.1 martin wedges[num].allocated = 1;
1801 1.1 martin wedges[num].pm->blocked++;
1802 1.1 martin if (pm_dk != NULL) {
1803 1.1 martin *pm_dk = malloc(sizeof(pm_devs_t));
1804 1.1 martin memset(*pm_dk, 0, sizeof **pm_dk);
1805 1.1 martin memcpy(&(*pm_dk)->bsdlabel[0], p, sizeof (*pm_dk)->bsdlabel[0]);
1806 1.1 martin (*pm_dk)->found = -1;
1807 1.1 martin (*pm_dk)->isspecial = 1;
1808 1.1 martin (*pm_dk)->sectorsize = 512; /* XXX: xxx */
1809 1.1 martin (*pm_dk)->dlcylsize = MEG;
1810 1.1 martin (*pm_dk)->refdev = wedges[num].pm;
1811 1.1 martin snprintf((*pm_dk)->diskdev, SSTRSIZE, "dk%d", num);
1812 1.1 martin snprintf((*pm_dk)->diskdev_descr, STRSIZE, " %s (%s)",
1813 1.1 martin (*pm_dk)->diskdev, getfstypename(p->pi_fstype));
1814 1.1 martin }
1815 1.1 martin } else
1816 1.1 martin if (logfp)
1817 1.1 martin fprintf(logfp, "Cannot create wedge dk%d for %s.\n",
1818 1.1 martin num, wedges[num].pm->diskdev);
1819 1.1 martin
1820 1.1 martin /* Hack, see above */
1821 1.1 martin for (i = 0; i < num; i ++)
1822 1.1 martin if (! wedges[i].allocated && wedges[i].todel) {
1823 1.1 martin hackerr = run_program(RUN_SILENT | RUN_ERROR_OK,
1824 1.1 martin "dkctl %s delwedge dk%d", wedges[num].pm->diskdev, i);
1825 1.13 dholland (void)hackerr; /* XXX */
1826 1.1 martin wedges[i].todel = 0;
1827 1.1 martin }
1828 1.1 martin
1829 1.1 martin return error;
1830 1.1 martin }
1831 1.1 martin
1832 1.1 martin static int
1833 1.1 martin pm_gpt_commit(void)
1834 1.1 martin {
1835 1.1 martin uint i, error;
1836 1.1 martin pm_devs_t *pm_i, *pm_dk = NULL;
1837 1.1 martin char fstype[STRSIZE]; fstype[0] = '\0';
1838 1.1 martin partinfo *p;
1839 1.1 martin
1840 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
1841 1.1 martin if (pm_i->gpt && pm_i->unsaved)
1842 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS,
1843 1.1 martin "gpt remove -a %s",
1844 1.1 martin pm_i->diskdev);
1845 1.1 martin
1846 1.1 martin for (i = 0; i < MAX_WEDGES; i++) {
1847 1.1 martin if (wedges[i].pm == NULL ||
1848 1.1 martin ! wedges[i].pm->unsaved ||
1849 1.1 martin wedges[i].ptn < 0)
1850 1.1 martin continue;
1851 1.1 martin error = 0;
1852 1.1 martin p = &(wedges[i].pm->bsdlabel[wedges[i].ptn]);
1853 1.1 martin if (wedges[i].pm->gpt) {
1854 1.1 martin if (get_gptfs_by_id(p->pi_fstype) != NULL)
1855 1.1 martin snprintf(fstype, STRSIZE, "-t %s", get_gptfs_by_id(p->pi_fstype));
1856 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
1857 1.1 martin "gpt add -i %u -b %u -s %u %s %s",
1858 1.1 martin wedges[i].ptn + 1,
1859 1.1 martin p->pi_offset, p->pi_size,
1860 1.1 martin fstype, wedges[i].pm->diskdev);
1861 1.1 martin }
1862 1.1 martin
1863 1.1 martin if (error || wedges[i].allocated) {
1864 1.1 martin if (logfp && error)
1865 1.1 martin fprintf(logfp, "Cannot create GPT partition #%d on %s\n",
1866 1.1 martin i, wedges[i].pm->diskdev);
1867 1.1 martin continue;
1868 1.1 martin }
1869 1.1 martin
1870 1.1 martin error += pm_wedge_create(i, &pm_dk);
1871 1.1 martin if (pm_dk != NULL) {
1872 1.4 riz /* Create file system on wedge and add it to list */
1873 1.1 martin pm_select(pm_dk);
1874 1.1 martin make_filesystems();
1875 1.1 martin SLIST_INSERT_AFTER(wedges[i].pm, pm_dk, l);
1876 1.1 martin memset(p, 0, sizeof *p);
1877 1.1 martin if (error)
1878 1.1 martin return -1;
1879 1.1 martin }
1880 1.1 martin }
1881 1.1 martin
1882 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
1883 1.1 martin if (pm_i->gpt && pm_i->unsaved)
1884 1.1 martin pm_i->unsaved = 0;
1885 1.1 martin
1886 1.1 martin return 0;
1887 1.1 martin }
1888 1.1 martin
1889 1.1 martin /***
1890 1.4 riz Partman generic functions
1891 1.4 riz ***/
1892 1.1 martin
1893 1.1 martin int
1894 1.1 martin pm_getrefdev(pm_devs_t *pm_cur)
1895 1.1 martin {
1896 1.1 martin int i, ii, dev_num, num_devs, num_devs_s;
1897 1.1 martin char dev[SSTRSIZE]; dev[0] = '\0';
1898 1.1 martin
1899 1.1 martin pm_cur->refdev = NULL;
1900 1.1 martin if (! strncmp(pm_cur->diskdev, "cgd", 3)) {
1901 1.1 martin dev_num = pm_cur->diskdev[3] - '0';
1902 1.1 martin for (i = 0; i < MAX_CGD; i++)
1903 1.1 martin if (cgds[i].blocked && cgds[i].node == dev_num) {
1904 1.1 martin pm_cur->refdev = &cgds[i];
1905 1.1 martin
1906 1.1 martin snprintf(pm_cur->diskdev_descr, STRSIZE, "%s (%s, %s-%d)",
1907 1.1 martin pm_cur->diskdev_descr, cgds[i].pm_name,
1908 1.1 martin cgds[i].enc_type, cgds[i].key_size);
1909 1.1 martin break;
1910 1.1 martin }
1911 1.1 martin } else if (! strncmp(pm_cur->diskdev, "vnd", 3)) {
1912 1.1 martin dev_num = pm_cur->diskdev[3] - '0';
1913 1.1 martin for (i = 0; i < MAX_VND; i++)
1914 1.1 martin if (vnds[i].blocked && vnds[i].node == dev_num) {
1915 1.1 martin pm_cur->refdev = &vnds[i];
1916 1.1 martin pm_getdevstring(dev, SSTRSIZE, vnds[i].pm, vnds[i].pm_part);
1917 1.1 martin snprintf(pm_cur->diskdev_descr, STRSIZE, "%s (%s, %s)",
1918 1.1 martin pm_cur->diskdev_descr, dev, vnds[i].filepath);
1919 1.1 martin break;
1920 1.1 martin }
1921 1.1 martin } else if (! strncmp(pm_cur->diskdev, "raid", 4)) {
1922 1.1 martin dev_num = pm_cur->diskdev[4] - '0';
1923 1.1 martin for (i = 0; i < MAX_RAID; i++)
1924 1.1 martin if (raids[i].blocked && raids[i].node == dev_num) {
1925 1.1 martin pm_cur->refdev = &raids[i];
1926 1.1 martin num_devs = 0; num_devs_s = 0;
1927 1.1 martin for (ii = 0; ii < MAX_IN_RAID; ii++)
1928 1.1 martin if (raids[i].pm[ii] != NULL) {
1929 1.1 martin if(raids[i].pm_is_spare[ii])
1930 1.1 martin num_devs_s++;
1931 1.1 martin else
1932 1.1 martin num_devs++;
1933 1.1 martin }
1934 1.1 martin snprintf(pm_cur->diskdev_descr, STRSIZE,
1935 1.1 martin "%s (lvl %d, %d disks, %d spare)", pm_cur->diskdev_descr,
1936 1.1 martin raids[i].raid_level, num_devs, num_devs_s);
1937 1.1 martin break;
1938 1.1 martin }
1939 1.1 martin } else
1940 1.1 martin return -1;
1941 1.1 martin return 0;
1942 1.1 martin }
1943 1.1 martin
1944 1.1 martin /* Detect that partition is in use */
1945 1.1 martin int
1946 1.1 martin pm_partusage(pm_devs_t *pm_cur, int part_num, int do_del)
1947 1.1 martin {
1948 1.1 martin int i, ii, retvalue = 0;
1949 1.1 martin
1950 1.1 martin if (part_num < 0) {
1951 1.1 martin /* Check all partitions on device */
1952 1.1 martin for (i = 0; i < MAXPARTITIONS; i++)
1953 1.1 martin retvalue += pm_partusage(pm_cur, i, do_del);
1954 1.1 martin return retvalue;
1955 1.1 martin }
1956 1.1 martin
1957 1.1 martin for (i = 0; i < MAX_CGD; i++)
1958 1.1 martin if (cgds[i].enabled &&
1959 1.1 martin cgds[i].pm == pm_cur &&
1960 1.1 martin cgds[i].pm_part == part_num) {
1961 1.1 martin if (do_del) {
1962 1.1 martin cgds[i].pm = NULL;
1963 1.1 martin strcpy(cgds[i].pm_name, "");
1964 1.1 martin }
1965 1.1 martin return 1;
1966 1.1 martin }
1967 1.1 martin for (i = 0; i < MAX_RAID; i++)
1968 1.1 martin for (ii = 0; ii < MAX_IN_RAID; ii++)
1969 1.1 martin if (raids[i].enabled &&
1970 1.1 martin raids[i].pm[ii] == pm_cur &&
1971 1.1 martin raids[i].pm_part[ii] == part_num) {
1972 1.1 martin if (do_del)
1973 1.1 martin raids[i].pm[ii] = NULL;
1974 1.1 martin return 1;
1975 1.1 martin }
1976 1.1 martin for (i = 0; i < MAX_LVM_VG; i++)
1977 1.1 martin for (ii = 0; ii < MAX_LVM_PV; ii++)
1978 1.1 martin if (lvms[i].enabled &&
1979 1.1 martin lvms[i].pv[ii].pm == pm_cur &&
1980 1.1 martin lvms[i].pv[ii].pm_part == part_num) {
1981 1.1 martin if (do_del)
1982 1.1 martin lvms[i].pv[ii].pm = NULL;
1983 1.1 martin return 1;
1984 1.1 martin }
1985 1.1 martin
1986 1.1 martin return 0;
1987 1.1 martin }
1988 1.1 martin
1989 1.4 riz /* Clean up removed devices */
1990 1.1 martin static int
1991 1.1 martin pm_clean(void)
1992 1.1 martin {
1993 1.1 martin int count = 0;
1994 1.1 martin pm_devs_t *pm_i;
1995 1.1 martin
1996 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
1997 1.1 martin if (! pm_i->found) {
1998 1.1 martin count++;
1999 1.1 martin SLIST_REMOVE(&pm_head, pm_i, pm_devs_t, l);
2000 1.1 martin free(pm_i);
2001 1.1 martin }
2002 1.1 martin return count;
2003 1.1 martin }
2004 1.1 martin
2005 1.1 martin void
2006 1.1 martin pm_make_bsd_partitions(pm_devs_t *pm_cur)
2007 1.1 martin {
2008 1.1 martin int i;
2009 1.1 martin partinfo baklabel[MAXPARTITIONS];
2010 1.1 martin memcpy(baklabel, &pm_cur->bsdlabel, sizeof baklabel);
2011 1.1 martin
2012 1.1 martin pm_cur->unsaved = 1;
2013 1.1 martin layoutkind = LY_SETNEW;
2014 1.1 martin md_make_bsd_partitions();
2015 1.1 martin pm_cur->bootable = (pm_cur->bsdlabel[pm_cur->rootpart].pi_flags & PIF_MOUNT) ?
2016 1.1 martin 1 : 0;
2017 1.1 martin for (i = 0; i < MAXPARTITIONS; i++)
2018 1.1 martin if (pm_cur->bsdlabel[i].pi_fstype != baklabel[i].pi_fstype ||
2019 1.1 martin pm_cur->bsdlabel[i].lvmpv != baklabel[i].lvmpv)
2020 1.1 martin pm_partusage(pm_cur, i, 1);
2021 1.1 martin }
2022 1.1 martin
2023 1.1 martin void
2024 1.1 martin pm_setfstype(pm_devs_t *pm_cur, int part_num, int fstype)
2025 1.1 martin {
2026 1.1 martin pm_cur->bsdlabel[part_num].pi_mount[0] = '\0';
2027 1.1 martin pm_cur->bsdlabel[part_num].pi_flags = 0;
2028 1.1 martin pm_cur->bsdlabel[part_num].lvmpv = 0;
2029 1.1 martin pm_cur->bsdlabel[part_num].pi_fstype = fstype;
2030 1.1 martin return;
2031 1.1 martin }
2032 1.1 martin
2033 1.1 martin static void
2034 1.1 martin pm_select(pm_devs_t *pm_devs_in)
2035 1.1 martin {
2036 1.1 martin pm = pm_devs_in;
2037 1.1 martin if (logfp)
2038 1.1 martin (void)fprintf(logfp, "Partman device: %s\n", pm->diskdev);
2039 1.1 martin return;
2040 1.1 martin }
2041 1.1 martin
2042 1.1 martin void
2043 1.1 martin pm_rename(pm_devs_t *pm_cur)
2044 1.1 martin {
2045 1.1 martin pm_select(pm_cur);
2046 1.1 martin msg_prompt_win(MSG_packname, -1, 18, 0, 0, pm_cur->bsddiskname,
2047 1.1 martin pm_cur->bsddiskname, sizeof pm_cur->bsddiskname);
2048 1.1 martin #ifndef NO_DISKLABEL
2049 1.1 martin (void) savenewlabel(pm_cur->bsdlabel, MAXPARTITIONS);
2050 1.1 martin #endif
2051 1.1 martin return;
2052 1.1 martin }
2053 1.1 martin
2054 1.1 martin int
2055 1.1 martin pm_editpart(int part_num)
2056 1.1 martin {
2057 1.1 martin partinfo backup = pm->bsdlabel[part_num];
2058 1.1 martin
2059 1.1 martin edit_ptn(&(struct menudesc){.cursel = part_num}, NULL);
2060 1.1 martin if (checkoverlap(pm->bsdlabel, MAXPARTITIONS, PART_D, PART_C)) {
2061 1.1 martin msg_display_add(MSG_cantsave);
2062 1.1 martin process_menu(MENU_ok, NULL);
2063 1.1 martin pm->bsdlabel[part_num] = backup;
2064 1.1 martin return -1;
2065 1.1 martin }
2066 1.1 martin pm->unsaved = 1;
2067 1.1 martin return 0;
2068 1.1 martin }
2069 1.1 martin
2070 1.1 martin /* Safe erase of disk */
2071 1.1 martin int
2072 1.1 martin pm_shred(pm_devs_t *pm_cur, int part, int shredtype)
2073 1.1 martin {
2074 1.1 martin int error = -1;
2075 1.1 martin char dev[SSTRSIZE];
2076 1.1 martin
2077 1.1 martin pm_getdevstring(dev, SSTRSIZE, pm_cur, part);
2078 1.1 martin switch(shredtype) {
2079 1.1 martin case SHRED_ZEROS:
2080 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
2081 1.1 martin "dd of=/dev/%s if=/dev/zero bs=1m progress=100 msgfmt=human",
2082 1.1 martin dev);
2083 1.1 martin break;
2084 1.1 martin case SHRED_RANDOM:
2085 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
2086 1.1 martin "dd of=/dev/%s if=/dev/urandom bs=1m progress=100 msgfmt=human",
2087 1.1 martin dev);
2088 1.1 martin break;
2089 1.1 martin case SHRED_CRYPTO:
2090 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
2091 1.1 martin "sh -c 'cgdconfig -s cgd0 /dev/%s aes-cbc 128 < /dev/urandom'",
2092 1.1 martin dev); /* XXX: cgd0?! */
2093 1.1 martin if (! error) {
2094 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
2095 1.1 martin "dd of=/dev/rcgd0d if=/dev/urandom bs=1m progress=100 msgfmt=human");
2096 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS,
2097 1.1 martin "cgdconfig -u cgd0");
2098 1.1 martin }
2099 1.1 martin break;
2100 1.1 martin default:
2101 1.1 martin return -1;
2102 1.1 martin }
2103 1.1 martin pm_partusage(pm_cur, -1, 1);
2104 1.1 martin memset(&pm_cur->oldlabel, 0, sizeof pm_cur->oldlabel);
2105 1.1 martin memset(&pm_cur->bsdlabel, 0, sizeof pm_cur->bsdlabel);
2106 1.1 martin return error;
2107 1.1 martin }
2108 1.1 martin
2109 1.1 martin static int
2110 1.1 martin pm_mountall_sort(const void *a, const void *b)
2111 1.1 martin {
2112 1.1 martin return strcmp(mnts[*(const int *)a].on, mnts[*(const int *)b].on);
2113 1.1 martin }
2114 1.1 martin
2115 1.1 martin /* Mount all available partitions */
2116 1.1 martin static int
2117 1.1 martin pm_mountall(void)
2118 1.1 martin {
2119 1.1 martin int num_devs = 0;
2120 1.1 martin int mnts_order[MAX_MNTS];
2121 1.1 martin int i, ii, error, ok;
2122 1.1 martin char dev[SSTRSIZE]; dev[0] = '\0';
2123 1.1 martin pm_devs_t *pm_i;
2124 1.1 martin
2125 1.1 martin localfs_dev[0] = '\0';
2126 1.15 christos if (mnts == NULL)
2127 1.17 martin mnts = calloc(MAX_MNTS, sizeof(*mnts));
2128 1.1 martin
2129 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l) {
2130 1.1 martin ok = 0;
2131 1.1 martin for (i = 0; i < MAXPARTITIONS; i++) {
2132 1.1 martin if (!(pm_i->bsdlabel[i].pi_flags & PIF_MOUNT &&
2133 1.1 martin pm_i->bsdlabel[i].mnt_opts != NULL))
2134 1.1 martin continue;
2135 1.1 martin mnts[num_devs].mnt_opts = pm_i->bsdlabel[i].mnt_opts;
2136 1.2 martin if (strlen(pm_i->bsdlabel[i].mounted) > 0) {
2137 1.1 martin /* Device is already mounted. So, doing mount_null */
2138 1.1 martin strlcpy(mnts[num_devs].dev, pm_i->bsdlabel[i].mounted, MOUNTLEN);
2139 1.1 martin mnts[num_devs].mnt_opts = "-t null";
2140 1.1 martin } else {
2141 1.1 martin pm_getdevstring(dev, SSTRSIZE, pm_i, i);
2142 1.1 martin snprintf(mnts[num_devs].dev, STRSIZE, "/dev/%s", dev);
2143 1.1 martin }
2144 1.1 martin mnts[num_devs].on = pm_i->bsdlabel[i].pi_mount;
2145 1.1 martin if (strcmp(pm_i->bsdlabel[i].pi_mount, "/") == 0) {
2146 1.1 martin if (pm_i->isspecial)
2147 1.1 martin pm_i->bootable = 1;
2148 1.1 martin /* Use disk with / as a default if the user has
2149 1.1 martin the sets on a local disk */
2150 1.1 martin strlcpy(localfs_dev, pm_i->diskdev, SSTRSIZE);
2151 1.1 martin }
2152 1.1 martin num_devs++;
2153 1.1 martin ok = 1;
2154 1.1 martin }
2155 1.1 martin if (ok)
2156 1.1 martin md_pre_mount();
2157 1.1 martin }
2158 1.1 martin if (strlen(localfs_dev) < 1) {
2159 1.1 martin msg_display(MSG_noroot);
2160 1.1 martin process_menu(MENU_ok, NULL);
2161 1.1 martin return -1;
2162 1.1 martin }
2163 1.1 martin for (i = 0; i < num_devs; i++)
2164 1.1 martin mnts_order[i] = i;
2165 1.1 martin qsort(mnts_order, num_devs, sizeof mnts_order[0], pm_mountall_sort);
2166 1.1 martin
2167 1.1 martin for (i = 0; i < num_devs; i++) {
2168 1.1 martin ii = mnts_order[i];
2169 1.1 martin make_target_dir(mnts[ii].on);
2170 1.1 martin error = target_mount_do(mnts[ii].mnt_opts, mnts[ii].dev, mnts[ii].on);
2171 1.1 martin if (error)
2172 1.1 martin return error;
2173 1.1 martin }
2174 1.1 martin return 0;
2175 1.1 martin }
2176 1.1 martin
2177 1.1 martin /* Mount partition bypassing ordinary order */
2178 1.1 martin static int
2179 1.1 martin pm_mount(pm_devs_t *pm_cur, int part_num)
2180 1.1 martin {
2181 1.1 martin int error = 0;
2182 1.1 martin char buf[MOUNTLEN];
2183 1.1 martin
2184 1.1 martin if (strlen(pm_cur->bsdlabel[part_num].mounted) > 0)
2185 1.1 martin return 0;
2186 1.1 martin
2187 1.1 martin snprintf(buf, MOUNTLEN, "/tmp/%s%c", pm_cur->diskdev, part_num + 'a');
2188 1.1 martin if (! dir_exists_p(buf))
2189 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS, "/bin/mkdir -p %s", buf);
2190 1.1 martin if (pm_cur->bsdlabel[part_num].pi_flags & PIF_MOUNT &&
2191 1.1 martin pm_cur->bsdlabel[part_num].mnt_opts != NULL &&
2192 1.1 martin strlen(pm_cur->bsdlabel[part_num].mounted) < 1)
2193 1.1 martin error += run_program(RUN_DISPLAY | RUN_PROGRESS, "/sbin/mount %s /dev/%s%c %s",
2194 1.1 martin pm_cur->bsdlabel[part_num].mnt_opts,
2195 1.1 martin pm_cur->diskdev, part_num + 'a', buf);
2196 1.1 martin
2197 1.1 martin if (error)
2198 1.1 martin pm_cur->bsdlabel[part_num].mounted[0] = '\0';
2199 1.1 martin else {
2200 1.1 martin strlcpy(pm_cur->bsdlabel[part_num].mounted, buf, MOUNTLEN);
2201 1.1 martin pm_cur->blocked++;
2202 1.1 martin }
2203 1.1 martin return error;
2204 1.1 martin }
2205 1.1 martin
2206 1.1 martin void
2207 1.1 martin pm_umount(pm_devs_t *pm_cur, int part_num)
2208 1.1 martin {
2209 1.1 martin char buf[SSTRSIZE]; buf[0] = '\0';
2210 1.1 martin pm_getdevstring(buf, SSTRSIZE, pm_cur, part_num);
2211 1.1 martin
2212 1.1 martin if (run_program(RUN_DISPLAY | RUN_PROGRESS,
2213 1.1 martin "umount -f /dev/%s", buf) == 0) {
2214 1.1 martin pm_cur->bsdlabel[part_num].mounted[0] = '\0';
2215 1.1 martin if (pm_cur->blocked > 0)
2216 1.1 martin pm_cur->blocked--;
2217 1.1 martin }
2218 1.1 martin return;
2219 1.1 martin }
2220 1.1 martin
2221 1.1 martin int
2222 1.1 martin pm_unconfigure(pm_devs_t *pm_cur)
2223 1.1 martin {
2224 1.1 martin int i, error = 0, num = 0;
2225 1.1 martin if (! strncmp(pm_cur->diskdev, "cgd", 3)) {
2226 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "cgdconfig -u %s", pm_cur->diskdev);
2227 1.1 martin if (! error && pm_cur->refdev != NULL) {
2228 1.1 martin ((cgds_t*)pm_cur->refdev)->pm->blocked--;
2229 1.1 martin ((cgds_t*)pm_cur->refdev)->blocked = 0;
2230 1.1 martin }
2231 1.1 martin } else if (! strncmp(pm_cur->diskdev, "vnd", 3)) {
2232 1.19 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "vndconfig -u %s", pm_cur->diskdev);
2233 1.1 martin if (! error && pm_cur->refdev != NULL) {
2234 1.1 martin ((vnds_t*)pm_cur->refdev)->pm->blocked--;
2235 1.1 martin ((vnds_t*)pm_cur->refdev)->blocked = 0;
2236 1.1 martin }
2237 1.1 martin } else if (! strncmp(pm_cur->diskdev, "raid", 4)) {
2238 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "raidctl -u %s", pm_cur->diskdev);
2239 1.1 martin if (! error && pm_cur->refdev != NULL) {
2240 1.1 martin ((raids_t*)pm_cur->refdev)->blocked = 0;
2241 1.1 martin for (i = 0; i < MAX_IN_RAID; i++)
2242 1.1 martin if (((raids_t*)pm_cur->refdev)->pm[i] != NULL)
2243 1.1 martin ((raids_t*)pm_cur->refdev)->pm[i]->blocked--;
2244 1.1 martin }
2245 1.1 martin } else if (! strncmp(pm_cur->diskdev, "dk", 2)) {
2246 1.1 martin if (pm_cur->refdev == NULL)
2247 1.1 martin return -2;
2248 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "dkctl %s delwedge %s",
2249 1.1 martin ((pm_devs_t*)pm_cur->refdev)->diskdev, pm_cur->diskdev);
2250 1.1 martin if (! error) {
2251 1.1 martin if (pm_cur->refdev != NULL && ((pm_devs_t*)pm_cur->refdev)->blocked > 0)
2252 1.1 martin ((pm_devs_t*)pm_cur->refdev)->blocked--;
2253 1.1 martin sscanf(pm_cur->diskdev, "dk%d", &num);
2254 1.1 martin if (num >= 0 && num < MAX_WEDGES)
2255 1.1 martin wedges[num].allocated = 0;
2256 1.1 martin }
2257 1.1 martin } /* XXX: lvm */
2258 1.1 martin else
2259 1.1 martin error = run_program(RUN_DISPLAY | RUN_PROGRESS, "eject -t disk /dev/%sd",
2260 1.1 martin pm_cur->diskdev);
2261 1.1 martin if (!error)
2262 1.1 martin pm_cur->found = 0;
2263 1.1 martin return error;
2264 1.1 martin }
2265 1.1 martin
2266 1.1 martin /* Last checks before leaving partition manager */
2267 1.1 martin static int
2268 1.1 martin pm_lastcheck(void)
2269 1.1 martin {
2270 1.1 martin FILE *file_tmp = fopen(concat_paths(targetroot_mnt, "/etc/fstab"), "r");
2271 1.1 martin if (file_tmp == NULL)
2272 1.1 martin return 1;
2273 1.1 martin fclose(file_tmp);
2274 1.1 martin return 0;
2275 1.1 martin }
2276 1.1 martin
2277 1.4 riz /* Are there unsaved changes? */
2278 1.1 martin static int
2279 1.1 martin pm_needsave(void)
2280 1.1 martin {
2281 1.1 martin pm_devs_t *pm_i;
2282 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
2283 1.1 martin if (pm_i->unsaved) {
2284 1.1 martin /* Oops, we have unsaved changes */
2285 1.1 martin changed = 1;
2286 1.1 martin msg_display(MSG_saveprompt);
2287 1.10 martin return ask_yesno(NULL);
2288 1.1 martin }
2289 1.1 martin return 0;
2290 1.1 martin }
2291 1.1 martin
2292 1.1 martin /* Write all changes to disk */
2293 1.1 martin static int
2294 1.1 martin pm_commit(menudesc *m, void *arg)
2295 1.1 martin {
2296 1.1 martin int retcode;
2297 1.1 martin pm_devs_t *pm_i;
2298 1.1 martin if (m != NULL && arg != NULL)
2299 1.1 martin ((part_entry_t *)arg)[0].retvalue = m->cursel + 1;
2300 1.1 martin
2301 1.1 martin pm_gpt_commit();
2302 1.1 martin
2303 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l) {
2304 1.1 martin if (! pm_i->unsaved)
2305 1.1 martin continue;
2306 1.1 martin pm_select(pm_i);
2307 1.1 martin
2308 1.1 martin if (pm_i->isspecial) {
2309 1.1 martin if (make_filesystems() != 0) {
2310 1.1 martin if (logfp)
2311 1.1 martin fprintf(logfp, "Special disk %s preparing error\n", pm_i->diskdev);
2312 1.1 martin continue;
2313 1.1 martin }
2314 1.1 martin pm_i->unsaved = 0;
2315 1.1 martin } else if (! pm_i->gpt) {
2316 1.1 martin #ifndef NO_DISKLABEL
2317 1.1 martin savenewlabel(pm_i->bsdlabel, MAXPARTITIONS);
2318 1.1 martin #endif
2319 1.1 martin if (
2320 1.1 martin write_disklabel() != 0 || /* Write slices table (disklabel) */
2321 1.8 abs set_swap_if_low_ram(pm->diskdev, pm->bsdlabel) != 0 ||
2322 1.1 martin md_post_disklabel() != 0 || /* Enable swap and check badblock */
2323 1.4 riz make_filesystems() != 0 /* Create filesystems with newfs */
2324 1.1 martin ) {
2325 1.1 martin /* Oops, something failed... */
2326 1.1 martin if (logfp)
2327 1.1 martin fprintf(logfp, "Disk %s preparing error\n", pm_i->diskdev);
2328 1.1 martin continue;
2329 1.1 martin }
2330 1.1 martin pm_i->unsaved = 0;
2331 1.1 martin }
2332 1.1 martin }
2333 1.1 martin
2334 1.1 martin /* Call all functions that may create new devices */
2335 1.1 martin if ((retcode = pm_raid_commit()) != 0) {
2336 1.1 martin if (logfp)
2337 1.1 martin fprintf(logfp, "RAIDframe configuring error #%d\n", retcode);
2338 1.1 martin return -1;
2339 1.1 martin }
2340 1.1 martin if ((retcode = pm_cgd_commit()) != 0) {
2341 1.1 martin if (logfp)
2342 1.1 martin fprintf(logfp, "CGD configuring error #%d\n", retcode);
2343 1.1 martin return -1;
2344 1.1 martin }
2345 1.1 martin if ((retcode = pm_lvm_commit()) != 0) {
2346 1.1 martin if (logfp)
2347 1.1 martin fprintf(logfp, "LVM configuring error #%d\n", retcode);
2348 1.1 martin return -1;
2349 1.1 martin }
2350 1.1 martin if ((retcode = pm_vnd_commit()) != 0) {
2351 1.1 martin if (logfp)
2352 1.1 martin fprintf(logfp, "VND configuring error #%d\n", retcode);
2353 1.1 martin return -1;
2354 1.1 martin }
2355 1.1 martin if (m != NULL && arg != NULL)
2356 1.1 martin pm_upddevlist(m, arg);
2357 1.1 martin if (logfp)
2358 1.1 martin fflush (logfp);
2359 1.1 martin return 0;
2360 1.1 martin }
2361 1.1 martin
2362 1.1 martin static int
2363 1.1 martin pm_savebootsector(void)
2364 1.1 martin {
2365 1.1 martin pm_devs_t *pm_i;
2366 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
2367 1.1 martin if (pm_i->bootable) {
2368 1.1 martin if (! strncmp("raid", pm_i->diskdev, 4))
2369 1.1 martin if (run_program(RUN_DISPLAY | RUN_PROGRESS,
2370 1.1 martin "raidctl -v -A root %s", pm_i->diskdev) != 0) {
2371 1.1 martin if (logfp)
2372 1.1 martin fprintf(logfp, "Error writting RAID bootsector to %s\n",
2373 1.1 martin pm_i->diskdev);
2374 1.1 martin continue;
2375 1.1 martin }
2376 1.1 martin if (pm_i->gpt && ! pm_i->isspecial) {
2377 1.1 martin if (pm_i->rootpart < 0 ||
2378 1.1 martin run_program(RUN_DISPLAY | RUN_PROGRESS,
2379 1.1 martin "gpt biosboot -i %d %s",
2380 1.1 martin pm_i->rootpart + 1, pm_i->diskdev) != 0) {
2381 1.1 martin if (logfp)
2382 1.1 martin fprintf(logfp, "Error writting GPT bootsector to %s\n",
2383 1.1 martin pm_i->diskdev);
2384 1.1 martin continue;
2385 1.1 martin }
2386 1.1 martin } else {
2387 1.1 martin pm_select(pm_i);
2388 1.1 martin if (
2389 1.1 martin #ifndef NO_DISKLABEL
2390 1.1 martin check_partitions() == 0 ||
2391 1.1 martin #endif
2392 1.1 martin md_post_newfs() != 0) {
2393 1.1 martin if (logfp)
2394 1.1 martin fprintf(logfp, "Error writting bootsector to %s\n",
2395 1.1 martin pm_i->diskdev);
2396 1.1 martin continue;
2397 1.1 martin }
2398 1.1 martin }
2399 1.1 martin }
2400 1.1 martin return 0;
2401 1.1 martin }
2402 1.1 martin
2403 1.1 martin /* Function for 'Enter'-menu */
2404 1.1 martin static int
2405 1.1 martin pm_submenu(menudesc *m, void *arg)
2406 1.1 martin {
2407 1.1 martin int part_num = -1;
2408 1.1 martin pm_devs_t *pm_cur = NULL;
2409 1.1 martin ((part_entry_t *)arg)[0].retvalue = m->cursel + 1;
2410 1.1 martin
2411 1.1 martin switch (((part_entry_t *)arg)[m->cursel].type) {
2412 1.1 martin case PM_DISK_T:
2413 1.1 martin case PM_WEDGE_T:
2414 1.1 martin case PM_PART_T:
2415 1.1 martin case PM_SPEC_T:
2416 1.1 martin if (((part_entry_t *)arg)[m->cursel].dev_ptr != NULL) {
2417 1.1 martin pm_cur = ((part_entry_t *)arg)[m->cursel].dev_ptr;
2418 1.1 martin if (pm_cur == NULL)
2419 1.1 martin return -1;
2420 1.1 martin if (pm_cur->blocked) {
2421 1.1 martin msg_display(MSG_wannaunblock);
2422 1.10 martin if (!ask_noyes(NULL))
2423 1.1 martin return -2;
2424 1.1 martin pm_cur->blocked = 0;
2425 1.1 martin }
2426 1.1 martin pm_select(pm_cur);
2427 1.1 martin }
2428 1.1 martin default:
2429 1.1 martin break;
2430 1.1 martin }
2431 1.1 martin
2432 1.1 martin switch (((part_entry_t *)arg)[m->cursel].type) {
2433 1.1 martin case PM_DISK_T:
2434 1.6 martin if (pm_cur != NULL && pm_cur->gpt) {
2435 1.1 martin process_menu(MENU_pmgptentry, &part_num);
2436 1.1 martin pm_wedges_fill(pm_cur);
2437 1.6 martin } else {
2438 1.1 martin process_menu(MENU_pmdiskentry, &part_num);
2439 1.6 martin }
2440 1.1 martin break;
2441 1.1 martin case PM_WEDGE_T:
2442 1.1 martin case PM_PART_T:
2443 1.1 martin part_num = ((part_entry_t *)arg)[m->cursel].dev_num;
2444 1.1 martin process_menu(MENU_pmpartentry, &part_num);
2445 1.6 martin if (pm_cur != NULL && pm_cur->gpt)
2446 1.1 martin pm_wedges_fill(pm_cur);
2447 1.1 martin break;
2448 1.1 martin case PM_SPEC_T:
2449 1.1 martin part_num = 0;
2450 1.1 martin process_menu(MENU_pmpartentry, &part_num);
2451 1.1 martin break;
2452 1.1 martin case PM_RAID_T:
2453 1.1 martin return pm_edit(PMR_MENU_END, pm_raid_edit_menufmt,
2454 1.1 martin pm_raid_set_value, pm_raid_check, pm_raid_init,
2455 1.1 martin NULL, ((part_entry_t *)arg)[m->cursel].dev_ptr, 0, &raids_t_info);
2456 1.1 martin case PM_VND_T:
2457 1.1 martin return pm_edit(PMV_MENU_END, pm_vnd_edit_menufmt,
2458 1.1 martin pm_vnd_set_value, pm_vnd_check, pm_vnd_init,
2459 1.1 martin NULL, ((part_entry_t *)arg)[m->cursel].dev_ptr, 0, &vnds_t_info);
2460 1.1 martin case PM_CGD_T:
2461 1.1 martin return pm_cgd_edit(((part_entry_t *)arg)[m->cursel].dev_ptr,
2462 1.1 martin NULL);
2463 1.1 martin case PM_LVM_T:
2464 1.1 martin return pm_edit(PML_MENU_END, pm_lvm_edit_menufmt,
2465 1.1 martin pm_lvm_set_value, pm_lvm_check, pm_lvm_init,
2466 1.1 martin NULL, ((part_entry_t *)arg)[m->cursel].dev_ptr, 0, &lvms_t_info);
2467 1.1 martin case PM_LVMLV_T:
2468 1.1 martin return pm_edit(PMLV_MENU_END, pm_lvmlv_edit_menufmt,
2469 1.1 martin pm_lvmlv_set_value, pm_lvmlv_check, pm_lvmlv_init,
2470 1.1 martin NULL, ((part_entry_t *)arg)[m->cursel].dev_ptr,
2471 1.1 martin ((part_entry_t *)arg)[m->cursel].dev_ptr_delta, &lv_t_info);
2472 1.1 martin }
2473 1.1 martin return 0;
2474 1.1 martin }
2475 1.1 martin
2476 1.1 martin /* Functions that generate menu entries text */
2477 1.1 martin static void
2478 1.1 martin pm_menufmt(menudesc *m, int opt, void *arg)
2479 1.1 martin {
2480 1.1 martin const char *dev_status = "";
2481 1.1 martin char buf[STRSIZE];
2482 1.1 martin int part_num = ((part_entry_t *)arg)[opt].dev_num;
2483 1.1 martin pm_devs_t *pm_cur = ((part_entry_t *)arg)[opt].dev_ptr;
2484 1.1 martin
2485 1.1 martin switch (((part_entry_t *)arg)[opt].type) {
2486 1.1 martin case PM_DISK_T:
2487 1.1 martin if (pm_cur->blocked)
2488 1.1 martin dev_status = msg_string(MSG_pmblocked);
2489 1.1 martin else if (! pm_cur->unsaved)
2490 1.1 martin dev_status = msg_string(MSG_pmunchanged);
2491 1.1 martin else if (pm_cur->bootable)
2492 1.1 martin dev_status = msg_string(MSG_pmsetboot);
2493 1.1 martin else
2494 1.1 martin dev_status = msg_string(MSG_pmused);
2495 1.1 martin wprintw(m->mw, "%-33.32s %-22.21s %12.12s",
2496 1.1 martin pm_cur->diskdev_descr,
2497 1.1 martin (pm_cur->gpt) ?
2498 1.1 martin msg_string(MSG_pmgptdisk) :
2499 1.1 martin pm_cur->bsddiskname,
2500 1.1 martin dev_status);
2501 1.1 martin break;
2502 1.1 martin case PM_WEDGE_T:
2503 1.1 martin part_num = ((part_entry_t *)arg)[opt].wedge_num;
2504 1.1 martin snprintf(buf, STRSIZE, "dk%d: %s",
2505 1.1 martin part_num,
2506 1.1 martin wedges[part_num].pm->bsdlabel[wedges[part_num].ptn].pi_mount);
2507 1.24 martin wprintw(m->mw, " %-30.29s %-22.21s %11luM",
2508 1.1 martin buf,
2509 1.1 martin (wedges[part_num].pm->bsdlabel[wedges[part_num].ptn].lvmpv) ?
2510 1.1 martin "lvm pv" :
2511 1.1 martin getfslabelname(wedges[part_num].pm->bsdlabel[wedges[part_num].
2512 1.1 martin ptn].pi_fstype),
2513 1.1 martin wedges[part_num].pm->bsdlabel[wedges[part_num].ptn].pi_size /
2514 1.1 martin (MEG / pm_cur->sectorsize));
2515 1.1 martin break;
2516 1.1 martin case PM_PART_T:
2517 1.1 martin snprintf(buf, STRSIZE, "%s%c: %s %s",
2518 1.1 martin pm_cur->diskdev,
2519 1.1 martin 'a' + part_num,
2520 1.1 martin pm_cur->bsdlabel[part_num].pi_mount,
2521 1.1 martin (strlen(pm_cur->bsdlabel[part_num].mounted) > 0) ? msg_string(MSG_pmmounted) :
2522 1.1 martin (part_num == PART_B ||
2523 1.1 martin strlen (pm_cur->bsdlabel[part_num].pi_mount ) < 1 ||
2524 1.1 martin pm_cur->bsdlabel[part_num].pi_flags & PIF_MOUNT) ?
2525 1.1 martin "" : msg_string(MSG_pmunused));
2526 1.24 martin wprintw(m->mw, " %-30.29s %-22.21s %11luM",
2527 1.1 martin buf,
2528 1.1 martin (pm_cur->bsdlabel[part_num].lvmpv) ?
2529 1.1 martin "lvm pv" :
2530 1.1 martin getfslabelname(pm_cur->bsdlabel[part_num].pi_fstype),
2531 1.1 martin pm_cur->bsdlabel[part_num].pi_size / (MEG / pm_cur->sectorsize));
2532 1.1 martin break;
2533 1.1 martin case PM_SPEC_T:
2534 1.1 martin snprintf(buf, STRSIZE, "%s: %s",
2535 1.1 martin pm_cur->diskdev_descr, pm_cur->bsdlabel[0].pi_mount);
2536 1.24 martin wprintw(m->mw, "%-33.32s %-22.21s %11luM", buf,
2537 1.1 martin getfslabelname(pm_cur->bsdlabel[0].pi_fstype),
2538 1.1 martin pm_cur->bsdlabel[0].pi_size / (MEG / pm_cur->sectorsize));
2539 1.1 martin break;
2540 1.1 martin case PM_RAID_T:
2541 1.1 martin pm_raid_menufmt(m, opt, arg);
2542 1.1 martin break;
2543 1.1 martin case PM_VND_T:
2544 1.1 martin pm_vnd_menufmt(m, opt, arg);
2545 1.1 martin break;
2546 1.1 martin case PM_CGD_T:
2547 1.1 martin pm_cgd_menufmt(m, opt, arg);
2548 1.1 martin break;
2549 1.1 martin case PM_LVM_T:
2550 1.1 martin pm_lvm_menufmt(m, opt, arg);
2551 1.1 martin break;
2552 1.1 martin case PM_LVMLV_T:
2553 1.1 martin pm_lvmlv_menufmt(m, opt, arg);
2554 1.1 martin break;
2555 1.1 martin }
2556 1.1 martin return;
2557 1.1 martin }
2558 1.1 martin
2559 1.1 martin /* Submenu for RAID/LVM/CGD/VND */
2560 1.1 martin static void
2561 1.1 martin pm_upddevlist_adv(menudesc *m, void *arg, int *i,
2562 1.1 martin pm_upddevlist_adv_t *d)
2563 1.1 martin {
2564 1.1 martin int ii;
2565 1.1 martin if (d->create_msg != NULL) {
2566 1.4 riz /* We want to have menu entry that creates a new device */
2567 1.1 martin ((part_entry_t *)arg)[*i].type = d->pe_type;
2568 1.1 martin ((part_entry_t *)arg)[*i].dev_ptr = NULL;
2569 1.1 martin ((part_entry_t *)arg)[*i].dev_ptr_delta = d->s->parent_size * d->sub_num;
2570 1.1 martin m->opts[(*i)++] = (struct menu_ent) {
2571 1.1 martin .opt_name = d->create_msg,
2572 1.1 martin .opt_action = pm_submenu,
2573 1.1 martin };
2574 1.1 martin }
2575 1.1 martin for (ii = 0; ii < d->s->max; ii++) {
2576 1.1 martin if (d->s->entry_enabled == NULL ||
2577 1.1 martin d->s->entry_blocked == NULL ||
2578 1.1 martin *(int*)((char*)d->s->entry_enabled + d->s->entry_size * ii +
2579 1.1 martin d->s->parent_size * d->sub_num) == 0 ||
2580 1.1 martin *(int*)((char*)d->s->entry_blocked + d->s->entry_size * ii +
2581 1.1 martin d->s->parent_size * d->sub_num) != 0)
2582 1.1 martin continue;
2583 1.1 martin /* We have a entry for displaying */
2584 1.1 martin changed = 1;
2585 1.1 martin m->opts[*i] = (struct menu_ent) {
2586 1.1 martin .opt_name = NULL,
2587 1.1 martin .opt_action = pm_submenu,
2588 1.1 martin };
2589 1.1 martin ((part_entry_t *)arg)[*i].type = d->pe_type;
2590 1.1 martin ((part_entry_t *)arg)[*i].dev_ptr = (char*)d->s->entry_first +
2591 1.1 martin d->s->entry_size * ii + d->s->parent_size * d->sub_num;
2592 1.1 martin (*i)++;
2593 1.4 riz /* We should show submenu for current entry */
2594 1.1 martin if (d->sub != NULL) {
2595 1.1 martin d->sub->sub_num = ii;
2596 1.1 martin pm_upddevlist_adv(m, arg, i, d->sub);
2597 1.1 martin }
2598 1.1 martin }
2599 1.1 martin return;
2600 1.1 martin }
2601 1.1 martin
2602 1.1 martin /* Update partman main menu with devices list */
2603 1.1 martin static int
2604 1.1 martin pm_upddevlist(menudesc *m, void *arg)
2605 1.1 martin {
2606 1.1 martin int i = 0, ii;
2607 1.1 martin pm_devs_t *pm_i;
2608 1.1 martin
2609 1.1 martin if (arg != NULL)
2610 1.1 martin ((part_entry_t *)arg)[0].retvalue = m->cursel + 1;
2611 1.1 martin
2612 1.1 martin changed = 0;
2613 1.1 martin /* Mark all devices as not found */
2614 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l)
2615 1.1 martin if (pm_i->found > 0)
2616 1.1 martin pm_i->found = 0;
2617 1.1 martin /* Detect all present devices */
2618 1.5 martin (void)find_disks("partman");
2619 1.20 kre if (have_lvm)
2620 1.20 kre pm_lvm_find();
2621 1.1 martin pm_clean();
2622 1.1 martin
2623 1.1 martin if (m == NULL || arg == NULL)
2624 1.1 martin return -1;
2625 1.1 martin
2626 1.1 martin SLIST_FOREACH(pm_i, &pm_head, l) {
2627 1.1 martin m->opts[i].opt_name = NULL;
2628 1.1 martin m->opts[i].opt_action = pm_submenu;
2629 1.1 martin ((part_entry_t *)arg)[i].dev_ptr = pm_i;
2630 1.1 martin ((part_entry_t *)arg)[i].dev_num = -1;
2631 1.1 martin if (pm_i->isspecial)
2632 1.1 martin ((part_entry_t *)arg)[i].type = PM_SPEC_T;
2633 1.1 martin else {
2634 1.1 martin ((part_entry_t *)arg)[i].type = PM_DISK_T;
2635 1.1 martin if (pm_i->gpt) {
2636 1.1 martin pm_wedges_fill(pm_i);
2637 1.1 martin for (ii = 0; ii < MAX_WEDGES; ii++)
2638 1.1 martin if (wedges[ii].pm == pm_i) {
2639 1.1 martin i++;
2640 1.1 martin m->opts[i].opt_name = NULL;
2641 1.1 martin m->opts[i].opt_action = pm_submenu;
2642 1.1 martin ((part_entry_t *)arg)[i].dev_ptr = pm_i;
2643 1.1 martin ((part_entry_t *)arg)[i].dev_num = wedges[ii].ptn;
2644 1.1 martin ((part_entry_t *)arg)[i].wedge_num = ii;
2645 1.1 martin ((part_entry_t *)arg)[i].type = PM_WEDGE_T;
2646 1.1 martin }
2647 1.1 martin } else {
2648 1.1 martin for (ii = 0; ii < MAXPARTITIONS; ii++)
2649 1.1 martin if (pm_i->bsdlabel[ii].pi_fstype != FS_UNUSED) {
2650 1.1 martin i++;
2651 1.1 martin m->opts[i].opt_name = NULL;
2652 1.1 martin m->opts[i].opt_action = pm_submenu;
2653 1.1 martin ((part_entry_t *)arg)[i].dev_ptr = pm_i;
2654 1.1 martin ((part_entry_t *)arg)[i].dev_num = ii;
2655 1.1 martin ((part_entry_t *)arg)[i].type = PM_PART_T;
2656 1.1 martin }
2657 1.1 martin }
2658 1.1 martin }
2659 1.1 martin i++;
2660 1.1 martin }
2661 1.1 martin if (have_cgd) {
2662 1.1 martin pm_upddevlist_adv(m, arg, &i,
2663 1.1 martin &(pm_upddevlist_adv_t) {MSG_create_cgd, PM_CGD_T, &cgds_t_info, 0, NULL});
2664 1.1 martin }
2665 1.1 martin if (have_lvm) {
2666 1.1 martin pm_upddevlist_adv(m, arg, &i,
2667 1.1 martin &(pm_upddevlist_adv_t) {MSG_create_cnd, PM_VND_T, &vnds_t_info, 0, NULL});
2668 1.1 martin pm_upddevlist_adv(m, arg, &i,
2669 1.1 martin &(pm_upddevlist_adv_t) {MSG_create_vg, PM_LVM_T, &lvms_t_info, 0,
2670 1.1 martin &(pm_upddevlist_adv_t) {MSG_create_lv, PM_LVMLV_T, &lv_t_info, 0, NULL}});
2671 1.1 martin }
2672 1.1 martin if (have_raid) {
2673 1.1 martin pm_upddevlist_adv(m, arg, &i,
2674 1.1 martin &(pm_upddevlist_adv_t) {MSG_create_raid, PM_RAID_T, &raids_t_info, 0, NULL});
2675 1.1 martin }
2676 1.1 martin
2677 1.1 martin m->opts[i++] = (struct menu_ent) {
2678 1.1 martin .opt_name = MSG_updpmlist,
2679 1.1 martin .opt_action = pm_upddevlist,
2680 1.1 martin };
2681 1.1 martin m->opts[i ] = (struct menu_ent) {
2682 1.1 martin .opt_name = MSG_savepm,
2683 1.1 martin .opt_action = pm_commit,
2684 1.1 martin };
2685 1.1 martin for (ii = 0; ii <= i; ii++) {
2686 1.1 martin m->opts[ii].opt_menu = OPT_NOMENU;
2687 1.1 martin m->opts[ii].opt_flags = OPT_EXIT;
2688 1.1 martin }
2689 1.1 martin
2690 1.1 martin if (((part_entry_t *)arg)[0].retvalue >= 0)
2691 1.1 martin m->cursel = ((part_entry_t *)arg)[0].retvalue - 1;
2692 1.1 martin return i;
2693 1.1 martin }
2694 1.1 martin
2695 1.1 martin static void
2696 1.1 martin pm_menuin(menudesc *m, void *arg)
2697 1.1 martin {
2698 1.1 martin if (cursel > m->numopts)
2699 1.1 martin m->cursel = m->numopts;
2700 1.1 martin else if (cursel < 0)
2701 1.1 martin m->cursel = 0;
2702 1.1 martin else
2703 1.1 martin m->cursel = cursel;
2704 1.1 martin }
2705 1.1 martin
2706 1.1 martin static void
2707 1.1 martin pm_menuout(menudesc *m, void *arg)
2708 1.1 martin {
2709 1.1 martin cursel = m->cursel;
2710 1.1 martin }
2711 1.1 martin
2712 1.9 martin /* initialize have_* variables */
2713 1.9 martin void
2714 1.9 martin check_available_binaries()
2715 1.9 martin {
2716 1.9 martin static int did_test = false;
2717 1.9 martin
2718 1.9 martin if (did_test) return;
2719 1.9 martin did_test = 1;
2720 1.9 martin
2721 1.9 martin have_raid = binary_available("raidctl");
2722 1.19 martin have_vnd = binary_available("vndconfig");
2723 1.9 martin have_cgd = binary_available("cgdconfig");
2724 1.9 martin have_lvm = binary_available("lvm");
2725 1.9 martin have_gpt = binary_available("gpt");
2726 1.9 martin have_dk = binary_available("dkctl");
2727 1.9 martin }
2728 1.9 martin
2729 1.1 martin /* Main partman function */
2730 1.1 martin int
2731 1.1 martin partman(void)
2732 1.1 martin {
2733 1.1 martin int menu_no, menu_num_entries;
2734 1.1 martin static int firstrun = 1;
2735 1.1 martin menu_ent menu_entries[MAX_ENTRIES+6];
2736 1.1 martin part_entry_t args[MAX_ENTRIES];
2737 1.1 martin
2738 1.1 martin if (firstrun) {
2739 1.9 martin check_available_binaries();
2740 1.1 martin
2741 1.3 martin if (!have_raid)
2742 1.3 martin remove_raid_options();
2743 1.17 martin else if (!(raids = calloc(MAX_RAID, sizeof(*raids))))
2744 1.15 christos have_raid = 0;
2745 1.15 christos
2746 1.15 christos #define remove_vnd_options() (void)0
2747 1.15 christos if (!have_vnd)
2748 1.15 christos remove_vnd_options();
2749 1.17 martin else if (!(vnds = calloc(MAX_VND, sizeof(*vnds))))
2750 1.15 christos have_vnd = 0;
2751 1.15 christos
2752 1.15 christos if (!have_cgd)
2753 1.15 christos remove_cgd_options();
2754 1.17 martin else if (!(cgds = calloc(MAX_CGD, sizeof(*cgds))))
2755 1.15 christos have_cgd = 0;
2756 1.15 christos
2757 1.3 martin if (!have_lvm)
2758 1.3 martin remove_lvm_options();
2759 1.17 martin else if (!(lvms = calloc(MAX_LVM_VG, sizeof(*lvms))))
2760 1.15 christos have_lvm = 0;
2761 1.15 christos
2762 1.3 martin if (!have_gpt)
2763 1.3 martin remove_gpt_options();
2764 1.3 martin
2765 1.1 martin raids_t_info = (structinfo_t) {
2766 1.1 martin .max = MAX_RAID,
2767 1.1 martin .entry_size = sizeof raids[0],
2768 1.1 martin .entry_first = &raids[0],
2769 1.1 martin .entry_enabled = &(raids[0].enabled),
2770 1.1 martin .entry_blocked = &(raids[0].blocked),
2771 1.1 martin .entry_node = &(raids[0].node),
2772 1.1 martin };
2773 1.1 martin vnds_t_info = (structinfo_t) {
2774 1.1 martin .max = MAX_VND,
2775 1.1 martin .entry_size = sizeof vnds[0],
2776 1.1 martin .entry_first = &vnds[0],
2777 1.1 martin .entry_enabled = &(vnds[0].enabled),
2778 1.1 martin .entry_blocked = &(vnds[0].blocked),
2779 1.1 martin .entry_node = &(vnds[0].node),
2780 1.1 martin };
2781 1.1 martin cgds_t_info = (structinfo_t) {
2782 1.1 martin .max = MAX_CGD,
2783 1.1 martin .entry_size = sizeof cgds[0],
2784 1.1 martin .entry_first = &cgds[0],
2785 1.1 martin .entry_enabled = &(cgds[0].enabled),
2786 1.1 martin .entry_blocked = &(cgds[0].blocked),
2787 1.1 martin .entry_node = &(cgds[0].node),
2788 1.1 martin };
2789 1.1 martin lvms_t_info = (structinfo_t) {
2790 1.1 martin .max = MAX_LVM_VG,
2791 1.1 martin .entry_size = sizeof lvms[0],
2792 1.1 martin .entry_first = &lvms[0],
2793 1.1 martin .entry_enabled = &(lvms[0].enabled),
2794 1.1 martin .entry_blocked = &(lvms[0].blocked),
2795 1.1 martin .entry_node = NULL,
2796 1.1 martin };
2797 1.1 martin lv_t_info = (structinfo_t) {
2798 1.1 martin .max = MAX_LVM_LV,
2799 1.1 martin .entry_size = sizeof lvms[0].lv[0],
2800 1.1 martin .entry_first = &lvms[0].lv[0],
2801 1.1 martin .entry_enabled = &(lvms[0].lv[0].size),
2802 1.1 martin .entry_blocked = &(lvms[0].lv[0].blocked),
2803 1.1 martin .parent_size = sizeof lvms[0],
2804 1.1 martin };
2805 1.1 martin
2806 1.1 martin cursel = 0;
2807 1.1 martin changed = 0;
2808 1.1 martin firstrun = 0;
2809 1.1 martin }
2810 1.1 martin
2811 1.1 martin do {
2812 1.1 martin menu_num_entries = pm_upddevlist(&(menudesc){.opts = menu_entries}, args);
2813 1.1 martin menu_no = new_menu(MSG_partman_header,
2814 1.1 martin menu_entries, menu_num_entries+1, 1, 1, 0, 75, /* Fixed width */
2815 1.1 martin MC_ALWAYS_SCROLL | MC_NOBOX | MC_NOCLEAR,
2816 1.1 martin pm_menuin, pm_menufmt, pm_menuout, NULL, MSG_finishpm);
2817 1.1 martin if (menu_no == -1)
2818 1.1 martin args[0].retvalue = -1;
2819 1.1 martin else {
2820 1.1 martin args[0].retvalue = 0;
2821 1.1 martin clear();
2822 1.1 martin refresh();
2823 1.1 martin process_menu(menu_no, &args);
2824 1.1 martin free_menu(menu_no);
2825 1.1 martin }
2826 1.1 martin
2827 1.1 martin if (args[0].retvalue == 0) {
2828 1.1 martin if (pm_needsave())
2829 1.1 martin pm_commit(NULL, NULL);
2830 1.1 martin if (pm_mountall() != 0 ||
2831 1.1 martin make_fstab() != 0 ||
2832 1.1 martin pm_lastcheck() != 0 ||
2833 1.1 martin pm_savebootsector() != 0) {
2834 1.1 martin msg_display(MSG_wannatry);
2835 1.10 martin args[0].retvalue = (ask_yesno(NULL)) ? 1:-1;
2836 1.1 martin }
2837 1.1 martin }
2838 1.1 martin } while (args[0].retvalue > 0);
2839 1.1 martin
2840 1.1 martin /* retvalue <0 - error, retvalue ==0 - user quits, retvalue >0 - all ok */
2841 1.1 martin return (args[0].retvalue >= 0)?0:-1;
2842 1.1 martin }
2843 1.9 martin
2844 1.9 martin void
2845 1.9 martin update_wedges(const char *disk)
2846 1.9 martin {
2847 1.9 martin check_available_binaries();
2848 1.9 martin
2849 1.9 martin if (!have_dk)
2850 1.9 martin return;
2851 1.9 martin
2852 1.9 martin run_program(RUN_SILENT | RUN_ERROR_OK,
2853 1.9 martin "dkctl %s makewedges", disk);
2854 1.9 martin }
2855