[thirdparty/mdadm.git] / mdstat.c

/*
 * mdstat - parse /proc/mdstat file. Part of:
 * mdadm - manage Linux "md" devices aka RAID arrays.
 *
 * Copyright (C) 2002-2009 Neil Brown <neilb@suse.de>
 *
 *
 *    This program is free software; you can redistribute it and/or modify
 *    it under the terms of the GNU General Public License as published by
 *    the Free Software Foundation; either version 2 of the License, or
 *    (at your option) any later version.
 *
 *    This program is distributed in the hope that it will be useful,
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *    GNU General Public License for more details.
 *
 *    You should have received a copy of the GNU General Public License
 *    along with this program; if not, write to the Free Software
 *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 *    Author: Neil Brown
 *    Email: <neilb@suse.de>
 */

/*
 * The /proc/mdstat file comes in at least 3 flavours:
 * In an unpatched 2.2 kernel (md 0.36.6):
 *  Personalities : [n raidx] ...
 *  read_ahead {not set|%d sectors}
 *  md0 : {in}active{ raidX /dev/hda...  %d blocks{ maxfault=%d}}
 *  md1 : .....
 *
 * Normally only 4 md lines, but all are listed.
 *
 * In a patched 2.2 kernel (md 0.90.0)
 *  Personalities : [raidx] ...
 *  read_ahead {not set|%d sectors}
 *  mdN : {in}active {(readonly)} raidX dev[%d]{(F)} ... %d blocks STATUS RESYNC
 *  ... Only initialised arrays listed
 *  unused devices: {dev dev ... | <none>}
 *
 * STATUS is personality dependant:
 *    linear:  %dk rounding
 *    raid0:   %dk chunks
 *    raid1:   [%d/%d] [U_U]   ( raid/working.  operational or not)
 *    raid5:   level 4/5, %dk chunk, algorithm %d [%d/%d] [U_U]
 *
 * RESYNC is  empty or:
 *    {resync|recovery}=%u%% finish=%u.%umin
 *  or
 *    resync=DELAYED
 *
 * In a 2.4 kernel (md 0.90.0/2.4)
 *  Personalities : [raidX] ...
 *  read_ahead {not set|%d sectors}
 *  mdN : {in}active {(read-only)} raidX dev[%d]{(F)} ...
 *       %d blocks STATUS
 *       RESYNC
 *  unused devices: {dev dev .. | <none>}
 *
 *  STATUS matches 0.90.0/2.2
 *  RESYNC includes [===>....],
 *          adds a space after {resync|recovery} and before and after '='
 *          adds a decimal to the recovery percent.
 *	    adds (%d/%d) resync amount  and max_blocks, before finish.
 *	    adds speed=%dK/sec after finish
 *
 *
 *
 * Out of this we want to extract:
 *   list of devices, active or not
 *   pattern of failed drives (so need number of drives)
 *   percent resync complete
 *
 * As continuation is indicated by leading space, we use
 *  conf_line from config.c to read logical lines
 *
 */

#include	"mdadm.h"
#include	"dlink.h"
#include	<sys/select.h>
#include	<ctype.h>

static void free_member_devnames(struct dev_member *m)
{
	while(m) {
		struct dev_member *t = m;

		m = m->next;
		free(t->name);
		free(t);
	}
}

static int add_member_devname(struct dev_member **m, char *name)
{
	struct dev_member *new;
	char *t;

	if ((t = strchr(name, '[')) == NULL)
		/* not a device */
		return 0;

	new = xmalloc(sizeof(*new));
	new->name = strndup(name, t - name);
	new->next = *m;
	*m = new;
	return 1;
}

void free_mdstat(struct mdstat_ent *ms)
{
	while (ms) {
		struct mdstat_ent *t;
		free(ms->level);
		free(ms->pattern);
		free(ms->metadata_version);
		free_member_devnames(ms->members);
		t = ms;
		ms = ms->next;
		free(t);
	}
}

