xref: /titanic_50/usr/src/cmd/avs/dsw/iiboot.c (revision 3d729aecc03ea6ebb9bd5d56b8dccd24f57daa41) 
1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or http://www.opensolaris.org/os/licensing.
10  * See the License for the specific language governing permissions
11  * and limitations under the License.
12  *
13  * When distributing Covered Code, include this CDDL HEADER in each
14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15  * If applicable, add the following below this CDDL HEADER, with the
16  * fields enclosed by brackets "[]" replaced with your own identifying
17  * information: Portions Copyright [yyyy] [name of copyright owner]
18  *
19  * CDDL HEADER END
20  */
21 /*
22  * Copyright 2010 Sun Microsystems, Inc.  All rights reserved.
23  * Use is subject to license terms.
24  */
25 
26 #include <sys/types.h>
27 #include <sys/wait.h>
28 #include <stdio.h>
29 #include <sys/param.h>
30 #include <errno.h>
31 #include <limits.h>
32 #include <fcntl.h>
33 #include <strings.h>
34 #include <stdlib.h>
35 #include <unistd.h>
36 #include <signal.h>
37 
38 #include <locale.h>
39 #include <langinfo.h>
40 #include <libintl.h>
41 #include <stdarg.h>
42 #include <ctype.h>
43 
44 #include <sys/nsctl/cfg.h>
45 
46 #include <sys/unistat/spcs_s.h>
47 #include <sys/unistat/spcs_s_u.h>
48 #include <sys/unistat/spcs_errors.h>
49 
50 #include <sys/nsctl/dsw.h>
51 #include <sys/nskernd.h>
52 
53 #define	MAX_PROCESSES 64
54 
55 int parseopts(int, char **, int *);
56 int read_resume_cfg();
57 int read_suspend_cfg();
58 void iiboot_usage(void);
59 extern char *basename(char *);
60 
61 dsw_config_t *resume_list = 0;
62 dsw_ioctl_t *suspend_list = 0;
63 int	n_structs;
64 char *program;
65 char *cfg_cluster_tag = NULL;
66 
67 volatile int fork_cnt;
68 volatile int fork_rc;
69 
70 static void
71 iiboot_msg(char *prefix, spcs_s_info_t *status, char *string, va_list ap)
72 {
73 	if (status) {
74 		(void) fprintf(stderr, "II: %s\n", prefix);
75 		spcs_s_report(*status, stderr);
76 		spcs_s_ufree(status);
77 	} else {
78 		(void) fprintf(stderr, "%s: %s: ", program, prefix);
79 	}
80 
81 	if (string && *string != '\0') {
82 		(void) vfprintf(stderr, string, ap);
83 	}
84 
85 	(void) fprintf(stderr, "\n");
86 }
87 
88 static void
89 iiboot_err(spcs_s_info_t *status, char *string, ...)
90 {
91 	va_list ap;
92 	va_start(ap, string);
93 
94 	iiboot_msg(gettext("Error"), status, string, ap);
95 
96 	va_end(ap);
97 	exit(1);
98 }
99 
100 static void
101 iiboot_warn(spcs_s_info_t *status, char *string, ...)
102 {
103 	va_list ap;
104 	va_start(ap, string);
105 
106 	iiboot_msg(gettext("warning"), status, string, ap);
107 
108 	va_end(ap);
109 }
110 
111 /* ARGSUSED */
112 static void
113 sigchld(int sig)
114 {
115 	int wait_loc = 0;
116 
117 	(void) wait(&wait_loc);
118 	if (WIFEXITED(wait_loc) && (WEXITSTATUS(wait_loc) == 0)) {
119 		;
120 		/*EMPTY*/
121 	} else {
122 		fork_rc = WEXITSTATUS(wait_loc);
123 	}
124 
125 	if (fork_cnt > 0)
126 		--fork_cnt;
127 }
128 
129 
130 int
131 #ifdef lint
132 iiboot_lintmain(int argc, char *argv[])
133 #else
134 main(int argc, char *argv[])
135 #endif
136 {
137 	int pairs;
138 	pid_t pid = 0;
139 	int flag = 0;
140 	int i, j;
141 	int rc;
142 	int	ioctl_fd;
143 	void *ioarg;
144 	dsw_ioctl_t *ii_iop, ii_suspend;
145 	dsw_list_t args = {0};
146 	dsw_config_t *ii_cfgp, *lp = NULL;
147 	spcs_s_info_t ustatus;
148 	int max_processes = MAX_PROCESSES;
149 
150 	(void) setlocale(LC_ALL, "");
151 	(void) textdomain("ii");
152 
153 	program = strdup(basename(argv[0]));
154 
155 	if ((ioctl_fd = open(DSWDEV, O_RDWR, 0)) == -1) {
156 		spcs_log("ii", NULL, "iiboot open %s failed, errno %d",
157 			DSWDEV, errno);
158 		iiboot_err(NULL,
159 		    gettext("Failed to open Point-in-Time Copy control "
160 			    "device"));
161 	}
162 
163 	if (parseopts(argc, argv, &flag))
164 		return (1);
165 
166 	if (flag == DSWIOC_RESUME)
167 		pairs = read_resume_cfg();
168 	else
169 		pairs = -1;
170 
171 	if (pairs == 0) {
172 #ifdef DEBUG
173 		iiboot_err(NULL,
174 		    gettext("Config contains no Point-in-Time Copy sets"));
175 #endif
176 		return (0);
177 	}
178 
179 	if (cfg_cluster_tag == NULL && flag != DSWIOC_RESUME) {
180 		if (ioctl(ioctl_fd, DSWIOC_SHUTDOWN, 0) < 0) {
181 			spcs_log("ii", &ustatus, "iiboot shutdown failed");
182 			iiboot_err(NULL, gettext("SHUTDOWN ioctl error"));
183 		}
184 		return (0);
185 	} else if (cfg_cluster_tag != NULL && flag == DSWIOC_SUSPEND) {
186 		bzero(&ii_suspend, sizeof (dsw_ioctl_t));
187 		ii_suspend.status = spcs_s_ucreate();
188 		ii_suspend.flags = CV_IS_CLUSTER;
189 		(void) strncpy(ii_suspend.shadow_vol, cfg_cluster_tag,
190 		    DSW_NAMELEN);
191 		rc = ioctl(ioctl_fd, flag, &ii_suspend);
192 		if ((rc) && (errno != DSW_ECNOTFOUND)) {
193 			spcs_log("ii", &ii_suspend.status,
194 			    "iiboot resume cluster %s failed", cfg_cluster_tag);
195 			iiboot_err(&ii_suspend.status, gettext("ioctl error"));
196 			spcs_s_ufree(&ii_suspend.status);
197 			return (-1);
198 		}
199 		spcs_s_ufree(&ii_suspend.status);
200 		return (0);
201 
202 	} else if ((cfg_cluster_tag != NULL) && (flag == DSWIOC_RESUME)) {
203 		/*
204 		 * If we are running in a Sun Cluster, this is a resume
205 		 * operation, get a list of all shadow volumes, where the
206 		 * shadow volumes match the shadows of the sets being resumed
207 		 */
208 		rc = ioctl(ioctl_fd, DSWIOC_LISTLEN, &args);
209 		if (rc == -1) {
210 			spcs_log("ii", NULL,
211 				"iiboot get LIST failed, errno %d", errno);
212 			iiboot_err(NULL,
213 				gettext("Failed to get LIST of Point-in-Time "
214 				    "sets"));
215 			return (-1);
216 		}
217 
218 		args.status = spcs_s_ucreate();
219 		args.list_used = 0;
220 		args.list_size = rc + 4;
221 		lp = args.list = (dsw_config_t *)
222 		    malloc(args.list_size * sizeof (dsw_config_t));
223 		if (args.list == NULL) {
224 			iiboot_err(NULL,
225 				gettext("Failed to allocate memory"));
226 		}
227 		if (ioctl(ioctl_fd, DSWIOC_LIST, &args)  == -1) {
228 			spcs_log("ii", &args.status, "Failed to get LIST");
229 			iiboot_err(&args.status, gettext("ioctl error"));
230 		}
231 		spcs_s_ufree(&args.status);
232 
233 		/* Remove all elements that are not in the resume list */
234 		for (j = args.list_used; j; j--) {
235 			for (i = 0; i < pairs; i++) {
236 				if (strcmp(lp->shadow_vol,
237 				    resume_list[i].shadow_vol) == 0) {
238 					if (strlen(lp->cluster_tag) == 0) {
239 						lp++;
240 						break;
241 					}
242 				}
243 			}
244 			if (i != pairs)
245 				continue;
246 			(void) memmove(lp, lp + 1, j * sizeof (dsw_config_t));
247 			args.list_used--;
248 		}
249 	}
250 
251 	(void) sigset(SIGCHLD, sigchld);
252 	fork_cnt = fork_rc = 0;
253 	for (i = 0; i < pairs; i++) {
254 		ustatus = spcs_s_ucreate();
255 		if (flag == DSWIOC_RESUME) {
256 			ioarg = (void *) (ii_cfgp = (resume_list + i));
257 			ii_cfgp->status = ustatus;
258 			pid = fork();
259 		} else {
260 			ioarg = (void *) (ii_iop = (suspend_list + i));
261 			ii_iop->status = ustatus;
262 		}
263 		while (pid == -1) {		/* error forking */
264 			perror("fork");
265 
266 			/* back off on the max processes and try again */
267 			--max_processes;
268 			if (fork_cnt > 0) {
269 				(void) pause();
270 			}
271 			pid = fork();
272 		}
273 
274 		if (pid > 0) {		/* this is parent process */
275 			++fork_cnt;
276 			while (fork_cnt > MAX_PROCESSES) {
277 				(void) pause();
278 			}
279 			continue;
280 		}
281 
282 		rc = ioctl(ioctl_fd, flag, ioarg);
283 		if (rc == SPCS_S_ERROR) {
284 			if (flag == DSWIOC_RESUME)
285 				spcs_log("ii", &ustatus,
286 					"iiboot resume %s failed",
287 					ii_cfgp->shadow_vol);
288 			else
289 				spcs_log("ii", &ustatus,
290 					"iiboot suspend %s failed",
291 					ii_iop->shadow_vol);
292 			iiboot_err(&ustatus, gettext("ioctl error"));
293 		}
294 		/* Resuming child */
295 		spcs_s_ufree(&ustatus);
296 		if (flag == DSWIOC_RESUME)
297 			exit(0);
298 	}
299 
300 	/*
301 	 * Allow all processes to finish up before exiting
302 	 * Set rc for success
303 	 */
304 	while (fork_cnt > 0) {
305 		(void) alarm(60);	/* wake up in 60 secs just in case */
306 		(void) pause();
307 	}
308 	(void) alarm(0);
309 
310 	/* Disable duplicate shadows that were part of the implicit join */
311 	if ((j = args.list_used) != 0) {
312 		int setno;
313 		char key[CFG_MAX_KEY], buf[CFG_MAX_BUF], sn[CFG_MAX_BUF];
314 		CFGFILE *cfg;
315 		char *mst, *shd, *ctag;
316 		pid_t pid = fork();
317 
318 		if (pid == -1) {
319 			iiboot_err(NULL, gettext("Failed to fork"));
320 			return (errno);
321 		} else if (pid > 0) {
322 			return (0);	/* Parent, OK exit */
323 		}
324 
325 		for (j = args.list_used, lp = args.list; j; j--, lp++) {
326 		    setno = 0;
327 		    while (++setno) {
328 
329 			/*
330 			 * Open the configuration database
331 			 */
332 			if (!(cfg = cfg_open(""))) {
333 			    iiboot_err(NULL, gettext("Failed to open dscfg"));
334 			    return (-1);
335 			}
336 
337 			/* Sooner or later, this lock will be free */
338 			while (!cfg_lock(cfg, CFG_WRLOCK))
339 				(void) sleep(2);
340 
341 			(void) snprintf(key, CFG_MAX_KEY, "ii.set%d", setno);
342 			if (cfg_get_cstring(cfg, key, buf, CFG_MAX_BUF) < 0) {
343 				cfg_close(cfg);
344 				break;
345 			}
346 
347 			/* For imported shadows, master must be special tag */
348 			mst = strtok(buf, " ");		/* master */
349 			shd = strtok(NULL, " ");	/* shadow */
350 			(void) strtok(NULL, " ");	/* bitmap */
351 			(void) strtok(NULL, " ");	/* mode */
352 			(void) strtok(NULL, " ");	/* overflow */
353 			ctag = strtok(NULL, " ");	/* cnode */
354 
355 			/*
356 			 * For this record to be processed, the shadow volume
357 			 * name must match and the cluster tag must be blank
358 			 */
359 			if (strcmp(lp->shadow_vol, shd) || strcmp(ctag, "-")) {
360 				cfg_close(cfg);
361 				continue;
362 			}
363 
364 			/* Derrive local cluster tag */
365 			if (cfg_l_dgname(lp->shadow_vol, sn, sizeof (sn)))
366 				ctag = sn;
367 			else
368 				iiboot_err(NULL, gettext(
369 					"Failed to device group for shadow %s"),
370 					lp->shadow_vol);
371 
372 			/* disable master volume if not imported */
373 			if (strcmp(mst, II_IMPORTED_SHADOW))
374 			    if (cfg_vol_disable(cfg, mst, cfg_cluster_tag,
375 				"ii") < 0)
376 				iiboot_err(NULL, gettext(
377 				    "SV disable of master failed"));
378 
379 			/*
380 			 * Delete the Imported Shadow set
381 			 */
382 			if (cfg_put_cstring(cfg, key, NULL, 0) < 0) {
383 				iiboot_err(NULL, gettext(
384 					"Failed to delete Imported shadow %s"),
385 					lp->shadow_vol);
386 			}
387 
388 			/*
389 			 * SV disable shadow volume
390 			 */
391 			if (cfg_vol_disable(cfg, shd, NULL, "ii") < 0)
392 				iiboot_err(NULL, gettext(
393 					"SV disable of shadow failed"));
394 
395 			/*
396 			 * Commit the delete
397 			 */
398 			(void) cfg_commit(cfg);
399 			cfg_close(cfg);
400 
401 			/*
402 			 * Open the configuration database
403 			 */
404 			if (!(cfg = cfg_open(""))) {
405 			    iiboot_err(NULL, gettext("Failed to open dscfg"));
406 			    return (-1);
407 			}
408 
409 			/* Sooner or later, this lock will be free */
410 			while (!cfg_lock(cfg, CFG_WRLOCK))
411 				(void) sleep(2);
412 
413 			/* Set cluster tag for Shadow volume */
414 			(void) cfg_vol_enable(cfg, shd, ctag, "ii");
415 
416 
417 			/*
418 			 * Commit the delete
419 			 */
420 			(void) cfg_commit(cfg);
421 			cfg_close(cfg);
422 		    }
423 		}
424 	}
425 	return (fork_rc);
426 }
427 
428 static int
429 set_is_offline(char *cflags)
430 {
431 	unsigned int flags;
432 	int conv;
433 
434 	if (!cflags || !*cflags)
435 		return (0);
436 
437 	/* convert flags to an int */
438 	conv = sscanf(cflags, "%x", &flags);
439 	return ((conv == 1) && ((flags & DSW_OFFLINE) != 0));
440 }
441 
442 /*
443  * read_resume_cfg()
444  *
445  * DESCRIPTION: Read the relevant config info via libcfg
446  *
447  * Outputs:
448  *	int i			Number of Point-in-Time Copy sets
449  *
450  * Side Effects: The 0 to i-1 entries in the resume_list are filled.
451  *
452  */
453 
454 int
455 read_resume_cfg()
456 {
457 	CFGFILE *cfg;
458 	int i;
459 	char *buf, **entry, *mst, *shd, *bmp, *ctag, *opt, *ptr;
460 	int valid_sets;
461 	dsw_config_t *p;
462 	static int offset = sizeof (NSKERN_II_BMP_OPTION);
463 
464 	spcs_log("ii", NULL, "iiboot resume cluster tag %s",
465 			cfg_cluster_tag ? cfg_cluster_tag : "<none>");
466 	if ((cfg = cfg_open("")) == NULL) {
467 		spcs_log("ii", NULL, "iiboot cfg_open failed, errno %d",
468 			errno);
469 		iiboot_err(NULL, gettext("Error opening config"));
470 	}
471 
472 	cfg_resource(cfg, cfg_cluster_tag);
473 	if (!cfg_lock(cfg, CFG_RDLOCK)) {
474 		spcs_log("ii", NULL, "iiboot CFG_RDLOCK failed, errno %d",
475 			errno);
476 		iiboot_err(NULL, gettext("Error locking config"));
477 	}
478 
479 	/* Determine number of set, if zero return 0 */
480 	if ((n_structs = cfg_get_section(cfg, &entry, "ii")) == 0)
481 		return (0);
482 
483 	resume_list = calloc(n_structs, sizeof (*resume_list));
484 	if (resume_list == NULL) {
485 		spcs_log("ii", NULL, "iiboot resume realloc failed, errno %d",
486 		    errno);
487 		iiboot_err(NULL, gettext("Resume realloc failed"));
488 	}
489 
490 	valid_sets = 0;
491 	p = resume_list;
492 	for (i = 0; i < n_structs; i++) {
493 		buf = entry[i];
494 		mst = strtok(buf, " ");
495 		shd = strtok(NULL, " ");
496 		bmp = strtok(NULL, " ");
497 		(void) strtok(NULL, " ");	/* mode */
498 		(void) strtok(NULL, " ");	/* overflow */
499 		ctag = strtok(NULL, " ");	/* ctag */
500 		if (ctag)
501 			ctag += strspn(ctag, "-");
502 		opt = strtok(NULL, " ");
503 
504 		if (!mst || !shd || !bmp)
505 			break;
506 
507 		/* If cluster tags don't match, skip record */
508 		if ((cfg_cluster_tag && strcmp(ctag, cfg_cluster_tag)) ||
509 		    (!cfg_cluster_tag && strlen(ctag))) {
510 			free(buf);
511 			continue;
512 		}
513 
514 		ptr = strstr(opt, NSKERN_II_BMP_OPTION "=");
515 		if (ptr && set_is_offline(ptr + offset)) {
516 			free(buf);
517 			continue;
518 		}
519 
520 		(void) strncpy(p->master_vol, mst, DSW_NAMELEN);
521 		(void) strncpy(p->shadow_vol, shd, DSW_NAMELEN);
522 		(void) strncpy(p->bitmap_vol, bmp, DSW_NAMELEN);
523 		if (ctag)
524 			(void) strncpy(p->cluster_tag, ctag, DSW_NAMELEN);
525 		free(buf);
526 		++p;
527 		++valid_sets;
528 	}
529 
530 	while (i < n_structs)
531 		free(entry[i++]);
532 	if (entry)
533 		free(entry);
534 
535 	cfg_close(cfg);
536 	return (valid_sets);
537 }
538 
539 /*
540  * read_suspend_cfg()
541  *
542  * DESCRIPTION: Read the relevant config info via libcfg
543  *
544  * Outputs:
545  *	int i			Number of Point-in-Time Copy sets
546  *
547  * Side Effects: The 0 to i-1 entries in the suspend_list are filled.
548  *
549  */
550 
551 int
552 read_suspend_cfg()
553 {
554 	int rc;
555 	CFGFILE *cfg;
556 	int i;
557 	char buf[CFG_MAX_BUF];
558 	char key[CFG_MAX_KEY];
559 	int setnumber;
560 	dsw_ioctl_t *p;
561 
562 	spcs_log("ii", NULL, "iiboot suspend cluster tag %s",
563 			cfg_cluster_tag ? cfg_cluster_tag : "<none>");
564 
565 	if (cfg_cluster_tag == NULL) {
566 		return (1);
567 	}
568 
569 	if ((cfg = cfg_open("")) == NULL) {
570 		spcs_log("ii", NULL, "iiboot cfg_open failed, errno %d",
571 			errno);
572 		iiboot_err(NULL, gettext("Error opening config"));
573 	}
574 
575 	cfg_resource(cfg, cfg_cluster_tag);
576 	if (!cfg_lock(cfg, CFG_RDLOCK)) {
577 		spcs_log("ii", NULL, "iiboot CFG_RDLOCK failed, errno %d",
578 			errno);
579 		iiboot_err(NULL, gettext("Error locking config"));
580 	}
581 
582 
583 	/*CSTYLED*/
584 	for (i = 0; ; i++) {
585 		setnumber = i + 1;
586 
587 		bzero(buf, CFG_MAX_BUF);
588 		(void) snprintf(key, sizeof (key), "ii.set%d", setnumber);
589 		rc = cfg_get_cstring(cfg, key, buf, CFG_MAX_BUF);
590 		if (rc < 0)
591 			break;
592 		if (n_structs < setnumber) {
593 			n_structs += 2;
594 			suspend_list = realloc(suspend_list,
595 					sizeof (*suspend_list) * n_structs);
596 			if (suspend_list == NULL) {
597 			    spcs_log("ii", NULL,
598 			    "iiboot suspend realloc failed, errno %d",
599 			    errno);
600 			    iiboot_err(NULL, gettext("Suspend realloc failed"));
601 			}
602 		}
603 		p = suspend_list + i;
604 
605 		(void) snprintf(key, sizeof (key), "ii.set%d.shadow",
606 		    setnumber);
607 		(void) cfg_get_cstring(cfg, key, p->shadow_vol, DSW_NAMELEN);
608 
609 	}
610 
611 	cfg_close(cfg);
612 	return (i);
613 }
614 
615 
616 int
617 parseopts(argc, argv, flag)
618 int argc;
619 char **argv;
620 int *flag;
621 {
622 	int  errflag = 0;
623 	int  Cflag = 0;
624 	char c;
625 	char inval = 0;
626 
627 	while ((c = getopt(argc, argv, "hrsC:")) != -1) {
628 		switch (c) {
629 		case 'C':
630 			if (Cflag) {
631 				iiboot_warn(NULL,
632 				    gettext("-C specified multiple times"));
633 				iiboot_usage();
634 				return (-1);
635 			}
636 
637 			Cflag++;
638 			cfg_cluster_tag = (optarg[0] == '-') ? NULL : optarg;
639 			break;
640 
641 		case 'h':
642 			iiboot_usage();
643 			exit(0);
644 			/* NOTREACHED */
645 
646 		case 'r':
647 			if (*flag)
648 				inval = 1;
649 			*flag = DSWIOC_RESUME;
650 			break;
651 		case 's':
652 			if (*flag)
653 				inval = 1;
654 			*flag = DSWIOC_SUSPEND;
655 			break;
656 		case '?':
657 			errflag++;
658 		}
659 	}
660 
661 	if (inval) {
662 		iiboot_warn(NULL, gettext("Invalid argument combination"));
663 		errflag = 1;
664 	}
665 
666 	if (!*flag || errflag) {
667 		iiboot_usage();
668 		return (-1);
669 	}
670 
671 	return (0);
672 }
673 
674 void
675 iiboot_usage()
676 {
677 	(void) fprintf(stderr, gettext("usage:\n"));
678 	(void) fprintf(stderr,
679 		gettext("\t%s -r [-C tag]\t\tresume\n"), program);
680 	(void) fprintf(stderr,
681 		gettext("\t%s -s [-C tag]\t\tsuspend\n"), program);
682 	(void) fprintf(stderr, gettext("\t%s -h\t\t\tthis help message\n"),
683 	    program);
684 }
685