1/* $NetBSD: libdm-nbsd-iface.c,v 1.12 2018/11/24 11:27:37 mlelstv Exp $ */
2
3/*
4 * Copyright (C) 2001-2004 Sistina Software, Inc. All rights reserved.
5 * Copyright (C) 2004-2007 Red Hat, Inc. All rights reserved.
6 * Copyright (C) 2008 Adam Hamsik. All rights reserved.
7 *
8 * This file is part of the device-mapper userspace tools.
9 *
10 * This copyrighted material is made available to anyone wishing to use,
11 * modify, copy, or redistribute it subject to the terms and conditions
12 * of the GNU Lesser General Public License v.2.1.
13 *
14 * You should have received a copy of the GNU Lesser General Public License
15 * along with this program; if not, write to the Free Software Foundation,
16 * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 */
18
19#include "dmlib.h"
20#include "libdm-targets.h"
21#include "libdm-common.h"
22#include "libdm-netbsd.h"
23
24#include <sys/ioctl.h>
25#include <sys/sysctl.h>
26
27#include <fcntl.h>
28#include <paths.h>
29#include <dirent.h>
30#include <fts.h>
31#include <limits.h>
32
33#include <dm.h>
34#include <dev/dm/netbsd-dm.h>
35
36#include <dm-ioctl.h>
37
38#ifdef RUMP_ACTION
39#include <rump/rump.h>
40#include <rump/rump_syscalls.h>
41#endif
42
43/*
44 * Ensure build compatibility.
45 * The hard-coded versions here are the highest present
46 * in the _cmd_data arrays.
47 */
48
49#if !((DM_VERSION_MAJOR == 1 && DM_VERSION_MINOR >= 0) || \
50 (DM_VERSION_MAJOR == 4 && DM_VERSION_MINOR >= 0))
51#error The version of dm-ioctl.h included is incompatible.
52#endif
53
54/* dm major version no for running kernel */
55static unsigned _dm_version_minor = 0;
56static unsigned _dm_version_patchlevel = 0;
57
58static int _control_fd = -1;
59static int _version_checked = 0;
60static int _version_ok = 1;
61static unsigned _ioctl_buffer_double_factor = 0;
62
63/* *INDENT-OFF* */
64
65/*
66 * XXX Remove this structure and write another own one
67 * I don't understand why ioctl calls has different
68 * names then dm task type
69 */
70static struct cmd_data _cmd_data_v4[] = {
71 {"create", DM_DEV_CREATE, {4, 0, 0}},
72 {"reload", DM_TABLE_LOAD, {4, 0, 0}}, /* DM_DEVICE_RELOAD */
73 {"remove", DM_DEV_REMOVE, {4, 0, 0}},
74 {"remove_all", DM_REMOVE_ALL, {4, 0, 0}},
75 {"suspend", DM_DEV_SUSPEND, {4, 0, 0}},
76 {"resume", DM_DEV_SUSPEND, {4, 0, 0}},
77 {"info", DM_DEV_STATUS, {4, 0, 0}},
78 {"deps", DM_TABLE_DEPS, {4, 0, 0}}, /* DM_DEVICE_DEPS */
79 {"rename", DM_DEV_RENAME, {4, 0, 0}},
80 {"version", DM_VERSION, {4, 0, 0}},
81 {"status", DM_TABLE_STATUS, {4, 0, 0}},
82 {"table", DM_TABLE_STATUS, {4, 0, 0}}, /* DM_DEVICE_TABLE */
83 {"waitevent", DM_DEV_WAIT, {4, 0, 0}},
84 {"names", DM_LIST_DEVICES, {4, 0, 0}},
85 {"clear", DM_TABLE_CLEAR, {4, 0, 0}},
86 {"mknodes", DM_DEV_STATUS, {4, 0, 0}},
87#ifdef DM_LIST_VERSIONS
88 {"targets", DM_LIST_VERSIONS, {4, 1, 0}},
89#endif
90#ifdef DM_TARGET_MSG
91 {"message", DM_TARGET_MSG, {4, 2, 0}},
92#endif
93#ifdef DM_DEV_SET_GEOMETRY
94 {"setgeometry", DM_DEV_SET_GEOMETRY, {4, 6, 0}},
95#endif
96};
97/* *INDENT-ON* */
98
99/*
100 * In NetBSD we use sysctl to get kernel drivers info. control device
101 * has predefined minor number 0 and major number = char major number
102 * of dm driver. First slot is therefore ocupied with control device
103 * and minor device starts from 1;
104 */
105
106static int _control_device_number(uint32_t *major, uint32_t *minor)
107{
108
109 nbsd_get_dm_major(major, DM_CHAR_MAJOR);
110
111 *minor = 0;
112
113 return 1;
114}
115
116/*
117 * Returns 1 if exists; 0 if it doesn't; -1 if it's wrong
118 */
119static int _control_exists(const char *control, uint32_t major, uint32_t minor)
120{
121 struct stat buf;
122
123 if (stat(control, &buf) < 0) {
124 if (errno != ENOENT)
125 log_sys_error("stat", control);
126 return 0;
127 }
128
129 if (!S_ISCHR(buf.st_mode)) {
130 log_verbose("%s: Wrong inode type", control);
131 if (!unlink(control))
132 return 0;
133 log_sys_error("unlink", control);
134 return -1;
135 }
136
137 if (major && buf.st_rdev != MKDEV(major, minor)) {
138 log_verbose("%s: Wrong device number: (%u, %u) instead of "
139 "(%u, %u)", control,
140 MAJOR(buf.st_mode), MINOR(buf.st_mode),
141 major, minor);
142 if (!unlink(control))
143 return 0;
144 log_sys_error("unlink", control);
145 return -1;
146 }
147
148 return 1;
149}
150
151static int _create_control(const char *control, uint32_t major, uint32_t minor)
152{
153 int ret;
154 mode_t old_umask;
155
156 if (!major)
157 return 0;
158
159 old_umask = umask(DM_DEV_DIR_UMASK);
160 ret = dm_create_dir(dm_dir());
161 umask(old_umask);
162
163 if (!ret)
164 return 0;
165
166 log_verbose("Creating device %s (%u, %u)", control, major, minor);
167
168 old_umask = umask(0);
169 if (mknod(control, S_IFCHR | DM_CONTROL_DEVICE_MODE,
170 MKDEV(major, minor)) < 0) {
171 umask(old_umask);
172 log_sys_error("mknod", control);
173 return 0;
174 }
175 umask(old_umask);
176 if (chown(control, DM_DEVICE_UID, DM_DEVICE_GID) == -1) {
177 log_sys_error("chown", control);
178 return 0;
179 }
180
181
182 return 1;
183}
184
185/* Check if major is device-mapper block device major number */
186int dm_is_dm_major(uint32_t major)
187{
188 uint32_t dm_major;
189
190 nbsd_get_dm_major(&dm_major, DM_BLOCK_MAJOR);
191
192 if (major == dm_major)
193 return 1;
194
195 return 0;
196}
197
198/* Open control device if doesn't exist create it. */
199static int _open_control(void)
200{
201 char control[PATH_MAX];
202 uint32_t major = 0, minor = 0;
203
204 if (_control_fd != -1)
205 return 1;
206
207#ifdef RUMP_ACTION
208 rump_init();
209#endif
210 snprintf(control, sizeof(control), "%s/control", dm_dir());
211
212 if (!_control_device_number(&major, &minor))
213 log_error("Is device-mapper driver missing from kernel?");
214
215 if (!_control_exists(control, major, minor) &&
216 !_create_control(control, major, minor))
217 goto error;
218
219 if ((_control_fd = open(control, O_RDWR)) < 0) {
220 log_sys_error("open", control);
221 goto error;
222 }
223
224 return 1;
225
226error:
227 log_error("Failure to communicate with kernel device-mapper driver.");
228 return 0;
229}
230
231/*
232 * Destroy dm task structure there are some dynamically alocated values there.
233 * name, uuid, head, tail list.
234 */
235void dm_task_destroy(struct dm_task *dmt)
236{
237 struct target *t, *n;
238
239 for (t = dmt->head; t; t = n) {
240 n = t->next;
241 dm_free(t->params);
242 dm_free(t->type);
243 dm_free(t);
244 }
245
246 if (dmt->dev_name)
247 dm_free(dmt->dev_name);
248
249 if (dmt->newname)
250 dm_free(dmt->newname);
251
252 if (dmt->message)
253 dm_free(dmt->message);
254
255 if (dmt->dmi.v4)
256 dm_free(dmt->dmi.v4);
257
258 if (dmt->uuid)
259 dm_free(dmt->uuid);
260
261 dm_free(dmt);
262
263}
264
265/* Get kernel driver version from dm_ioctl structure. */
266int dm_task_get_driver_version(struct dm_task *dmt, char *version, size_t size)
267{
268 unsigned *v;
269
270 if (!dmt->dmi.v4) {
271 version[0] = '\0';
272 return 0;
273 }
274
275 v = dmt->dmi.v4->version;
276 snprintf(version, size, "%u.%u.%u", v[0], v[1], v[2]);
277 _dm_version_minor = v[1];
278 _dm_version_patchlevel = v[2];
279
280 return 1;
281}
282
283/* Get kernel driver protocol version and comapre it with library version. */
284static int _check_version(char *version, size_t size)
285{
286 struct dm_task *task;
287 int r;
288
289 if (!(task = dm_task_create(DM_DEVICE_VERSION))) {
290 log_error("Failed to get device-mapper version");
291 version[0] = '\0';
292 return 0;
293 }
294
295 r = dm_task_run(task);
296 dm_task_get_driver_version(task, version, size);
297 dm_task_destroy(task);
298
299 return r;
300}
301
302/*
303 * Find out device-mapper's major version number the first time
304 * this is called and whether or not we support it.
305 */
306int dm_check_version(void)
307{
308 char dmversion[64];
309
310 if (_version_checked)
311 return _version_ok;
312
313 _version_checked = 1;
314
315 if (_check_version(dmversion, sizeof(dmversion)))
316 return 1;
317
318
319 return 0;
320}
321
322int dm_cookie_supported(void)
323{
324 return (0);
325}
326
327/* Get next target(table description) from list pointed by dmt->head. */
328void *dm_get_next_target(struct dm_task *dmt, void *next,
329 uint64_t *start, uint64_t *length,
330 char **target_type, char **params)
331{
332 struct target *t = (struct target *) next;
333
334 if (!t)
335 t = dmt->head;
336
337 if (!t)
338 return NULL;
339
340 *start = t->start;
341 *length = t->length;
342 *target_type = t->type;
343 *params = t->params;
344
345 return t->next;
346}
347
348/* Unmarshall the target info returned from a status call */
349static int _unmarshal_status(struct dm_task *dmt, struct dm_ioctl *dmi)
350{
351 char *outbuf = (char *) dmi + dmi->data_start;
352 char *outptr = outbuf;
353 uint32_t i;
354 struct dm_target_spec *spec;
355
356 for (i = 0; i < dmi->target_count; i++) {
357 spec = (struct dm_target_spec *) outptr;
358 if (!dm_task_add_target(dmt, spec->sector_start,
359 spec->length,
360 spec->target_type,
361 outptr + sizeof(*spec))) {
362 return 0;
363 }
364
365 outptr = outbuf + spec->next;
366 }
367
368 return 1;
369}
370
371static char *
372get_dev_name(dev_t dev)
373{
374 static char * const dirs[2] = { _PATH_DEV, NULL };
375 static char d_buf[MAXPATHLEN];
376 FTS *ftsp;
377 FTSENT *fe;
378 char *name;
379
380 if ((ftsp = fts_open(dirs, FTS_NOCHDIR | FTS_PHYSICAL, NULL)) == NULL)
381 return NULL;
382
383 name = NULL;
384 while ((fe = fts_read(ftsp)) != NULL) {
385 if (fe->fts_info != FTS_DEFAULT)
386 continue;
387 if (S_ISBLK(fe->fts_statp->st_mode)) {
388 if (fe->fts_statp->st_rdev == dev) {
389 strlcpy(d_buf, fe->fts_path, sizeof(d_buf));
390 name = d_buf;
391 break;
392 }
393 }
394 }
395
396 fts_close(ftsp);
397
398 return name;
399}
400
401/*
402 * @dev_major is major number of char device
403 *
404 * I have to find it's block device number and lookup dev in
405 * device database to find device path.
406 *
407 */
408
409int dm_format_dev(char *buf, int bufsize, uint32_t dev_major,
410 uint32_t dev_minor)
411{
412 int r;
413 uint32_t dm_major;
414 int major;
415 char *name;
416 mode_t mode;
417 dev_t dev;
418 size_t val_len,i;
419 struct kinfo_drivers *kd;
420
421 major = -1;
422 mode = 0;
423
424 nbsd_get_dm_major(&dm_major, DM_BLOCK_MAJOR);
425
426 if (bufsize < 8)
427 return 0;
428
429 if (sysctlbyname("kern.drivers",NULL,&val_len,NULL,0) < 0) {
430 printf("sysctlbyname failed\n");
431 return 0;
432 }
433
434 if ((kd = malloc (val_len)) == NULL){
435 printf("malloc kd info error\n");
436 return 0;
437 }
438
439 if (sysctlbyname("kern.drivers", kd, &val_len, NULL, 0) < 0) {
440 free(kd);
441 printf("sysctlbyname failed kd\n");
442 return 0;
443 }
444
445 for (i = 0, val_len /= sizeof(*kd); i < val_len; i++){
446 if (kd[i].d_cmajor == dev_major) {
447 major = kd[i].d_bmajor;
448 break;
449 }
450 }
451
452 if (major != -1) {
453 dev = MKDEV(major,dev_minor);
454 mode |= S_IFBLK;
455 if ((name = devname(dev,mode)) == NULL)
456 name = get_dev_name(dev);
457 } else
458 name = NULL;
459
460 free(kd);
461
462 if (name == NULL)
463 r = snprintf(buf, (size_t) bufsize, "%d:%d", dev_major, dev_minor);
464 else
465 r = snprintf(buf, (size_t) bufsize, _PATH_DEV "%s", name);
466
467 if (r < 0 || r > bufsize - 1)
468 return 0;
469
470 return 1;
471}
472
473/* Fill info from dm_ioctl structure. Look at DM_EXISTS_FLAG*/
474int dm_task_get_info(struct dm_task *dmt, struct dm_info *info)
475{
476 if (!dmt->dmi.v4)
477 return 0;
478
479 memset(info, 0, sizeof(*info));
480
481 info->exists = dmt->dmi.v4->flags & DM_EXISTS_FLAG ? 1 : 0;
482 if (!info->exists)
483 return 1;
484
485 info->suspended = dmt->dmi.v4->flags & DM_SUSPEND_FLAG ? 1 : 0;
486 info->read_only = dmt->dmi.v4->flags & DM_READONLY_FLAG ? 1 : 0;
487 info->live_table = dmt->dmi.v4->flags & DM_ACTIVE_PRESENT_FLAG ? 1 : 0;
488 info->inactive_table = dmt->dmi.v4->flags & DM_INACTIVE_PRESENT_FLAG ?
489 1 : 0;
490 info->target_count = dmt->dmi.v4->target_count;
491 info->open_count = dmt->dmi.v4->open_count;
492 info->event_nr = dmt->dmi.v4->event_nr;
493
494 nbsd_get_dm_major(&info->major, DM_BLOCK_MAJOR); /* get netbsd dm device major number */
495 info->minor = MINOR(dmt->dmi.v4->dev);
496
497 return 1;
498}
499
500/* Unsupported on NetBSD */
501uint32_t dm_task_get_read_ahead(const struct dm_task *dmt, uint32_t *read_ahead)
502{
503 *read_ahead = DM_READ_AHEAD_NONE;
504 return 1;
505}
506
507const char *dm_task_get_name(const struct dm_task *dmt)
508{
509
510 return (dmt->dmi.v4->name);
511}
512
513const char *dm_task_get_uuid(const struct dm_task *dmt)
514{
515
516 return (dmt->dmi.v4->uuid);
517}
518
519struct dm_deps *dm_task_get_deps(struct dm_task *dmt)
520{
521 return (struct dm_deps *) (((void *) dmt->dmi.v4) +
522 dmt->dmi.v4->data_start);
523}
524
525struct dm_names *dm_task_get_names(struct dm_task *dmt)
526{
527 return (struct dm_names *) (((void *) dmt->dmi.v4) +
528 dmt->dmi.v4->data_start);
529}
530
531struct dm_versions *dm_task_get_versions(struct dm_task *dmt)
532{
533 return (struct dm_versions *) (((void *) dmt->dmi.v4) +
534 dmt->dmi.v4->data_start);
535}
536
537int dm_task_set_ro(struct dm_task *dmt)
538{
539 dmt->read_only = 1;
540 return 1;
541}
542
543/* Unsupported on NetBSD */
544int dm_task_set_read_ahead(struct dm_task *dmt, uint32_t read_ahead,
545 uint32_t read_ahead_flags)
546{
547 return 1;
548}
549
550int dm_task_suppress_identical_reload(struct dm_task *dmt)
551{
552 dmt->suppress_identical_reload = 1;
553 return 1;
554}
555
556int dm_task_set_newname(struct dm_task *dmt, const char *newname)
557{
558 if (!(dmt->newname = dm_strdup(newname))) {
559 log_error("dm_task_set_newname: strdup(%s) failed", newname);
560 return 0;
561 }
562
563 return 1;
564}
565
566int dm_task_set_message(struct dm_task *dmt, const char *message)
567{
568 if (!(dmt->message = dm_strdup(message))) {
569 log_error("dm_task_set_message: strdup(%s) failed", message);
570 return 0;
571 }
572
573 return 1;
574}
575
576int dm_task_set_sector(struct dm_task *dmt, uint64_t sector)
577{
578 dmt->sector = sector;
579
580 return 1;
581}
582
583/* Unsupported in NetBSD */
584int dm_task_set_geometry(struct dm_task *dmt, const char *cylinders,
585 const char *heads, const char *sectors, const char *start)
586{
587 return 0;
588}
589
590int dm_task_no_flush(struct dm_task *dmt)
591{
592 dmt->no_flush = 1;
593
594 return 1;
595}
596
597int dm_task_no_open_count(struct dm_task *dmt)
598{
599 dmt->no_open_count = 1;
600
601 return 1;
602}
603
604int dm_task_skip_lockfs(struct dm_task *dmt)
605{
606 dmt->skip_lockfs = 1;
607
608 return 1;
609}
610
611int dm_task_query_inactive_table(struct dm_task *dmt)
612{
613 dmt->query_inactive_table = 1;
614
615 return 1;
616}
617
618int dm_task_set_event_nr(struct dm_task *dmt, uint32_t event_nr)
619{
620 dmt->event_nr = event_nr;
621
622 return 1;
623}
624
625/* Allocate one target(table description) entry. */
626struct target *create_target(uint64_t start, uint64_t len, const char *type,
627 const char *params)
628{
629 struct target *t = dm_malloc(sizeof(*t));
630
631 if (!t) {
632 log_error("create_target: malloc(%" PRIsize_t ") failed",
633 sizeof(*t));
634 return NULL;
635 }
636
637 memset(t, 0, sizeof(*t));
638
639 if (!(t->params = dm_strdup(params))) {
640 log_error("create_target: strdup(params) failed");
641 goto bad;
642 }
643
644 if (!(t->type = dm_strdup(type))) {
645 log_error("create_target: strdup(type) failed");
646 goto bad;
647 }
648
649 t->start = start;
650 t->length = len;
651 return t;
652
653 bad:
654 dm_free(t->params);
655 dm_free(t->type);
656 dm_free(t);
657 return NULL;
658}
659
660/* Parse given dm task structure to proplib dictionary. */
661static int _flatten(struct dm_task *dmt, libdm_task_t task)
662{
663 libdm_cmd_t cmd;
664 libdm_table_t table;
665
666 struct target *t;
667
668 size_t len;
669 char type[DM_MAX_TYPE_NAME];
670
671 uint32_t major, flags;
672 int count = 0;
673
674 flags = 0;
675
676 cmd = libdm_cmd_create();
677
678 for (t = dmt->head; t; t = t->next) {
679 strlcpy(type,t->type,DM_MAX_TYPE_NAME);
680
681 table = libdm_table_create();
682
683 libdm_table_set_start(t->start, table);
684 libdm_table_set_length(t->length, table);
685 libdm_table_set_target(type, table);
686 libdm_table_set_params(t->params, table);
687 libdm_cmd_set_table(table, cmd);
688
689 libdm_table_destroy(table);
690
691 count++;
692 }
693
694 if (count && (dmt->sector || dmt->message)) {
695 log_error("targets and message are incompatible");
696 return -1;
697 }
698
699 if (count && dmt->newname) {
700 log_error("targets and newname are incompatible");
701 return -1;
702 }
703
704 if (count && dmt->geometry) {
705 log_error("targets and geometry are incompatible");
706 return -1;
707 }
708
709 if (dmt->newname && (dmt->sector || dmt->message)) {
710 log_error("message and newname are incompatible");
711 return -1;
712 }
713
714 if (dmt->newname && dmt->geometry) {
715 log_error("geometry and newname are incompatible");
716 return -1;
717 }
718
719 if (dmt->geometry && (dmt->sector || dmt->message)) {
720 log_error("geometry and message are incompatible");
721 return -1;
722 }
723
724 if (dmt->sector && !dmt->message) {
725 log_error("message is required with sector");
726 return -1;
727 }
728
729 if (dmt->newname)
730 len += strlen(dmt->newname) + 1;
731
732 if (dmt->message)
733 len += sizeof(struct dm_target_msg) + strlen(dmt->message) + 1;
734
735 if (dmt->geometry)
736 len += strlen(dmt->geometry) + 1;
737
738 nbsd_get_dm_major(&major, DM_BLOCK_MAJOR);
739 /*
740 * Only devices with major which is equal to netbsd dm major
741 * dm devices in NetBSD can't have more majors then one assigned to dm.
742 */
743 if (dmt->major != major && dmt->major != -1)
744 return -1;
745
746 if (dmt->minor >= 0) {
747 flags |= DM_PERSISTENT_DEV_FLAG;
748 libdm_task_set_minor(dmt->minor, task);
749 }
750
751 /* Set values to dictionary. */
752 if (dmt->dev_name)
753 libdm_task_set_name(dmt->dev_name, task);
754
755 if (dmt->uuid)
756 libdm_task_set_uuid(dmt->uuid, task);
757
758 if (dmt->type == DM_DEVICE_SUSPEND)
759 flags |= DM_SUSPEND_FLAG;
760 if (dmt->no_flush)
761 flags |= DM_NOFLUSH_FLAG;
762 if (dmt->read_only)
763 flags |= DM_READONLY_FLAG;
764 if (dmt->skip_lockfs)
765 flags |= DM_SKIP_LOCKFS_FLAG;
766
767 if (dmt->query_inactive_table) {
768 if (_dm_version_minor < 16)
769 log_warn("WARNING: Inactive table query unsupported "
770 "by kernel. It will use live table.");
771 flags |= DM_QUERY_INACTIVE_TABLE_FLAG;
772 }
773
774 libdm_task_set_flags(task, flags);
775
776// prop_dictionary_set_uint32(dm_dict, DM_IOCTL_EVENT, dmt->event_nr);
777
778 if (dmt->newname)
779 libdm_dev_set_newname(dmt->newname, cmd);
780
781 /* Add array for all COMMAND specific data. */
782 libdm_task_set_cmd(cmd, task);
783 libdm_cmd_destroy(cmd);
784
785 return 0;
786}
787
788static int _process_mapper_dir(struct dm_task *dmt)
789{
790 struct dirent *dirent;
791 DIR *d;
792 const char *dir;
793 int r = 1;
794
795 dir = dm_dir();
796 if (!(d = opendir(dir))) {
797 log_sys_error("opendir", dir);
798 return 0;
799 }
800
801 while ((dirent = readdir(d))) {
802 if (!strcmp(dirent->d_name, ".") ||
803 !strcmp(dirent->d_name, "..") ||
804 !strcmp(dirent->d_name, "control"))
805 continue;
806 dm_task_set_name(dmt, dirent->d_name);
807 dm_task_run(dmt);
808 }
809
810 if (closedir(d))
811 log_sys_error("closedir", dir);
812
813 return r;
814}
815
816/* Get list of all devices. */
817static int _process_all_v4(struct dm_task *dmt)
818{
819 struct dm_task *task;
820 struct dm_names *names;
821 unsigned next = 0;
822 int r = 1;
823
824 if (!(task = dm_task_create(DM_DEVICE_LIST)))
825 return 0;
826
827 if (!dm_task_run(task)) {
828 r = 0;
829 goto out;
830 }
831
832 if (!(names = dm_task_get_names(task))) {
833 r = 0;
834 goto out;
835 }
836
837 if (!names->dev)
838 goto out;
839
840 do {
841 names = (void *) names + next;
842 if (!dm_task_set_name(dmt, names->name)) {
843 r = 0;
844 goto out;
845 }
846 if (!dm_task_run(dmt))
847 r = 0;
848 next = names->next;
849 } while (next);
850
851 out:
852 dm_task_destroy(task);
853 return r;
854}
855
856static int _mknodes_v4(struct dm_task *dmt)
857{
858 (void) _process_mapper_dir(dmt);
859
860 return _process_all_v4(dmt);
861}
862
863/* Create new device and load table to it. */
864static int _create_and_load_v4(struct dm_task *dmt)
865{
866 struct dm_task *task;
867 int r;
868
869 printf("create and load called \n");
870
871 /* Use new task struct to create the device */
872 if (!(task = dm_task_create(DM_DEVICE_CREATE))) {
873 log_error("Failed to create device-mapper task struct");
874 return 0;
875 }
876
877 /* Copy across relevant fields */
878 if (dmt->dev_name && !dm_task_set_name(task, dmt->dev_name)) {
879 dm_task_destroy(task);
880 return 0;
881 }
882
883 if (dmt->uuid && !dm_task_set_uuid(task, dmt->uuid)) {
884 dm_task_destroy(task);
885 return 0;
886 }
887
888 task->major = dmt->major;
889 task->minor = dmt->minor;
890 task->uid = dmt->uid;
891 task->gid = dmt->gid;
892 task->mode = dmt->mode;
893
894 r = dm_task_run(task);
895 dm_task_destroy(task);
896 if (!r)
897 return r;
898
899 /* Next load the table */
900 if (!(task = dm_task_create(DM_DEVICE_RELOAD))) {
901 log_error("Failed to create device-mapper task struct");
902 return 0;
903 }
904
905 /* Copy across relevant fields */
906 if (dmt->dev_name && !dm_task_set_name(task, dmt->dev_name)) {
907 dm_task_destroy(task);
908 return 0;
909 }
910
911 task->read_only = dmt->read_only;
912 task->head = dmt->head;
913 task->tail = dmt->tail;
914
915 r = dm_task_run(task);
916
917 task->head = NULL;
918 task->tail = NULL;
919 dm_task_destroy(task);
920 if (!r)
921 goto revert;
922
923 /* Use the original structure last so the info will be correct */
924 dmt->type = DM_DEVICE_RESUME;
925 dm_free(dmt->uuid);
926 dmt->uuid = NULL;
927
928 r = dm_task_run(dmt);
929
930 if (r)
931 return r;
932
933 revert:
934 dmt->type = DM_DEVICE_REMOVE;
935 dm_free(dmt->uuid);
936 dmt->uuid = NULL;
937
938 if (!dm_task_run(dmt))
939 log_error("Failed to revert device creation.");
940
941 return r;
942}
943
944uint64_t dm_task_get_existing_table_size(struct dm_task *dmt)
945{
946 return dmt->existing_table_size;
947}
948
949static int _reload_with_suppression_v4(struct dm_task *dmt)
950{
951 struct dm_task *task;
952 struct target *t1, *t2;
953 int r;
954
955 /* New task to get existing table information */
956 if (!(task = dm_task_create(DM_DEVICE_TABLE))) {
957 log_error("Failed to create device-mapper task struct");
958 return 0;
959 }
960
961 /* Copy across relevant fields */
962 if (dmt->dev_name && !dm_task_set_name(task, dmt->dev_name)) {
963 dm_task_destroy(task);
964 return 0;
965 }
966
967 if (dmt->uuid && !dm_task_set_uuid(task, dmt->uuid)) {
968 dm_task_destroy(task);
969 return 0;
970 }
971
972 task->major = dmt->major;
973 task->minor = dmt->minor;
974
975 r = dm_task_run(task);
976
977 if (!r) {
978 dm_task_destroy(task);
979 return r;
980 }
981
982 /* Store existing table size */
983 t2 = task->head;
984 while (t2 && t2->next)
985 t2 = t2->next;
986 dmt->existing_table_size = t2 ? t2->start + t2->length : 0;
987
988 if ((task->dmi.v4->flags & DM_READONLY_FLAG) ? 1 : 0 != dmt->read_only)
989 goto no_match;
990
991 t1 = dmt->head;
992 t2 = task->head;
993
994 while (t1 && t2) {
995 while (t2->params[strlen(t2->params) - 1] == ' ')
996 t2->params[strlen(t2->params) - 1] = '\0';
997 if ((t1->start != t2->start) ||
998 (t1->length != t2->length) ||
999 (strcmp(t1->type, t2->type)) ||
1000 (strcmp(t1->params, t2->params)))
1001 goto no_match;
1002 t1 = t1->next;
1003 t2 = t2->next;
1004 }
1005
1006 if (!t1 && !t2) {
1007 dmt->dmi.v4 = task->dmi.v4;
1008 task->dmi.v4 = NULL;
1009 dm_task_destroy(task);
1010 return 1;
1011 }
1012
1013no_match:
1014 dm_task_destroy(task);
1015
1016 /* Now do the original reload */
1017 dmt->suppress_identical_reload = 0;
1018 r = dm_task_run(dmt);
1019
1020 return r;
1021}
1022
1023/*
1024 * This function is heart of NetBSD libdevmapper-> device-mapper kernel protocol
1025 * It creates proplib_dictionary from dm task structure and sends it to NetBSD
1026 * kernel driver. After succesfull ioctl it create dmi structure from returned
1027 * proplib dictionary. This way I keep number of changes in NetBSD version of
1028 * libdevmapper as small as posible.
1029 */
1030static struct dm_ioctl *_do_dm_ioctl(struct dm_task *dmt, unsigned command)
1031{
1032 struct dm_ioctl *dmi;
1033 libdm_task_t task;
1034
1035 task = libdm_task_create(_cmd_data_v4[dmt->type].name);
1036
1037 /* Parse dmi from libdevmapper to dictionary */
1038 if (_flatten(dmt, task) < 0)
1039 goto bad;
1040
1041 if (dmt->type == DM_DEVICE_TABLE)
1042 libdm_task_set_status_flag(task);
1043
1044 libdm_task_set_exists_flag(task);
1045
1046 log_very_verbose("Ioctl type %s --- flags %d",_cmd_data_v4[dmt->type].name, libdm_task_get_flags(task));
1047 /* Send dictionary to kernel and wait for reply. */
1048 if (libdm_task_run(task) != 0) {
1049 if (errno == ENOENT &&
1050 ((dmt->type == DM_DEVICE_INFO) ||
1051 (dmt->type == DM_DEVICE_MKNODES) ||
1052 (dmt->type == DM_DEVICE_STATUS))) {
1053
1054 /*
1055 * Linux version doesn't fail when ENOENT is returned
1056 * for nonexisting device after info, deps, mknodes call.
1057 * It returns dmi sent to kernel with DM_EXISTS_FLAG = 0;
1058 */
1059
1060 dmi = nbsd_dm_dict_to_dmi(task, _cmd_data_v4[dmt->type].cmd);
1061
1062 libdm_task_del_exists_flag(task);
1063
1064 libdm_task_destroy(task);
1065
1066 goto out;
1067 } else {
1068 log_error("ioctl %s call failed with errno %d\n",
1069 _cmd_data_v4[dmt->type].name, errno);
1070 libdm_task_destroy(task);
1071 goto bad;
1072 }
1073 }
1074
1075 /* Parse kernel dictionary to dmi structure and return it to libdevmapper. */
1076 dmi = nbsd_dm_dict_to_dmi(task, _cmd_data_v4[dmt->type].cmd);
1077
1078 libdm_task_destroy(task);
1079out:
1080 return dmi;
1081bad:
1082 return NULL;
1083}
1084
1085/* Create new edvice nodes in mapper/ dir. */
1086void dm_task_update_nodes(void)
1087{
1088 update_devs();
1089}
1090
1091/* Run dm command which is descirbed in dm_task structure. */
1092int dm_task_run(struct dm_task *dmt)
1093{
1094 struct dm_ioctl *dmi;
1095 unsigned command;
1096
1097 if ((unsigned) dmt->type >=
1098 (sizeof(_cmd_data_v4) / sizeof(*_cmd_data_v4))) {
1099 log_error("Internal error: unknown device-mapper task %d",
1100 dmt->type);
1101 return 0;
1102 }
1103
1104 command = _cmd_data_v4[dmt->type].cmd;
1105
1106 /* Old-style creation had a table supplied */
1107 if (dmt->type == DM_DEVICE_CREATE && dmt->head)
1108 return _create_and_load_v4(dmt);
1109
1110 if (dmt->type == DM_DEVICE_MKNODES && !dmt->dev_name &&
1111 !dmt->uuid && dmt->major <= 0)
1112 return _mknodes_v4(dmt);
1113
1114 if ((dmt->type == DM_DEVICE_RELOAD) && dmt->suppress_identical_reload)
1115 return _reload_with_suppression_v4(dmt);
1116
1117 if (!_open_control())
1118 return 0;
1119
1120 if (!(dmi = _do_dm_ioctl(dmt, command)))
1121 return 0;
1122
1123 switch (dmt->type) {
1124 case DM_DEVICE_CREATE:
1125 add_dev_node(dmt->dev_name, MAJOR(dmi->dev), MINOR(dmi->dev),
1126 dmt->uid, dmt->gid, dmt->mode, 0);
1127 break;
1128
1129 case DM_DEVICE_REMOVE:
1130 /* FIXME Kernel needs to fill in dmi->name */
1131 if (dmt->dev_name)
1132 rm_dev_node(dmt->dev_name, 0);
1133 break;
1134
1135 case DM_DEVICE_RENAME:
1136 /* FIXME Kernel needs to fill in dmi->name */
1137 if (dmt->dev_name)
1138 rename_dev_node(dmt->dev_name, dmt->newname, 0);
1139 break;
1140
1141 case DM_DEVICE_RESUME:
1142 /* FIXME Kernel needs to fill in dmi->name */
1143 set_dev_node_read_ahead(dmt->dev_name, dmt->read_ahead,
1144 dmt->read_ahead_flags);
1145 break;
1146
1147 case DM_DEVICE_MKNODES:
1148 if (dmi->flags & DM_EXISTS_FLAG)
1149 add_dev_node(dmi->name, MAJOR(dmi->dev),
1150 MINOR(dmi->dev),
1151 dmt->uid, dmt->gid, dmt->mode, 0);
1152 else if (dmt->dev_name)
1153 rm_dev_node(dmt->dev_name, 0);
1154 break;
1155
1156 case DM_DEVICE_STATUS:
1157 case DM_DEVICE_TABLE:
1158 case DM_DEVICE_WAITEVENT:
1159 if (!_unmarshal_status(dmt, dmi))
1160 goto bad;
1161 break;
1162 }
1163
1164 /* Was structure reused? */
1165 if (dmt->dmi.v4)
1166 dm_free(dmt->dmi.v4);
1167
1168 dmt->dmi.v4 = dmi;
1169 return 1;
1170
1171 bad:
1172 dm_free(dmi);
1173 return 0;
1174}
1175
1176void dm_lib_release(void)
1177{
1178 if (_control_fd != -1) {
1179 close(_control_fd);
1180 _control_fd = -1;
1181 }
1182 update_devs();
1183}
1184
1185void dm_lib_exit(void)
1186{
1187 dm_lib_release();
1188 dm_dump_memory();
1189 _version_ok = 1;
1190 _version_checked = 0;
1191}
1192