static int mdstat_fd = -1;
struct mdstat_ent *mdstat_read(int hold, int start)
{
	FILE *f;
	struct mdstat_ent *all, *rv, **end, **insert_here;
	char *line;
	int fd;

	if (hold && mdstat_fd != -1) {
		off_t offset = lseek(mdstat_fd, 0L, 0);
		if (offset == (off_t)-1) {
			return NULL;
		}
		fd = dup(mdstat_fd);
		if (fd >= 0)
			f = fdopen(fd, "r");
		else
			return NULL;
	} else
		f = fopen("/proc/mdstat", "r");
	if (f == NULL)
		return NULL;
	else
		fcntl(fileno(f), F_SETFD, FD_CLOEXEC);

	all = NULL;
	end = &all;
	for (; (line = conf_line(f)) ; free_line(line)) {
		struct mdstat_ent *ent;
		char *w;
		char devnm[32];
		int in_devs = 0;

		if (strcmp(line, "Personalities") == 0)
			continue;
		if (strcmp(line, "read_ahead") == 0)
			continue;
		if (strcmp(line, "unused") == 0)
			continue;
		insert_here = NULL;
		/* Better be an md line.. */
		if (strncmp(line, "md", 2)!= 0 || strlen(line) >= 32 ||
		    (line[2] != '_' && !isdigit(line[2])))
			continue;
		strcpy(devnm, line);

		ent = xmalloc(sizeof(*ent));
		ent->level = ent->pattern= NULL;
		ent->next = NULL;
		ent->percent = RESYNC_NONE;
		ent->active = -1;
		ent->resync = 0;
		ent->metadata_version = NULL;
		ent->raid_disks = 0;
		ent->devcnt = 0;
		ent->members = NULL;

		strcpy(ent->devnm, devnm);

		for (w=dl_next(line); w!= line ; w=dl_next(w)) {
			int l = strlen(w);
			char *eq;
			if (strcmp(w, "active") == 0)
				ent->active = 1;
			else if (strcmp(w, "inactive") == 0) {
				ent->active = 0;
				in_devs = 1;
			} else if (ent->active > 0 &&
				 ent->level == NULL &&
				 w[0] != '(' /*readonly*/) {
				ent->level = xstrdup(w);
				in_devs = 1;
			} else if (in_devs && strcmp(w, "blocks") == 0)
				in_devs = 0;
			else if (in_devs) {
				char *ep = strchr(w, '[');
				ent->devcnt +=
					add_member_devname(&ent->members, w);
				if (ep && strncmp(w, "md", 2) == 0) {
					/* This has an md device as a component.
					 * If that device is already in the
					 * list, make sure we insert before
					 * there.
					 */
					struct mdstat_ent **ih;
					ih = &all;
					while (ih != insert_here && *ih &&
					       ((int)strlen((*ih)->devnm) !=
						ep-w ||
						strncmp((*ih)->devnm, w,
							ep-w) != 0))
						ih = & (*ih)->next;
					insert_here = ih;
				}
			} else if (strcmp(w, "super") == 0 &&
				   dl_next(w) != line) {
				w = dl_next(w);
				ent->metadata_version = xstrdup(w);
			} else if (w[0] == '[' && isdigit(w[1])) {
				ent->raid_disks = atoi(w+1);
			} else if (!ent->pattern &&
				   w[0] == '[' &&
				   (w[1] == 'U' || w[1] == '_')) {
				ent->pattern = xstrdup(w+1);
				if (ent->pattern[l-2] == ']')
					ent->pattern[l-2] = '\0';
			} else if (ent->percent == RESYNC_NONE &&
				   strncmp(w, "re", 2) == 0 &&
				   w[l-1] == '%' &&
				   (eq = strchr(w, '=')) != NULL ) {
				ent->percent = atoi(eq+1);
				if (strncmp(w,"resync", 6) == 0)
					ent->resync = 1;
				else if (strncmp(w, "reshape", 7) == 0)
					ent->resync = 2;
				else
					ent->resync = 0;
			} else if (ent->percent == RESYNC_NONE &&
				   (w[0] == 'r' || w[0] == 'c')) {
				if (strncmp(w, "resync", 6) == 0)
					ent->resync = 1;
				if (strncmp(w, "reshape", 7) == 0)
					ent->resync = 2;
				if (strncmp(w, "recovery", 8) == 0)
					ent->resync = 0;
				if (strncmp(w, "check", 5) == 0)
					ent->resync = 3;

				if (l > 8 && strcmp(w+l-8, "=DELAYED") == 0)
					ent->percent = RESYNC_DELAYED;
				if (l > 8 && strcmp(w+l-8, "=PENDING") == 0)
					ent->percent = RESYNC_PENDING;
				if (l > 7 && strcmp(w+l-7, "=REMOTE") == 0)
					ent->percent = RESYNC_REMOTE;
			} else if (ent->percent == RESYNC_NONE &&
				   w[0] >= '0' &&
				   w[0] <= '9' &&
				   w[l-1] == '%') {
				ent->percent = atoi(w);
			}
		}
		if (insert_here && (*insert_here)) {
			ent->next = *insert_here;
			*insert_here = ent;
		} else {
			*end = ent;
			end = &ent->next;
		}
	}
	if (hold && mdstat_fd == -1) {
		mdstat_fd = dup(fileno(f));
		fcntl(mdstat_fd, F_SETFD, FD_CLOEXEC);
	}
	fclose(f);

