]> git.ipfire.org Git - thirdparty/mdadm.git/blame - super-ddf.c
DDF (cleanup): use a common macro for failed searches
[thirdparty/mdadm.git] / super-ddf.c
CommitLineData
a322f70c
DW
1/*
2 * mdadm - manage Linux "md" devices aka RAID arrays.
3 *
e736b623 4 * Copyright (C) 2006-2009 Neil Brown <neilb@suse.de>
a322f70c
DW
5 *
6 *
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation; either version 2 of the License, or
10 * (at your option) any later version.
11 *
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with this program; if not, write to the Free Software
19 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 *
21 * Author: Neil Brown
22 * Email: <neil@brown.name>
23 *
24 * Specifications for DDF takes from Common RAID DDF Specification Revision 1.2
25 * (July 28 2006). Reused by permission of SNIA.
26 */
27
28#define HAVE_STDINT_H 1
29#include "mdadm.h"
549e9569 30#include "mdmon.h"
a322f70c
DW
31#include "sha1.h"
32#include <values.h>
33
a322f70c
DW
34/* a non-official T10 name for creation GUIDs */
35static char T10[] = "Linux-MD";
36
37/* DDF timestamps are 1980 based, so we need to add
38 * second-in-decade-of-seventies to convert to linux timestamps.
39 * 10 years with 2 leap years.
40 */
41#define DECADE (3600*24*(365*10+2))
42unsigned long crc32(
43 unsigned long crc,
44 const unsigned char *buf,
45 unsigned len);
46
bedbf68a 47#define DDF_NOTFOUND (~0U)
48#define DDF_CONTAINER (DDF_NOTFOUND-1)
49
a322f70c
DW
50/* The DDF metadata handling.
51 * DDF metadata lives at the end of the device.
52 * The last 512 byte block provides an 'anchor' which is used to locate
53 * the rest of the metadata which usually lives immediately behind the anchor.
54 *
55 * Note:
56 * - all multibyte numeric fields are bigendian.
57 * - all strings are space padded.
58 *
59 */
60
61/* Primary Raid Level (PRL) */
62#define DDF_RAID0 0x00
63#define DDF_RAID1 0x01
64#define DDF_RAID3 0x03
65#define DDF_RAID4 0x04
66#define DDF_RAID5 0x05
67#define DDF_RAID1E 0x11
68#define DDF_JBOD 0x0f
69#define DDF_CONCAT 0x1f
70#define DDF_RAID5E 0x15
71#define DDF_RAID5EE 0x25
59e36268 72#define DDF_RAID6 0x06
a322f70c
DW
73
74/* Raid Level Qualifier (RLQ) */
75#define DDF_RAID0_SIMPLE 0x00
76#define DDF_RAID1_SIMPLE 0x00 /* just 2 devices in this plex */
77#define DDF_RAID1_MULTI 0x01 /* exactly 3 devices in this plex */
78#define DDF_RAID3_0 0x00 /* parity in first extent */
79#define DDF_RAID3_N 0x01 /* parity in last extent */
80#define DDF_RAID4_0 0x00 /* parity in first extent */
81#define DDF_RAID4_N 0x01 /* parity in last extent */
82/* these apply to raid5e and raid5ee as well */
83#define DDF_RAID5_0_RESTART 0x00 /* same as 'right asymmetric' - layout 1 */
59e36268 84#define DDF_RAID6_0_RESTART 0x01 /* raid6 different from raid5 here!!! */
a322f70c
DW
85#define DDF_RAID5_N_RESTART 0x02 /* same as 'left asymmetric' - layout 0 */
86#define DDF_RAID5_N_CONTINUE 0x03 /* same as 'left symmetric' - layout 2 */
87
88#define DDF_RAID1E_ADJACENT 0x00 /* raid10 nearcopies==2 */
89#define DDF_RAID1E_OFFSET 0x01 /* raid10 offsetcopies==2 */
90
91/* Secondary RAID Level (SRL) */
92#define DDF_2STRIPED 0x00 /* This is weirder than RAID0 !! */
93#define DDF_2MIRRORED 0x01
94#define DDF_2CONCAT 0x02
95#define DDF_2SPANNED 0x03 /* This is also weird - be careful */
96
97/* Magic numbers */
98#define DDF_HEADER_MAGIC __cpu_to_be32(0xDE11DE11)
99#define DDF_CONTROLLER_MAGIC __cpu_to_be32(0xAD111111)
100#define DDF_PHYS_RECORDS_MAGIC __cpu_to_be32(0x22222222)
101#define DDF_PHYS_DATA_MAGIC __cpu_to_be32(0x33333333)
102#define DDF_VIRT_RECORDS_MAGIC __cpu_to_be32(0xDDDDDDDD)
103#define DDF_VD_CONF_MAGIC __cpu_to_be32(0xEEEEEEEE)
104#define DDF_SPARE_ASSIGN_MAGIC __cpu_to_be32(0x55555555)
105#define DDF_VU_CONF_MAGIC __cpu_to_be32(0x88888888)
106#define DDF_VENDOR_LOG_MAGIC __cpu_to_be32(0x01dBEEF0)
107#define DDF_BBM_LOG_MAGIC __cpu_to_be32(0xABADB10C)
108
109#define DDF_GUID_LEN 24
59e36268
NB
110#define DDF_REVISION_0 "01.00.00"
111#define DDF_REVISION_2 "01.02.00"
a322f70c
DW
112
113struct ddf_header {
88c164f4 114 __u32 magic; /* DDF_HEADER_MAGIC */
a322f70c
DW
115 __u32 crc;
116 char guid[DDF_GUID_LEN];
59e36268 117 char revision[8]; /* 01.02.00 */
a322f70c
DW
118 __u32 seq; /* starts at '1' */
119 __u32 timestamp;
120 __u8 openflag;
121 __u8 foreignflag;
122 __u8 enforcegroups;
123 __u8 pad0; /* 0xff */
124 __u8 pad1[12]; /* 12 * 0xff */
125 /* 64 bytes so far */
126 __u8 header_ext[32]; /* reserved: fill with 0xff */
127 __u64 primary_lba;
128 __u64 secondary_lba;
129 __u8 type;
130 __u8 pad2[3]; /* 0xff */
131 __u32 workspace_len; /* sectors for vendor space -
132 * at least 32768(sectors) */
133 __u64 workspace_lba;
134 __u16 max_pd_entries; /* one of 15, 63, 255, 1023, 4095 */
135 __u16 max_vd_entries; /* 2^(4,6,8,10,12)-1 : i.e. as above */
136 __u16 max_partitions; /* i.e. max num of configuration
137 record entries per disk */
138 __u16 config_record_len; /* 1 +ROUNDUP(max_primary_element_entries
139 *12/512) */
140 __u16 max_primary_element_entries; /* 16, 64, 256, 1024, or 4096 */
141 __u8 pad3[54]; /* 0xff */
142 /* 192 bytes so far */
143 __u32 controller_section_offset;
144 __u32 controller_section_length;
145 __u32 phys_section_offset;
146 __u32 phys_section_length;
147 __u32 virt_section_offset;
148 __u32 virt_section_length;
149 __u32 config_section_offset;
150 __u32 config_section_length;
151 __u32 data_section_offset;
152 __u32 data_section_length;
153 __u32 bbm_section_offset;
154 __u32 bbm_section_length;
155 __u32 diag_space_offset;
156 __u32 diag_space_length;
157 __u32 vendor_offset;
158 __u32 vendor_length;
159 /* 256 bytes so far */
160 __u8 pad4[256]; /* 0xff */
161};
162
163/* type field */
164#define DDF_HEADER_ANCHOR 0x00
165#define DDF_HEADER_PRIMARY 0x01
166#define DDF_HEADER_SECONDARY 0x02
167
168/* The content of the 'controller section' - global scope */
169struct ddf_controller_data {
88c164f4 170 __u32 magic; /* DDF_CONTROLLER_MAGIC */
a322f70c
DW
171 __u32 crc;
172 char guid[DDF_GUID_LEN];
173 struct controller_type {
174 __u16 vendor_id;
175 __u16 device_id;
176 __u16 sub_vendor_id;
177 __u16 sub_device_id;
178 } type;
179 char product_id[16];
180 __u8 pad[8]; /* 0xff */
181 __u8 vendor_data[448];
182};
183
184/* The content of phys_section - global scope */
185struct phys_disk {
88c164f4 186 __u32 magic; /* DDF_PHYS_RECORDS_MAGIC */
a322f70c
DW
187 __u32 crc;
188 __u16 used_pdes;
189 __u16 max_pdes;
190 __u8 pad[52];
191 struct phys_disk_entry {
192 char guid[DDF_GUID_LEN];
193 __u32 refnum;
194 __u16 type;
195 __u16 state;
196 __u64 config_size; /* DDF structures must be after here */
197 char path[18]; /* another horrible structure really */
198 __u8 pad[6];
199 } entries[0];
200};
201
202/* phys_disk_entry.type is a bitmap - bigendian remember */
203#define DDF_Forced_PD_GUID 1
204#define DDF_Active_in_VD 2
88c164f4 205#define DDF_Global_Spare 4 /* VD_CONF records are ignored */
a322f70c
DW
206#define DDF_Spare 8 /* overrides Global_spare */
207#define DDF_Foreign 16
208#define DDF_Legacy 32 /* no DDF on this device */
209
210#define DDF_Interface_mask 0xf00
211#define DDF_Interface_SCSI 0x100
212#define DDF_Interface_SAS 0x200
213#define DDF_Interface_SATA 0x300
214#define DDF_Interface_FC 0x400
215
216/* phys_disk_entry.state is a bigendian bitmap */
217#define DDF_Online 1
218#define DDF_Failed 2 /* overrides 1,4,8 */
219#define DDF_Rebuilding 4
220#define DDF_Transition 8
221#define DDF_SMART 16
222#define DDF_ReadErrors 32
223#define DDF_Missing 64
224
225/* The content of the virt_section global scope */
226struct virtual_disk {
88c164f4 227 __u32 magic; /* DDF_VIRT_RECORDS_MAGIC */
a322f70c
DW
228 __u32 crc;
229 __u16 populated_vdes;
230 __u16 max_vdes;
231 __u8 pad[52];
232 struct virtual_entry {
233 char guid[DDF_GUID_LEN];
234 __u16 unit;
235 __u16 pad0; /* 0xffff */
236 __u16 guid_crc;
237 __u16 type;
238 __u8 state;
239 __u8 init_state;
240 __u8 pad1[14];
241 char name[16];
242 } entries[0];
243};
244
245/* virtual_entry.type is a bitmap - bigendian */
246#define DDF_Shared 1
247#define DDF_Enforce_Groups 2
248#define DDF_Unicode 4
249#define DDF_Owner_Valid 8
250
251/* virtual_entry.state is a bigendian bitmap */
252#define DDF_state_mask 0x7
253#define DDF_state_optimal 0x0
254#define DDF_state_degraded 0x1
255#define DDF_state_deleted 0x2
256#define DDF_state_missing 0x3
257#define DDF_state_failed 0x4
7a7cc504 258#define DDF_state_part_optimal 0x5
a322f70c
DW
259
260#define DDF_state_morphing 0x8
261#define DDF_state_inconsistent 0x10
262
263/* virtual_entry.init_state is a bigendian bitmap */
264#define DDF_initstate_mask 0x03
265#define DDF_init_not 0x00
7a7cc504
NB
266#define DDF_init_quick 0x01 /* initialisation is progress.
267 * i.e. 'state_inconsistent' */
a322f70c
DW
268#define DDF_init_full 0x02
269
270#define DDF_access_mask 0xc0
271#define DDF_access_rw 0x00
272#define DDF_access_ro 0x80
273#define DDF_access_blocked 0xc0
274
275/* The content of the config_section - local scope
276 * It has multiple records each config_record_len sectors
277 * They can be vd_config or spare_assign
278 */
279
280struct vd_config {
88c164f4 281 __u32 magic; /* DDF_VD_CONF_MAGIC */
a322f70c
DW
282 __u32 crc;
283 char guid[DDF_GUID_LEN];
284 __u32 timestamp;
285 __u32 seqnum;
286 __u8 pad0[24];
287 __u16 prim_elmnt_count;
288 __u8 chunk_shift; /* 0 == 512, 1==1024 etc */
289 __u8 prl;
290 __u8 rlq;
291 __u8 sec_elmnt_count;
292 __u8 sec_elmnt_seq;
293 __u8 srl;
598f0d58
NB
294 __u64 blocks; /* blocks per component could be different
295 * on different component devices...(only
296 * for concat I hope) */
297 __u64 array_blocks; /* blocks in array */
a322f70c
DW
298 __u8 pad1[8];
299 __u32 spare_refs[8];
300 __u8 cache_pol[8];
301 __u8 bg_rate;
302 __u8 pad2[3];
303 __u8 pad3[52];
304 __u8 pad4[192];
305 __u8 v0[32]; /* reserved- 0xff */
306 __u8 v1[32]; /* reserved- 0xff */
307 __u8 v2[16]; /* reserved- 0xff */
308 __u8 v3[16]; /* reserved- 0xff */
309 __u8 vendor[32];
310 __u32 phys_refnum[0]; /* refnum of each disk in sequence */
311 /*__u64 lba_offset[0]; LBA offset in each phys. Note extents in a
312 bvd are always the same size */
313};
314
315/* vd_config.cache_pol[7] is a bitmap */
316#define DDF_cache_writeback 1 /* else writethrough */
317#define DDF_cache_wadaptive 2 /* only applies if writeback */
318#define DDF_cache_readahead 4
319#define DDF_cache_radaptive 8 /* only if doing read-ahead */
320#define DDF_cache_ifnobatt 16 /* even to write cache if battery is poor */
321#define DDF_cache_wallowed 32 /* enable write caching */
322#define DDF_cache_rallowed 64 /* enable read caching */
323
324struct spare_assign {
88c164f4 325 __u32 magic; /* DDF_SPARE_ASSIGN_MAGIC */
a322f70c
DW
326 __u32 crc;
327 __u32 timestamp;
328 __u8 reserved[7];
329 __u8 type;
330 __u16 populated; /* SAEs used */
331 __u16 max; /* max SAEs */
332 __u8 pad[8];
333 struct spare_assign_entry {
334 char guid[DDF_GUID_LEN];
335 __u16 secondary_element;
336 __u8 pad[6];
337 } spare_ents[0];
338};
339/* spare_assign.type is a bitmap */
340#define DDF_spare_dedicated 0x1 /* else global */
341#define DDF_spare_revertible 0x2 /* else committable */
342#define DDF_spare_active 0x4 /* else not active */
343#define DDF_spare_affinity 0x8 /* enclosure affinity */
344
345/* The data_section contents - local scope */
346struct disk_data {
88c164f4 347 __u32 magic; /* DDF_PHYS_DATA_MAGIC */
a322f70c
DW
348 __u32 crc;
349 char guid[DDF_GUID_LEN];
350 __u32 refnum; /* crc of some magic drive data ... */
351 __u8 forced_ref; /* set when above was not result of magic */
352 __u8 forced_guid; /* set if guid was forced rather than magic */
353 __u8 vendor[32];
354 __u8 pad[442];
355};
356
357/* bbm_section content */
358struct bad_block_log {
359 __u32 magic;
360 __u32 crc;
361 __u16 entry_count;
362 __u32 spare_count;
363 __u8 pad[10];
364 __u64 first_spare;
365 struct mapped_block {
366 __u64 defective_start;
367 __u32 replacement_start;
368 __u16 remap_count;
369 __u8 pad[2];
370 } entries[0];
371};
372
373/* Struct for internally holding ddf structures */
374/* The DDF structure stored on each device is potentially
375 * quite different, as some data is global and some is local.
376 * The global data is:
377 * - ddf header
378 * - controller_data
379 * - Physical disk records
380 * - Virtual disk records
381 * The local data is:
382 * - Configuration records
383 * - Physical Disk data section
384 * ( and Bad block and vendor which I don't care about yet).
385 *
386 * The local data is parsed into separate lists as it is read
387 * and reconstructed for writing. This means that we only need
388 * to make config changes once and they are automatically
389 * propagated to all devices.
390 * Note that the ddf_super has space of the conf and disk data
391 * for this disk and also for a list of all such data.
392 * The list is only used for the superblock that is being
393 * built in Create or Assemble to describe the whole array.
394 */
395struct ddf_super {
6416d527 396 struct ddf_header anchor, primary, secondary;
a322f70c 397 struct ddf_controller_data controller;
6416d527 398 struct ddf_header *active;
a322f70c
DW
399 struct phys_disk *phys;
400 struct virtual_disk *virt;
401 int pdsize, vdsize;
f21e18ca 402 unsigned int max_part, mppe, conf_rec_len;
d2ca6449 403 int currentdev;
18a2f463 404 int updates_pending;
a322f70c 405 struct vcl {
6416d527
NB
406 union {
407 char space[512];
408 struct {
409 struct vcl *next;
410 __u64 *lba_offset; /* location in 'conf' of
411 * the lba table */
f21e18ca 412 unsigned int vcnum; /* index into ->virt */
8ec5d685 413 struct vd_config **other_bvds;
6416d527
NB
414 __u64 *block_sizes; /* NULL if all the same */
415 };
416 };
a322f70c 417 struct vd_config conf;
d2ca6449 418 } *conflist, *currentconf;
a322f70c 419 struct dl {
6416d527
NB
420 union {
421 char space[512];
422 struct {
423 struct dl *next;
424 int major, minor;
425 char *devname;
426 int fd;
427 unsigned long long size; /* sectors */
097bcf00 428 unsigned long long primary_lba; /* sectors */
429 unsigned long long secondary_lba; /* sectors */
430 unsigned long long workspace_lba; /* sectors */
6416d527
NB
431 int pdnum; /* index in ->phys */
432 struct spare_assign *spare;
8592f29d
N
433 void *mdupdate; /* hold metadata update */
434
435 /* These fields used by auto-layout */
436 int raiddisk; /* slot to fill in autolayout */
437 __u64 esize;
6416d527
NB
438 };
439 };
a322f70c 440 struct disk_data disk;
b2280677 441 struct vcl *vlist[0]; /* max_part in size */
2cc2983d 442 } *dlist, *add_list;
a322f70c
DW
443};
444
445#ifndef offsetof
446#define offsetof(t,f) ((size_t)&(((t*)0)->f))
447#endif
448
7d5a7ff3 449#if DEBUG
450static int all_ff(char *guid);
451static void pr_state(struct ddf_super *ddf, const char *msg)
452{
453 unsigned int i;
454 dprintf("%s/%s: ", __func__, msg);
455 for (i = 0; i < __be16_to_cpu(ddf->active->max_vd_entries); i++) {
456 if (all_ff(ddf->virt->entries[i].guid))
457 continue;
458 dprintf("%u(s=%02x i=%02x) ", i,
459 ddf->virt->entries[i].state,
460 ddf->virt->entries[i].init_state);
461 }
462 dprintf("\n");
463}
464#else
465static void pr_state(const struct ddf_super *ddf, const char *msg) {}
466#endif
467
468#define ddf_set_updates_pending(x) \
469 do { (x)->updates_pending = 1; pr_state(x, __func__); } while (0)
470
f21e18ca 471static unsigned int calc_crc(void *buf, int len)
a322f70c
DW
472{
473 /* crcs are always at the same place as in the ddf_header */
474 struct ddf_header *ddf = buf;
475 __u32 oldcrc = ddf->crc;
476 __u32 newcrc;
477 ddf->crc = 0xffffffff;
478
479 newcrc = crc32(0, buf, len);
480 ddf->crc = oldcrc;
4abe6b70
N
481 /* The crc is store (like everything) bigendian, so convert
482 * here for simplicity
483 */
484 return __cpu_to_be32(newcrc);
a322f70c
DW
485}
486
487static int load_ddf_header(int fd, unsigned long long lba,
488 unsigned long long size,
489 int type,
490 struct ddf_header *hdr, struct ddf_header *anchor)
491{
492 /* read a ddf header (primary or secondary) from fd/lba
493 * and check that it is consistent with anchor
494 * Need to check:
495 * magic, crc, guid, rev, and LBA's header_type, and
496 * everything after header_type must be the same
497 */
498 if (lba >= size-1)
499 return 0;
500
501 if (lseek64(fd, lba<<9, 0) < 0)
502 return 0;
503
504 if (read(fd, hdr, 512) != 512)
505 return 0;
506
507 if (hdr->magic != DDF_HEADER_MAGIC)
508 return 0;
509 if (calc_crc(hdr, 512) != hdr->crc)
510 return 0;
511 if (memcmp(anchor->guid, hdr->guid, DDF_GUID_LEN) != 0 ||
512 memcmp(anchor->revision, hdr->revision, 8) != 0 ||
513 anchor->primary_lba != hdr->primary_lba ||
514 anchor->secondary_lba != hdr->secondary_lba ||
515 hdr->type != type ||
516 memcmp(anchor->pad2, hdr->pad2, 512 -
517 offsetof(struct ddf_header, pad2)) != 0)
518 return 0;
519
520 /* Looks good enough to me... */
521 return 1;
522}
523
524static void *load_section(int fd, struct ddf_super *super, void *buf,
525 __u32 offset_be, __u32 len_be, int check)
526{
527 unsigned long long offset = __be32_to_cpu(offset_be);
528 unsigned long long len = __be32_to_cpu(len_be);
529 int dofree = (buf == NULL);
530
531 if (check)
532 if (len != 2 && len != 8 && len != 32
533 && len != 128 && len != 512)
534 return NULL;
535
536 if (len > 1024)
537 return NULL;
538 if (buf) {
539 /* All pre-allocated sections are a single block */
540 if (len != 1)
541 return NULL;
3d2c4fc7
DW
542 } else if (posix_memalign(&buf, 512, len<<9) != 0)
543 buf = NULL;
6416d527 544
a322f70c
DW
545 if (!buf)
546 return NULL;
547
548 if (super->active->type == 1)
549 offset += __be64_to_cpu(super->active->primary_lba);
550 else
551 offset += __be64_to_cpu(super->active->secondary_lba);
552
f21e18ca 553 if ((unsigned long long)lseek64(fd, offset<<9, 0) != (offset<<9)) {
a322f70c
DW
554 if (dofree)
555 free(buf);
556 return NULL;
557 }
f21e18ca 558 if ((unsigned long long)read(fd, buf, len<<9) != (len<<9)) {
a322f70c
DW
559 if (dofree)
560 free(buf);
561 return NULL;
562 }
563 return buf;
564}
565
566static int load_ddf_headers(int fd, struct ddf_super *super, char *devname)
567{
568 unsigned long long dsize;
569
570 get_dev_size(fd, NULL, &dsize);
571
572 if (lseek64(fd, dsize-512, 0) < 0) {
573 if (devname)
e7b84f9d
N
574 pr_err("Cannot seek to anchor block on %s: %s\n",
575 devname, strerror(errno));
a322f70c
DW
576 return 1;
577 }
578 if (read(fd, &super->anchor, 512) != 512) {
579 if (devname)
e7b84f9d
N
580 pr_err("Cannot read anchor block on %s: %s\n",
581 devname, strerror(errno));
a322f70c
DW
582 return 1;
583 }
584 if (super->anchor.magic != DDF_HEADER_MAGIC) {
585 if (devname)
e7b84f9d 586 pr_err("no DDF anchor found on %s\n",
a322f70c
DW
587 devname);
588 return 2;
589 }
590 if (calc_crc(&super->anchor, 512) != super->anchor.crc) {
591 if (devname)
e7b84f9d 592 pr_err("bad CRC on anchor on %s\n",
a322f70c
DW
593 devname);
594 return 2;
595 }
59e36268
NB
596 if (memcmp(super->anchor.revision, DDF_REVISION_0, 8) != 0 &&
597 memcmp(super->anchor.revision, DDF_REVISION_2, 8) != 0) {
a322f70c 598 if (devname)
e7b84f9d 599 pr_err("can only support super revision"
59e36268
NB
600 " %.8s and earlier, not %.8s on %s\n",
601 DDF_REVISION_2, super->anchor.revision,devname);
a322f70c
DW
602 return 2;
603 }
604 if (load_ddf_header(fd, __be64_to_cpu(super->anchor.primary_lba),
605 dsize >> 9, 1,
606 &super->primary, &super->anchor) == 0) {
607 if (devname)
e7b84f9d
N
608 pr_err("Failed to load primary DDF header "
609 "on %s\n", devname);
a322f70c
DW
610 return 2;
611 }
612 super->active = &super->primary;
613 if (load_ddf_header(fd, __be64_to_cpu(super->anchor.secondary_lba),
614 dsize >> 9, 2,
615 &super->secondary, &super->anchor)) {
616 if ((__be32_to_cpu(super->primary.seq)
617 < __be32_to_cpu(super->secondary.seq) &&
618 !super->secondary.openflag)
619 || (__be32_to_cpu(super->primary.seq)
620 == __be32_to_cpu(super->secondary.seq) &&
621 super->primary.openflag && !super->secondary.openflag)
622 )
623 super->active = &super->secondary;
624 }
625 return 0;
626}
627
628static int load_ddf_global(int fd, struct ddf_super *super, char *devname)
629{
630 void *ok;
631 ok = load_section(fd, super, &super->controller,
632 super->active->controller_section_offset,
633 super->active->controller_section_length,
634 0);
635 super->phys = load_section(fd, super, NULL,
636 super->active->phys_section_offset,
637 super->active->phys_section_length,
638 1);
639 super->pdsize = __be32_to_cpu(super->active->phys_section_length) * 512;
640
641 super->virt = load_section(fd, super, NULL,
642 super->active->virt_section_offset,
643 super->active->virt_section_length,
644 1);
645 super->vdsize = __be32_to_cpu(super->active->virt_section_length) * 512;
646 if (!ok ||
647 !super->phys ||
648 !super->virt) {
649 free(super->phys);
650 free(super->virt);
a2349791
NB
651 super->phys = NULL;
652 super->virt = NULL;
a322f70c
DW
653 return 2;
654 }
655 super->conflist = NULL;
656 super->dlist = NULL;
8c3b8c2c
NB
657
658 super->max_part = __be16_to_cpu(super->active->max_partitions);
659 super->mppe = __be16_to_cpu(super->active->max_primary_element_entries);
660 super->conf_rec_len = __be16_to_cpu(super->active->config_record_len);
a322f70c
DW
661 return 0;
662}
663
3dc821b0 664static void add_other_bvd(struct vcl *vcl, struct vd_config *vd,
665 unsigned int len)
666{
667 int i;
668 for (i = 0; i < vcl->conf.sec_elmnt_count-1; i++)
669 if (vcl->other_bvds[i] != NULL &&
670 vcl->other_bvds[i]->sec_elmnt_seq == vd->sec_elmnt_seq)
671 break;
672
673 if (i < vcl->conf.sec_elmnt_count-1) {
674 if (vd->seqnum <= vcl->other_bvds[i]->seqnum)
675 return;
676 } else {
677 for (i = 0; i < vcl->conf.sec_elmnt_count-1; i++)
678 if (vcl->other_bvds[i] == NULL)
679 break;
680 if (i == vcl->conf.sec_elmnt_count-1) {
681 pr_err("no space for sec level config %u, count is %u\n",
682 vd->sec_elmnt_seq, vcl->conf.sec_elmnt_count);
683 return;
684 }
685 if (posix_memalign((void **)&vcl->other_bvds[i], 512, len)
686 != 0) {
687 pr_err("%s could not allocate vd buf\n", __func__);
688 return;
689 }
690 }
691 memcpy(vcl->other_bvds[i], vd, len);
692}
693
a322f70c
DW
694static int load_ddf_local(int fd, struct ddf_super *super,
695 char *devname, int keep)
696{
697 struct dl *dl;
698 struct stat stb;
699 char *conf;
f21e18ca
N
700 unsigned int i;
701 unsigned int confsec;
b2280677 702 int vnum;
f21e18ca 703 unsigned int max_virt_disks = __be16_to_cpu(super->active->max_vd_entries);
d2ca6449 704 unsigned long long dsize;
a322f70c
DW
705
706 /* First the local disk info */
3d2c4fc7 707 if (posix_memalign((void**)&dl, 512,
6416d527 708 sizeof(*dl) +
3d2c4fc7 709 (super->max_part) * sizeof(dl->vlist[0])) != 0) {
e7b84f9d 710 pr_err("%s could not allocate disk info buffer\n",
3d2c4fc7
DW
711 __func__);
712 return 1;
713 }
a322f70c
DW
714
715 load_section(fd, super, &dl->disk,
716 super->active->data_section_offset,
717 super->active->data_section_length,
718 0);
503975b9 719 dl->devname = devname ? xstrdup(devname) : NULL;
598f0d58 720
a322f70c
DW
721 fstat(fd, &stb);
722 dl->major = major(stb.st_rdev);
723 dl->minor = minor(stb.st_rdev);
724 dl->next = super->dlist;
725 dl->fd = keep ? fd : -1;
d2ca6449
NB
726
727 dl->size = 0;
728 if (get_dev_size(fd, devname, &dsize))
729 dl->size = dsize >> 9;
097bcf00 730 /* If the disks have different sizes, the LBAs will differ
731 * between phys disks.
732 * At this point here, the values in super->active must be valid
733 * for this phys disk. */
734 dl->primary_lba = super->active->primary_lba;
735 dl->secondary_lba = super->active->secondary_lba;
736 dl->workspace_lba = super->active->workspace_lba;
b2280677 737 dl->spare = NULL;
f21e18ca 738 for (i = 0 ; i < super->max_part ; i++)
a322f70c
DW
739 dl->vlist[i] = NULL;
740 super->dlist = dl;
59e36268 741 dl->pdnum = -1;
f21e18ca 742 for (i = 0; i < __be16_to_cpu(super->active->max_pd_entries); i++)
5575e7d9
NB
743 if (memcmp(super->phys->entries[i].guid,
744 dl->disk.guid, DDF_GUID_LEN) == 0)
745 dl->pdnum = i;
746
a322f70c
DW
747 /* Now the config list. */
748 /* 'conf' is an array of config entries, some of which are
749 * probably invalid. Those which are good need to be copied into
750 * the conflist
751 */
a322f70c
DW
752
753 conf = load_section(fd, super, NULL,
754 super->active->config_section_offset,
755 super->active->config_section_length,
756 0);
757
b2280677 758 vnum = 0;
e223334f
N
759 for (confsec = 0;
760 confsec < __be32_to_cpu(super->active->config_section_length);
761 confsec += super->conf_rec_len) {
a322f70c 762 struct vd_config *vd =
e223334f 763 (struct vd_config *)((char*)conf + confsec*512);
a322f70c
DW
764 struct vcl *vcl;
765
b2280677
NB
766 if (vd->magic == DDF_SPARE_ASSIGN_MAGIC) {
767 if (dl->spare)
768 continue;
3d2c4fc7
DW
769 if (posix_memalign((void**)&dl->spare, 512,
770 super->conf_rec_len*512) != 0) {
e7b84f9d
N
771 pr_err("%s could not allocate spare info buf\n",
772 __func__);
3d2c4fc7
DW
773 return 1;
774 }
613b0d17 775
b2280677
NB
776 memcpy(dl->spare, vd, super->conf_rec_len*512);
777 continue;
778 }
a322f70c
DW
779 if (vd->magic != DDF_VD_CONF_MAGIC)
780 continue;
781 for (vcl = super->conflist; vcl; vcl = vcl->next) {
782 if (memcmp(vcl->conf.guid,
783 vd->guid, DDF_GUID_LEN) == 0)
784 break;
785 }
786
787 if (vcl) {
b2280677 788 dl->vlist[vnum++] = vcl;
3dc821b0 789 if (vcl->other_bvds != NULL &&
790 vcl->conf.sec_elmnt_seq != vd->sec_elmnt_seq) {
791 add_other_bvd(vcl, vd, super->conf_rec_len*512);
792 continue;
793 }
a322f70c
DW
794 if (__be32_to_cpu(vd->seqnum) <=
795 __be32_to_cpu(vcl->conf.seqnum))
796 continue;
59e36268 797 } else {
3d2c4fc7 798 if (posix_memalign((void**)&vcl, 512,
6416d527 799 (super->conf_rec_len*512 +
3d2c4fc7 800 offsetof(struct vcl, conf))) != 0) {
e7b84f9d
N
801 pr_err("%s could not allocate vcl buf\n",
802 __func__);
3d2c4fc7
DW
803 return 1;
804 }
a322f70c 805 vcl->next = super->conflist;
59e36268 806 vcl->block_sizes = NULL; /* FIXME not for CONCAT */
8ec5d685 807 if (vd->sec_elmnt_count > 1)
808 vcl->other_bvds =
809 xcalloc(vd->sec_elmnt_count - 1,
810 sizeof(struct vd_config *));
811 else
812 vcl->other_bvds = NULL;
a322f70c 813 super->conflist = vcl;
b2280677 814 dl->vlist[vnum++] = vcl;
a322f70c 815 }
8c3b8c2c 816 memcpy(&vcl->conf, vd, super->conf_rec_len*512);
a322f70c 817 vcl->lba_offset = (__u64*)
8c3b8c2c 818 &vcl->conf.phys_refnum[super->mppe];
59e36268
NB
819
820 for (i=0; i < max_virt_disks ; i++)
821 if (memcmp(super->virt->entries[i].guid,
822 vcl->conf.guid, DDF_GUID_LEN)==0)
823 break;
824 if (i < max_virt_disks)
825 vcl->vcnum = i;
a322f70c
DW
826 }
827 free(conf);
828
829 return 0;
830}
831
832#ifndef MDASSEMBLE
833static int load_super_ddf_all(struct supertype *st, int fd,
e1902a7b 834 void **sbp, char *devname);
a322f70c 835#endif
37424f13
DW
836
837static void free_super_ddf(struct supertype *st);
838
a322f70c
DW
839static int load_super_ddf(struct supertype *st, int fd,
840 char *devname)
841{
842 unsigned long long dsize;
843 struct ddf_super *super;
844 int rv;
845
a322f70c
DW
846 if (get_dev_size(fd, devname, &dsize) == 0)
847 return 1;
848
b31df436 849 if (!st->ignore_hw_compat && test_partition(fd))
691c6ee1
N
850 /* DDF is not allowed on partitions */
851 return 1;
852
a322f70c
DW
853 /* 32M is a lower bound */
854 if (dsize <= 32*1024*1024) {
97320d7c 855 if (devname)
e7b84f9d
N
856 pr_err("%s is too small for ddf: "
857 "size is %llu sectors.\n",
858 devname, dsize>>9);
97320d7c 859 return 1;
a322f70c
DW
860 }
861 if (dsize & 511) {
97320d7c 862 if (devname)
e7b84f9d
N
863 pr_err("%s is an odd size for ddf: "
864 "size is %llu bytes.\n",
865 devname, dsize);
97320d7c 866 return 1;
a322f70c
DW
867 }
868
37424f13
DW
869 free_super_ddf(st);
870
6416d527 871 if (posix_memalign((void**)&super, 512, sizeof(*super))!= 0) {
e7b84f9d 872 pr_err("malloc of %zu failed.\n",
a322f70c
DW
873 sizeof(*super));
874 return 1;
875 }
a2349791 876 memset(super, 0, sizeof(*super));
a322f70c
DW
877
878 rv = load_ddf_headers(fd, super, devname);
879 if (rv) {
880 free(super);
881 return rv;
882 }
883
884 /* Have valid headers and have chosen the best. Let's read in the rest*/
885
886 rv = load_ddf_global(fd, super, devname);
887
888 if (rv) {
889 if (devname)
e7b84f9d
N
890 pr_err("Failed to load all information "
891 "sections on %s\n", devname);
a322f70c
DW
892 free(super);
893 return rv;
894 }
895
3d2c4fc7
DW
896 rv = load_ddf_local(fd, super, devname, 0);
897
898 if (rv) {
899 if (devname)
e7b84f9d
N
900 pr_err("Failed to load all information "
901 "sections on %s\n", devname);
3d2c4fc7
DW
902 free(super);
903 return rv;
904 }
a322f70c
DW
905
906 /* Should possibly check the sections .... */
907
908 st->sb = super;
909 if (st->ss == NULL) {
910 st->ss = &super_ddf;
911 st->minor_version = 0;
912 st->max_devs = 512;
913 }
914 return 0;
915
916}
917
918static void free_super_ddf(struct supertype *st)
919{
920 struct ddf_super *ddf = st->sb;
921 if (ddf == NULL)
922 return;
923 free(ddf->phys);
924 free(ddf->virt);
925 while (ddf->conflist) {
926 struct vcl *v = ddf->conflist;
927 ddf->conflist = v->next;
59e36268
NB
928 if (v->block_sizes)
929 free(v->block_sizes);
3dc821b0 930 if (v->other_bvds) {
931 int i;
932 for (i = 0; i < v->conf.sec_elmnt_count-1; i++)
933 if (v->other_bvds[i] != NULL)
934 free(v->other_bvds[i]);
8ec5d685 935 free(v->other_bvds);
3dc821b0 936 }
a322f70c
DW
937 free(v);
938 }
939 while (ddf->dlist) {
940 struct dl *d = ddf->dlist;
941 ddf->dlist = d->next;
942 if (d->fd >= 0)
943 close(d->fd);
b2280677
NB
944 if (d->spare)
945 free(d->spare);
a322f70c
DW
946 free(d);
947 }
8a38cb04
N
948 while (ddf->add_list) {
949 struct dl *d = ddf->add_list;
950 ddf->add_list = d->next;
951 if (d->fd >= 0)
952 close(d->fd);
953 if (d->spare)
954 free(d->spare);
955 free(d);
956 }
a322f70c
DW
957 free(ddf);
958 st->sb = NULL;
959}
960
961static struct supertype *match_metadata_desc_ddf(char *arg)
962{
963 /* 'ddf' only support containers */
964 struct supertype *st;
965 if (strcmp(arg, "ddf") != 0 &&
966 strcmp(arg, "default") != 0
967 )
968 return NULL;
969
503975b9 970 st = xcalloc(1, sizeof(*st));
a322f70c
DW
971 st->ss = &super_ddf;
972 st->max_devs = 512;
973 st->minor_version = 0;
974 st->sb = NULL;
975 return st;
976}
977
a322f70c
DW
978#ifndef MDASSEMBLE
979
980static mapping_t ddf_state[] = {
981 { "Optimal", 0},
982 { "Degraded", 1},
983 { "Deleted", 2},
984 { "Missing", 3},
985 { "Failed", 4},
986 { "Partially Optimal", 5},
987 { "-reserved-", 6},
988 { "-reserved-", 7},
989 { NULL, 0}
990};
991
992static mapping_t ddf_init_state[] = {
993 { "Not Initialised", 0},
994 { "QuickInit in Progress", 1},
995 { "Fully Initialised", 2},
996 { "*UNKNOWN*", 3},
997 { NULL, 0}
998};
999static mapping_t ddf_access[] = {
1000 { "Read/Write", 0},
1001 { "Reserved", 1},
1002 { "Read Only", 2},
1003 { "Blocked (no access)", 3},
1004 { NULL ,0}
1005};
1006
1007static mapping_t ddf_level[] = {
1008 { "RAID0", DDF_RAID0},
1009 { "RAID1", DDF_RAID1},
1010 { "RAID3", DDF_RAID3},
1011 { "RAID4", DDF_RAID4},
1012 { "RAID5", DDF_RAID5},
1013 { "RAID1E",DDF_RAID1E},
1014 { "JBOD", DDF_JBOD},
1015 { "CONCAT",DDF_CONCAT},
1016 { "RAID5E",DDF_RAID5E},
1017 { "RAID5EE",DDF_RAID5EE},
1018 { "RAID6", DDF_RAID6},
1019 { NULL, 0}
1020};
1021static mapping_t ddf_sec_level[] = {
1022 { "Striped", DDF_2STRIPED},
1023 { "Mirrored", DDF_2MIRRORED},
1024 { "Concat", DDF_2CONCAT},
1025 { "Spanned", DDF_2SPANNED},
1026 { NULL, 0}
1027};
1028#endif
1029
1030struct num_mapping {
1031 int num1, num2;
1032};
1033static struct num_mapping ddf_level_num[] = {
1034 { DDF_RAID0, 0 },
1035 { DDF_RAID1, 1 },
1036 { DDF_RAID3, LEVEL_UNSUPPORTED },
60f18132
NB
1037 { DDF_RAID4, 4 },
1038 { DDF_RAID5, 5 },
a322f70c
DW
1039 { DDF_RAID1E, LEVEL_UNSUPPORTED },
1040 { DDF_JBOD, LEVEL_UNSUPPORTED },
1041 { DDF_CONCAT, LEVEL_LINEAR },
1042 { DDF_RAID5E, LEVEL_UNSUPPORTED },
1043 { DDF_RAID5EE, LEVEL_UNSUPPORTED },
1044 { DDF_RAID6, 6},
1045 { MAXINT, MAXINT }
1046};
1047
1048static int map_num1(struct num_mapping *map, int num)
1049{
1050 int i;
1051 for (i=0 ; map[i].num1 != MAXINT; i++)
1052 if (map[i].num1 == num)
1053 break;
1054 return map[i].num2;
1055}
1056
42dc2744
N
1057static int all_ff(char *guid)
1058{
1059 int i;
1060 for (i = 0; i < DDF_GUID_LEN; i++)
1061 if (guid[i] != (char)0xff)
1062 return 0;
1063 return 1;
1064}
1065
a322f70c
DW
1066#ifndef MDASSEMBLE
1067static void print_guid(char *guid, int tstamp)
1068{
1069 /* A GUIDs are part (or all) ASCII and part binary.
1070 * They tend to be space padded.
59e36268
NB
1071 * We print the GUID in HEX, then in parentheses add
1072 * any initial ASCII sequence, and a possible
1073 * time stamp from bytes 16-19
a322f70c
DW
1074 */
1075 int l = DDF_GUID_LEN;
1076 int i;
59e36268
NB
1077
1078 for (i=0 ; i<DDF_GUID_LEN ; i++) {
1079 if ((i&3)==0 && i != 0) printf(":");
1080 printf("%02X", guid[i]&255);
1081 }
1082
cfccea8c 1083 printf("\n (");
a322f70c
DW
1084 while (l && guid[l-1] == ' ')
1085 l--;
1086 for (i=0 ; i<l ; i++) {
1087 if (guid[i] >= 0x20 && guid[i] < 0x7f)
1088 fputc(guid[i], stdout);
1089 else
59e36268 1090 break;
a322f70c
DW
1091 }
1092 if (tstamp) {
1093 time_t then = __be32_to_cpu(*(__u32*)(guid+16)) + DECADE;
1094 char tbuf[100];
1095 struct tm *tm;
1096 tm = localtime(&then);
59e36268 1097 strftime(tbuf, 100, " %D %T",tm);
a322f70c
DW
1098 fputs(tbuf, stdout);
1099 }
59e36268 1100 printf(")");
a322f70c
DW
1101}
1102
1103static void examine_vd(int n, struct ddf_super *sb, char *guid)
1104{
8c3b8c2c 1105 int crl = sb->conf_rec_len;
a322f70c
DW
1106 struct vcl *vcl;
1107
1108 for (vcl = sb->conflist ; vcl ; vcl = vcl->next) {
f21e18ca 1109 unsigned int i;
a322f70c
DW
1110 struct vd_config *vc = &vcl->conf;
1111
1112 if (calc_crc(vc, crl*512) != vc->crc)
1113 continue;
1114 if (memcmp(vc->guid, guid, DDF_GUID_LEN) != 0)
1115 continue;
1116
1117 /* Ok, we know about this VD, let's give more details */
b06e3095 1118 printf(" Raid Devices[%d] : %d (", n,
a322f70c 1119 __be16_to_cpu(vc->prim_elmnt_count));
f21e18ca 1120 for (i = 0; i < __be16_to_cpu(vc->prim_elmnt_count); i++) {
b06e3095
N
1121 int j;
1122 int cnt = __be16_to_cpu(sb->phys->used_pdes);
1123 for (j=0; j<cnt; j++)
1124 if (vc->phys_refnum[i] == sb->phys->entries[j].refnum)
1125 break;
1126 if (i) printf(" ");
1127 if (j < cnt)
1128 printf("%d", j);
1129 else
1130 printf("--");
1131 }
1132 printf(")\n");
1133 if (vc->chunk_shift != 255)
613b0d17
N
1134 printf(" Chunk Size[%d] : %d sectors\n", n,
1135 1 << vc->chunk_shift);
a322f70c
DW
1136 printf(" Raid Level[%d] : %s\n", n,
1137 map_num(ddf_level, vc->prl)?:"-unknown-");
1138 if (vc->sec_elmnt_count != 1) {
1139 printf(" Secondary Position[%d] : %d of %d\n", n,
1140 vc->sec_elmnt_seq, vc->sec_elmnt_count);
1141 printf(" Secondary Level[%d] : %s\n", n,
1142 map_num(ddf_sec_level, vc->srl) ?: "-unknown-");
1143 }
1144 printf(" Device Size[%d] : %llu\n", n,
c9b6907b 1145 (unsigned long long)__be64_to_cpu(vc->blocks)/2);
a322f70c 1146 printf(" Array Size[%d] : %llu\n", n,
c9b6907b 1147 (unsigned long long)__be64_to_cpu(vc->array_blocks)/2);
a322f70c
DW
1148 }
1149}
1150
1151static void examine_vds(struct ddf_super *sb)
1152{
1153 int cnt = __be16_to_cpu(sb->virt->populated_vdes);
1154 int i;
1155 printf(" Virtual Disks : %d\n", cnt);
1156
1157 for (i=0; i<cnt; i++) {
1158 struct virtual_entry *ve = &sb->virt->entries[i];
b06e3095 1159 printf("\n");
a322f70c
DW
1160 printf(" VD GUID[%d] : ", i); print_guid(ve->guid, 1);
1161 printf("\n");
1162 printf(" unit[%d] : %d\n", i, __be16_to_cpu(ve->unit));
1163 printf(" state[%d] : %s, %s%s\n", i,
1164 map_num(ddf_state, ve->state & 7),
1165 (ve->state & 8) ? "Morphing, ": "",
1166 (ve->state & 16)? "Not Consistent" : "Consistent");
1167 printf(" init state[%d] : %s\n", i,
1168 map_num(ddf_init_state, ve->init_state&3));
1169 printf(" access[%d] : %s\n", i,
1170 map_num(ddf_access, (ve->init_state>>6) & 3));
1171 printf(" Name[%d] : %.16s\n", i, ve->name);
1172 examine_vd(i, sb, ve->guid);
1173 }
1174 if (cnt) printf("\n");
1175}
1176
1177static void examine_pds(struct ddf_super *sb)
1178{
1179 int cnt = __be16_to_cpu(sb->phys->used_pdes);
1180 int i;
1181 struct dl *dl;
1182 printf(" Physical Disks : %d\n", cnt);
962371a5 1183 printf(" Number RefNo Size Device Type/State\n");
a322f70c
DW
1184
1185 for (i=0 ; i<cnt ; i++) {
1186 struct phys_disk_entry *pd = &sb->phys->entries[i];
1187 int type = __be16_to_cpu(pd->type);
1188 int state = __be16_to_cpu(pd->state);
1189
b06e3095
N
1190 //printf(" PD GUID[%d] : ", i); print_guid(pd->guid, 0);
1191 //printf("\n");
1192 printf(" %3d %08x ", i,
a322f70c 1193 __be32_to_cpu(pd->refnum));
613b0d17 1194 printf("%8lluK ",
c9b6907b 1195 (unsigned long long)__be64_to_cpu(pd->config_size)>>1);
b06e3095
N
1196 for (dl = sb->dlist; dl ; dl = dl->next) {
1197 if (dl->disk.refnum == pd->refnum) {
1198 char *dv = map_dev(dl->major, dl->minor, 0);
1199 if (dv) {
962371a5 1200 printf("%-15s", dv);
b06e3095
N
1201 break;
1202 }
1203 }
1204 }
1205 if (!dl)
962371a5 1206 printf("%15s","");
b06e3095 1207 printf(" %s%s%s%s%s",
a322f70c 1208 (type&2) ? "active":"",
b06e3095 1209 (type&4) ? "Global-Spare":"",
a322f70c
DW
1210 (type&8) ? "spare" : "",
1211 (type&16)? ", foreign" : "",
1212 (type&32)? "pass-through" : "");
18cb4496
N
1213 if (state & DDF_Failed)
1214 /* This over-rides these three */
1215 state &= ~(DDF_Online|DDF_Rebuilding|DDF_Transition);
b06e3095 1216 printf("/%s%s%s%s%s%s%s",
a322f70c
DW
1217 (state&1)? "Online": "Offline",
1218 (state&2)? ", Failed": "",
1219 (state&4)? ", Rebuilding": "",
1220 (state&8)? ", in-transition": "",
b06e3095
N
1221 (state&16)? ", SMART-errors": "",
1222 (state&32)? ", Unrecovered-Read-Errors": "",
a322f70c 1223 (state&64)? ", Missing" : "");
a322f70c
DW
1224 printf("\n");
1225 }
1226}
1227
1228static void examine_super_ddf(struct supertype *st, char *homehost)
1229{
1230 struct ddf_super *sb = st->sb;
1231
1232 printf(" Magic : %08x\n", __be32_to_cpu(sb->anchor.magic));
1233 printf(" Version : %.8s\n", sb->anchor.revision);
598f0d58
NB
1234 printf("Controller GUID : "); print_guid(sb->controller.guid, 0);
1235 printf("\n");
1236 printf(" Container GUID : "); print_guid(sb->anchor.guid, 1);
a322f70c
DW
1237 printf("\n");
1238 printf(" Seq : %08x\n", __be32_to_cpu(sb->active->seq));
1239 printf(" Redundant hdr : %s\n", sb->secondary.magic == DDF_HEADER_MAGIC
1240 ?"yes" : "no");
1241 examine_vds(sb);
1242 examine_pds(sb);
1243}
1244
a5d85af7 1245static void getinfo_super_ddf(struct supertype *st, struct mdinfo *info, char *map);
ff54de6e 1246
bedbf68a 1247static void uuid_from_ddf_guid(const char *guid, int uuid[4]);
42dc2744 1248static void uuid_from_super_ddf(struct supertype *st, int uuid[4]);
ff54de6e 1249
bedbf68a 1250static unsigned int get_vd_num_of_subarray(struct supertype *st)
1251{
1252 /*
1253 * Figure out the VD number for this supertype.
1254 * Returns DDF_CONTAINER for the container itself,
1255 * and DDF_NOTFOUND on error.
1256 */
1257 struct ddf_super *ddf = st->sb;
1258 struct mdinfo *sra;
1259 char *sub, *end;
1260 unsigned int vcnum;
1261
1262 if (*st->container_devnm == '\0')
1263 return DDF_CONTAINER;
1264
1265 sra = sysfs_read(-1, st->devnm, GET_VERSION);
1266 if (!sra || sra->array.major_version != -1 ||
1267 sra->array.minor_version != -2 ||
1268 !is_subarray(sra->text_version))
1269 return DDF_NOTFOUND;
1270
1271 sub = strchr(sra->text_version + 1, '/');
1272 if (sub != NULL)
1273 vcnum = strtoul(sub + 1, &end, 10);
1274 if (sub == NULL || *sub == '\0' || *end != '\0' ||
1275 vcnum >= __be16_to_cpu(ddf->active->max_vd_entries))
1276 return DDF_NOTFOUND;
1277
1278 return vcnum;
1279}
1280
061f2c6a 1281static void brief_examine_super_ddf(struct supertype *st, int verbose)
4737ae25
N
1282{
1283 /* We just write a generic DDF ARRAY entry
1284 */
1285 struct mdinfo info;
1286 char nbuf[64];
a5d85af7 1287 getinfo_super_ddf(st, &info, NULL);
4737ae25
N
1288 fname_from_uuid(st, &info, nbuf, ':');
1289
1290 printf("ARRAY metadata=ddf UUID=%s\n", nbuf + 5);
1291}
1292
1293static void brief_examine_subarrays_ddf(struct supertype *st, int verbose)
a322f70c
DW
1294{
1295 /* We just write a generic DDF ARRAY entry
a322f70c 1296 */
42dc2744 1297 struct ddf_super *ddf = st->sb;
ff54de6e 1298 struct mdinfo info;
f21e18ca 1299 unsigned int i;
ff54de6e 1300 char nbuf[64];
a5d85af7 1301 getinfo_super_ddf(st, &info, NULL);
ff54de6e 1302 fname_from_uuid(st, &info, nbuf, ':');
42dc2744 1303
f21e18ca 1304 for (i = 0; i < __be16_to_cpu(ddf->virt->max_vdes); i++) {
42dc2744
N
1305 struct virtual_entry *ve = &ddf->virt->entries[i];
1306 struct vcl vcl;
1307 char nbuf1[64];
1308 if (all_ff(ve->guid))
1309 continue;
1310 memcpy(vcl.conf.guid, ve->guid, DDF_GUID_LEN);
1311 ddf->currentconf =&vcl;
1312 uuid_from_super_ddf(st, info.uuid);
1313 fname_from_uuid(st, &info, nbuf1, ':');
1314 printf("ARRAY container=%s member=%d UUID=%s\n",
1315 nbuf+5, i, nbuf1+5);
1316 }
a322f70c
DW
1317}
1318
bceedeec
N
1319static void export_examine_super_ddf(struct supertype *st)
1320{
1321 struct mdinfo info;
1322 char nbuf[64];
a5d85af7 1323 getinfo_super_ddf(st, &info, NULL);
bceedeec
N
1324 fname_from_uuid(st, &info, nbuf, ':');
1325 printf("MD_METADATA=ddf\n");
1326 printf("MD_LEVEL=container\n");
1327 printf("MD_UUID=%s\n", nbuf+5);
1328}
bceedeec 1329
74db60b0
N
1330static int copy_metadata_ddf(struct supertype *st, int from, int to)
1331{
1332 void *buf;
1333 unsigned long long dsize, offset;
1334 int bytes;
1335 struct ddf_header *ddf;
1336 int written = 0;
1337
1338 /* The meta consists of an anchor, a primary, and a secondary.
1339 * This all lives at the end of the device.
1340 * So it is easiest to find the earliest of primary and
1341 * secondary, and copy everything from there.
1342 *
1343 * Anchor is 512 from end It contains primary_lba and secondary_lba
1344 * we choose one of those
1345 */
1346
1347 if (posix_memalign(&buf, 4096, 4096) != 0)
1348 return 1;
1349
1350 if (!get_dev_size(from, NULL, &dsize))
1351 goto err;
1352
1353 if (lseek64(from, dsize-512, 0) < 0)
1354 goto err;
1355 if (read(from, buf, 512) != 512)
1356 goto err;
1357 ddf = buf;
1358 if (ddf->magic != DDF_HEADER_MAGIC ||
1359 calc_crc(ddf, 512) != ddf->crc ||
1360 (memcmp(ddf->revision, DDF_REVISION_0, 8) != 0 &&
1361 memcmp(ddf->revision, DDF_REVISION_2, 8) != 0))
1362 goto err;
1363
1364 offset = dsize - 512;
1365 if ((__be64_to_cpu(ddf->primary_lba) << 9) < offset)
1366 offset = __be64_to_cpu(ddf->primary_lba) << 9;
1367 if ((__be64_to_cpu(ddf->secondary_lba) << 9) < offset)
1368 offset = __be64_to_cpu(ddf->secondary_lba) << 9;
1369
1370 bytes = dsize - offset;
1371
1372 if (lseek64(from, offset, 0) < 0 ||
1373 lseek64(to, offset, 0) < 0)
1374 goto err;
1375 while (written < bytes) {
1376 int n = bytes - written;
1377 if (n > 4096)
1378 n = 4096;
1379 if (read(from, buf, n) != n)
1380 goto err;
1381 if (write(to, buf, n) != n)
1382 goto err;
1383 written += n;
1384 }
1385 free(buf);
1386 return 0;
1387err:
1388 free(buf);
1389 return 1;
1390}
1391
a322f70c
DW
1392static void detail_super_ddf(struct supertype *st, char *homehost)
1393{
1394 /* FIXME later
1395 * Could print DDF GUID
1396 * Need to find which array
1397 * If whole, briefly list all arrays
1398 * If one, give name
1399 */
1400}
1401
1402static void brief_detail_super_ddf(struct supertype *st)
1403{
ff54de6e
N
1404 struct mdinfo info;
1405 char nbuf[64];
bedbf68a 1406 struct ddf_super *ddf = st->sb;
1407 unsigned int vcnum = get_vd_num_of_subarray(st);
1408 if (vcnum == DDF_CONTAINER)
1409 uuid_from_super_ddf(st, info.uuid);
1410 else if (vcnum == DDF_NOTFOUND)
1411 return;
1412 else
1413 uuid_from_ddf_guid(ddf->virt->entries[vcnum].guid, info.uuid);
ff54de6e
N
1414 fname_from_uuid(st, &info, nbuf,':');
1415 printf(" UUID=%s", nbuf + 5);
a322f70c 1416}
a322f70c
DW
1417#endif
1418
1419static int match_home_ddf(struct supertype *st, char *homehost)
1420{
1421 /* It matches 'this' host if the controller is a
1422 * Linux-MD controller with vendor_data matching
1423 * the hostname
1424 */
1425 struct ddf_super *ddf = st->sb;
f21e18ca 1426 unsigned int len;
d1d3482b
N
1427
1428 if (!homehost)
1429 return 0;
1430 len = strlen(homehost);
a322f70c
DW
1431
1432 return (memcmp(ddf->controller.guid, T10, 8) == 0 &&
1433 len < sizeof(ddf->controller.vendor_data) &&
1434 memcmp(ddf->controller.vendor_data, homehost,len) == 0 &&
1435 ddf->controller.vendor_data[len] == 0);
1436}
1437
0e600426 1438#ifndef MDASSEMBLE
f21e18ca 1439static struct vd_config *find_vdcr(struct ddf_super *ddf, unsigned int inst)
a322f70c 1440{
7a7cc504 1441 struct vcl *v;
59e36268 1442
7a7cc504 1443 for (v = ddf->conflist; v; v = v->next)
59e36268 1444 if (inst == v->vcnum)
7a7cc504
NB
1445 return &v->conf;
1446 return NULL;
1447}
0e600426 1448#endif
7a7cc504
NB
1449
1450static int find_phys(struct ddf_super *ddf, __u32 phys_refnum)
1451{
1452 /* Find the entry in phys_disk which has the given refnum
1453 * and return it's index
1454 */
f21e18ca
N
1455 unsigned int i;
1456 for (i = 0; i < __be16_to_cpu(ddf->phys->max_pdes); i++)
7a7cc504
NB
1457 if (ddf->phys->entries[i].refnum == phys_refnum)
1458 return i;
1459 return -1;
a322f70c
DW
1460}
1461
bedbf68a 1462static void uuid_from_ddf_guid(const char *guid, int uuid[4])
1463{
1464 char buf[20];
1465 struct sha1_ctx ctx;
1466 sha1_init_ctx(&ctx);
1467 sha1_process_bytes(guid, DDF_GUID_LEN, &ctx);
1468 sha1_finish_ctx(&ctx, buf);
1469 memcpy(uuid, buf, 4*4);
1470}
1471
a322f70c
DW
1472static void uuid_from_super_ddf(struct supertype *st, int uuid[4])
1473{
1474 /* The uuid returned here is used for:
1475 * uuid to put into bitmap file (Create, Grow)
1476 * uuid for backup header when saving critical section (Grow)
1477 * comparing uuids when re-adding a device into an array
51006d85
N
1478 * In these cases the uuid required is that of the data-array,
1479 * not the device-set.
1480 * uuid to recognise same set when adding a missing device back
1481 * to an array. This is a uuid for the device-set.
613b0d17 1482 *
a322f70c
DW
1483 * For each of these we can make do with a truncated
1484 * or hashed uuid rather than the original, as long as
1485 * everyone agrees.
a322f70c
DW
1486 * In the case of SVD we assume the BVD is of interest,
1487 * though that might be the case if a bitmap were made for
1488 * a mirrored SVD - worry about that later.
1489 * So we need to find the VD configuration record for the
1490 * relevant BVD and extract the GUID and Secondary_Element_Seq.
1491 * The first 16 bytes of the sha1 of these is used.
1492 */
1493 struct ddf_super *ddf = st->sb;
d2ca6449 1494 struct vcl *vcl = ddf->currentconf;
c5afc314 1495 char *guid;
a322f70c 1496
c5afc314
N
1497 if (vcl)
1498 guid = vcl->conf.guid;
1499 else
1500 guid = ddf->anchor.guid;
bedbf68a 1501 uuid_from_ddf_guid(guid, uuid);
a322f70c
DW
1502}
1503
a5d85af7 1504static void getinfo_super_ddf_bvd(struct supertype *st, struct mdinfo *info, char *map);
78e44928 1505
a5d85af7 1506static void getinfo_super_ddf(struct supertype *st, struct mdinfo *info, char *map)
a322f70c
DW
1507{
1508 struct ddf_super *ddf = st->sb;
a5d85af7 1509 int map_disks = info->array.raid_disks;
90fa1a29 1510 __u32 *cptr;
a322f70c 1511
78e44928 1512 if (ddf->currentconf) {
a5d85af7 1513 getinfo_super_ddf_bvd(st, info, map);
78e44928
NB
1514 return;
1515 }
95eeceeb 1516 memset(info, 0, sizeof(*info));
78e44928 1517
a322f70c
DW
1518 info->array.raid_disks = __be16_to_cpu(ddf->phys->used_pdes);
1519 info->array.level = LEVEL_CONTAINER;
1520 info->array.layout = 0;
1521 info->array.md_minor = -1;
90fa1a29
JS
1522 cptr = (__u32 *)(ddf->anchor.guid + 16);
1523 info->array.ctime = DECADE + __be32_to_cpu(*cptr);
1524
a322f70c
DW
1525 info->array.utime = 0;
1526 info->array.chunk_size = 0;
510242aa 1527 info->container_enough = 1;
a322f70c 1528
a322f70c
DW
1529 info->disk.major = 0;
1530 info->disk.minor = 0;
cba0191b
NB
1531 if (ddf->dlist) {
1532 info->disk.number = __be32_to_cpu(ddf->dlist->disk.refnum);
59e36268 1533 info->disk.raid_disk = find_phys(ddf, ddf->dlist->disk.refnum);
d2ca6449
NB
1534
1535 info->data_offset = __be64_to_cpu(ddf->phys->
613b0d17
N
1536 entries[info->disk.raid_disk].
1537 config_size);
d2ca6449 1538 info->component_size = ddf->dlist->size - info->data_offset;
cba0191b
NB
1539 } else {
1540 info->disk.number = -1;
661dce36 1541 info->disk.raid_disk = -1;
cba0191b
NB
1542// info->disk.raid_disk = find refnum in the table and use index;
1543 }
f22385f9 1544 info->disk.state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
a19c88b8 1545
921d9e16 1546 info->recovery_start = MaxSector;
a19c88b8 1547 info->reshape_active = 0;
6e75048b 1548 info->recovery_blocked = 0;
c5afc314 1549 info->name[0] = 0;
a322f70c 1550
f35f2525
N
1551 info->array.major_version = -1;
1552 info->array.minor_version = -2;
159c3a1a 1553 strcpy(info->text_version, "ddf");
a67dd8cc 1554 info->safe_mode_delay = 0;
159c3a1a 1555
c5afc314 1556 uuid_from_super_ddf(st, info->uuid);
a322f70c 1557
a5d85af7
N
1558 if (map) {
1559 int i;
1560 for (i = 0 ; i < map_disks; i++) {
1561 if (i < info->array.raid_disks &&
1562 (__be16_to_cpu(ddf->phys->entries[i].state) & DDF_Online) &&
1563 !(__be16_to_cpu(ddf->phys->entries[i].state) & DDF_Failed))
1564 map[i] = 1;
1565 else
1566 map[i] = 0;
1567 }
1568 }
a322f70c
DW
1569}
1570
598f0d58
NB
1571static int rlq_to_layout(int rlq, int prl, int raiddisks);
1572
a5d85af7 1573static void getinfo_super_ddf_bvd(struct supertype *st, struct mdinfo *info, char *map)
a322f70c
DW
1574{
1575 struct ddf_super *ddf = st->sb;
d2ca6449
NB
1576 struct vcl *vc = ddf->currentconf;
1577 int cd = ddf->currentdev;
db42fa9b 1578 int j;
8592f29d 1579 struct dl *dl;
a5d85af7 1580 int map_disks = info->array.raid_disks;
90fa1a29 1581 __u32 *cptr;
a322f70c 1582
95eeceeb 1583 memset(info, 0, sizeof(*info));
a322f70c
DW
1584 /* FIXME this returns BVD info - what if we want SVD ?? */
1585
d2ca6449
NB
1586 info->array.raid_disks = __be16_to_cpu(vc->conf.prim_elmnt_count);
1587 info->array.level = map_num1(ddf_level_num, vc->conf.prl);
1588 info->array.layout = rlq_to_layout(vc->conf.rlq, vc->conf.prl,
598f0d58 1589 info->array.raid_disks);
a322f70c 1590 info->array.md_minor = -1;
90fa1a29
JS
1591 cptr = (__u32 *)(vc->conf.guid + 16);
1592 info->array.ctime = DECADE + __be32_to_cpu(*cptr);
d2ca6449
NB
1593 info->array.utime = DECADE + __be32_to_cpu(vc->conf.timestamp);
1594 info->array.chunk_size = 512 << vc->conf.chunk_shift;
da9b4a62 1595 info->custom_array_size = 0;
d2ca6449 1596
f21e18ca 1597 if (cd >= 0 && (unsigned)cd < ddf->mppe) {
d2ca6449
NB
1598 info->data_offset = __be64_to_cpu(vc->lba_offset[cd]);
1599 if (vc->block_sizes)
1600 info->component_size = vc->block_sizes[cd];
1601 else
1602 info->component_size = __be64_to_cpu(vc->conf.blocks);
1603 }
a322f70c 1604
fb204fb2
N
1605 for (dl = ddf->dlist; dl ; dl = dl->next)
1606 if (dl->raiddisk == ddf->currentdev)
1607 break;
1608
a322f70c
DW
1609 info->disk.major = 0;
1610 info->disk.minor = 0;
fb204fb2 1611 info->disk.state = 0;
8592f29d
N
1612 if (dl) {
1613 info->disk.major = dl->major;
1614 info->disk.minor = dl->minor;
fb204fb2
N
1615 info->disk.raid_disk = dl->raiddisk;
1616 info->disk.number = dl->pdnum;
1617 info->disk.state = (1<<MD_DISK_SYNC)|(1<<MD_DISK_ACTIVE);
8592f29d 1618 }
a322f70c 1619
103f2410
NB
1620 info->container_member = ddf->currentconf->vcnum;
1621
921d9e16 1622 info->recovery_start = MaxSector;
80d26cb2 1623 info->resync_start = 0;
624c5ad4 1624 info->reshape_active = 0;
6e75048b 1625 info->recovery_blocked = 0;
80d26cb2
NB
1626 if (!(ddf->virt->entries[info->container_member].state
1627 & DDF_state_inconsistent) &&
1628 (ddf->virt->entries[info->container_member].init_state
1629 & DDF_initstate_mask)
1630 == DDF_init_full)
b7528a20 1631 info->resync_start = MaxSector;
80d26cb2 1632
a322f70c
DW
1633 uuid_from_super_ddf(st, info->uuid);
1634
f35f2525
N
1635 info->array.major_version = -1;
1636 info->array.minor_version = -2;
9b63e648 1637 sprintf(info->text_version, "/%s/%d",
4dd2df09 1638 st->container_devnm,
9b63e648 1639 info->container_member);
a67dd8cc 1640 info->safe_mode_delay = 200;
159c3a1a 1641
db42fa9b
N
1642 memcpy(info->name, ddf->virt->entries[info->container_member].name, 16);
1643 info->name[16]=0;
1644 for(j=0; j<16; j++)
1645 if (info->name[j] == ' ')
1646 info->name[j] = 0;
a5d85af7
N
1647
1648 if (map)
1649 for (j = 0; j < map_disks; j++) {
1650 map[j] = 0;
1651 if (j < info->array.raid_disks) {
1652 int i = find_phys(ddf, vc->conf.phys_refnum[j]);
613b0d17 1653 if (i >= 0 &&
a5d85af7
N
1654 (__be16_to_cpu(ddf->phys->entries[i].state) & DDF_Online) &&
1655 !(__be16_to_cpu(ddf->phys->entries[i].state) & DDF_Failed))
1656 map[i] = 1;
1657 }
1658 }
a322f70c
DW
1659}
1660
1661static int update_super_ddf(struct supertype *st, struct mdinfo *info,
1662 char *update,
1663 char *devname, int verbose,
1664 int uuid_set, char *homehost)
1665{
1666 /* For 'assemble' and 'force' we need to return non-zero if any
1667 * change was made. For others, the return value is ignored.
1668 * Update options are:
1669 * force-one : This device looks a bit old but needs to be included,
1670 * update age info appropriately.
1671 * assemble: clear any 'faulty' flag to allow this device to
1672 * be assembled.
1673 * force-array: Array is degraded but being forced, mark it clean
1674 * if that will be needed to assemble it.
1675 *
1676 * newdev: not used ????
1677 * grow: Array has gained a new device - this is currently for
1678 * linear only
1679 * resync: mark as dirty so a resync will happen.
59e36268 1680 * uuid: Change the uuid of the array to match what is given
a322f70c
DW
1681 * homehost: update the recorded homehost
1682 * name: update the name - preserving the homehost
1683 * _reshape_progress: record new reshape_progress position.
1684 *
1685 * Following are not relevant for this version:
1686 * sparc2.2 : update from old dodgey metadata
1687 * super-minor: change the preferred_minor number
1688 * summaries: update redundant counters.
1689 */
1690 int rv = 0;
1691// struct ddf_super *ddf = st->sb;
7a7cc504 1692// struct vd_config *vd = find_vdcr(ddf, info->container_member);
a322f70c
DW
1693// struct virtual_entry *ve = find_ve(ddf);
1694
a322f70c
DW
1695 /* we don't need to handle "force-*" or "assemble" as
1696 * there is no need to 'trick' the kernel. We the metadata is
1697 * first updated to activate the array, all the implied modifications
1698 * will just happen.
1699 */
1700
1701 if (strcmp(update, "grow") == 0) {
1702 /* FIXME */
1e2b2765 1703 } else if (strcmp(update, "resync") == 0) {
a322f70c 1704// info->resync_checkpoint = 0;
1e2b2765 1705 } else if (strcmp(update, "homehost") == 0) {
a322f70c
DW
1706 /* homehost is stored in controller->vendor_data,
1707 * or it is when we are the vendor
1708 */
1709// if (info->vendor_is_local)
1710// strcpy(ddf->controller.vendor_data, homehost);
1e2b2765 1711 rv = -1;
f49208ec 1712 } else if (strcmp(update, "name") == 0) {
a322f70c
DW
1713 /* name is stored in virtual_entry->name */
1714// memset(ve->name, ' ', 16);
1715// strncpy(ve->name, info->name, 16);
1e2b2765 1716 rv = -1;
f49208ec 1717 } else if (strcmp(update, "_reshape_progress") == 0) {
a322f70c 1718 /* We don't support reshape yet */
f49208ec
N
1719 } else if (strcmp(update, "assemble") == 0 ) {
1720 /* Do nothing, just succeed */
1721 rv = 0;
1e2b2765
N
1722 } else
1723 rv = -1;
a322f70c
DW
1724
1725// update_all_csum(ddf);
1726
1727 return rv;
1728}
1729
5f8097be
NB
1730static void make_header_guid(char *guid)
1731{
1732 __u32 stamp;
5f8097be
NB
1733 /* Create a DDF Header of Virtual Disk GUID */
1734
1735 /* 24 bytes of fiction required.
1736 * first 8 are a 'vendor-id' - "Linux-MD"
1737 * next 8 are controller type.. how about 0X DEAD BEEF 0000 0000
1738 * Remaining 8 random number plus timestamp
1739 */
1740 memcpy(guid, T10, sizeof(T10));
1741 stamp = __cpu_to_be32(0xdeadbeef);
1742 memcpy(guid+8, &stamp, 4);
1743 stamp = __cpu_to_be32(0);
1744 memcpy(guid+12, &stamp, 4);
1745 stamp = __cpu_to_be32(time(0) - DECADE);
1746 memcpy(guid+16, &stamp, 4);
bfb7ea78 1747 stamp = random32();
5f8097be 1748 memcpy(guid+20, &stamp, 4);
5f8097be 1749}
59e36268 1750
78e44928
NB
1751static int init_super_ddf_bvd(struct supertype *st,
1752 mdu_array_info_t *info,
1753 unsigned long long size,
1754 char *name, char *homehost,
83cd1e97 1755 int *uuid, unsigned long long data_offset);
78e44928 1756
a322f70c
DW
1757static int init_super_ddf(struct supertype *st,
1758 mdu_array_info_t *info,
1759 unsigned long long size, char *name, char *homehost,
83cd1e97 1760 int *uuid, unsigned long long data_offset)
a322f70c
DW
1761{
1762 /* This is primarily called by Create when creating a new array.
1763 * We will then get add_to_super called for each component, and then
1764 * write_init_super called to write it out to each device.
1765 * For DDF, Create can create on fresh devices or on a pre-existing
1766 * array.
1767 * To create on a pre-existing array a different method will be called.
1768 * This one is just for fresh drives.
1769 *
1770 * We need to create the entire 'ddf' structure which includes:
1771 * DDF headers - these are easy.
1772 * Controller data - a Sector describing this controller .. not that
1773 * this is a controller exactly.
1774 * Physical Disk Record - one entry per device, so
1775 * leave plenty of space.
1776 * Virtual Disk Records - again, just leave plenty of space.
1777 * This just lists VDs, doesn't give details
1778 * Config records - describes the VDs that use this disk
1779 * DiskData - describes 'this' device.
1780 * BadBlockManagement - empty
1781 * Diag Space - empty
1782 * Vendor Logs - Could we put bitmaps here?
1783 *
1784 */
1785 struct ddf_super *ddf;
1786 char hostname[17];
1787 int hostlen;
a322f70c
DW
1788 int max_phys_disks, max_virt_disks;
1789 unsigned long long sector;
1790 int clen;
1791 int i;
1792 int pdsize, vdsize;
1793 struct phys_disk *pd;
1794 struct virtual_disk *vd;
1795
83cd1e97 1796 if (data_offset != INVALID_SECTORS) {
ed503f89 1797 pr_err("data-offset not supported by DDF\n");
83cd1e97
N
1798 return 0;
1799 }
1800
78e44928 1801 if (st->sb)
83cd1e97
N
1802 return init_super_ddf_bvd(st, info, size, name, homehost, uuid,
1803 data_offset);
ba7eb04f 1804
3d2c4fc7 1805 if (posix_memalign((void**)&ddf, 512, sizeof(*ddf)) != 0) {
e7b84f9d 1806 pr_err("%s could not allocate superblock\n", __func__);
3d2c4fc7
DW
1807 return 0;
1808 }
6264b437 1809 memset(ddf, 0, sizeof(*ddf));
a322f70c
DW
1810 ddf->dlist = NULL; /* no physical disks yet */
1811 ddf->conflist = NULL; /* No virtual disks yet */
955e9ea1
DW
1812 st->sb = ddf;
1813
1814 if (info == NULL) {
1815 /* zeroing superblock */
1816 return 0;
1817 }
a322f70c
DW
1818
1819 /* At least 32MB *must* be reserved for the ddf. So let's just
1820 * start 32MB from the end, and put the primary header there.
1821 * Don't do secondary for now.
1822 * We don't know exactly where that will be yet as it could be
1823 * different on each device. To just set up the lengths.
1824 *
1825 */
1826
1827 ddf->anchor.magic = DDF_HEADER_MAGIC;
5f8097be 1828 make_header_guid(ddf->anchor.guid);
a322f70c 1829
59e36268 1830 memcpy(ddf->anchor.revision, DDF_REVISION_2, 8);
a322f70c
DW
1831 ddf->anchor.seq = __cpu_to_be32(1);
1832 ddf->anchor.timestamp = __cpu_to_be32(time(0) - DECADE);
1833 ddf->anchor.openflag = 0xFF;
1834 ddf->anchor.foreignflag = 0;
1835 ddf->anchor.enforcegroups = 0; /* Is this best?? */
1836 ddf->anchor.pad0 = 0xff;
1837 memset(ddf->anchor.pad1, 0xff, 12);
1838 memset(ddf->anchor.header_ext, 0xff, 32);
1839 ddf->anchor.primary_lba = ~(__u64)0;
1840 ddf->anchor.secondary_lba = ~(__u64)0;
1841 ddf->anchor.type = DDF_HEADER_ANCHOR;
1842 memset(ddf->anchor.pad2, 0xff, 3);
1843 ddf->anchor.workspace_len = __cpu_to_be32(32768); /* Must be reserved */
1844 ddf->anchor.workspace_lba = ~(__u64)0; /* Put this at bottom
1845 of 32M reserved.. */
1846 max_phys_disks = 1023; /* Should be enough */
1847 ddf->anchor.max_pd_entries = __cpu_to_be16(max_phys_disks);
1848 max_virt_disks = 255;
1849 ddf->anchor.max_vd_entries = __cpu_to_be16(max_virt_disks); /* ?? */
1850 ddf->anchor.max_partitions = __cpu_to_be16(64); /* ?? */
1851 ddf->max_part = 64;
8c3b8c2c 1852 ddf->mppe = 256;
59e36268
NB
1853 ddf->conf_rec_len = 1 + ROUND_UP(ddf->mppe * (4+8), 512)/512;
1854 ddf->anchor.config_record_len = __cpu_to_be16(ddf->conf_rec_len);
1855 ddf->anchor.max_primary_element_entries = __cpu_to_be16(ddf->mppe);
a322f70c 1856 memset(ddf->anchor.pad3, 0xff, 54);
a322f70c
DW
1857 /* controller sections is one sector long immediately
1858 * after the ddf header */
1859 sector = 1;
1860 ddf->anchor.controller_section_offset = __cpu_to_be32(sector);
1861 ddf->anchor.controller_section_length = __cpu_to_be32(1);
1862 sector += 1;
1863
1864 /* phys is 8 sectors after that */
1865 pdsize = ROUND_UP(sizeof(struct phys_disk) +
1866 sizeof(struct phys_disk_entry)*max_phys_disks,
1867 512);
1868 switch(pdsize/512) {
1869 case 2: case 8: case 32: case 128: case 512: break;
1870 default: abort();
1871 }
1872 ddf->anchor.phys_section_offset = __cpu_to_be32(sector);
1873 ddf->anchor.phys_section_length =
1874 __cpu_to_be32(pdsize/512); /* max_primary_element_entries/8 */
1875 sector += pdsize/512;
1876
1877 /* virt is another 32 sectors */
1878 vdsize = ROUND_UP(sizeof(struct virtual_disk) +
1879 sizeof(struct virtual_entry) * max_virt_disks,
1880 512);
1881 switch(vdsize/512) {
1882 case 2: case 8: case 32: case 128: case 512: break;
1883 default: abort();
1884 }
1885 ddf->anchor.virt_section_offset = __cpu_to_be32(sector);
1886 ddf->anchor.virt_section_length =
1887 __cpu_to_be32(vdsize/512); /* max_vd_entries/8 */
1888 sector += vdsize/512;
1889
59e36268 1890 clen = ddf->conf_rec_len * (ddf->max_part+1);
a322f70c
DW
1891 ddf->anchor.config_section_offset = __cpu_to_be32(sector);
1892 ddf->anchor.config_section_length = __cpu_to_be32(clen);
1893 sector += clen;
1894
1895 ddf->anchor.data_section_offset = __cpu_to_be32(sector);
1896 ddf->anchor.data_section_length = __cpu_to_be32(1);
1897 sector += 1;
1898
1899 ddf->anchor.bbm_section_length = __cpu_to_be32(0);
1900 ddf->anchor.bbm_section_offset = __cpu_to_be32(0xFFFFFFFF);
1901 ddf->anchor.diag_space_length = __cpu_to_be32(0);
1902 ddf->anchor.diag_space_offset = __cpu_to_be32(0xFFFFFFFF);
1903 ddf->anchor.vendor_length = __cpu_to_be32(0);
1904 ddf->anchor.vendor_offset = __cpu_to_be32(0xFFFFFFFF);
1905
1906 memset(ddf->anchor.pad4, 0xff, 256);
1907
1908 memcpy(&ddf->primary, &ddf->anchor, 512);
1909 memcpy(&ddf->secondary, &ddf->anchor, 512);
1910
1911 ddf->primary.openflag = 1; /* I guess.. */
1912 ddf->primary.type = DDF_HEADER_PRIMARY;
1913
1914 ddf->secondary.openflag = 1; /* I guess.. */
1915 ddf->secondary.type = DDF_HEADER_SECONDARY;
1916
1917 ddf->active = &ddf->primary;
1918
1919 ddf->controller.magic = DDF_CONTROLLER_MAGIC;
1920
1921 /* 24 more bytes of fiction required.
1922 * first 8 are a 'vendor-id' - "Linux-MD"
1923 * Remaining 16 are serial number.... maybe a hostname would do?
1924 */
1925 memcpy(ddf->controller.guid, T10, sizeof(T10));
1ba6bff9
DW
1926 gethostname(hostname, sizeof(hostname));
1927 hostname[sizeof(hostname) - 1] = 0;
a322f70c
DW
1928 hostlen = strlen(hostname);
1929 memcpy(ddf->controller.guid + 24 - hostlen, hostname, hostlen);
1930 for (i = strlen(T10) ; i+hostlen < 24; i++)
1931 ddf->controller.guid[i] = ' ';
1932
1933 ddf->controller.type.vendor_id = __cpu_to_be16(0xDEAD);
1934 ddf->controller.type.device_id = __cpu_to_be16(0xBEEF);
1935 ddf->controller.type.sub_vendor_id = 0;
1936 ddf->controller.type.sub_device_id = 0;
1937 memcpy(ddf->controller.product_id, "What Is My PID??", 16);
1938 memset(ddf->controller.pad, 0xff, 8);
1939 memset(ddf->controller.vendor_data, 0xff, 448);
a9e1c11d
N
1940 if (homehost && strlen(homehost) < 440)
1941 strcpy((char*)ddf->controller.vendor_data, homehost);
a322f70c 1942
3d2c4fc7 1943 if (posix_memalign((void**)&pd, 512, pdsize) != 0) {
e7b84f9d 1944 pr_err("%s could not allocate pd\n", __func__);
3d2c4fc7
DW
1945 return 0;
1946 }
6416d527 1947 ddf->phys = pd;
a322f70c
DW
1948 ddf->pdsize = pdsize;
1949
1950 memset(pd, 0xff, pdsize);
1951 memset(pd, 0, sizeof(*pd));
076515ba 1952 pd->magic = DDF_PHYS_RECORDS_MAGIC;
a322f70c
DW
1953 pd->used_pdes = __cpu_to_be16(0);
1954 pd->max_pdes = __cpu_to_be16(max_phys_disks);
1955 memset(pd->pad, 0xff, 52);
1956
3d2c4fc7 1957 if (posix_memalign((void**)&vd, 512, vdsize) != 0) {
e7b84f9d 1958 pr_err("%s could not allocate vd\n", __func__);
3d2c4fc7
DW
1959 return 0;
1960 }
6416d527 1961 ddf->virt = vd;
a322f70c
DW
1962 ddf->vdsize = vdsize;
1963 memset(vd, 0, vdsize);
1964 vd->magic = DDF_VIRT_RECORDS_MAGIC;
1965 vd->populated_vdes = __cpu_to_be16(0);
1966 vd->max_vdes = __cpu_to_be16(max_virt_disks);
1967 memset(vd->pad, 0xff, 52);
1968
5f8097be
NB
1969 for (i=0; i<max_virt_disks; i++)
1970 memset(&vd->entries[i], 0xff, sizeof(struct virtual_entry));
1971
a322f70c 1972 st->sb = ddf;
7d5a7ff3 1973 ddf_set_updates_pending(ddf);
a322f70c
DW
1974 return 1;
1975}
1976
5f8097be
NB
1977static int chunk_to_shift(int chunksize)
1978{
1979 return ffs(chunksize/512)-1;
1980}
1981
1982static int level_to_prl(int level)
1983{
1984 switch (level) {
1985 case LEVEL_LINEAR: return DDF_CONCAT;
1986 case 0: return DDF_RAID0;
1987 case 1: return DDF_RAID1;
1988 case 4: return DDF_RAID4;
1989 case 5: return DDF_RAID5;
1990 case 6: return DDF_RAID6;
1991 default: return -1;
1992 }
1993}
613b0d17 1994
5f8097be
NB
1995static int layout_to_rlq(int level, int layout, int raiddisks)
1996{
1997 switch(level) {
1998 case 0:
1999 return DDF_RAID0_SIMPLE;
2000 case 1:
2001 switch(raiddisks) {
2002 case 2: return DDF_RAID1_SIMPLE;
2003 case 3: return DDF_RAID1_MULTI;
2004 default: return -1;
2005 }
2006 case 4:
2007 switch(layout) {
2008 case 0: return DDF_RAID4_N;
2009 }
2010 break;
2011 case 5:
5f8097be
NB
2012 switch(layout) {
2013 case ALGORITHM_LEFT_ASYMMETRIC:
2014 return DDF_RAID5_N_RESTART;
2015 case ALGORITHM_RIGHT_ASYMMETRIC:
b640a252 2016 return DDF_RAID5_0_RESTART;
5f8097be
NB
2017 case ALGORITHM_LEFT_SYMMETRIC:
2018 return DDF_RAID5_N_CONTINUE;
2019 case ALGORITHM_RIGHT_SYMMETRIC:
2020 return -1; /* not mentioned in standard */
2021 }
b640a252
N
2022 case 6:
2023 switch(layout) {
2024 case ALGORITHM_ROTATING_N_RESTART:
2025 return DDF_RAID5_N_RESTART;
2026 case ALGORITHM_ROTATING_ZERO_RESTART:
2027 return DDF_RAID6_0_RESTART;
2028 case ALGORITHM_ROTATING_N_CONTINUE:
2029 return DDF_RAID5_N_CONTINUE;
2030 }
5f8097be
NB
2031 }
2032 return -1;
2033}
2034
598f0d58
NB
2035static int rlq_to_layout(int rlq, int prl, int raiddisks)
2036{
2037 switch(prl) {
2038 case DDF_RAID0:
2039 return 0; /* hopefully rlq == DDF_RAID0_SIMPLE */
2040 case DDF_RAID1:
2041 return 0; /* hopefully rlq == SIMPLE or MULTI depending
2042 on raiddisks*/
2043 case DDF_RAID4:
2044 switch(rlq) {
2045 case DDF_RAID4_N:
2046 return 0;
2047 default:
2048 /* not supported */
2049 return -1; /* FIXME this isn't checked */
2050 }
2051 case DDF_RAID5:
598f0d58
NB
2052 switch(rlq) {
2053 case DDF_RAID5_N_RESTART:
2054 return ALGORITHM_LEFT_ASYMMETRIC;
2055 case DDF_RAID5_0_RESTART:
2056 return ALGORITHM_RIGHT_ASYMMETRIC;
2057 case DDF_RAID5_N_CONTINUE:
2058 return ALGORITHM_LEFT_SYMMETRIC;
2059 default:
2060 return -1;
2061 }
59e36268
NB
2062 case DDF_RAID6:
2063 switch(rlq) {
2064 case DDF_RAID5_N_RESTART:
b640a252 2065 return ALGORITHM_ROTATING_N_RESTART;
59e36268 2066 case DDF_RAID6_0_RESTART:
b640a252 2067 return ALGORITHM_ROTATING_ZERO_RESTART;
59e36268 2068 case DDF_RAID5_N_CONTINUE:
b640a252 2069 return ALGORITHM_ROTATING_N_CONTINUE;
59e36268
NB
2070 default:
2071 return -1;
2072 }
598f0d58
NB
2073 }
2074 return -1;
2075}
2076
0e600426 2077#ifndef MDASSEMBLE
59e36268
NB
2078struct extent {
2079 unsigned long long start, size;
2080};
78e44928 2081static int cmp_extent(const void *av, const void *bv)
59e36268
NB
2082{
2083 const struct extent *a = av;
2084 const struct extent *b = bv;
2085 if (a->start < b->start)
2086 return -1;
2087 if (a->start > b->start)
2088 return 1;
2089 return 0;
2090}
2091
78e44928 2092static struct extent *get_extents(struct ddf_super *ddf, struct dl *dl)
59e36268
NB
2093{
2094 /* find a list of used extents on the give physical device
2095 * (dnum) of the given ddf.
2096 * Return a malloced array of 'struct extent'
2097
613b0d17 2098 * FIXME ignore DDF_Legacy devices?
59e36268
NB
2099
2100 */
2101 struct extent *rv;
2102 int n = 0;
f21e18ca 2103 unsigned int i, j;
59e36268 2104
503975b9 2105 rv = xmalloc(sizeof(struct extent) * (ddf->max_part + 2));
59e36268
NB
2106
2107 for (i = 0; i < ddf->max_part; i++) {
2108 struct vcl *v = dl->vlist[i];
2109 if (v == NULL)
2110 continue;
f21e18ca 2111 for (j = 0; j < v->conf.prim_elmnt_count; j++)
59e36268
NB
2112 if (v->conf.phys_refnum[j] == dl->disk.refnum) {
2113 /* This device plays role 'j' in 'v'. */
2114 rv[n].start = __be64_to_cpu(v->lba_offset[j]);
2115 rv[n].size = __be64_to_cpu(v->conf.blocks);
2116 n++;
2117 break;
2118 }
2119 }
2120 qsort(rv, n, sizeof(*rv), cmp_extent);
2121
2122 rv[n].start = __be64_to_cpu(ddf->phys->entries[dl->pdnum].config_size);
2123 rv[n].size = 0;
2124 return rv;
2125}
0e600426 2126#endif
59e36268 2127
5f8097be
NB
2128static int init_super_ddf_bvd(struct supertype *st,
2129 mdu_array_info_t *info,
2130 unsigned long long size,
2131 char *name, char *homehost,
83cd1e97 2132 int *uuid, unsigned long long data_offset)
5f8097be
NB
2133{
2134 /* We are creating a BVD inside a pre-existing container.
2135 * so st->sb is already set.
2136 * We need to create a new vd_config and a new virtual_entry
2137 */
2138 struct ddf_super *ddf = st->sb;
f21e18ca 2139 unsigned int venum;
5f8097be
NB
2140 struct virtual_entry *ve;
2141 struct vcl *vcl;
2142 struct vd_config *vc;
5f8097be
NB
2143
2144 if (__be16_to_cpu(ddf->virt->populated_vdes)
2145 >= __be16_to_cpu(ddf->virt->max_vdes)) {
e7b84f9d
N
2146 pr_err("This ddf already has the "
2147 "maximum of %d virtual devices\n",
2148 __be16_to_cpu(ddf->virt->max_vdes));
5f8097be
NB
2149 return 0;
2150 }
2151
97c9c100
N
2152 if (name)
2153 for (venum = 0; venum < __be16_to_cpu(ddf->virt->max_vdes); venum++)
2154 if (!all_ff(ddf->virt->entries[venum].guid)) {
2155 char *n = ddf->virt->entries[venum].name;
2156
2157 if (strncmp(name, n, 16) == 0) {
e7b84f9d
N
2158 pr_err("This ddf already"
2159 " has an array called %s\n",
2160 name);
97c9c100
N
2161 return 0;
2162 }
2163 }
2164
5f8097be
NB
2165 for (venum = 0; venum < __be16_to_cpu(ddf->virt->max_vdes); venum++)
2166 if (all_ff(ddf->virt->entries[venum].guid))
2167 break;
2168 if (venum == __be16_to_cpu(ddf->virt->max_vdes)) {
e7b84f9d 2169 pr_err("Cannot find spare slot for "
613b0d17 2170 "virtual disk - DDF is corrupt\n");
5f8097be
NB
2171 return 0;
2172 }
2173 ve = &ddf->virt->entries[venum];
2174
2175 /* A Virtual Disk GUID contains the T10 Vendor ID, controller type,
2176 * timestamp, random number
2177 */
2178 make_header_guid(ve->guid);
2179 ve->unit = __cpu_to_be16(info->md_minor);
2180 ve->pad0 = 0xFFFF;
2181 ve->guid_crc = crc32(0, (unsigned char*)ddf->anchor.guid, DDF_GUID_LEN);
2182 ve->type = 0;
7a7cc504
NB
2183 ve->state = DDF_state_degraded; /* Will be modified as devices are added */
2184 if (info->state & 1) /* clean */
2185 ve->init_state = DDF_init_full;
2186 else
2187 ve->init_state = DDF_init_not;
2188
5f8097be
NB
2189 memset(ve->pad1, 0xff, 14);
2190 memset(ve->name, ' ', 16);
2191 if (name)
2192 strncpy(ve->name, name, 16);
2193 ddf->virt->populated_vdes =
2194 __cpu_to_be16(__be16_to_cpu(ddf->virt->populated_vdes)+1);
2195
2196 /* Now create a new vd_config */
3d2c4fc7
DW
2197 if (posix_memalign((void**)&vcl, 512,
2198 (offsetof(struct vcl, conf) + ddf->conf_rec_len * 512)) != 0) {
e7b84f9d 2199 pr_err("%s could not allocate vd_config\n", __func__);
3d2c4fc7
DW
2200 return 0;
2201 }
8c3b8c2c 2202 vcl->lba_offset = (__u64*) &vcl->conf.phys_refnum[ddf->mppe];
59e36268
NB
2203 vcl->vcnum = venum;
2204 vcl->block_sizes = NULL; /* FIXME not for CONCAT */
8ec5d685 2205 vcl->other_bvds = NULL;
5f8097be
NB
2206
2207 vc = &vcl->conf;
2208
2209 vc->magic = DDF_VD_CONF_MAGIC;
2210 memcpy(vc->guid, ve->guid, DDF_GUID_LEN);
2211 vc->timestamp = __cpu_to_be32(time(0)-DECADE);
2212 vc->seqnum = __cpu_to_be32(1);
2213 memset(vc->pad0, 0xff, 24);
2214 vc->prim_elmnt_count = __cpu_to_be16(info->raid_disks);
2215 vc->chunk_shift = chunk_to_shift(info->chunk_size);
2216 vc->prl = level_to_prl(info->level);
2217 vc->rlq = layout_to_rlq(info->level, info->layout, info->raid_disks);
2218 vc->sec_elmnt_count = 1;
2219 vc->sec_elmnt_seq = 0;
2220 vc->srl = 0;
2221 vc->blocks = __cpu_to_be64(info->size * 2);
2222 vc->array_blocks = __cpu_to_be64(
2223 calc_array_size(info->level, info->raid_disks, info->layout,
2224 info->chunk_size, info->size*2));
2225 memset(vc->pad1, 0xff, 8);
2226 vc->spare_refs[0] = 0xffffffff;
2227 vc->spare_refs[1] = 0xffffffff;
2228 vc->spare_refs[2] = 0xffffffff;
2229 vc->spare_refs[3] = 0xffffffff;
2230 vc->spare_refs[4] = 0xffffffff;
2231 vc->spare_refs[5] = 0xffffffff;
2232 vc->spare_refs[6] = 0xffffffff;
2233 vc->spare_refs[7] = 0xffffffff;
2234 memset(vc->cache_pol, 0, 8);
2235 vc->bg_rate = 0x80;
2236 memset(vc->pad2, 0xff, 3);
2237 memset(vc->pad3, 0xff, 52);
2238 memset(vc->pad4, 0xff, 192);
2239 memset(vc->v0, 0xff, 32);
2240 memset(vc->v1, 0xff, 32);
2241 memset(vc->v2, 0xff, 16);
2242 memset(vc->v3, 0xff, 16);
2243 memset(vc->vendor, 0xff, 32);
598f0d58 2244
8c3b8c2c 2245 memset(vc->phys_refnum, 0xff, 4*ddf->mppe);
e5a2a3cf 2246 memset(vc->phys_refnum+ddf->mppe, 0x00, 8*ddf->mppe);
5f8097be
NB
2247
2248 vcl->next = ddf->conflist;
2249 ddf->conflist = vcl;
d2ca6449 2250 ddf->currentconf = vcl;
7d5a7ff3 2251 ddf_set_updates_pending(ddf);
5f8097be
NB
2252 return 1;
2253}
2254
0e600426 2255#ifndef MDASSEMBLE
5f8097be
NB
2256static void add_to_super_ddf_bvd(struct supertype *st,
2257 mdu_disk_info_t *dk, int fd, char *devname)
2258{
2259 /* fd and devname identify a device with-in the ddf container (st).
2260 * dk identifies a location in the new BVD.
2261 * We need to find suitable free space in that device and update
2262 * the phys_refnum and lba_offset for the newly created vd_config.
2263 * We might also want to update the type in the phys_disk
5575e7d9 2264 * section.
8592f29d
N
2265 *
2266 * Alternately: fd == -1 and we have already chosen which device to
2267 * use and recorded in dlist->raid_disk;
5f8097be
NB
2268 */
2269 struct dl *dl;
2270 struct ddf_super *ddf = st->sb;
2271 struct vd_config *vc;
2272 __u64 *lba_offset;
f21e18ca
N
2273 unsigned int working;
2274 unsigned int i;
59e36268
NB
2275 unsigned long long blocks, pos, esize;
2276 struct extent *ex;
5f8097be 2277
8592f29d
N
2278 if (fd == -1) {
2279 for (dl = ddf->dlist; dl ; dl = dl->next)
2280 if (dl->raiddisk == dk->raid_disk)
2281 break;
2282 } else {
2283 for (dl = ddf->dlist; dl ; dl = dl->next)
2284 if (dl->major == dk->major &&
2285 dl->minor == dk->minor)
2286 break;
2287 }
5f8097be
NB
2288 if (!dl || ! (dk->state & (1<<MD_DISK_SYNC)))
2289 return;
2290
d2ca6449
NB
2291 vc = &ddf->currentconf->conf;
2292 lba_offset = ddf->currentconf->lba_offset;
59e36268
NB
2293
2294 ex = get_extents(ddf, dl);
2295 if (!ex)
2296 return;
2297
2298 i = 0; pos = 0;
2299 blocks = __be64_to_cpu(vc->blocks);
d2ca6449
NB
2300 if (ddf->currentconf->block_sizes)
2301 blocks = ddf->currentconf->block_sizes[dk->raid_disk];
59e36268
NB
2302
2303 do {
2304 esize = ex[i].start - pos;
2305 if (esize >= blocks)
2306 break;
2307 pos = ex[i].start + ex[i].size;
2308 i++;
2309 } while (ex[i-1].size);
2310
2311 free(ex);
2312 if (esize < blocks)
2313 return;
2314
d2ca6449 2315 ddf->currentdev = dk->raid_disk;
5f8097be 2316 vc->phys_refnum[dk->raid_disk] = dl->disk.refnum;
59e36268 2317 lba_offset[dk->raid_disk] = __cpu_to_be64(pos);
5f8097be 2318
f21e18ca 2319 for (i = 0; i < ddf->max_part ; i++)
5575e7d9
NB
2320 if (dl->vlist[i] == NULL)
2321 break;
2322 if (i == ddf->max_part)
2323 return;
d2ca6449 2324 dl->vlist[i] = ddf->currentconf;
5f8097be 2325
8592f29d
N
2326 if (fd >= 0)
2327 dl->fd = fd;
2328 if (devname)
2329 dl->devname = devname;
7a7cc504
NB
2330
2331 /* Check how many working raid_disks, and if we can mark
2332 * array as optimal yet
2333 */
2334 working = 0;
5575e7d9 2335
f21e18ca 2336 for (i = 0; i < __be16_to_cpu(vc->prim_elmnt_count); i++)
7a7cc504
NB
2337 if (vc->phys_refnum[i] != 0xffffffff)
2338 working++;
59e36268 2339
5575e7d9 2340 /* Find which virtual_entry */
d2ca6449 2341 i = ddf->currentconf->vcnum;
7a7cc504 2342 if (working == __be16_to_cpu(vc->prim_elmnt_count))
5575e7d9
NB
2343 ddf->virt->entries[i].state =
2344 (ddf->virt->entries[i].state & ~DDF_state_mask)
7a7cc504
NB
2345 | DDF_state_optimal;
2346
2347 if (vc->prl == DDF_RAID6 &&
2348 working+1 == __be16_to_cpu(vc->prim_elmnt_count))
5575e7d9
NB
2349 ddf->virt->entries[i].state =
2350 (ddf->virt->entries[i].state & ~DDF_state_mask)
7a7cc504 2351 | DDF_state_part_optimal;
5575e7d9
NB
2352
2353 ddf->phys->entries[dl->pdnum].type &= ~__cpu_to_be16(DDF_Global_Spare);
2354 ddf->phys->entries[dl->pdnum].type |= __cpu_to_be16(DDF_Active_in_VD);
7d5a7ff3 2355 ddf_set_updates_pending(ddf);
5f8097be
NB
2356}
2357
a322f70c
DW
2358/* add a device to a container, either while creating it or while
2359 * expanding a pre-existing container
2360 */
f20c3968 2361static int add_to_super_ddf(struct supertype *st,
72ca9bcf
N
2362 mdu_disk_info_t *dk, int fd, char *devname,
2363 unsigned long long data_offset)
a322f70c
DW
2364{
2365 struct ddf_super *ddf = st->sb;
2366 struct dl *dd;
2367 time_t now;
2368 struct tm *tm;
2369 unsigned long long size;
2370 struct phys_disk_entry *pde;
f21e18ca 2371 unsigned int n, i;
a322f70c 2372 struct stat stb;
90fa1a29 2373 __u32 *tptr;
a322f70c 2374
78e44928
NB
2375 if (ddf->currentconf) {
2376 add_to_super_ddf_bvd(st, dk, fd, devname);
f20c3968 2377 return 0;
78e44928
NB
2378 }
2379
a322f70c
DW
2380 /* This is device numbered dk->number. We need to create
2381 * a phys_disk entry and a more detailed disk_data entry.
2382 */
2383 fstat(fd, &stb);
3d2c4fc7
DW
2384 if (posix_memalign((void**)&dd, 512,
2385 sizeof(*dd) + sizeof(dd->vlist[0]) * ddf->max_part) != 0) {
e7b84f9d
N
2386 pr_err("%s could allocate buffer for new disk, aborting\n",
2387 __func__);
f20c3968 2388 return 1;
3d2c4fc7 2389 }
a322f70c
DW
2390 dd->major = major(stb.st_rdev);
2391 dd->minor = minor(stb.st_rdev);
2392 dd->devname = devname;
a322f70c 2393 dd->fd = fd;
b2280677 2394 dd->spare = NULL;
a322f70c
DW
2395
2396 dd->disk.magic = DDF_PHYS_DATA_MAGIC;
2397 now = time(0);
2398 tm = localtime(&now);
2399 sprintf(dd->disk.guid, "%8s%04d%02d%02d",
2400 T10, tm->tm_year+1900, tm->tm_mon+1, tm->tm_mday);
90fa1a29
JS
2401 tptr = (__u32 *)(dd->disk.guid + 16);
2402 *tptr++ = random32();
2403 *tptr = random32();
a322f70c 2404
59e36268
NB
2405 do {
2406 /* Cannot be bothered finding a CRC of some irrelevant details*/
bfb7ea78 2407 dd->disk.refnum = random32();
f21e18ca
N
2408 for (i = __be16_to_cpu(ddf->active->max_pd_entries);
2409 i > 0; i--)
2410 if (ddf->phys->entries[i-1].refnum == dd->disk.refnum)
59e36268 2411 break;
f21e18ca 2412 } while (i > 0);
59e36268 2413
a322f70c
DW
2414 dd->disk.forced_ref = 1;
2415 dd->disk.forced_guid = 1;
2416 memset(dd->disk.vendor, ' ', 32);
2417 memcpy(dd->disk.vendor, "Linux", 5);
2418 memset(dd->disk.pad, 0xff, 442);
b2280677 2419 for (i = 0; i < ddf->max_part ; i++)
a322f70c
DW
2420 dd->vlist[i] = NULL;
2421
2422 n = __be16_to_cpu(ddf->phys->used_pdes);
2423 pde = &ddf->phys->entries[n];
5575e7d9
NB
2424 dd->pdnum = n;
2425
2cc2983d
N
2426 if (st->update_tail) {
2427 int len = (sizeof(struct phys_disk) +
2428 sizeof(struct phys_disk_entry));
2429 struct phys_disk *pd;
2430
503975b9 2431 pd = xmalloc(len);
2cc2983d
N
2432 pd->magic = DDF_PHYS_RECORDS_MAGIC;
2433 pd->used_pdes = __cpu_to_be16(n);
2434 pde = &pd->entries[0];
2435 dd->mdupdate = pd;
2436 } else {
2437 n++;
2438 ddf->phys->used_pdes = __cpu_to_be16(n);
2439 }
a322f70c
DW
2440
2441 memcpy(pde->guid, dd->disk.guid, DDF_GUID_LEN);
2442 pde->refnum = dd->disk.refnum;
5575e7d9 2443 pde->type = __cpu_to_be16(DDF_Forced_PD_GUID | DDF_Global_Spare);
a322f70c
DW
2444 pde->state = __cpu_to_be16(DDF_Online);
2445 get_dev_size(fd, NULL, &size);
2446 /* We are required to reserve 32Meg, and record the size in sectors */
2447 pde->config_size = __cpu_to_be64( (size - 32*1024*1024) / 512);
2448 sprintf(pde->path, "%17.17s","Information: nil") ;
2449 memset(pde->pad, 0xff, 6);
2450
d2ca6449 2451 dd->size = size >> 9;
2cc2983d
N
2452 if (st->update_tail) {
2453 dd->next = ddf->add_list;
2454 ddf->add_list = dd;
2455 } else {
2456 dd->next = ddf->dlist;
2457 ddf->dlist = dd;
7d5a7ff3 2458 ddf_set_updates_pending(ddf);
2cc2983d 2459 }
f20c3968
DW
2460
2461 return 0;
a322f70c
DW
2462}
2463
4dd968cc
N
2464static int remove_from_super_ddf(struct supertype *st, mdu_disk_info_t *dk)
2465{
2466 struct ddf_super *ddf = st->sb;
2467 struct dl *dl;
2468
2469 /* mdmon has noticed that this disk (dk->major/dk->minor) has
2470 * disappeared from the container.
2471 * We need to arrange that it disappears from the metadata and
2472 * internal data structures too.
2473 * Most of the work is done by ddf_process_update which edits
2474 * the metadata and closes the file handle and attaches the memory
2475 * where free_updates will free it.
2476 */
2477 for (dl = ddf->dlist; dl ; dl = dl->next)
2478 if (dl->major == dk->major &&
2479 dl->minor == dk->minor)
2480 break;
2481 if (!dl)
2482 return -1;
2483
2484 if (st->update_tail) {
2485 int len = (sizeof(struct phys_disk) +
2486 sizeof(struct phys_disk_entry));
2487 struct phys_disk *pd;
2488
503975b9 2489 pd = xmalloc(len);
4dd968cc
N
2490 pd->magic = DDF_PHYS_RECORDS_MAGIC;
2491 pd->used_pdes = __cpu_to_be16(dl->pdnum);
2492 pd->entries[0].state = __cpu_to_be16(DDF_Missing);
2493 append_metadata_update(st, pd, len);
2494 }
2495 return 0;
2496}
2497
a322f70c
DW
2498/*
2499 * This is the write_init_super method for a ddf container. It is
2500 * called when creating a container or adding another device to a
2501 * container.
2502 */
42d5dfd9 2503#define NULL_CONF_SZ 4096
18a2f463 2504
e3c2a365 2505static unsigned int get_pd_index_from_refnum(const struct vcl *vc,
2506 __u32 refnum, unsigned int nmax,
2507 const struct vd_config **bvd,
2508 unsigned int *idx);
2509
7f798aca 2510static int __write_ddf_structure(struct dl *d, struct ddf_super *ddf, __u8 type,
2511 char *null_aligned)
a322f70c 2512{
7f798aca 2513 unsigned long long sector;
2514 struct ddf_header *header;
2515 int fd, i, n_config, conf_size;
2516
2517 fd = d->fd;
2518
2519 switch (type) {
2520 case DDF_HEADER_PRIMARY:
2521 header = &ddf->primary;
2522 sector = __be64_to_cpu(header->primary_lba);
2523 break;
2524 case DDF_HEADER_SECONDARY:
2525 header = &ddf->secondary;
2526 sector = __be64_to_cpu(header->secondary_lba);
2527 break;
2528 default:
2529 return 0;
2530 }
2531
2532 header->type = type;
2533 header->openflag = 0;
2534 header->crc = calc_crc(header, 512);
2535
2536 lseek64(fd, sector<<9, 0);
2537 if (write(fd, header, 512) < 0)
2538 return 0;
2539
2540 ddf->controller.crc = calc_crc(&ddf->controller, 512);
2541 if (write(fd, &ddf->controller, 512) < 0)
2542 return 0;
a322f70c 2543
7f798aca 2544 ddf->phys->crc = calc_crc(ddf->phys, ddf->pdsize);
2545 if (write(fd, ddf->phys, ddf->pdsize) < 0)
2546 return 0;
2547 ddf->virt->crc = calc_crc(ddf->virt, ddf->vdsize);
2548 if (write(fd, ddf->virt, ddf->vdsize) < 0)
2549 return 0;
2550
2551 /* Now write lots of config records. */
2552 n_config = ddf->max_part;
2553 conf_size = ddf->conf_rec_len * 512;
2554 for (i = 0 ; i <= n_config ; i++) {
e3c2a365 2555 struct vcl *c;
2556 struct vd_config *vdc = NULL;
2557 if (i == n_config) {
7f798aca 2558 c = (struct vcl *)d->spare;
e3c2a365 2559 if (c)
2560 vdc = &c->conf;
2561 } else {
2562 unsigned int dummy;
2563 c = d->vlist[i];
2564 if (c)
2565 get_pd_index_from_refnum(
2566 c, d->disk.refnum,
2567 ddf->mppe,
2568 (const struct vd_config **)&vdc,
2569 &dummy);
2570 }
7f798aca 2571 if (c) {
dacf3dc5 2572 vdc->seqnum = header->seq;
e3c2a365 2573 vdc->crc = calc_crc(vdc, conf_size);
2574 if (write(fd, vdc, conf_size) < 0)
7f798aca 2575 break;
2576 } else {
2577 unsigned int togo = conf_size;
2578 while (togo > NULL_CONF_SZ) {
2579 if (write(fd, null_aligned, NULL_CONF_SZ) < 0)
2580 break;
2581 togo -= NULL_CONF_SZ;
2582 }
2583 if (write(fd, null_aligned, togo) < 0)
2584 break;
2585 }
2586 }
2587 if (i <= n_config)
2588 return 0;
2589
2590 d->disk.crc = calc_crc(&d->disk, 512);
2591 if (write(fd, &d->disk, 512) < 0)
2592 return 0;
2593
2594 return 1;
2595}
2596
2597static int __write_init_super_ddf(struct supertype *st)
2598{
a322f70c 2599 struct ddf_super *ddf = st->sb;
a322f70c 2600 struct dl *d;
175593bf
DW
2601 int attempts = 0;
2602 int successes = 0;
7f798aca 2603 unsigned long long size;
42d5dfd9 2604 char *null_aligned;
0175cbf6 2605 __u32 seq;
42d5dfd9 2606
7d5a7ff3 2607 pr_state(ddf, __func__);
42d5dfd9
JS
2608 if (posix_memalign((void**)&null_aligned, 4096, NULL_CONF_SZ) != 0) {
2609 return -ENOMEM;
2610 }
2611 memset(null_aligned, 0xff, NULL_CONF_SZ);
a322f70c 2612
dc9e279c 2613 seq = ddf->active->seq + 1;
0175cbf6 2614
175593bf
DW
2615 /* try to write updated metadata,
2616 * if we catch a failure move on to the next disk
2617 */
a322f70c
DW
2618 for (d = ddf->dlist; d; d=d->next) {
2619 int fd = d->fd;
2620
2621 if (fd < 0)
2622 continue;
2623
175593bf 2624 attempts++;
a322f70c
DW
2625 /* We need to fill in the primary, (secondary) and workspace
2626 * lba's in the headers, set their checksums,
2627 * Also checksum phys, virt....
2628 *
2629 * Then write everything out, finally the anchor is written.
2630 */
2631 get_dev_size(fd, NULL, &size);
2632 size /= 512;
097bcf00 2633 if (d->workspace_lba != 0)
2634 ddf->anchor.workspace_lba = d->workspace_lba;
2635 else
2636 ddf->anchor.workspace_lba =
2637 __cpu_to_be64(size - 32*1024*2);
2638 if (d->primary_lba != 0)
2639 ddf->anchor.primary_lba = d->primary_lba;
2640 else
2641 ddf->anchor.primary_lba =
2642 __cpu_to_be64(size - 16*1024*2);
2643 if (d->secondary_lba != 0)
2644 ddf->anchor.secondary_lba = d->secondary_lba;
2645 else
2646 ddf->anchor.secondary_lba =
2647 __cpu_to_be64(size - 32*1024*2);
0175cbf6 2648 ddf->anchor.seq = seq;
a322f70c
DW
2649 memcpy(&ddf->primary, &ddf->anchor, 512);
2650 memcpy(&ddf->secondary, &ddf->anchor, 512);
2651
2652 ddf->anchor.openflag = 0xFF; /* 'open' means nothing */
2653 ddf->anchor.seq = 0xFFFFFFFF; /* no sequencing in anchor */
2654 ddf->anchor.crc = calc_crc(&ddf->anchor, 512);
2655
7f798aca 2656 if (!__write_ddf_structure(d, ddf, DDF_HEADER_PRIMARY,
2657 null_aligned))
175593bf 2658 continue;
a322f70c 2659
7f798aca 2660 if (!__write_ddf_structure(d, ddf, DDF_HEADER_SECONDARY,
2661 null_aligned))
175593bf 2662 continue;
a322f70c 2663
a322f70c 2664 lseek64(fd, (size-1)*512, SEEK_SET);
175593bf
DW
2665 if (write(fd, &ddf->anchor, 512) < 0)
2666 continue;
2667 successes++;
2668 }
42d5dfd9 2669 free(null_aligned);
175593bf 2670
175593bf 2671 return attempts != successes;
a322f70c 2672}
7a7cc504
NB
2673
2674static int write_init_super_ddf(struct supertype *st)
2675{
9b1fb677
DW
2676 struct ddf_super *ddf = st->sb;
2677 struct vcl *currentconf = ddf->currentconf;
2678
2679 /* we are done with currentconf reset it to point st at the container */
2680 ddf->currentconf = NULL;
edd8d13c
NB
2681
2682 if (st->update_tail) {
2683 /* queue the virtual_disk and vd_config as metadata updates */
2684 struct virtual_disk *vd;
2685 struct vd_config *vc;
edd8d13c
NB
2686 int len;
2687
9b1fb677 2688 if (!currentconf) {
2cc2983d
N
2689 int len = (sizeof(struct phys_disk) +
2690 sizeof(struct phys_disk_entry));
2691
2692 /* adding a disk to the container. */
2693 if (!ddf->add_list)
2694 return 0;
2695
2696 append_metadata_update(st, ddf->add_list->mdupdate, len);
2697 ddf->add_list->mdupdate = NULL;
2698 return 0;
2699 }
2700
2701 /* Newly created VD */
2702
edd8d13c
NB
2703 /* First the virtual disk. We have a slightly fake header */
2704 len = sizeof(struct virtual_disk) + sizeof(struct virtual_entry);
503975b9 2705 vd = xmalloc(len);
edd8d13c 2706 *vd = *ddf->virt;
9b1fb677
DW
2707 vd->entries[0] = ddf->virt->entries[currentconf->vcnum];
2708 vd->populated_vdes = __cpu_to_be16(currentconf->vcnum);
edd8d13c
NB
2709 append_metadata_update(st, vd, len);
2710
2711 /* Then the vd_config */
2712 len = ddf->conf_rec_len * 512;
503975b9 2713 vc = xmalloc(len);
9b1fb677 2714 memcpy(vc, &currentconf->conf, len);
edd8d13c
NB
2715 append_metadata_update(st, vc, len);
2716
2717 /* FIXME I need to close the fds! */
2718 return 0;
613b0d17 2719 } else {
d682f344
N
2720 struct dl *d;
2721 for (d = ddf->dlist; d; d=d->next)
ba728be7 2722 while (Kill(d->devname, NULL, 0, -1, 1) == 0);
1cc7f4fe 2723 return __write_init_super_ddf(st);
d682f344 2724 }
7a7cc504
NB
2725}
2726
a322f70c
DW
2727#endif
2728
387fcd59
N
2729static __u64 avail_size_ddf(struct supertype *st, __u64 devsize,
2730 unsigned long long data_offset)
a322f70c
DW
2731{
2732 /* We must reserve the last 32Meg */
2733 if (devsize <= 32*1024*2)
2734 return 0;
2735 return devsize - 32*1024*2;
2736}
2737
2738#ifndef MDASSEMBLE
8592f29d
N
2739
2740static int reserve_space(struct supertype *st, int raiddisks,
2741 unsigned long long size, int chunk,
2742 unsigned long long *freesize)
2743{
2744 /* Find 'raiddisks' spare extents at least 'size' big (but
2745 * only caring about multiples of 'chunk') and remember
2746 * them.
2747 * If the cannot be found, fail.
2748 */
2749 struct dl *dl;
2750 struct ddf_super *ddf = st->sb;
2751 int cnt = 0;
2752
2753 for (dl = ddf->dlist; dl ; dl=dl->next) {
613b0d17 2754 dl->raiddisk = -1;
8592f29d
N
2755 dl->esize = 0;
2756 }
2757 /* Now find largest extent on each device */
2758 for (dl = ddf->dlist ; dl ; dl=dl->next) {
2759 struct extent *e = get_extents(ddf, dl);
2760 unsigned long long pos = 0;
2761 int i = 0;
2762 int found = 0;
2763 unsigned long long minsize = size;
2764
2765 if (size == 0)
2766 minsize = chunk;
2767
2768 if (!e)
2769 continue;
2770 do {
2771 unsigned long long esize;
2772 esize = e[i].start - pos;
2773 if (esize >= minsize) {
2774 found = 1;
2775 minsize = esize;
2776 }
2777 pos = e[i].start + e[i].size;
2778 i++;
2779 } while (e[i-1].size);
2780 if (found) {
2781 cnt++;
2782 dl->esize = minsize;
2783 }
2784 free(e);
2785 }
2786 if (cnt < raiddisks) {
e7b84f9d 2787 pr_err("not enough devices with space to create array.\n");
8592f29d
N
2788 return 0; /* No enough free spaces large enough */
2789 }
2790 if (size == 0) {
2791 /* choose the largest size of which there are at least 'raiddisk' */
2792 for (dl = ddf->dlist ; dl ; dl=dl->next) {
2793 struct dl *dl2;
2794 if (dl->esize <= size)
2795 continue;
2796 /* This is bigger than 'size', see if there are enough */
2797 cnt = 0;
7b80ad6a 2798 for (dl2 = ddf->dlist; dl2 ; dl2=dl2->next)
8592f29d
N
2799 if (dl2->esize >= dl->esize)
2800 cnt++;
2801 if (cnt >= raiddisks)
2802 size = dl->esize;
2803 }
2804 if (chunk) {
2805 size = size / chunk;
2806 size *= chunk;
2807 }
2808 *freesize = size;
2809 if (size < 32) {
e7b84f9d 2810 pr_err("not enough spare devices to create array.\n");
8592f29d
N
2811 return 0;
2812 }
2813 }
2814 /* We have a 'size' of which there are enough spaces.
2815 * We simply do a first-fit */
2816 cnt = 0;
2817 for (dl = ddf->dlist ; dl && cnt < raiddisks ; dl=dl->next) {
2818 if (dl->esize < size)
2819 continue;
613b0d17 2820
8592f29d
N
2821 dl->raiddisk = cnt;
2822 cnt++;
2823 }
2824 return 1;
2825}
2826
2c514b71
NB
2827static int
2828validate_geometry_ddf_container(struct supertype *st,
2829 int level, int layout, int raiddisks,
2830 int chunk, unsigned long long size,
af4348dd 2831 unsigned long long data_offset,
2c514b71
NB
2832 char *dev, unsigned long long *freesize,
2833 int verbose);
78e44928
NB
2834
2835static int validate_geometry_ddf_bvd(struct supertype *st,
2836 int level, int layout, int raiddisks,
c21e737b 2837 int *chunk, unsigned long long size,
af4348dd 2838 unsigned long long data_offset,
2c514b71
NB
2839 char *dev, unsigned long long *freesize,
2840 int verbose);
78e44928
NB
2841
2842static int validate_geometry_ddf(struct supertype *st,
2c514b71 2843 int level, int layout, int raiddisks,
c21e737b 2844 int *chunk, unsigned long long size,
af4348dd 2845 unsigned long long data_offset,
2c514b71
NB
2846 char *dev, unsigned long long *freesize,
2847 int verbose)
a322f70c
DW
2848{
2849 int fd;
2850 struct mdinfo *sra;
2851 int cfd;
2852
2853 /* ddf potentially supports lots of things, but it depends on
2854 * what devices are offered (and maybe kernel version?)
2855 * If given unused devices, we will make a container.
2856 * If given devices in a container, we will make a BVD.
2857 * If given BVDs, we make an SVD, changing all the GUIDs in the process.
2858 */
2859
bb7295f1
N
2860 if (chunk && *chunk == UnSet)
2861 *chunk = DEFAULT_CHUNK;
2862
542ef4ec 2863 if (level == -1000000) level = LEVEL_CONTAINER;
a322f70c 2864 if (level == LEVEL_CONTAINER) {
78e44928
NB
2865 /* Must be a fresh device to add to a container */
2866 return validate_geometry_ddf_container(st, level, layout,
c21e737b 2867 raiddisks, chunk?*chunk:0,
af4348dd
N
2868 size, data_offset, dev,
2869 freesize,
2c514b71 2870 verbose);
5f8097be
NB
2871 }
2872
78e44928
NB
2873 if (!dev) {
2874 /* Initial sanity check. Exclude illegal levels. */
2875 int i;
2876 for (i=0; ddf_level_num[i].num1 != MAXINT; i++)
2877 if (ddf_level_num[i].num2 == level)
2878 break;
b42f577a
N
2879 if (ddf_level_num[i].num1 == MAXINT) {
2880 if (verbose)
e7b84f9d 2881 pr_err("DDF does not support level %d arrays\n",
613b0d17 2882 level);
78e44928 2883 return 0;
b42f577a 2884 }
78e44928 2885 /* Should check layout? etc */
8592f29d
N
2886
2887 if (st->sb && freesize) {
2888 /* --create was given a container to create in.
2889 * So we need to check that there are enough
2890 * free spaces and return the amount of space.
2891 * We may as well remember which drives were
2892 * chosen so that add_to_super/getinfo_super
2893 * can return them.
2894 */
c21e737b 2895 return reserve_space(st, raiddisks, size, chunk?*chunk:0, freesize);
8592f29d 2896 }
a322f70c 2897 return 1;
78e44928 2898 }
a322f70c 2899
8592f29d
N
2900 if (st->sb) {
2901 /* A container has already been opened, so we are
2902 * creating in there. Maybe a BVD, maybe an SVD.
2903 * Should make a distinction one day.
2904 */
2905 return validate_geometry_ddf_bvd(st, level, layout, raiddisks,
af4348dd
N
2906 chunk, size, data_offset, dev,
2907 freesize,
8592f29d
N
2908 verbose);
2909 }
78e44928
NB
2910 /* This is the first device for the array.
2911 * If it is a container, we read it in and do automagic allocations,
2912 * no other devices should be given.
2913 * Otherwise it must be a member device of a container, and we
2914 * do manual allocation.
2915 * Later we should check for a BVD and make an SVD.
a322f70c 2916 */
a322f70c
DW
2917 fd = open(dev, O_RDONLY|O_EXCL, 0);
2918 if (fd >= 0) {
4dd2df09 2919 sra = sysfs_read(fd, NULL, GET_VERSION);
a322f70c
DW
2920 close(fd);
2921 if (sra && sra->array.major_version == -1 &&
78e44928
NB
2922 strcmp(sra->text_version, "ddf") == 0) {
2923
2924 /* load super */
2925 /* find space for 'n' devices. */
2926 /* remember the devices */
2927 /* Somehow return the fact that we have enough */
a322f70c
DW
2928 }
2929
2c514b71 2930 if (verbose)
e7b84f9d
N
2931 pr_err("ddf: Cannot create this array "
2932 "on device %s - a container is required.\n",
2933 dev);
a322f70c
DW
2934 return 0;
2935 }
2936 if (errno != EBUSY || (fd = open(dev, O_RDONLY, 0)) < 0) {
2c514b71 2937 if (verbose)
e7b84f9d 2938 pr_err("ddf: Cannot open %s: %s\n",
613b0d17 2939 dev, strerror(errno));
a322f70c
DW
2940 return 0;
2941 }
2942 /* Well, it is in use by someone, maybe a 'ddf' container. */
2943 cfd = open_container(fd);
2944 if (cfd < 0) {
2945 close(fd);
2c514b71 2946 if (verbose)
e7b84f9d 2947 pr_err("ddf: Cannot use %s: %s\n",
613b0d17 2948 dev, strerror(EBUSY));
a322f70c
DW
2949 return 0;
2950 }
4dd2df09 2951 sra = sysfs_read(cfd, NULL, GET_VERSION);
a322f70c
DW
2952 close(fd);
2953 if (sra && sra->array.major_version == -1 &&
2954 strcmp(sra->text_version, "ddf") == 0) {
2955 /* This is a member of a ddf container. Load the container
2956 * and try to create a bvd
2957 */
2958 struct ddf_super *ddf;
e1902a7b 2959 if (load_super_ddf_all(st, cfd, (void **)&ddf, NULL) == 0) {
5f8097be 2960 st->sb = ddf;
4dd2df09 2961 strcpy(st->container_devnm, fd2devnm(cfd));
a322f70c 2962 close(cfd);
78e44928 2963 return validate_geometry_ddf_bvd(st, level, layout,
a322f70c 2964 raiddisks, chunk, size,
af4348dd 2965 data_offset,
2c514b71
NB
2966 dev, freesize,
2967 verbose);
a322f70c
DW
2968 }
2969 close(cfd);
c42ec1ed
DW
2970 } else /* device may belong to a different container */
2971 return 0;
2972
a322f70c
DW
2973 return 1;
2974}
2975
2c514b71
NB
2976static int
2977validate_geometry_ddf_container(struct supertype *st,
2978 int level, int layout, int raiddisks,
2979 int chunk, unsigned long long size,
af4348dd 2980 unsigned long long data_offset,
2c514b71
NB
2981 char *dev, unsigned long long *freesize,
2982 int verbose)
a322f70c
DW
2983{
2984 int fd;
2985 unsigned long long ldsize;
2986
2987 if (level != LEVEL_CONTAINER)
2988 return 0;
2989 if (!dev)
2990 return 1;
2991
2992 fd = open(dev, O_RDONLY|O_EXCL, 0);
2993 if (fd < 0) {
2c514b71 2994 if (verbose)
e7b84f9d 2995 pr_err("ddf: Cannot open %s: %s\n",
613b0d17 2996 dev, strerror(errno));
a322f70c
DW
2997 return 0;
2998 }
2999 if (!get_dev_size(fd, dev, &ldsize)) {
3000 close(fd);
3001 return 0;
3002 }
3003 close(fd);
3004
387fcd59 3005 *freesize = avail_size_ddf(st, ldsize >> 9, INVALID_SECTORS);
ea17e7aa
N
3006 if (*freesize == 0)
3007 return 0;
a322f70c
DW
3008
3009 return 1;
3010}
3011
78e44928
NB
3012static int validate_geometry_ddf_bvd(struct supertype *st,
3013 int level, int layout, int raiddisks,
c21e737b 3014 int *chunk, unsigned long long size,
af4348dd 3015 unsigned long long data_offset,
2c514b71
NB
3016 char *dev, unsigned long long *freesize,
3017 int verbose)
a322f70c
DW
3018{
3019 struct stat stb;
3020 struct ddf_super *ddf = st->sb;
3021 struct dl *dl;
5f8097be
NB
3022 unsigned long long pos = 0;
3023 unsigned long long maxsize;
3024 struct extent *e;
3025 int i;
a322f70c 3026 /* ddf/bvd supports lots of things, but not containers */
b42f577a
N
3027 if (level == LEVEL_CONTAINER) {
3028 if (verbose)
e7b84f9d 3029 pr_err("DDF cannot create a container within an container\n");
a322f70c 3030 return 0;
b42f577a 3031 }
a322f70c
DW
3032 /* We must have the container info already read in. */
3033 if (!ddf)
3034 return 0;
3035
5f8097be
NB
3036 if (!dev) {
3037 /* General test: make sure there is space for
3038 * 'raiddisks' device extents of size 'size'.
3039 */
3040 unsigned long long minsize = size;
3041 int dcnt = 0;
3042 if (minsize == 0)
3043 minsize = 8;
3044 for (dl = ddf->dlist; dl ; dl = dl->next)
3045 {
3046 int found = 0;
7e1432fb 3047 pos = 0;
5f8097be
NB
3048
3049 i = 0;
3050 e = get_extents(ddf, dl);
3051 if (!e) continue;
3052 do {
3053 unsigned long long esize;
3054 esize = e[i].start - pos;
3055 if (esize >= minsize)
3056 found = 1;
3057 pos = e[i].start + e[i].size;
3058 i++;
3059 } while (e[i-1].size);
3060 if (found)
3061 dcnt++;
3062 free(e);
3063 }
3064 if (dcnt < raiddisks) {
2c514b71 3065 if (verbose)
e7b84f9d
N
3066 pr_err("ddf: Not enough devices with "
3067 "space for this array (%d < %d)\n",
3068 dcnt, raiddisks);
5f8097be
NB
3069 return 0;
3070 }
3071 return 1;
3072 }
a322f70c
DW
3073 /* This device must be a member of the set */
3074 if (stat(dev, &stb) < 0)
3075 return 0;
3076 if ((S_IFMT & stb.st_mode) != S_IFBLK)
3077 return 0;
3078 for (dl = ddf->dlist ; dl ; dl = dl->next) {
f21e18ca
N
3079 if (dl->major == (int)major(stb.st_rdev) &&
3080 dl->minor == (int)minor(stb.st_rdev))
a322f70c
DW
3081 break;
3082 }
5f8097be 3083 if (!dl) {
2c514b71 3084 if (verbose)
e7b84f9d 3085 pr_err("ddf: %s is not in the "
613b0d17
N
3086 "same DDF set\n",
3087 dev);
5f8097be
NB
3088 return 0;
3089 }
3090 e = get_extents(ddf, dl);
3091 maxsize = 0;
3092 i = 0;
3093 if (e) do {
613b0d17
N
3094 unsigned long long esize;
3095 esize = e[i].start - pos;
3096 if (esize >= maxsize)
3097 maxsize = esize;
3098 pos = e[i].start + e[i].size;
3099 i++;
3100 } while (e[i-1].size);
5f8097be 3101 *freesize = maxsize;
a322f70c
DW
3102 // FIXME here I am
3103
3104 return 1;
3105}
59e36268 3106
a322f70c 3107static int load_super_ddf_all(struct supertype *st, int fd,
e1902a7b 3108 void **sbp, char *devname)
a322f70c
DW
3109{
3110 struct mdinfo *sra;
3111 struct ddf_super *super;
3112 struct mdinfo *sd, *best = NULL;
3113 int bestseq = 0;
3114 int seq;
3115 char nm[20];
3116 int dfd;
3117
b526e52d 3118 sra = sysfs_read(fd, 0, GET_LEVEL|GET_VERSION|GET_DEVS|GET_STATE);
a322f70c
DW
3119 if (!sra)
3120 return 1;
3121 if (sra->array.major_version != -1 ||
3122 sra->array.minor_version != -2 ||
3123 strcmp(sra->text_version, "ddf") != 0)
3124 return 1;
3125
6416d527 3126 if (posix_memalign((void**)&super, 512, sizeof(*super)) != 0)
a322f70c 3127 return 1;
a2349791 3128 memset(super, 0, sizeof(*super));
a322f70c
DW
3129
3130 /* first, try each device, and choose the best ddf */
3131 for (sd = sra->devs ; sd ; sd = sd->next) {
3132 int rv;
3133 sprintf(nm, "%d:%d", sd->disk.major, sd->disk.minor);
7a7cc504
NB
3134 dfd = dev_open(nm, O_RDONLY);
3135 if (dfd < 0)
a322f70c
DW
3136 return 2;
3137 rv = load_ddf_headers(dfd, super, NULL);
7a7cc504 3138 close(dfd);
a322f70c
DW
3139 if (rv == 0) {
3140 seq = __be32_to_cpu(super->active->seq);
3141 if (super->active->openflag)
3142 seq--;
3143 if (!best || seq > bestseq) {
3144 bestseq = seq;
3145 best = sd;
3146 }
3147 }
3148 }
3149 if (!best)
3150 return 1;
3151 /* OK, load this ddf */
3152 sprintf(nm, "%d:%d", best->disk.major, best->disk.minor);
3153 dfd = dev_open(nm, O_RDONLY);
7a7cc504 3154 if (dfd < 0)
a322f70c
DW
3155 return 1;
3156 load_ddf_headers(dfd, super, NULL);
3157 load_ddf_global(dfd, super, NULL);
3158 close(dfd);
3159 /* Now we need the device-local bits */
3160 for (sd = sra->devs ; sd ; sd = sd->next) {
3d2c4fc7
DW
3161 int rv;
3162
a322f70c 3163 sprintf(nm, "%d:%d", sd->disk.major, sd->disk.minor);
e1902a7b 3164 dfd = dev_open(nm, O_RDWR);
7a7cc504 3165 if (dfd < 0)
a322f70c 3166 return 2;
3d2c4fc7
DW
3167 rv = load_ddf_headers(dfd, super, NULL);
3168 if (rv == 0)
e1902a7b 3169 rv = load_ddf_local(dfd, super, NULL, 1);
3d2c4fc7
DW
3170 if (rv)
3171 return 1;
a322f70c 3172 }
33414a01 3173
a322f70c
DW
3174 *sbp = super;
3175 if (st->ss == NULL) {
78e44928 3176 st->ss = &super_ddf;
a322f70c
DW
3177 st->minor_version = 0;
3178 st->max_devs = 512;
3179 }
4dd2df09 3180 strcpy(st->container_devnm, fd2devnm(fd));
a322f70c
DW
3181 return 0;
3182}
2b959fbf
N
3183
3184static int load_container_ddf(struct supertype *st, int fd,
3185 char *devname)
3186{
3187 return load_super_ddf_all(st, fd, &st->sb, devname);
3188}
3189
0e600426 3190#endif /* MDASSEMBLE */
a322f70c 3191
a5c7adb3 3192static int check_secondary(const struct vcl *vc)
3193{
3194 const struct vd_config *conf = &vc->conf;
3195 int i;
3196
3197 /* The only DDF secondary RAID level md can support is
3198 * RAID 10, if the stripe sizes and Basic volume sizes
3199 * are all equal.
3200 * Other configurations could in theory be supported by exposing
3201 * the BVDs to user space and using device mapper for the secondary
3202 * mapping. So far we don't support that.
3203 */
3204
3205 __u64 sec_elements[4] = {0, 0, 0, 0};
3206#define __set_sec_seen(n) (sec_elements[(n)>>6] |= (1<<((n)&63)))
3207#define __was_sec_seen(n) ((sec_elements[(n)>>6] & (1<<((n)&63))) != 0)
3208
3209 if (vc->other_bvds == NULL) {
3210 pr_err("No BVDs for secondary RAID found\n");
3211 return -1;
3212 }
3213 if (conf->prl != DDF_RAID1) {
3214 pr_err("Secondary RAID level only supported for mirrored BVD\n");
3215 return -1;
3216 }
3217 if (conf->srl != DDF_2STRIPED && conf->srl != DDF_2SPANNED) {
3218 pr_err("Secondary RAID level %d is unsupported\n",
3219 conf->srl);
3220 return -1;
3221 }
3222 __set_sec_seen(conf->sec_elmnt_seq);
3223 for (i = 0; i < conf->sec_elmnt_count-1; i++) {
3224 const struct vd_config *bvd = vc->other_bvds[i];
3225 if (bvd == NULL) {
e3c2a365 3226 pr_err("BVD %d is missing\n", i+1);
a5c7adb3 3227 return -1;
3228 }
3229 if (bvd->srl != conf->srl) {
3230 pr_err("Inconsistent secondary RAID level across BVDs\n");
3231 return -1;
3232 }
3233 if (bvd->prl != conf->prl) {
3234 pr_err("Different RAID levels for BVDs are unsupported\n");
3235 return -1;
3236 }
3237 if (bvd->prim_elmnt_count != conf->prim_elmnt_count) {
3238 pr_err("All BVDs must have the same number of primary elements\n");
3239 return -1;
3240 }
3241 if (bvd->chunk_shift != conf->chunk_shift) {
3242 pr_err("Different strip sizes for BVDs are unsupported\n");
3243 return -1;
3244 }
3245 if (bvd->array_blocks != conf->array_blocks) {
3246 pr_err("Different BVD sizes are unsupported\n");
3247 return -1;
3248 }
3249 __set_sec_seen(bvd->sec_elmnt_seq);
3250 }
3251 for (i = 0; i < conf->sec_elmnt_count; i++) {
3252 if (!__was_sec_seen(i)) {
3253 pr_err("BVD %d is missing\n", i);
3254 return -1;
3255 }
3256 }
3257 return 0;
3258}
3259
8a38db86 3260static unsigned int get_pd_index_from_refnum(const struct vcl *vc,
4e587018 3261 __u32 refnum, unsigned int nmax,
3262 const struct vd_config **bvd,
3263 unsigned int *idx)
8a38db86 3264{
4e587018 3265 unsigned int i, j, n, sec, cnt;
3266
3267 cnt = __be16_to_cpu(vc->conf.prim_elmnt_count);
3268 sec = (vc->conf.sec_elmnt_count == 1 ? 0 : vc->conf.sec_elmnt_seq);
3269
3270 for (i = 0, j = 0 ; i < nmax ; i++) {
3271 /* j counts valid entries for this BVD */
3272 if (vc->conf.phys_refnum[i] != 0xffffffff)
3273 j++;
3274 if (vc->conf.phys_refnum[i] == refnum) {
3275 *bvd = &vc->conf;
3276 *idx = i;
3277 return sec * cnt + j - 1;
3278 }
3279 }
3280 if (vc->other_bvds == NULL)
3281 goto bad;
3282
3283 for (n = 1; n < vc->conf.sec_elmnt_count; n++) {
3284 struct vd_config *vd = vc->other_bvds[n-1];
3285 if (vd == NULL)
3286 continue;
3287 sec = vd->sec_elmnt_seq;
3288 for (i = 0, j = 0 ; i < nmax ; i++) {
3289 if (vd->phys_refnum[i] != 0xffffffff)
3290 j++;
3291 if (vd->phys_refnum[i] == refnum) {
3292 *bvd = vd;
3293 *idx = i;
3294 return sec * cnt + j - 1;
3295 }
3296 }
3297 }
3298bad:
3299 *bvd = NULL;
d6e7b083 3300 return DDF_NOTFOUND;
8a38db86 3301}
3302
00bbdbda 3303static struct mdinfo *container_content_ddf(struct supertype *st, char *subarray)
598f0d58
NB
3304{
3305 /* Given a container loaded by load_super_ddf_all,
3306 * extract information about all the arrays into
3307 * an mdinfo tree.
3308 *
3309 * For each vcl in conflist: create an mdinfo, fill it in,
3310 * then look for matching devices (phys_refnum) in dlist
3311 * and create appropriate device mdinfo.
3312 */
3313 struct ddf_super *ddf = st->sb;
3314 struct mdinfo *rest = NULL;
3315 struct vcl *vc;
3316
3317 for (vc = ddf->conflist ; vc ; vc=vc->next)
3318 {
f21e18ca
N
3319 unsigned int i;
3320 unsigned int j;
598f0d58 3321 struct mdinfo *this;
00bbdbda 3322 char *ep;
90fa1a29 3323 __u32 *cptr;
8a38db86 3324 unsigned int pd;
00bbdbda
N
3325
3326 if (subarray &&
3327 (strtoul(subarray, &ep, 10) != vc->vcnum ||
3328 *ep != '\0'))
3329 continue;
3330
a5c7adb3 3331 if (vc->conf.sec_elmnt_count > 1) {
3332 if (check_secondary(vc) != 0)
3333 continue;
3334 }
3335
503975b9 3336 this = xcalloc(1, sizeof(*this));
598f0d58
NB
3337 this->next = rest;
3338 rest = this;
3339
4e587018 3340 if (vc->conf.sec_elmnt_count == 1) {
3341 this->array.level = map_num1(ddf_level_num,
3342 vc->conf.prl);
3343 this->array.raid_disks =
3344 __be16_to_cpu(vc->conf.prim_elmnt_count);
3345 this->array.layout =
3346 rlq_to_layout(vc->conf.rlq, vc->conf.prl,
3347 this->array.raid_disks);
3348 } else {
3349 /* The only supported layout is RAID 10.
3350 * Compatibility has been checked in check_secondary()
3351 * above.
3352 */
3353 this->array.level = 10;
3354 this->array.raid_disks =
3355 __be16_to_cpu(vc->conf.prim_elmnt_count)
3356 * vc->conf.sec_elmnt_count;
3357 this->array.layout = 0x100 |
3358 __be16_to_cpu(vc->conf.prim_elmnt_count);
3359 }
598f0d58 3360 this->array.md_minor = -1;
f35f2525
N
3361 this->array.major_version = -1;
3362 this->array.minor_version = -2;
90fa1a29
JS
3363 cptr = (__u32 *)(vc->conf.guid + 16);
3364 this->array.ctime = DECADE + __be32_to_cpu(*cptr);
598f0d58
NB
3365 this->array.utime = DECADE +
3366 __be32_to_cpu(vc->conf.timestamp);
3367 this->array.chunk_size = 512 << vc->conf.chunk_shift;
3368
59e36268 3369 i = vc->vcnum;
7a7cc504
NB
3370 if ((ddf->virt->entries[i].state & DDF_state_inconsistent) ||
3371 (ddf->virt->entries[i].init_state & DDF_initstate_mask) !=
ed9d66aa 3372 DDF_init_full) {
598f0d58 3373 this->array.state = 0;
ed9d66aa
NB
3374 this->resync_start = 0;
3375 } else {
598f0d58 3376 this->array.state = 1;
b7528a20 3377 this->resync_start = MaxSector;
ed9d66aa 3378 }
db42fa9b
N
3379 memcpy(this->name, ddf->virt->entries[i].name, 16);
3380 this->name[16]=0;
3381 for(j=0; j<16; j++)
3382 if (this->name[j] == ' ')
3383 this->name[j] = 0;
598f0d58
NB
3384
3385 memset(this->uuid, 0, sizeof(this->uuid));
3386 this->component_size = __be64_to_cpu(vc->conf.blocks);
3387 this->array.size = this->component_size / 2;
5f2aace8 3388 this->container_member = i;
598f0d58 3389
c5afc314
N
3390 ddf->currentconf = vc;
3391 uuid_from_super_ddf(st, this->uuid);
3392 ddf->currentconf = NULL;
3393
60f18132 3394 sprintf(this->text_version, "/%s/%d",
4dd2df09 3395 st->container_devnm, this->container_member);
60f18132 3396
8a38db86 3397 for (pd = 0; pd < __be16_to_cpu(ddf->phys->used_pdes); pd++) {
598f0d58
NB
3398 struct mdinfo *dev;
3399 struct dl *d;
4e587018 3400 const struct vd_config *bvd;
3401 unsigned int iphys;
3402 __u64 *lba_offset;
fa033bec 3403 int stt;
598f0d58 3404
8a38db86 3405 if (ddf->phys->entries[pd].refnum == 0xFFFFFFFF)
bc17324f 3406 continue;
0cf5ef67
N
3407
3408 stt = __be16_to_cpu(ddf->phys->entries[pd].state);
fa033bec
N
3409 if ((stt & (DDF_Online|DDF_Failed|DDF_Rebuilding))
3410 != DDF_Online)
3411 continue;
3412
8a38db86 3413 i = get_pd_index_from_refnum(
4e587018 3414 vc, ddf->phys->entries[pd].refnum,
3415 ddf->mppe, &bvd, &iphys);
d6e7b083 3416 if (i == DDF_NOTFOUND)
8a38db86 3417 continue;
3418
fa033bec 3419 this->array.working_disks++;
bc17324f 3420
0cf5ef67 3421 for (d = ddf->dlist; d ; d=d->next)
8a38db86 3422 if (d->disk.refnum ==
3423 ddf->phys->entries[pd].refnum)
0cf5ef67
N
3424 break;
3425 if (d == NULL)
3426 /* Haven't found that one yet, maybe there are others */
3427 continue;
3428
503975b9 3429 dev = xcalloc(1, sizeof(*dev));
598f0d58
NB
3430 dev->next = this->devs;
3431 this->devs = dev;
3432
3433 dev->disk.number = __be32_to_cpu(d->disk.refnum);
3434 dev->disk.major = d->major;
3435 dev->disk.minor = d->minor;
3436 dev->disk.raid_disk = i;
3437 dev->disk.state = (1<<MD_DISK_SYNC)|(1<<MD_DISK_ACTIVE);
d23534e4 3438 dev->recovery_start = MaxSector;
598f0d58 3439
120f7677 3440 dev->events = __be32_to_cpu(ddf->primary.seq);
4e587018 3441 lba_offset = (__u64 *)&bvd->phys_refnum[ddf->mppe];
3442 dev->data_offset = __be64_to_cpu(lba_offset[iphys]);
3443 dev->component_size = __be64_to_cpu(bvd->blocks);
598f0d58
NB
3444 if (d->devname)
3445 strcpy(dev->name, d->devname);
3446 }
3447 }
3448 return rest;
3449}
3450
955e9ea1 3451static int store_super_ddf(struct supertype *st, int fd)
a322f70c 3452{
955e9ea1 3453 struct ddf_super *ddf = st->sb;
a322f70c 3454 unsigned long long dsize;
6416d527 3455 void *buf;
3d2c4fc7 3456 int rc;
a322f70c 3457
955e9ea1
DW
3458 if (!ddf)
3459 return 1;
3460
3461 /* ->dlist and ->conflist will be set for updates, currently not
3462 * supported
3463 */
3464 if (ddf->dlist || ddf->conflist)
3465 return 1;
3466
a322f70c
DW
3467 if (!get_dev_size(fd, NULL, &dsize))
3468 return 1;
3469
3d2c4fc7
DW
3470 if (posix_memalign(&buf, 512, 512) != 0)
3471 return 1;
6416d527
NB
3472 memset(buf, 0, 512);
3473
a322f70c 3474 lseek64(fd, dsize-512, 0);
3d2c4fc7 3475 rc = write(fd, buf, 512);
6416d527 3476 free(buf);
3d2c4fc7
DW
3477 if (rc < 0)
3478 return 1;
a322f70c
DW
3479 return 0;
3480}
3481
a19c88b8
NB
3482static int compare_super_ddf(struct supertype *st, struct supertype *tst)
3483{
3484 /*
3485 * return:
3486 * 0 same, or first was empty, and second was copied
3487 * 1 second had wrong number
3488 * 2 wrong uuid
3489 * 3 wrong other info
3490 */
3491 struct ddf_super *first = st->sb;
3492 struct ddf_super *second = tst->sb;
4eefd651 3493 struct dl *dl1, *dl2;
3494 struct vcl *vl1, *vl2;
2d210697 3495 unsigned int max_vds, max_pds, pd, vd;
a19c88b8
NB
3496
3497 if (!first) {
3498 st->sb = tst->sb;
3499 tst->sb = NULL;
3500 return 0;
3501 }
3502
3503 if (memcmp(first->anchor.guid, second->anchor.guid, DDF_GUID_LEN) != 0)
3504 return 2;
3505
2d210697 3506 if (first->anchor.seq != second->anchor.seq) {
3507 dprintf("%s: sequence number mismatch %u/%u\n", __func__,
3508 __be32_to_cpu(first->anchor.seq),
3509 __be32_to_cpu(second->anchor.seq));
3510 return 3;
3511 }
3512 if (first->max_part != second->max_part ||
3513 first->phys->used_pdes != second->phys->used_pdes ||
3514 first->virt->populated_vdes != second->virt->populated_vdes) {
3515 dprintf("%s: PD/VD number mismatch\n", __func__);
3516 return 3;
3517 }
3518
3519 max_pds = __be16_to_cpu(first->phys->used_pdes);
3520 for (dl2 = second->dlist; dl2; dl2 = dl2->next) {
3521 for (pd = 0; pd < max_pds; pd++)
3522 if (first->phys->entries[pd].refnum == dl2->disk.refnum)
3523 break;
3524 if (pd == max_pds) {
3525 dprintf("%s: no match for disk %08x\n", __func__,
3526 __be32_to_cpu(dl2->disk.refnum));
3527 return 3;
3528 }
3529 }
3530
3531 max_vds = __be16_to_cpu(first->active->max_vd_entries);
3532 for (vl2 = second->conflist; vl2; vl2 = vl2->next) {
3533 if (vl2->conf.magic != DDF_VD_CONF_MAGIC)
3534 continue;
3535 for (vd = 0; vd < max_vds; vd++)
3536 if (!memcmp(first->virt->entries[vd].guid,
3537 vl2->conf.guid, DDF_GUID_LEN))
3538 break;
3539 if (vd == max_vds) {
3540 dprintf("%s: no match for VD config\n", __func__);
3541 return 3;
3542 }
3543 }
a19c88b8 3544 /* FIXME should I look at anything else? */
2d210697 3545
4eefd651 3546 /*
3547 At this point we are fairly sure that the meta data matches.
3548 But the new disk may contain additional local data.
3549 Add it to the super block.
3550 */
3551 for (vl2 = second->conflist; vl2; vl2 = vl2->next) {
3552 for (vl1 = first->conflist; vl1; vl1 = vl1->next)
3553 if (!memcmp(vl1->conf.guid, vl2->conf.guid,
3554 DDF_GUID_LEN))
3555 break;
3556 if (vl1) {
3557 if (vl1->other_bvds != NULL &&
3558 vl1->conf.sec_elmnt_seq !=
3559 vl2->conf.sec_elmnt_seq) {
3560 dprintf("%s: adding BVD %u\n", __func__,
3561 vl2->conf.sec_elmnt_seq);
3562 add_other_bvd(vl1, &vl2->conf,
3563 first->conf_rec_len*512);
3564 }
3565 continue;
3566 }
3567
3568 if (posix_memalign((void **)&vl1, 512,
3569 (first->conf_rec_len*512 +
3570 offsetof(struct vcl, conf))) != 0) {
3571 pr_err("%s could not allocate vcl buf\n",
3572 __func__);
3573 return 3;
3574 }
3575
3576 vl1->next = first->conflist;
3577 vl1->block_sizes = NULL;
3f188b10 3578 if (vl2->conf.sec_elmnt_count > 1) {
4eefd651 3579 vl1->other_bvds = xcalloc(vl2->conf.sec_elmnt_count - 1,
3580 sizeof(struct vd_config *));
3581 } else
3582 vl1->other_bvds = NULL;
3583 memcpy(&vl1->conf, &vl2->conf, first->conf_rec_len*512);
3584 vl1->lba_offset = (__u64 *)
3585 &vl1->conf.phys_refnum[first->mppe];
3586 for (vd = 0; vd < max_vds; vd++)
3587 if (!memcmp(first->virt->entries[vd].guid,
3588 vl1->conf.guid, DDF_GUID_LEN))
3589 break;
3590 vl1->vcnum = vd;
3591 dprintf("%s: added config for VD %u\n", __func__, vl1->vcnum);
3592 first->conflist = vl1;
3593 }
3594
3595 for (dl2 = second->dlist; dl2; dl2 = dl2->next) {
3596 for (dl1 = first->dlist; dl1; dl1 = dl1->next)
3597 if (dl1->disk.refnum == dl2->disk.refnum)
3598 break;
3599 if (dl1)
3600 continue;
3601
3602 if (posix_memalign((void **)&dl1, 512,
3603 sizeof(*dl1) + (first->max_part) * sizeof(dl1->vlist[0]))
3604 != 0) {
3605 pr_err("%s could not allocate disk info buffer\n",
3606 __func__);
3607 return 3;
3608 }
3609 memcpy(dl1, dl2, sizeof(*dl1));
3610 dl1->mdupdate = NULL;
3611 dl1->next = first->dlist;
3612 dl1->fd = -1;
3613 for (pd = 0; pd < max_pds; pd++)
3614 if (first->phys->entries[pd].refnum == dl1->disk.refnum)
3615 break;
3616 dl1->pdnum = pd;
3617 if (dl2->spare) {
3618 if (posix_memalign((void **)&dl1->spare, 512,
3619 first->conf_rec_len*512) != 0) {
3620 pr_err("%s could not allocate spare info buf\n",
3621 __func__);
3622 return 3;
3623 }
3624 memcpy(dl1->spare, dl2->spare, first->conf_rec_len*512);
3625 }
3626 for (vd = 0 ; vd < first->max_part ; vd++) {
3627 if (!dl2->vlist[vd]) {
3628 dl1->vlist[vd] = NULL;
3629 continue;
3630 }
3631 for (vl1 = first->conflist; vl1; vl1 = vl1->next) {
3632 if (!memcmp(vl1->conf.guid,
3633 dl2->vlist[vd]->conf.guid,
3634 DDF_GUID_LEN))
3635 break;
3636 dl1->vlist[vd] = vl1;
3637 }
3638 }
3639 first->dlist = dl1;
3640 dprintf("%s: added disk %d: %08x\n", __func__, dl1->pdnum,
3641 dl1->disk.refnum);
3642 }
3643
a19c88b8
NB
3644 return 0;
3645}
3646
0e600426 3647#ifndef MDASSEMBLE
4e5528c6
NB
3648/*
3649 * A new array 'a' has been started which claims to be instance 'inst'
3650 * within container 'c'.
3651 * We need to confirm that the array matches the metadata in 'c' so
3652 * that we don't corrupt any metadata.
3653 */
cba0191b 3654static int ddf_open_new(struct supertype *c, struct active_array *a, char *inst)
549e9569 3655{
2c514b71 3656 dprintf("ddf: open_new %s\n", inst);
cba0191b 3657 a->info.container_member = atoi(inst);
549e9569
NB
3658 return 0;
3659}
3660
4e5528c6
NB
3661/*
3662 * The array 'a' is to be marked clean in the metadata.
ed9d66aa 3663 * If '->resync_start' is not ~(unsigned long long)0, then the array is only
4e5528c6
NB
3664 * clean up to the point (in sectors). If that cannot be recorded in the
3665 * metadata, then leave it as dirty.
3666 *
3667 * For DDF, we need to clear the DDF_state_inconsistent bit in the
3668 * !global! virtual_disk.virtual_entry structure.
3669 */
01f157d7 3670static int ddf_set_array_state(struct active_array *a, int consistent)
549e9569 3671{
4e5528c6
NB
3672 struct ddf_super *ddf = a->container->sb;
3673 int inst = a->info.container_member;
18a2f463 3674 int old = ddf->virt->entries[inst].state;
01f157d7
N
3675 if (consistent == 2) {
3676 /* Should check if a recovery should be started FIXME */
3677 consistent = 1;
b7941fd6 3678 if (!is_resync_complete(&a->info))
01f157d7
N
3679 consistent = 0;
3680 }
ed9d66aa
NB
3681 if (consistent)
3682 ddf->virt->entries[inst].state &= ~DDF_state_inconsistent;
3683 else
4e5528c6 3684 ddf->virt->entries[inst].state |= DDF_state_inconsistent;
18a2f463 3685 if (old != ddf->virt->entries[inst].state)
7d5a7ff3 3686 ddf_set_updates_pending(ddf);
18a2f463
NB
3687
3688 old = ddf->virt->entries[inst].init_state;
ed9d66aa 3689 ddf->virt->entries[inst].init_state &= ~DDF_initstate_mask;
b7941fd6 3690 if (is_resync_complete(&a->info))
ed9d66aa 3691 ddf->virt->entries[inst].init_state |= DDF_init_full;
b7941fd6 3692 else if (a->info.resync_start == 0)
ed9d66aa 3693 ddf->virt->entries[inst].init_state |= DDF_init_not;
4e5528c6 3694 else
ed9d66aa 3695 ddf->virt->entries[inst].init_state |= DDF_init_quick;
18a2f463 3696 if (old != ddf->virt->entries[inst].init_state)
7d5a7ff3 3697 ddf_set_updates_pending(ddf);
ed9d66aa 3698
2c514b71 3699 dprintf("ddf mark %d %s %llu\n", inst, consistent?"clean":"dirty",
b7941fd6 3700 a->info.resync_start);
01f157d7 3701 return consistent;
fd7cde1b
DW
3702}
3703
e1316fab 3704#define container_of(ptr, type, member) ({ \
5d500228
N
3705 const typeof( ((type *)0)->member ) *__mptr = (ptr); \
3706 (type *)( (char *)__mptr - offsetof(type,member) );})
7a7cc504
NB
3707/*
3708 * The state of each disk is stored in the global phys_disk structure
3709 * in phys_disk.entries[n].state.
3710 * This makes various combinations awkward.
3711 * - When a device fails in any array, it must be failed in all arrays
3712 * that include a part of this device.
3713 * - When a component is rebuilding, we cannot include it officially in the
3714 * array unless this is the only array that uses the device.
3715 *
3716 * So: when transitioning:
3717 * Online -> failed, just set failed flag. monitor will propagate
3718 * spare -> online, the device might need to be added to the array.
3719 * spare -> failed, just set failed. Don't worry if in array or not.
3720 */
8d45d196 3721static void ddf_set_disk(struct active_array *a, int n, int state)
549e9569 3722{
7a7cc504 3723 struct ddf_super *ddf = a->container->sb;
f21e18ca 3724 unsigned int inst = a->info.container_member;
7a7cc504
NB
3725 struct vd_config *vc = find_vdcr(ddf, inst);
3726 int pd = find_phys(ddf, vc->phys_refnum[n]);
3727 int i, st, working;
e1316fab
N
3728 struct mdinfo *mdi;
3729 struct dl *dl;
7a7cc504
NB
3730
3731 if (vc == NULL) {
2c514b71 3732 dprintf("ddf: cannot find instance %d!!\n", inst);
7a7cc504
NB
3733 return;
3734 }
e1316fab
N
3735 /* Find the matching slot in 'info'. */
3736 for (mdi = a->info.devs; mdi; mdi = mdi->next)
3737 if (mdi->disk.raid_disk == n)
3738 break;
3739 if (!mdi)
3740 return;
3741
3742 /* and find the 'dl' entry corresponding to that. */
3743 for (dl = ddf->dlist; dl; dl = dl->next)
77632af9
N
3744 if (mdi->state_fd >= 0 &&
3745 mdi->disk.major == dl->major &&
e1316fab
N
3746 mdi->disk.minor == dl->minor)
3747 break;
3748 if (!dl)
3749 return;
3750
3751 if (pd < 0 || pd != dl->pdnum) {
3752 /* disk doesn't currently exist or has changed.
3753 * If it is now in_sync, insert it. */
7a7cc504 3754 if ((state & DS_INSYNC) && ! (state & DS_FAULTY)) {
e1316fab
N
3755 struct vcl *vcl;
3756 pd = dl->pdnum;
3757 vc->phys_refnum[n] = dl->disk.refnum;
3758 vcl = container_of(vc, struct vcl, conf);
3759 vcl->lba_offset[n] = mdi->data_offset;
3760 ddf->phys->entries[pd].type &=
3761 ~__cpu_to_be16(DDF_Global_Spare);
3762 ddf->phys->entries[pd].type |=
3763 __cpu_to_be16(DDF_Active_in_VD);
7d5a7ff3 3764 ddf_set_updates_pending(ddf);
7a7cc504
NB
3765 }
3766 } else {
18a2f463 3767 int old = ddf->phys->entries[pd].state;
7a7cc504
NB
3768 if (state & DS_FAULTY)
3769 ddf->phys->entries[pd].state |= __cpu_to_be16(DDF_Failed);
3770 if (state & DS_INSYNC) {
3771 ddf->phys->entries[pd].state |= __cpu_to_be16(DDF_Online);
3772 ddf->phys->entries[pd].state &= __cpu_to_be16(~DDF_Rebuilding);
3773 }
18a2f463 3774 if (old != ddf->phys->entries[pd].state)
7d5a7ff3 3775 ddf_set_updates_pending(ddf);
7a7cc504
NB
3776 }
3777
2c514b71 3778 dprintf("ddf: set_disk %d to %x\n", n, state);
7e1432fb 3779
7a7cc504
NB
3780 /* Now we need to check the state of the array and update
3781 * virtual_disk.entries[n].state.
3782 * It needs to be one of "optimal", "degraded", "failed".
3783 * I don't understand 'deleted' or 'missing'.
3784 */
3785 working = 0;
3786 for (i=0; i < a->info.array.raid_disks; i++) {
3787 pd = find_phys(ddf, vc->phys_refnum[i]);
3788 if (pd < 0)
3789 continue;
57632f4a
NB
3790 st = __be16_to_cpu(ddf->phys->entries[pd].state);
3791 if ((st & (DDF_Online|DDF_Failed|DDF_Rebuilding))
7a7cc504
NB
3792 == DDF_Online)
3793 working++;
3794 }
3795 state = DDF_state_degraded;
3796 if (working == a->info.array.raid_disks)
3797 state = DDF_state_optimal;
3798 else switch(vc->prl) {
613b0d17
N
3799 case DDF_RAID0:
3800 case DDF_CONCAT:
3801 case DDF_JBOD:
7a7cc504 3802 state = DDF_state_failed;
613b0d17
N
3803 break;
3804 case DDF_RAID1:
3805 if (working == 0)
3806 state = DDF_state_failed;
3807 else if (working == 2 && state == DDF_state_degraded)
3808 state = DDF_state_part_optimal;
3809 break;
3810 case DDF_RAID4:
3811 case DDF_RAID5:
3812 if (working < a->info.array.raid_disks-1)
3813 state = DDF_state_failed;
3814 break;
3815 case DDF_RAID6:
3816 if (working < a->info.array.raid_disks-2)
3817 state = DDF_state_failed;
3818 else if (working == a->info.array.raid_disks-1)
3819 state = DDF_state_part_optimal;
3820 break;
3821 }
7a7cc504 3822
18a2f463
NB
3823 if (ddf->virt->entries[inst].state !=
3824 ((ddf->virt->entries[inst].state & ~DDF_state_mask)
3825 | state)) {
3826
3827 ddf->virt->entries[inst].state =
3828 (ddf->virt->entries[inst].state & ~DDF_state_mask)
3829 | state;
7d5a7ff3 3830 ddf_set_updates_pending(ddf);
18a2f463 3831 }
7a7cc504 3832
549e9569
NB
3833}
3834
2e735d19 3835static void ddf_sync_metadata(struct supertype *st)
549e9569 3836{
7a7cc504
NB
3837
3838 /*
3839 * Write all data to all devices.
3840 * Later, we might be able to track whether only local changes
3841 * have been made, or whether any global data has been changed,
3842 * but ddf is sufficiently weird that it probably always
3843 * changes global data ....
3844 */
18a2f463
NB
3845 struct ddf_super *ddf = st->sb;
3846 if (!ddf->updates_pending)
3847 return;
3848 ddf->updates_pending = 0;
1cc7f4fe 3849 __write_init_super_ddf(st);
2c514b71 3850 dprintf("ddf: sync_metadata\n");
549e9569
NB
3851}
3852
88c164f4
NB
3853static void ddf_process_update(struct supertype *st,
3854 struct metadata_update *update)
3855{
3856 /* Apply this update to the metadata.
3857 * The first 4 bytes are a DDF_*_MAGIC which guides
3858 * our actions.
3859 * Possible update are:
3860 * DDF_PHYS_RECORDS_MAGIC
4dd968cc
N
3861 * Add a new physical device or remove an old one.
3862 * Changes to this record only happen implicitly.
88c164f4
NB
3863 * used_pdes is the device number.
3864 * DDF_VIRT_RECORDS_MAGIC
3865 * Add a new VD. Possibly also change the 'access' bits.
3866 * populated_vdes is the entry number.
3867 * DDF_VD_CONF_MAGIC
3868 * New or updated VD. the VIRT_RECORD must already
3869 * exist. For an update, phys_refnum and lba_offset
3870 * (at least) are updated, and the VD_CONF must
3871 * be written to precisely those devices listed with
3872 * a phys_refnum.
3873 * DDF_SPARE_ASSIGN_MAGIC
3874 * replacement Spare Assignment Record... but for which device?
3875 *
3876 * So, e.g.:
3877 * - to create a new array, we send a VIRT_RECORD and
3878 * a VD_CONF. Then assemble and start the array.
3879 * - to activate a spare we send a VD_CONF to add the phys_refnum
3880 * and offset. This will also mark the spare as active with
3881 * a spare-assignment record.
3882 */
3883 struct ddf_super *ddf = st->sb;
3884 __u32 *magic = (__u32*)update->buf;
3885 struct phys_disk *pd;
3886 struct virtual_disk *vd;
3887 struct vd_config *vc;
3888 struct vcl *vcl;
3889 struct dl *dl;
f21e18ca
N
3890 unsigned int mppe;
3891 unsigned int ent;
c7079c84 3892 unsigned int pdnum, pd2;
88c164f4 3893
2c514b71 3894 dprintf("Process update %x\n", *magic);
7e1432fb 3895
88c164f4
NB
3896 switch (*magic) {
3897 case DDF_PHYS_RECORDS_MAGIC:
3898
3899 if (update->len != (sizeof(struct phys_disk) +
3900 sizeof(struct phys_disk_entry)))
3901 return;
3902 pd = (struct phys_disk*)update->buf;
3903
3904 ent = __be16_to_cpu(pd->used_pdes);
3905 if (ent >= __be16_to_cpu(ddf->phys->max_pdes))
3906 return;
4dd968cc
N
3907 if (pd->entries[0].state & __cpu_to_be16(DDF_Missing)) {
3908 struct dl **dlp;
3909 /* removing this disk. */
3910 ddf->phys->entries[ent].state |= __cpu_to_be16(DDF_Missing);
3911 for (dlp = &ddf->dlist; *dlp; dlp = &(*dlp)->next) {
3912 struct dl *dl = *dlp;
3913 if (dl->pdnum == (signed)ent) {
3914 close(dl->fd);
3915 dl->fd = -1;
3916 /* FIXME this doesn't free
3917 * dl->devname */
3918 update->space = dl;
3919 *dlp = dl->next;
3920 break;
3921 }
3922 }
7d5a7ff3 3923 ddf_set_updates_pending(ddf);
4dd968cc
N
3924 return;
3925 }
88c164f4
NB
3926 if (!all_ff(ddf->phys->entries[ent].guid))
3927 return;
3928 ddf->phys->entries[ent] = pd->entries[0];
3929 ddf->phys->used_pdes = __cpu_to_be16(1 +
613b0d17 3930 __be16_to_cpu(ddf->phys->used_pdes));
7d5a7ff3 3931 ddf_set_updates_pending(ddf);
2cc2983d
N
3932 if (ddf->add_list) {
3933 struct active_array *a;
3934 struct dl *al = ddf->add_list;
3935 ddf->add_list = al->next;
3936
3937 al->next = ddf->dlist;
3938 ddf->dlist = al;
3939
3940 /* As a device has been added, we should check
3941 * for any degraded devices that might make
3942 * use of this spare */
3943 for (a = st->arrays ; a; a=a->next)
3944 a->check_degraded = 1;
3945 }
88c164f4
NB
3946 break;
3947
3948 case DDF_VIRT_RECORDS_MAGIC:
3949
3950 if (update->len != (sizeof(struct virtual_disk) +
3951 sizeof(struct virtual_entry)))
3952 return;
3953 vd = (struct virtual_disk*)update->buf;
3954
3955 ent = __be16_to_cpu(vd->populated_vdes);
3956 if (ent >= __be16_to_cpu(ddf->virt->max_vdes))
3957 return;
3958 if (!all_ff(ddf->virt->entries[ent].guid))
3959 return;
3960 ddf->virt->entries[ent] = vd->entries[0];
3961 ddf->virt->populated_vdes = __cpu_to_be16(1 +
613b0d17 3962 __be16_to_cpu(ddf->virt->populated_vdes));
7d5a7ff3 3963 ddf_set_updates_pending(ddf);
88c164f4
NB
3964 break;
3965
3966 case DDF_VD_CONF_MAGIC:
2c514b71 3967 dprintf("len %d %d\n", update->len, ddf->conf_rec_len);
88c164f4
NB
3968
3969 mppe = __be16_to_cpu(ddf->anchor.max_primary_element_entries);
f21e18ca 3970 if ((unsigned)update->len != ddf->conf_rec_len * 512)
88c164f4
NB
3971 return;
3972 vc = (struct vd_config*)update->buf;
3973 for (vcl = ddf->conflist; vcl ; vcl = vcl->next)
3974 if (memcmp(vcl->conf.guid, vc->guid, DDF_GUID_LEN) == 0)
3975 break;
2c514b71 3976 dprintf("vcl = %p\n", vcl);
88c164f4
NB
3977 if (vcl) {
3978 /* An update, just copy the phys_refnum and lba_offset
3979 * fields
3980 */
3981 memcpy(vcl->conf.phys_refnum, vc->phys_refnum,
3982 mppe * (sizeof(__u32) + sizeof(__u64)));
3983 } else {
3984 /* A new VD_CONF */
e6b9548d
DW
3985 if (!update->space)
3986 return;
88c164f4
NB
3987 vcl = update->space;
3988 update->space = NULL;
3989 vcl->next = ddf->conflist;
edd8d13c 3990 memcpy(&vcl->conf, vc, update->len);
88c164f4
NB
3991 vcl->lba_offset = (__u64*)
3992 &vcl->conf.phys_refnum[mppe];
1502a43a
N
3993 for (ent = 0;
3994 ent < __be16_to_cpu(ddf->virt->populated_vdes);
3995 ent++)
3996 if (memcmp(vc->guid, ddf->virt->entries[ent].guid,
3997 DDF_GUID_LEN) == 0) {
3998 vcl->vcnum = ent;
3999 break;
4000 }
88c164f4
NB
4001 ddf->conflist = vcl;
4002 }
c7079c84
N
4003 /* Set DDF_Transition on all Failed devices - to help
4004 * us detect those that are no longer in use
4005 */
4006 for (pdnum = 0; pdnum < __be16_to_cpu(ddf->phys->used_pdes); pdnum++)
4007 if (ddf->phys->entries[pdnum].state
4008 & __be16_to_cpu(DDF_Failed))
4009 ddf->phys->entries[pdnum].state
4010 |= __be16_to_cpu(DDF_Transition);
88c164f4
NB
4011 /* Now make sure vlist is correct for each dl. */
4012 for (dl = ddf->dlist; dl; dl = dl->next) {
f21e18ca
N
4013 unsigned int dn;
4014 unsigned int vn = 0;
8401644c 4015 int in_degraded = 0;
88c164f4
NB
4016 for (vcl = ddf->conflist; vcl ; vcl = vcl->next)
4017 for (dn=0; dn < ddf->mppe ; dn++)
4018 if (vcl->conf.phys_refnum[dn] ==
4019 dl->disk.refnum) {
8401644c 4020 int vstate;
2c514b71
NB
4021 dprintf("dev %d has %p at %d\n",
4022 dl->pdnum, vcl, vn);
c7079c84
N
4023 /* Clear the Transition flag */
4024 if (ddf->phys->entries[dl->pdnum].state
4025 & __be16_to_cpu(DDF_Failed))
4026 ddf->phys->entries[dl->pdnum].state &=
4027 ~__be16_to_cpu(DDF_Transition);
4028
88c164f4 4029 dl->vlist[vn++] = vcl;
8401644c
N
4030 vstate = ddf->virt->entries[vcl->vcnum].state
4031 & DDF_state_mask;
4032 if (vstate == DDF_state_degraded ||
4033 vstate == DDF_state_part_optimal)
4034 in_degraded = 1;
88c164f4
NB
4035 break;
4036 }
4037 while (vn < ddf->max_part)
4038 dl->vlist[vn++] = NULL;
7e1432fb
NB
4039 if (dl->vlist[0]) {
4040 ddf->phys->entries[dl->pdnum].type &=
4041 ~__cpu_to_be16(DDF_Global_Spare);
8401644c
N
4042 if (!(ddf->phys->entries[dl->pdnum].type &
4043 __cpu_to_be16(DDF_Active_in_VD))) {
613b0d17
N
4044 ddf->phys->entries[dl->pdnum].type |=
4045 __cpu_to_be16(DDF_Active_in_VD);
4046 if (in_degraded)
4047 ddf->phys->entries[dl->pdnum].state |=
4048 __cpu_to_be16(DDF_Rebuilding);
4049 }
7e1432fb
NB
4050 }
4051 if (dl->spare) {
4052 ddf->phys->entries[dl->pdnum].type &=
4053 ~__cpu_to_be16(DDF_Global_Spare);
4054 ddf->phys->entries[dl->pdnum].type |=
4055 __cpu_to_be16(DDF_Spare);
4056 }
4057 if (!dl->vlist[0] && !dl->spare) {
4058 ddf->phys->entries[dl->pdnum].type |=
4059 __cpu_to_be16(DDF_Global_Spare);
4060 ddf->phys->entries[dl->pdnum].type &=
4061 ~__cpu_to_be16(DDF_Spare |
4062 DDF_Active_in_VD);
4063 }
88c164f4 4064 }
c7079c84
N
4065
4066 /* Now remove any 'Failed' devices that are not part
4067 * of any VD. They will have the Transition flag set.
4068 * Once done, we need to update all dl->pdnum numbers.
4069 */
4070 pd2 = 0;
4071 for (pdnum = 0; pdnum < __be16_to_cpu(ddf->phys->used_pdes); pdnum++)
4072 if ((ddf->phys->entries[pdnum].state
4073 & __be16_to_cpu(DDF_Failed))
4074 && (ddf->phys->entries[pdnum].state
4075 & __be16_to_cpu(DDF_Transition)))
4076 /* skip this one */;
4077 else if (pdnum == pd2)
4078 pd2++;
4079 else {
4080 ddf->phys->entries[pd2] = ddf->phys->entries[pdnum];
4081 for (dl = ddf->dlist; dl; dl = dl->next)
4082 if (dl->pdnum == (int)pdnum)
4083 dl->pdnum = pd2;
4084 pd2++;
4085 }
4086 ddf->phys->used_pdes = __cpu_to_be16(pd2);
4087 while (pd2 < pdnum) {
4088 memset(ddf->phys->entries[pd2].guid, 0xff, DDF_GUID_LEN);
4089 pd2++;
4090 }
4091
7d5a7ff3 4092 ddf_set_updates_pending(ddf);
88c164f4
NB
4093 break;
4094 case DDF_SPARE_ASSIGN_MAGIC:
4095 default: break;
4096 }
4097}
4098
edd8d13c
NB
4099static void ddf_prepare_update(struct supertype *st,
4100 struct metadata_update *update)
4101{
4102 /* This update arrived at managemon.
4103 * We are about to pass it to monitor.
4104 * If a malloc is needed, do it here.
4105 */
4106 struct ddf_super *ddf = st->sb;
4107 __u32 *magic = (__u32*)update->buf;
4108 if (*magic == DDF_VD_CONF_MAGIC)
e6b9548d 4109 if (posix_memalign(&update->space, 512,
613b0d17
N
4110 offsetof(struct vcl, conf)
4111 + ddf->conf_rec_len * 512) != 0)
e6b9548d 4112 update->space = NULL;
edd8d13c
NB
4113}
4114
7e1432fb
NB
4115/*
4116 * Check if the array 'a' is degraded but not failed.
4117 * If it is, find as many spares as are available and needed and
4118 * arrange for their inclusion.
4119 * We only choose devices which are not already in the array,
4120 * and prefer those with a spare-assignment to this array.
4121 * otherwise we choose global spares - assuming always that
4122 * there is enough room.
4123 * For each spare that we assign, we return an 'mdinfo' which
4124 * describes the position for the device in the array.
4125 * We also add to 'updates' a DDF_VD_CONF_MAGIC update with
4126 * the new phys_refnum and lba_offset values.
4127 *
4128 * Only worry about BVDs at the moment.
4129 */
4130static struct mdinfo *ddf_activate_spare(struct active_array *a,
4131 struct metadata_update **updates)
4132{
4133 int working = 0;
4134 struct mdinfo *d;
4135 struct ddf_super *ddf = a->container->sb;
4136 int global_ok = 0;
4137 struct mdinfo *rv = NULL;
4138 struct mdinfo *di;
4139 struct metadata_update *mu;
4140 struct dl *dl;
4141 int i;
4142 struct vd_config *vc;
4143 __u64 *lba;
4144
7e1432fb
NB
4145 for (d = a->info.devs ; d ; d = d->next) {
4146 if ((d->curr_state & DS_FAULTY) &&
613b0d17 4147 d->state_fd >= 0)
7e1432fb
NB
4148 /* wait for Removal to happen */
4149 return NULL;
4150 if (d->state_fd >= 0)
4151 working ++;
4152 }
4153
2c514b71
NB
4154 dprintf("ddf_activate: working=%d (%d) level=%d\n", working, a->info.array.raid_disks,
4155 a->info.array.level);
7e1432fb
NB
4156 if (working == a->info.array.raid_disks)
4157 return NULL; /* array not degraded */
4158 switch (a->info.array.level) {
4159 case 1:
4160 if (working == 0)
4161 return NULL; /* failed */
4162 break;
4163 case 4:
4164 case 5:
4165 if (working < a->info.array.raid_disks - 1)
4166 return NULL; /* failed */
4167 break;
4168 case 6:
4169 if (working < a->info.array.raid_disks - 2)
4170 return NULL; /* failed */
4171 break;
4172 default: /* concat or stripe */
4173 return NULL; /* failed */
4174 }
4175
4176 /* For each slot, if it is not working, find a spare */
4177 dl = ddf->dlist;
4178 for (i = 0; i < a->info.array.raid_disks; i++) {
4179 for (d = a->info.devs ; d ; d = d->next)
4180 if (d->disk.raid_disk == i)
4181 break;
2c514b71 4182 dprintf("found %d: %p %x\n", i, d, d?d->curr_state:0);
7e1432fb
NB
4183 if (d && (d->state_fd >= 0))
4184 continue;
4185
4186 /* OK, this device needs recovery. Find a spare */
4187 again:
4188 for ( ; dl ; dl = dl->next) {
4189 unsigned long long esize;
4190 unsigned long long pos;
4191 struct mdinfo *d2;
4192 int is_global = 0;
4193 int is_dedicated = 0;
4194 struct extent *ex;
f21e18ca 4195 unsigned int j;
7e1432fb
NB
4196 /* If in this array, skip */
4197 for (d2 = a->info.devs ; d2 ; d2 = d2->next)
7590d562
N
4198 if (d2->state_fd >= 0 &&
4199 d2->disk.major == dl->major &&
7e1432fb 4200 d2->disk.minor == dl->minor) {
2c514b71 4201 dprintf("%x:%x already in array\n", dl->major, dl->minor);
7e1432fb
NB
4202 break;
4203 }
4204 if (d2)
4205 continue;
4206 if (ddf->phys->entries[dl->pdnum].type &
4207 __cpu_to_be16(DDF_Spare)) {
4208 /* Check spare assign record */
4209 if (dl->spare) {
4210 if (dl->spare->type & DDF_spare_dedicated) {
4211 /* check spare_ents for guid */
4212 for (j = 0 ;
4213 j < __be16_to_cpu(dl->spare->populated);
4214 j++) {
4215 if (memcmp(dl->spare->spare_ents[j].guid,
4216 ddf->virt->entries[a->info.container_member].guid,
4217 DDF_GUID_LEN) == 0)
4218 is_dedicated = 1;
4219 }
4220 } else
4221 is_global = 1;
4222 }
4223 } else if (ddf->phys->entries[dl->pdnum].type &
4224 __cpu_to_be16(DDF_Global_Spare)) {
4225 is_global = 1;
e0e7aeaa
N
4226 } else if (!(ddf->phys->entries[dl->pdnum].state &
4227 __cpu_to_be16(DDF_Failed))) {
4228 /* we can possibly use some of this */
4229 is_global = 1;
7e1432fb
NB
4230 }
4231 if ( ! (is_dedicated ||
4232 (is_global && global_ok))) {
2c514b71 4233 dprintf("%x:%x not suitable: %d %d\n", dl->major, dl->minor,
613b0d17 4234 is_dedicated, is_global);
7e1432fb
NB
4235 continue;
4236 }
4237
4238 /* We are allowed to use this device - is there space?
4239 * We need a->info.component_size sectors */
4240 ex = get_extents(ddf, dl);
4241 if (!ex) {
2c514b71 4242 dprintf("cannot get extents\n");
7e1432fb
NB
4243 continue;
4244 }
4245 j = 0; pos = 0;
4246 esize = 0;
4247
4248 do {
4249 esize = ex[j].start - pos;
4250 if (esize >= a->info.component_size)
4251 break;
e5cc7d46
N
4252 pos = ex[j].start + ex[j].size;
4253 j++;
4254 } while (ex[j-1].size);
7e1432fb
NB
4255
4256 free(ex);
4257 if (esize < a->info.component_size) {
e5cc7d46
N
4258 dprintf("%x:%x has no room: %llu %llu\n",
4259 dl->major, dl->minor,
2c514b71 4260 esize, a->info.component_size);
7e1432fb
NB
4261 /* No room */
4262 continue;
4263 }
4264
4265 /* Cool, we have a device with some space at pos */
503975b9 4266 di = xcalloc(1, sizeof(*di));
7e1432fb
NB
4267 di->disk.number = i;
4268 di->disk.raid_disk = i;
4269 di->disk.major = dl->major;
4270 di->disk.minor = dl->minor;
4271 di->disk.state = 0;
d23534e4 4272 di->recovery_start = 0;
7e1432fb
NB
4273 di->data_offset = pos;
4274 di->component_size = a->info.component_size;
4275 di->container_member = dl->pdnum;
4276 di->next = rv;
4277 rv = di;
2c514b71
NB
4278 dprintf("%x:%x to be %d at %llu\n", dl->major, dl->minor,
4279 i, pos);
7e1432fb
NB
4280
4281 break;
4282 }
4283 if (!dl && ! global_ok) {
4284 /* not enough dedicated spares, try global */
4285 global_ok = 1;
4286 dl = ddf->dlist;
4287 goto again;
4288 }
4289 }
4290
4291 if (!rv)
4292 /* No spares found */
4293 return rv;
4294 /* Now 'rv' has a list of devices to return.
4295 * Create a metadata_update record to update the
4296 * phys_refnum and lba_offset values
4297 */
503975b9
N
4298 mu = xmalloc(sizeof(*mu));
4299 if (posix_memalign(&mu->space, 512, sizeof(struct vcl)) != 0) {
79244939
DW
4300 free(mu);
4301 mu = NULL;
4302 }
503975b9 4303 mu->buf = xmalloc(ddf->conf_rec_len * 512);
7590d562
N
4304 mu->len = ddf->conf_rec_len * 512;
4305 mu->space = NULL;
f50ae22e 4306 mu->space_list = NULL;
7e1432fb
NB
4307 mu->next = *updates;
4308 vc = find_vdcr(ddf, a->info.container_member);
4309 memcpy(mu->buf, vc, ddf->conf_rec_len * 512);
4310
4311 vc = (struct vd_config*)mu->buf;
4312 lba = (__u64*)&vc->phys_refnum[ddf->mppe];
4313 for (di = rv ; di ; di = di->next) {
4314 vc->phys_refnum[di->disk.raid_disk] =
4315 ddf->phys->entries[dl->pdnum].refnum;
4316 lba[di->disk.raid_disk] = di->data_offset;
4317 }
4318 *updates = mu;
4319 return rv;
4320}
0e600426 4321#endif /* MDASSEMBLE */
7e1432fb 4322
b640a252
N
4323static int ddf_level_to_layout(int level)
4324{
4325 switch(level) {
4326 case 0:
4327 case 1:
4328 return 0;
4329 case 5:
4330 return ALGORITHM_LEFT_SYMMETRIC;
4331 case 6:
4332 return ALGORITHM_ROTATING_N_CONTINUE;
4333 case 10:
4334 return 0x102;
4335 default:
4336 return UnSet;
4337 }
4338}
4339
30f58b22
DW
4340static void default_geometry_ddf(struct supertype *st, int *level, int *layout, int *chunk)
4341{
4342 if (level && *level == UnSet)
4343 *level = LEVEL_CONTAINER;
4344
4345 if (level && layout && *layout == UnSet)
4346 *layout = ddf_level_to_layout(*level);
4347}
4348
a322f70c
DW
4349struct superswitch super_ddf = {
4350#ifndef MDASSEMBLE
4351 .examine_super = examine_super_ddf,
4352 .brief_examine_super = brief_examine_super_ddf,
4737ae25 4353 .brief_examine_subarrays = brief_examine_subarrays_ddf,
bceedeec 4354 .export_examine_super = export_examine_super_ddf,
a322f70c
DW
4355 .detail_super = detail_super_ddf,
4356 .brief_detail_super = brief_detail_super_ddf,
4357 .validate_geometry = validate_geometry_ddf,
78e44928 4358 .write_init_super = write_init_super_ddf,
0e600426 4359 .add_to_super = add_to_super_ddf,
4dd968cc 4360 .remove_from_super = remove_from_super_ddf,
2b959fbf 4361 .load_container = load_container_ddf,
74db60b0 4362 .copy_metadata = copy_metadata_ddf,
a322f70c
DW
4363#endif
4364 .match_home = match_home_ddf,
4365 .uuid_from_super= uuid_from_super_ddf,
4366 .getinfo_super = getinfo_super_ddf,
4367 .update_super = update_super_ddf,
4368
4369 .avail_size = avail_size_ddf,
4370
a19c88b8
NB
4371 .compare_super = compare_super_ddf,
4372
a322f70c 4373 .load_super = load_super_ddf,
ba7eb04f 4374 .init_super = init_super_ddf,
955e9ea1 4375 .store_super = store_super_ddf,
a322f70c
DW
4376 .free_super = free_super_ddf,
4377 .match_metadata_desc = match_metadata_desc_ddf,
78e44928 4378 .container_content = container_content_ddf,
30f58b22 4379 .default_geometry = default_geometry_ddf,
a322f70c 4380
a322f70c 4381 .external = 1,
549e9569 4382
0e600426 4383#ifndef MDASSEMBLE
549e9569
NB
4384/* for mdmon */
4385 .open_new = ddf_open_new,
ed9d66aa 4386 .set_array_state= ddf_set_array_state,
549e9569
NB
4387 .set_disk = ddf_set_disk,
4388 .sync_metadata = ddf_sync_metadata,
88c164f4 4389 .process_update = ddf_process_update,
edd8d13c 4390 .prepare_update = ddf_prepare_update,
7e1432fb 4391 .activate_spare = ddf_activate_spare,
0e600426 4392#endif
4cce4069 4393 .name = "ddf",
a322f70c 4394};