	/* If we might want to start array,
	 * reverse the order, so that components comes before composites
	 */
	if (start) {
		rv = NULL;
		while (all) {
			struct mdstat_ent *e = all;
			all = all->next;
			e->next = rv;
			rv = e;
		}
	} else
		rv = all;
	return rv;
}

void mdstat_close(void)
{
	if (mdstat_fd >= 0)
		close(mdstat_fd);
	mdstat_fd = -1;
}

void mdstat_wait(int seconds)
{
	fd_set fds;
	struct timeval tm;
	int maxfd = 0;
	FD_ZERO(&fds);
	if (mdstat_fd >= 0) {
		FD_SET(mdstat_fd, &fds);
		maxfd = mdstat_fd;
	} else
		return;
	tm.tv_sec = seconds;
	tm.tv_usec = 0;
	select(maxfd + 1, NULL, NULL, &fds, &tm);
}

void mdstat_wait_fd(int fd, const sigset_t *sigmask)
{
	fd_set fds, rfds;
	int maxfd = 0;

	FD_ZERO(&fds);
	FD_ZERO(&rfds);
	if (mdstat_fd >= 0)
		FD_SET(mdstat_fd, &fds);

	if (fd >= 0) {
		struct stat stb;
		fstat(fd, &stb);
		if ((stb.st_mode & S_IFMT) == S_IFREG)
			/* Must be a /proc or /sys fd, so expect
			 * POLLPRI
			 * i.e. an 'exceptional' event.
			 */
			FD_SET(fd, &fds);
		else
			FD_SET(fd, &rfds);

		if (fd > maxfd)
			maxfd = fd;

	}
	if (mdstat_fd > maxfd)
		maxfd = mdstat_fd;

	pselect(maxfd + 1, &rfds, NULL, &fds,
		NULL, sigmask);
}

int mddev_busy(char *devnm)
{
	struct mdstat_ent *mdstat = mdstat_read(0, 0);
	struct mdstat_ent *me;

	for (me = mdstat ; me ; me = me->next)
		if (strcmp(me->devnm, devnm) == 0)
			break;
	free_mdstat(mdstat);
	return me != NULL;
}

struct mdstat_ent *mdstat_by_component(char *name)
{
	struct mdstat_ent *mdstat = mdstat_read(0, 0);

	while (mdstat) {
		struct dev_member *m;
		struct mdstat_ent *ent;
		if (mdstat->metadata_version &&
		    strncmp(mdstat->metadata_version, "external:", 9) == 0 &&
		    is_subarray(mdstat->metadata_version+9))
			/* don't return subarrays, only containers */
			;
		else for (m = mdstat->members; m; m = m->next) {
				if (strcmp(m->name, name) == 0) {
					free_mdstat(mdstat->next);
					mdstat->next = NULL;
					return mdstat;
				}
			}
		ent = mdstat;
		mdstat = mdstat->next;
		ent->next = NULL;
		free_mdstat(ent);
	}
	return NULL;
}

struct mdstat_ent *mdstat_by_subdev(char *subdev, char *container)
{
	struct mdstat_ent *mdstat = mdstat_read(0, 0);
	struct mdstat_ent *ent = NULL;

	while (mdstat) {
		/* metadata version must match:
		 *   external:[/-]%s/%s
		 * where first %s is 'container' and second %s is 'subdev'
		 */
		if (ent)
			free_mdstat(ent);
		ent = mdstat;
		mdstat = mdstat->next;
		ent->next = NULL;

		if (ent->metadata_version == NULL ||
		    strncmp(ent->metadata_version, "external:", 9) != 0)
			continue;

		if (!metadata_container_matches(ent->metadata_version+9,
					       container) ||
		    !metadata_subdev_matches(ent->metadata_version+9,
					     subdev))
			continue;

		free_mdstat(mdstat);
		return ent;
	}
	return NULL;
}
Commit	Line	Data
e0d19036 NB	1	/*
	2	* mdstat - parse /proc/mdstat file. Part of:
	3	* mdadm - manage Linux "md" devices aka RAID arrays.
	4	*
e736b623	5	* Copyright (C) 2002-2009 Neil Brown <neilb@suse.de>
e0d19036 NB	6	*
	7	*
	8	* This program is free software; you can redistribute it and/or modify
	9	* it under the terms of the GNU General Public License as published by
	10	* the Free Software Foundation; either version 2 of the License, or
	11	* (at your option) any later version.
	12	*
	13	* This program is distributed in the hope that it will be useful,
	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	16	* GNU General Public License for more details.
	17	*
	18	* You should have received a copy of the GNU General Public License
	19	* along with this program; if not, write to the Free Software
	20	* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	21	*
	22	* Author: Neil Brown
e736b623	23	* Email: <neilb@suse.de>
e0d19036 NB	24	*/
	25
	26	/*
	27	* The /proc/mdstat file comes in at least 3 flavours:
	28	* In an unpatched 2.2 kernel (md 0.36.6):
	29	* Personalities : [n raidx] ...
	30	* read_ahead {not set\|%d sectors}
	31	* md0 : {in}active{ raidX /dev/hda... %d blocks{ maxfault=%d}}
	32	* md1 : .....
	33	*
	34	* Normally only 4 md lines, but all are listed.
	35	*
	36	* In a patched 2.2 kernel (md 0.90.0)
	37	* Personalities : [raidx] ...
	38	* read_ahead {not set\|%d sectors}
	39	* mdN : {in}active {(readonly)} raidX dev[%d]{(F)} ... %d blocks STATUS RESYNC
	40	* ... Only initialised arrays listed
8f21823f	41	* unused devices: {dev dev ... \| <none>}
e0d19036 NB	42	*
	43	* STATUS is personality dependant:
	44	* linear: %dk rounding
	45	* raid0: %dk chunks
	46	* raid1: [%d/%d] [U_U] ( raid/working. operational or not)
	47	* raid5: level 4/5, %dk chunk, algorithm %d [%d/%d] [U_U]
	48	*
	49	* RESYNC is empty or:
	50	* {resync\|recovery}=%u%% finish=%u.%umin
	51	* or
	52	* resync=DELAYED
	53	*
	54	* In a 2.4 kernel (md 0.90.0/2.4)
	55	* Personalities : [raidX] ...
	56	* read_ahead {not set\|%d sectors}
	57	* mdN : {in}active {(read-only)} raidX dev[%d]{(F)} ...
	58	* %d blocks STATUS
	59	* RESYNC
8f21823f	60	* unused devices: {dev dev .. \| <none>}
e0d19036 NB	61	*
	62	* STATUS matches 0.90.0/2.2
	63	* RESYNC includes [===>....],
	64	* adds a space after {resync\|recovery} and before and after '='
	65	* adds a decimal to the recovery percent.
	66	* adds (%d/%d) resync amount and max_blocks, before finish.
	67	* adds speed=%dK/sec after finish
	68	*
	69	*
	70	*
	71	* Out of this we want to extract:
	72	* list of devices, active or not
	73	* pattern of failed drives (so need number of drives)
	74	* percent resync complete
	75	*
	76	* As continuation is indicated by leading space, we use
	77	* conf_line from config.c to read logical lines
	78	*
	79	*/
	80
	81	#include "mdadm.h"
	82	#include "dlink.h"
dd0781e5	83	#include <sys/select.h>
549e9569	84	#include <ctype.h>
e0d19036	85
3b57c466 N	86	static void free_member_devnames(struct dev_member *m)
	87	{
	88	while(m) {
	89	struct dev_member *t = m;
	90
	91	m = m->next;
	92	free(t->name);
	93	free(t);
	94	}
	95	}
	96
0ad6835c	97	static int add_member_devname(struct dev_member *m, char name)
3b57c466 N	98	{
	99	struct dev_member *new;
	100	char *t;
	101
	102	if ((t = strchr(name, '[')) == NULL)
	103	/* not a device */
0ad6835c	104	return 0;
3b57c466	105
503975b9	106	new = xmalloc(sizeof(*new));
3b57c466 N	107	new->name = strndup(name, t - name);
	108	new->next = *m;
	109	*m = new;
0ad6835c	110	return 1;
3b57c466 N	111	}
3b57c466 N	112
e0d19036 NB	113	void free_mdstat(struct mdstat_ent *ms)
	114	{
	115	while (ms) {
	116	struct mdstat_ent *t;
3b57c466 N	117	free(ms->level);
	118	free(ms->pattern);
	119	free(ms->metadata_version);
	120	free_member_devnames(ms->members);
e0d19036 NB	121	t = ms;
	122	ms = ms->next;
	123	free(t);
	124	}
	125	}
	126
dd0781e5	127	static int mdstat_fd = -1;
22a88995	128	struct mdstat_ent *mdstat_read(int hold, int start)
e0d19036 NB	129	{
e0d19036 NB	130	FILE *f;
22a88995	131	struct mdstat_ent all, rv, end, insert_here;
e0d19036	132	char *line;
d94a4f62	133	int fd;
e0d19036	134
dd0781e5	135	if (hold && mdstat_fd != -1) {
52209d6e TM	136	off_t offset = lseek(mdstat_fd, 0L, 0);
52209d6e TM	137	if (offset == (off_t)-1) {
52209d6e TM	138	return NULL;
52209d6e TM	139	}
d94a4f62 JS	140	fd = dup(mdstat_fd);
	141	if (fd >= 0)
	142	f = fdopen(fd, "r");
	143	else
	144	return NULL;
dd0781e5 NB	145	} else
dd0781e5 NB	146	f = fopen("/proc/mdstat", "r");
e0d19036 NB	147	if (f == NULL)
e0d19036 NB	148	return NULL;
e4dc5106 DL	149	else
e4dc5106 DL	150	fcntl(fileno(f), F_SETFD, FD_CLOEXEC);
e0d19036 NB	151
	152	all = NULL;
	153	end = &all;
	154	for (; (line = conf_line(f)) ; free_line(line)) {
	155	struct mdstat_ent *ent;
	156	char *w;
4dd2df09	157	char devnm[32];
22a88995	158	int in_devs = 0;
e0d19036	159
a9db8995	160	if (strcmp(line, "Personalities") == 0)
e0d19036	161	continue;
a9db8995	162	if (strcmp(line, "read_ahead") == 0)
e0d19036	163	continue;
a9db8995	164	if (strcmp(line, "unused") == 0)
e0d19036	165	continue;
22a88995	166	insert_here = NULL;
e0d19036	167	/* Better be an md line.. */
d7be7d87 JS	168	if (strncmp(line, "md", 2)!= 0 \|\| strlen(line) >= 32 \|\|
d7be7d87 JS	169	(line[2] != '_' && !isdigit(line[2])))
98c6faba	170	continue;
4dd2df09	171	strcpy(devnm, line);
e0d19036	172
503975b9	173	ent = xmalloc(sizeof(*ent));
9581efb1	174	ent->level = ent->pattern= NULL;
e0d19036	175	ent->next = NULL;
9dad51d4	176	ent->percent = RESYNC_NONE;
e0d19036	177	ent->active = -1;
e5329c37	178	ent->resync = 0;
549e9569 NB	179	ent->metadata_version = NULL;
549e9569 NB	180	ent->raid_disks = 0;
549e9569	181	ent->devcnt = 0;
3b57c466	182	ent->members = NULL;
e0d19036	183
4dd2df09	184	strcpy(ent->devnm, devnm);
aba69144	185
e0d19036 NB	186	for (w=dl_next(line); w!= line ; w=dl_next(w)) {
	187	int l = strlen(w);
	188	char *eq;
a9db8995	189	if (strcmp(w, "active") == 0)
e0d19036	190	ent->active = 1;
a9db8995	191	else if (strcmp(w, "inactive") == 0) {
e0d19036	192	ent->active = 0;
b6d7a7fb JD	193	in_devs = 1;
b6d7a7fb JD	194	} else if (ent->active > 0 &&
e0d19036	195	ent->level == NULL &&
22a88995	196	w[0] != '(' /readonly/) {
503975b9	197	ent->level = xstrdup(w);
22a88995	198	in_devs = 1;
a9db8995	199	} else if (in_devs && strcmp(w, "blocks") == 0)
22a88995	200	in_devs = 0;
549e9569	201	else if (in_devs) {
4dd2df09	202	char *ep = strchr(w, '[');
0ad6835c ML	203	ent->devcnt +=
0ad6835c ML	204	add_member_devname(&ent->members, w);
a9db8995	205	if (ep && strncmp(w, "md", 2) == 0) {
549e9569 NB	206	/* This has an md device as a component.
	207	* If that device is already in the
	208	* list, make sure we insert before
	209	* there.
	210	*/
	211	struct mdstat_ent **ih;
549e9569 NB	212	ih = &all;
549e9569 NB	213	while (ih != insert_here && *ih &&
d7be7d87 JS	214	((int)strlen((*ih)->devnm) !=
	215	ep-w \|\|
	216	strncmp((*ih)->devnm, w,
	217	ep-w) != 0))
549e9569 NB	218	ih = & (*ih)->next;
	219	insert_here = ih;
	220	}
	221	} else if (strcmp(w, "super") == 0 &&
	222	dl_next(w) != line) {
	223	w = dl_next(w);
503975b9	224	ent->metadata_version = xstrdup(w);
549e9569 NB	225	} else if (w[0] == '[' && isdigit(w[1])) {
549e9569 NB	226	ent->raid_disks = atoi(w+1);
22a88995	227	} else if (!ent->pattern &&
a9db8995 ZL	228	w[0] == '[' &&
a9db8995 ZL	229	(w[1] == 'U' \|\| w[1] == '_')) {
503975b9	230	ent->pattern = xstrdup(w+1);
a9db8995	231	if (ent->pattern[l-2] == ']')
e0d19036	232	ent->pattern[l-2] = '\0';
9dad51d4	233	} else if (ent->percent == RESYNC_NONE &&
a9db8995	234	strncmp(w, "re", 2) == 0 &&
e0d19036	235	w[l-1] == '%' &&
a9db8995	236	(eq = strchr(w, '=')) != NULL ) {
e0d19036	237	ent->percent = atoi(eq+1);
a9db8995	238	if (strncmp(w,"resync", 6) == 0)
e5329c37	239	ent->resync = 1;
a9db8995	240	else if (strncmp(w, "reshape", 7) == 0)
f94c116f N	241	ent->resync = 2;
	242	else
	243	ent->resync = 0;
9dad51d4	244	} else if (ent->percent == RESYNC_NONE &&
f94c116f	245	(w[0] == 'r' \|\| w[0] == 'c')) {
35c34037	246	if (strncmp(w, "resync", 6) == 0)
f94c116f	247	ent->resync = 1;
a9db8995	248	if (strncmp(w, "reshape", 7) == 0)
f94c116f	249	ent->resync = 2;
a9db8995	250	if (strncmp(w, "recovery", 8) == 0)
aa8d7dc7	251	ent->resync = 0;
a9db8995	252	if (strncmp(w, "check", 5) == 0)
f94c116f N	253	ent->resync = 3;
f94c116f N	254
2d3603ba	255	if (l > 8 && strcmp(w+l-8, "=DELAYED") == 0)
9dad51d4	256	ent->percent = RESYNC_DELAYED;
2d3603ba	257	if (l > 8 && strcmp(w+l-8, "=PENDING") == 0)
9dad51d4	258	ent->percent = RESYNC_PENDING;
1c294b5d LZ	259	if (l > 7 && strcmp(w+l-7, "=REMOTE") == 0)
1c294b5d LZ	260	ent->percent = RESYNC_REMOTE;
9dad51d4	261	} else if (ent->percent == RESYNC_NONE &&
aba69144	262	w[0] >= '0' &&
e0d19036 NB	263	w[0] <= '9' &&
	264	w[l-1] == '%') {
	265	ent->percent = atoi(w);
	266	}
	267	}
22a88995 NB	268	if (insert_here && (*insert_here)) {
	269	ent->next = *insert_here;
	270	*insert_here = ent;
	271	} else {
	272	*end = ent;
	273	end = &ent->next;
	274	}
e0d19036	275	}
e4dc5106	276	if (hold && mdstat_fd == -1) {
dd0781e5	277	mdstat_fd = dup(fileno(f));
e4dc5106 DL	278	fcntl(mdstat_fd, F_SETFD, FD_CLOEXEC);
e4dc5106 DL	279	}
e0d19036	280	fclose(f);
22a88995 NB	281
	282	/* If we might want to start array,
	283	* reverse the order, so that components comes before composites
	284	*/
	285	if (start) {
	286	rv = NULL;
	287	while (all) {
	288	struct mdstat_ent *e = all;
	289	all = all->next;
	290	e->next = rv;
	291	rv = e;
	292	}
a9db8995 ZL	293	} else
a9db8995 ZL	294	rv = all;
22a88995	295	return rv;
e0d19036	296	}
dd0781e5	297
a7a0d8a1 N	298	void mdstat_close(void)
	299	{
	300	if (mdstat_fd >= 0)
	301	close(mdstat_fd);
	302	mdstat_fd = -1;
	303	}
	304
dd0781e5 NB	305	void mdstat_wait(int seconds)
	306	{
	307	fd_set fds;
	308	struct timeval tm;
0b5ec75e	309	int maxfd = 0;
dd0781e5	310	FD_ZERO(&fds);
0b5ec75e	311	if (mdstat_fd >= 0) {
dd0781e5	312	FD_SET(mdstat_fd, &fds);
0b5ec75e	313	maxfd = mdstat_fd;
e2308733 MT	314	} else
e2308733 MT	315	return;
dd0781e5 NB	316	tm.tv_sec = seconds;
dd0781e5 NB	317	tm.tv_usec = 0;
0b5ec75e	318	select(maxfd + 1, NULL, NULL, &fds, &tm);
dd0781e5	319	}
8382f19b	320
58a4ba2a	321	void mdstat_wait_fd(int fd, const sigset_t *sigmask)
549e9569 NB	322	{
549e9569 NB	323	fd_set fds, rfds;
5d4d1b26	324	int maxfd = 0;
549e9569 NB	325
	326	FD_ZERO(&fds);
	327	FD_ZERO(&rfds);
	328	if (mdstat_fd >= 0)
	329	FD_SET(mdstat_fd, &fds);
5d4d1b26	330
58a4ba2a	331	if (fd >= 0) {
28005287 N	332	struct stat stb;
	333	fstat(fd, &stb);
	334	if ((stb.st_mode & S_IFMT) == S_IFREG)
	335	/* Must be a /proc or /sys fd, so expect
	336	* POLLPRI
	337	* i.e. an 'exceptional' event.
	338	*/
	339	FD_SET(fd, &fds);
	340	else
	341	FD_SET(fd, &rfds);
5d4d1b26 N	342
	343	if (fd > maxfd)
	344	maxfd = fd;
	345
28005287	346	}
0b5ec75e N	347	if (mdstat_fd > maxfd)
0b5ec75e N	348	maxfd = mdstat_fd;
549e9569	349
0b5ec75e	350	pselect(maxfd + 1, &rfds, NULL, &fds,
1ed3f387	351	NULL, sigmask);
549e9569 NB	352	}
549e9569 NB	353
4dd2df09	354	int mddev_busy(char *devnm)
8382f19b NB	355	{
	356	struct mdstat_ent *mdstat = mdstat_read(0, 0);
	357	struct mdstat_ent *me;
	358
	359	for (me = mdstat ; me ; me = me->next)
4dd2df09	360	if (strcmp(me->devnm, devnm) == 0)
8382f19b NB	361	break;
	362	free_mdstat(mdstat);
	363	return me != NULL;
	364	}
3b57c466 N	365
	366	struct mdstat_ent mdstat_by_component(char name)
	367	{
	368	struct mdstat_ent *mdstat = mdstat_read(0, 0);
	369
	370	while (mdstat) {
	371	struct dev_member *m;
	372	struct mdstat_ent *ent;
	373	if (mdstat->metadata_version &&
	374	strncmp(mdstat->metadata_version, "external:", 9) == 0 &&
	375	is_subarray(mdstat->metadata_version+9))
	376	/* don't return subarrays, only containers */
	377	;
	378	else for (m = mdstat->members; m; m = m->next) {
	379	if (strcmp(m->name, name) == 0) {
	380	free_mdstat(mdstat->next);
	381	mdstat->next = NULL;
	382	return mdstat;
	383	}
	384	}
	385	ent = mdstat;
	386	mdstat = mdstat->next;
	387	ent->next = NULL;
	388	free_mdstat(ent);
	389	}
	390	return NULL;
	391	}
78b10e66	392
4dd2df09	393	struct mdstat_ent mdstat_by_subdev(char subdev, char *container)
78b10e66 N	394	{
78b10e66 N	395	struct mdstat_ent *mdstat = mdstat_read(0, 0);
4dd2df09	396	struct mdstat_ent *ent = NULL;
78b10e66 N	397
78b10e66 N	398	while (mdstat) {
78b10e66	399	/* metadata version must match:
4dd2df09 N	400	* external:[/-]%s/%s
4dd2df09 N	401	* where first %s is 'container' and second %s is 'subdev'
78b10e66	402	*/
4dd2df09 N	403	if (ent)
4dd2df09 N	404	free_mdstat(ent);
78b10e66 N	405	ent = mdstat;
	406	mdstat = mdstat->next;
	407	ent->next = NULL;
4dd2df09 N	408
	409	if (ent->metadata_version == NULL \|\|
	410	strncmp(ent->metadata_version, "external:", 9) != 0)
	411	continue;
	412
	413	if (!metadata_container_matches(ent->metadata_version+9,
	414	container) \|\|
	415	!metadata_subdev_matches(ent->metadata_version+9,
	416	subdev))
	417	continue;
	418
	419	free_mdstat(mdstat);
	420	return ent;
78b10e66 N	421	}
	422	return NULL;
	423	}