dmctl.c revision 1.2.2.2 1 1.2.2.2 bouyer /*
2 1.2.2.2 bouyer * Copyright (c) 2010 The NetBSD Foundation, Inc.
3 1.2.2.2 bouyer * All rights reserved.
4 1.2.2.2 bouyer *
5 1.2.2.2 bouyer * This code is derived from software contributed to The NetBSD Foundation
6 1.2.2.2 bouyer * by Adam Hamsik.
7 1.2.2.2 bouyer *
8 1.2.2.2 bouyer * Redistribution and use in source and binary forms, with or without
9 1.2.2.2 bouyer * modification, are permitted provided that the following conditions
10 1.2.2.2 bouyer * are met:
11 1.2.2.2 bouyer * 1. Redistributions of source code must retain the above copyright
12 1.2.2.2 bouyer * notice, this list of conditions and the following disclaimer.
13 1.2.2.2 bouyer * 2. Redistributions in binary form must reproduce the above copyright
14 1.2.2.2 bouyer * notice, this list of conditions and the following disclaimer in the
15 1.2.2.2 bouyer * documentation and/or other materials provided with the distribution.
16 1.2.2.2 bouyer *
17 1.2.2.2 bouyer * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
18 1.2.2.2 bouyer * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
19 1.2.2.2 bouyer * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
20 1.2.2.2 bouyer * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
21 1.2.2.2 bouyer * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
22 1.2.2.2 bouyer * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
23 1.2.2.2 bouyer * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
24 1.2.2.2 bouyer * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
25 1.2.2.2 bouyer * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
26 1.2.2.2 bouyer * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27 1.2.2.2 bouyer * POSSIBILITY OF SUCH DAMAGE.
28 1.2.2.2 bouyer */
29 1.2.2.2 bouyer
30 1.2.2.2 bouyer #include <sys/types.h>
31 1.2.2.2 bouyer #include <sys/param.h>
32 1.2.2.2 bouyer
33 1.2.2.2 bouyer #include <ctype.h>
34 1.2.2.2 bouyer #include <err.h>
35 1.2.2.2 bouyer #include <errno.h>
36 1.2.2.2 bouyer #include <stdio.h>
37 1.2.2.2 bouyer #include <stdlib.h>
38 1.2.2.2 bouyer #include <string.h>
39 1.2.2.2 bouyer
40 1.2.2.2 bouyer #include <prop/proplib.h>
41 1.2.2.2 bouyer
42 1.2.2.2 bouyer #include <dm.h>
43 1.2.2.2 bouyer
44 1.2.2.2 bouyer #ifdef RUMP_ACTION
45 1.2.2.2 bouyer #include <rump/rump.h>
46 1.2.2.2 bouyer #include <rump/rumpclient.h>
47 1.2.2.2 bouyer #include <rump/rump_syscalls.h>
48 1.2.2.2 bouyer #endif
49 1.2.2.2 bouyer
50 1.2.2.2 bouyer /* dmctl command is used to communicate with device-mapper driver in NetBSD
51 1.2.2.2 bouyer * it uses libdm library to create and send required data to kernel.
52 1.2.2.2 bouyer *
53 1.2.2.2 bouyer * Main purpose of dmctl is to add posibility to use device-mapper driver
54 1.2.2.2 bouyer * from outside of LVM scope.
55 1.2.2.2 bouyer */
56 1.2.2.2 bouyer
57 1.2.2.2 bouyer #define DMCTL_CMD_REQ_NODEVNAME 0 /* Command do not require device name */
58 1.2.2.2 bouyer #define DMCTL_CMD_REQ_DEVNAME 1 /* Command require device name to work */
59 1.2.2.2 bouyer #define DMCTL_CMD_REQ_NEWNAME 2 /* Command require device name and
60 1.2.2.2 bouyer newname to work */
61 1.2.2.2 bouyer struct command {
62 1.2.2.2 bouyer const char *cmd_name;
63 1.2.2.2 bouyer const char *cmd_help;
64 1.2.2.2 bouyer const char *ioctl_cmd_name;
65 1.2.2.2 bouyer int min_args;
66 1.2.2.2 bouyer int (*cmd_func)(int, char *[], libdm_task_t);
67 1.2.2.2 bouyer };
68 1.2.2.2 bouyer
69 1.2.2.2 bouyer int fd; /* file descriptor for device */
70 1.2.2.2 bouyer const char *dvname; /* device name */
71 1.2.2.2 bouyer const char *cmdname; /* command user issued */
72 1.2.2.2 bouyer
73 1.2.2.2 bouyer static char * parse_stdin(char *);
74 1.2.2.2 bouyer
75 1.2.2.2 bouyer static int dmctl_get_version(int, char *[], libdm_task_t);
76 1.2.2.2 bouyer static int dmctl_get_targets(int, char *[], libdm_task_t);
77 1.2.2.2 bouyer static int dmctl_get_device_info(int, char *[], libdm_task_t);
78 1.2.2.2 bouyer static int dmctl_create_dev(int, char *[], libdm_task_t);
79 1.2.2.2 bouyer static int dmctl_dev_rename(int, char *[], libdm_task_t);
80 1.2.2.2 bouyer static int dmctl_dev_remove(int, char *[], libdm_task_t);
81 1.2.2.2 bouyer static int dmctl_dev_resume(int, char *[], libdm_task_t);
82 1.2.2.2 bouyer static int dmctl_dev_suspend(int, char *[], libdm_task_t);
83 1.2.2.2 bouyer static int dmctl_dev_deps(int, char *[], libdm_task_t);
84 1.2.2.2 bouyer static int dmctl_list_devices(int, char *[], libdm_task_t);
85 1.2.2.2 bouyer static int dmctl_table_reload(int, char *[], libdm_task_t);
86 1.2.2.2 bouyer static int dmctl_table_status(int, char *[], libdm_task_t);
87 1.2.2.2 bouyer void usage(void);
88 1.2.2.2 bouyer
89 1.2.2.2 bouyer struct command commands[] = {
90 1.2.2.2 bouyer { "version",
91 1.2.2.2 bouyer "Print driver and lib version.",
92 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_NODEVNAME,
93 1.2.2.2 bouyer dmctl_get_version },
94 1.2.2.2 bouyer { "targets",
95 1.2.2.2 bouyer "List available kernel targets.",
96 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_NODEVNAME,
97 1.2.2.2 bouyer dmctl_get_targets },
98 1.2.2.2 bouyer { "create",
99 1.2.2.2 bouyer "Create device with [dm device name].",
100 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
101 1.2.2.2 bouyer dmctl_create_dev },
102 1.2.2.2 bouyer { "ls",
103 1.2.2.2 bouyer "List existing dm devices.",
104 1.2.2.2 bouyer "names", DMCTL_CMD_REQ_NODEVNAME,
105 1.2.2.2 bouyer dmctl_list_devices },
106 1.2.2.2 bouyer { "info",
107 1.2.2.2 bouyer "Get info about device with [dm device name].",
108 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
109 1.2.2.2 bouyer dmctl_get_device_info },
110 1.2.2.2 bouyer { "rename",
111 1.2.2.2 bouyer "Rename device with [dm device name] to [dm device new name].",
112 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_NEWNAME,
113 1.2.2.2 bouyer dmctl_dev_rename },
114 1.2.2.2 bouyer { "remove",
115 1.2.2.2 bouyer "Remove device with [dm device name].",
116 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
117 1.2.2.2 bouyer dmctl_dev_remove },
118 1.2.2.2 bouyer { "resume",
119 1.2.2.2 bouyer "Resume IO on dm device [dm device name].",
120 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
121 1.2.2.2 bouyer dmctl_dev_resume },
122 1.2.2.2 bouyer { "suspend",
123 1.2.2.2 bouyer "Suspend IO on dm device [dm device name].",
124 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
125 1.2.2.2 bouyer dmctl_dev_suspend },
126 1.2.2.2 bouyer { "deps",
127 1.2.2.2 bouyer "Print physical dependiences for dm device [dm device name].",
128 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
129 1.2.2.2 bouyer dmctl_dev_deps },
130 1.2.2.2 bouyer { "reload",
131 1.2.2.2 bouyer "Switch active and passive tables for device with [dm device name].",
132 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
133 1.2.2.2 bouyer dmctl_table_reload },
134 1.2.2.2 bouyer { "status",
135 1.2.2.2 bouyer "Print status for device with [dm device name].",
136 1.2.2.2 bouyer "table", DMCTL_CMD_REQ_DEVNAME,
137 1.2.2.2 bouyer dmctl_table_status },
138 1.2.2.2 bouyer { "table",
139 1.2.2.2 bouyer "Print active table for device with [dm device name].",
140 1.2.2.2 bouyer NULL, DMCTL_CMD_REQ_DEVNAME,
141 1.2.2.2 bouyer dmctl_table_status },
142 1.2.2.2 bouyer { NULL,
143 1.2.2.2 bouyer NULL,
144 1.2.2.2 bouyer NULL, 0,
145 1.2.2.2 bouyer NULL },
146 1.2.2.2 bouyer };
147 1.2.2.2 bouyer
148 1.2.2.2 bouyer int
149 1.2.2.2 bouyer main(int argc, char *argv[])
150 1.2.2.2 bouyer {
151 1.2.2.2 bouyer int i;
152 1.2.2.2 bouyer int oargc;
153 1.2.2.2 bouyer libdm_task_t task;
154 1.2.2.2 bouyer
155 1.2.2.2 bouyer oargc = 0;
156 1.2.2.2 bouyer
157 1.2.2.2 bouyer #ifdef RUMP_ACTION
158 1.2.2.2 bouyer if (rumpclient_init() == -1)
159 1.2.2.2 bouyer err(EXIT_FAILURE, "rump client init failed");
160 1.2.2.2 bouyer #endif
161 1.2.2.2 bouyer
162 1.2.2.2 bouyer /* Must have at least: device command */
163 1.2.2.2 bouyer if (argc < 2)
164 1.2.2.2 bouyer usage();
165 1.2.2.2 bouyer
166 1.2.2.2 bouyer /* Skip program name, get and skip device name and command. */
167 1.2.2.2 bouyer cmdname = argv[1];
168 1.2.2.2 bouyer if (argc > 2) {
169 1.2.2.2 bouyer oargc = 1;
170 1.2.2.2 bouyer dvname = argv[2];
171 1.2.2.2 bouyer }
172 1.2.2.2 bouyer
173 1.2.2.2 bouyer if (argc > 3) {
174 1.2.2.2 bouyer argv += 3;
175 1.2.2.2 bouyer argc -= 3;
176 1.2.2.2 bouyer oargc = 2;
177 1.2.2.2 bouyer } else {
178 1.2.2.2 bouyer argv = 0;
179 1.2.2.2 bouyer argc = 0;
180 1.2.2.2 bouyer }
181 1.2.2.2 bouyer
182 1.2.2.2 bouyer for (i = 0; commands[i].cmd_name != NULL; i++)
183 1.2.2.2 bouyer if (strcmp(cmdname, commands[i].cmd_name) == 0)
184 1.2.2.2 bouyer break;
185 1.2.2.2 bouyer
186 1.2.2.2 bouyer if (commands[i].cmd_name == NULL)
187 1.2.2.2 bouyer errx(EXIT_FAILURE, "unknown command: %s", cmdname);
188 1.2.2.2 bouyer
189 1.2.2.2 bouyer if (commands[i].ioctl_cmd_name != NULL)
190 1.2.2.2 bouyer cmdname = commands[i].ioctl_cmd_name;
191 1.2.2.2 bouyer
192 1.2.2.2 bouyer if (oargc != commands[i].min_args) {
193 1.2.2.2 bouyer (void)fprintf(stderr, "Insufficient number of arguments for "
194 1.2.2.2 bouyer "command: %s specified\n", commands[i].cmd_name);
195 1.2.2.2 bouyer usage();
196 1.2.2.2 bouyer }
197 1.2.2.2 bouyer
198 1.2.2.2 bouyer /*
199 1.2.2.2 bouyer * Create libdm task, and pass it to command handler later.
200 1.2.2.2 bouyer * Don't release it here because it will be replaced by different
201 1.2.2.2 bouyer * dictionary received from kernel after libdm_task_run.
202 1.2.2.2 bouyer */
203 1.2.2.2 bouyer task = libdm_task_create(cmdname);
204 1.2.2.2 bouyer
205 1.2.2.2 bouyer (*commands[i].cmd_func)(argc, argv, task);
206 1.2.2.2 bouyer
207 1.2.2.2 bouyer return 0;
208 1.2.2.2 bouyer }
209 1.2.2.2 bouyer
210 1.2.2.2 bouyer /*
211 1.2.2.2 bouyer * Print library and kernel driver versions if command can be used only when
212 1.2.2.2 bouyer * major, minor number of library version is <= kernel.
213 1.2.2.2 bouyer */
214 1.2.2.2 bouyer static int
215 1.2.2.2 bouyer dmctl_get_version(int argc __unused, char *argv[] __unused, libdm_task_t task)
216 1.2.2.2 bouyer {
217 1.2.2.2 bouyer uint32_t ver[3], size;
218 1.2.2.2 bouyer
219 1.2.2.2 bouyer size = libdm_task_get_cmd_version(task, ver, sizeof(ver));
220 1.2.2.2 bouyer
221 1.2.2.2 bouyer printf("Library protocol version %d:%d:%d\n", ver[0], ver[1], ver[2]);
222 1.2.2.2 bouyer
223 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
224 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_get_version: libdm_task_run failed.");
225 1.2.2.2 bouyer
226 1.2.2.2 bouyer size = libdm_task_get_cmd_version(task, ver, 3);
227 1.2.2.2 bouyer printf("Kernel protocol version %d:%d:%d\n",ver[0], ver[1], ver[2]);
228 1.2.2.2 bouyer
229 1.2.2.2 bouyer libdm_task_destroy(task);
230 1.2.2.2 bouyer return 0;
231 1.2.2.2 bouyer }
232 1.2.2.2 bouyer
233 1.2.2.2 bouyer /*
234 1.2.2.2 bouyer * Get list of available targets from kernel and print them.
235 1.2.2.2 bouyer */
236 1.2.2.2 bouyer static int
237 1.2.2.2 bouyer dmctl_get_targets(int argc __unused, char *argv[] __unused, libdm_task_t task)
238 1.2.2.2 bouyer {
239 1.2.2.2 bouyer libdm_cmd_t cmd;
240 1.2.2.2 bouyer libdm_iter_t iter;
241 1.2.2.2 bouyer libdm_target_t target;
242 1.2.2.2 bouyer uint32_t ver[3];
243 1.2.2.2 bouyer
244 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
245 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_get_targets: libdm_task_run failed.");
246 1.2.2.2 bouyer
247 1.2.2.2 bouyer if ((cmd = libdm_task_get_cmd(task)) == NULL)
248 1.2.2.2 bouyer return ENOENT;
249 1.2.2.2 bouyer
250 1.2.2.2 bouyer iter = libdm_cmd_iter_create(cmd);
251 1.2.2.2 bouyer
252 1.2.2.2 bouyer while((target = libdm_cmd_get_target(iter)) != NULL){
253 1.2.2.2 bouyer printf("Target name: %s\n", libdm_target_get_name(target));
254 1.2.2.2 bouyer
255 1.2.2.2 bouyer libdm_target_get_version(target, ver, sizeof(ver));
256 1.2.2.2 bouyer printf("Target version %d.%d.%d\n\n", ver[0], ver[1], ver[2]);
257 1.2.2.2 bouyer
258 1.2.2.2 bouyer libdm_target_destroy(target);
259 1.2.2.2 bouyer }
260 1.2.2.2 bouyer
261 1.2.2.2 bouyer libdm_iter_destroy(iter);
262 1.2.2.2 bouyer libdm_cmd_destroy(cmd);
263 1.2.2.2 bouyer libdm_task_destroy(task);
264 1.2.2.2 bouyer
265 1.2.2.2 bouyer return 0;
266 1.2.2.2 bouyer }
267 1.2.2.2 bouyer
268 1.2.2.2 bouyer /*
269 1.2.2.2 bouyer * Create device with name used as second parameter.
270 1.2.2.2 bouyer * TODO: Support for UUIDs here.
271 1.2.2.2 bouyer */
272 1.2.2.2 bouyer static int
273 1.2.2.2 bouyer dmctl_create_dev(int argc __unused, char *argv[] __unused, libdm_task_t task)
274 1.2.2.2 bouyer {
275 1.2.2.2 bouyer
276 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
277 1.2.2.2 bouyer
278 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
279 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_create_dev: libdm_task_run failed.");
280 1.2.2.2 bouyer
281 1.2.2.2 bouyer libdm_task_destroy(task);
282 1.2.2.2 bouyer return 0;
283 1.2.2.2 bouyer }
284 1.2.2.2 bouyer
285 1.2.2.2 bouyer /*
286 1.2.2.2 bouyer * Get basic device info from device-mapper driver.
287 1.2.2.2 bouyer */
288 1.2.2.2 bouyer static int
289 1.2.2.2 bouyer dmctl_get_device_info(int argc __unused, char *argv[] __unused, libdm_task_t task)
290 1.2.2.2 bouyer {
291 1.2.2.2 bouyer
292 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
293 1.2.2.2 bouyer
294 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
295 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_get_device_info: libdm_task_run failed.\n");
296 1.2.2.2 bouyer
297 1.2.2.2 bouyer printf("Printing Device info for:\n");
298 1.2.2.2 bouyer printf("Device name: \t\t%s\n", libdm_task_get_name(task));
299 1.2.2.2 bouyer printf("Device uuid: \t\t%s\n", libdm_task_get_uuid(task));
300 1.2.2.2 bouyer printf("Device minor: \t\t%d\n", libdm_task_get_minor(task));
301 1.2.2.2 bouyer printf("Device target number: \t%d\n", libdm_task_get_target_num(task));
302 1.2.2.2 bouyer printf("Device flags: \t\t%d\n", libdm_task_get_flags(task));
303 1.2.2.2 bouyer
304 1.2.2.2 bouyer libdm_task_destroy(task);
305 1.2.2.2 bouyer return 0;
306 1.2.2.2 bouyer }
307 1.2.2.2 bouyer
308 1.2.2.2 bouyer /*
309 1.2.2.2 bouyer * List all device in device-mapper driver.
310 1.2.2.2 bouyer */
311 1.2.2.2 bouyer static int
312 1.2.2.2 bouyer dmctl_list_devices(int argc __unused, char *argv[] __unused, libdm_task_t task)
313 1.2.2.2 bouyer {
314 1.2.2.2 bouyer libdm_cmd_t cmd;
315 1.2.2.2 bouyer libdm_iter_t iter;
316 1.2.2.2 bouyer libdm_dev_t dev;
317 1.2.2.2 bouyer
318 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
319 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_list_devices: libdm_task_run failed.");
320 1.2.2.2 bouyer
321 1.2.2.2 bouyer if ((cmd = libdm_task_get_cmd(task)) == NULL)
322 1.2.2.2 bouyer return ENOENT;
323 1.2.2.2 bouyer
324 1.2.2.2 bouyer iter = libdm_cmd_iter_create(cmd);
325 1.2.2.2 bouyer
326 1.2.2.2 bouyer while((dev = libdm_cmd_get_dev(iter)) != NULL){
327 1.2.2.2 bouyer printf("Device name: %s, device minor: %d \n",
328 1.2.2.2 bouyer libdm_dev_get_name(dev), libdm_dev_get_minor(dev));
329 1.2.2.2 bouyer libdm_dev_destroy(dev);
330 1.2.2.2 bouyer }
331 1.2.2.2 bouyer
332 1.2.2.2 bouyer libdm_iter_destroy(iter);
333 1.2.2.2 bouyer libdm_cmd_destroy(cmd);
334 1.2.2.2 bouyer libdm_task_destroy(task);
335 1.2.2.2 bouyer
336 1.2.2.2 bouyer return 0;
337 1.2.2.2 bouyer }
338 1.2.2.2 bouyer
339 1.2.2.2 bouyer /*
340 1.2.2.2 bouyer * Rename device to new name
341 1.2.2.2 bouyer */
342 1.2.2.2 bouyer static int
343 1.2.2.2 bouyer dmctl_dev_rename(int argc __unused, char *argv[], libdm_task_t task)
344 1.2.2.2 bouyer {
345 1.2.2.2 bouyer libdm_cmd_t cmd;
346 1.2.2.2 bouyer
347 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
348 1.2.2.2 bouyer
349 1.2.2.2 bouyer cmd = libdm_cmd_create();
350 1.2.2.2 bouyer libdm_dev_set_newname(argv[0], cmd);
351 1.2.2.2 bouyer libdm_task_set_cmd(cmd, task);
352 1.2.2.2 bouyer
353 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
354 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_dev_rename: libdm_task_run failed.");
355 1.2.2.2 bouyer
356 1.2.2.2 bouyer libdm_cmd_destroy(cmd);
357 1.2.2.2 bouyer libdm_task_destroy(task);
358 1.2.2.2 bouyer
359 1.2.2.2 bouyer return 0;
360 1.2.2.2 bouyer }
361 1.2.2.2 bouyer
362 1.2.2.2 bouyer /*
363 1.2.2.2 bouyer * Remove device from dm device list.
364 1.2.2.2 bouyer */
365 1.2.2.2 bouyer static int
366 1.2.2.2 bouyer dmctl_dev_remove(int argc __unused, char *argv[] __unused, libdm_task_t task)
367 1.2.2.2 bouyer {
368 1.2.2.2 bouyer
369 1.2.2.2 bouyer if (dvname == NULL)
370 1.2.2.2 bouyer return (ENOENT);
371 1.2.2.2 bouyer
372 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
373 1.2.2.2 bouyer
374 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
375 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_dev_remove: libdm_task_run failed.");
376 1.2.2.2 bouyer
377 1.2.2.2 bouyer libdm_task_destroy(task);
378 1.2.2.2 bouyer return 0;
379 1.2.2.2 bouyer }
380 1.2.2.2 bouyer
381 1.2.2.2 bouyer /*
382 1.2.2.2 bouyer * Resume device which was suspended or created right now.
383 1.2.2.2 bouyer * Replace table in "active slot" witg table in "inactive slot".
384 1.2.2.2 bouyer */
385 1.2.2.2 bouyer static int
386 1.2.2.2 bouyer dmctl_dev_resume(int argc __unused, char *argv[] __unused, libdm_task_t task)
387 1.2.2.2 bouyer {
388 1.2.2.2 bouyer
389 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
390 1.2.2.2 bouyer
391 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
392 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_dev_resume: libdm_task_run failed.");
393 1.2.2.2 bouyer
394 1.2.2.2 bouyer libdm_task_destroy(task);
395 1.2.2.2 bouyer return 0;
396 1.2.2.2 bouyer }
397 1.2.2.2 bouyer
398 1.2.2.2 bouyer /*
399 1.2.2.2 bouyer * Resume device which was suspended or created right now.
400 1.2.2.2 bouyer * Replace table in "active slot" with table in "inactive slot".
401 1.2.2.2 bouyer */
402 1.2.2.2 bouyer static int
403 1.2.2.2 bouyer dmctl_dev_suspend(int argc __unused, char *argv[] __unused, libdm_task_t task)
404 1.2.2.2 bouyer {
405 1.2.2.2 bouyer
406 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
407 1.2.2.2 bouyer libdm_task_set_suspend_flag(task);
408 1.2.2.2 bouyer
409 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
410 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_dev_suspend: libdm_task_run failed.");
411 1.2.2.2 bouyer
412 1.2.2.2 bouyer libdm_task_destroy(task);
413 1.2.2.2 bouyer return 0;
414 1.2.2.2 bouyer }
415 1.2.2.2 bouyer
416 1.2.2.2 bouyer /*
417 1.2.2.2 bouyer * Get device dependiences from device-mapper. Device dependency is physical
418 1.2.2.2 bouyer * device on which dm device depends.
419 1.2.2.2 bouyer */
420 1.2.2.2 bouyer static int
421 1.2.2.2 bouyer dmctl_dev_deps(int argc __unused, char *argv[] __unused, libdm_task_t task)
422 1.2.2.2 bouyer {
423 1.2.2.2 bouyer libdm_cmd_t cmd;
424 1.2.2.2 bouyer libdm_iter_t iter;
425 1.2.2.2 bouyer dev_t dev_deps;
426 1.2.2.2 bouyer
427 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
428 1.2.2.2 bouyer
429 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
430 1.2.2.2 bouyer err(EXIT_FAILURE, "dmctl_dev_deps: libdm_task_run failed.");
431 1.2.2.2 bouyer
432 1.2.2.2 bouyer if ((cmd = libdm_task_get_cmd(task)) == NULL)
433 1.2.2.2 bouyer return ENOENT;
434 1.2.2.2 bouyer
435 1.2.2.2 bouyer iter = libdm_cmd_iter_create(cmd);
436 1.2.2.2 bouyer
437 1.2.2.2 bouyer printf("Device %s dependiences \n", dvname);
438 1.2.2.2 bouyer
439 1.2.2.2 bouyer while((dev_deps = libdm_cmd_get_deps(iter)) != 0)
440 1.2.2.2 bouyer printf("major: %d minor: %d\n", major(dev_deps), minor(dev_deps));
441 1.2.2.2 bouyer
442 1.2.2.2 bouyer libdm_iter_destroy(iter);
443 1.2.2.2 bouyer libdm_cmd_destroy(cmd);
444 1.2.2.2 bouyer libdm_task_destroy(task);
445 1.2.2.2 bouyer
446 1.2.2.2 bouyer return 0;
447 1.2.2.2 bouyer }
448 1.2.2.2 bouyer
449 1.2.2.2 bouyer /*
450 1.2.2.2 bouyer * Reload device table to get new one to use.
451 1.2.2.2 bouyer */
452 1.2.2.2 bouyer static int
453 1.2.2.2 bouyer dmctl_table_reload(int argc, char *argv[], libdm_task_t task)
454 1.2.2.2 bouyer {
455 1.2.2.2 bouyer libdm_cmd_t cmd;
456 1.2.2.2 bouyer libdm_table_t table;
457 1.2.2.2 bouyer
458 1.2.2.2 bouyer char *params;
459 1.2.2.2 bouyer char *file_path;
460 1.2.2.2 bouyer char target[128];
461 1.2.2.2 bouyer int len;
462 1.2.2.2 bouyer uint64_t start, length;
463 1.2.2.2 bouyer
464 1.2.2.2 bouyer file_path = NULL;
465 1.2.2.2 bouyer params = NULL;
466 1.2.2.2 bouyer
467 1.2.2.2 bouyer cmd = libdm_cmd_create();
468 1.2.2.2 bouyer
469 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
470 1.2.2.2 bouyer
471 1.2.2.2 bouyer if (argc != 0)
472 1.2.2.2 bouyer file_path = argv[0];
473 1.2.2.2 bouyer
474 1.2.2.2 bouyer while ((params = parse_stdin(file_path)) != NULL) {
475 1.2.2.2 bouyer table = libdm_table_create();
476 1.2.2.2 bouyer
477 1.2.2.2 bouyer sscanf(params, "%"PRIu64" %"PRIu64" %s %n", &start, &length, target, &len);
478 1.2.2.2 bouyer
479 1.2.2.2 bouyer libdm_table_set_start(start, table);
480 1.2.2.2 bouyer libdm_table_set_length(length, table);
481 1.2.2.2 bouyer libdm_table_set_target(target, table);
482 1.2.2.2 bouyer libdm_table_set_params(params + len, table);
483 1.2.2.2 bouyer libdm_cmd_set_table(table, cmd);
484 1.2.2.2 bouyer
485 1.2.2.2 bouyer libdm_table_destroy(table);
486 1.2.2.2 bouyer
487 1.2.2.2 bouyer free(params);
488 1.2.2.2 bouyer }
489 1.2.2.2 bouyer
490 1.2.2.2 bouyer libdm_task_set_cmd(cmd, task);
491 1.2.2.2 bouyer
492 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
493 1.2.2.2 bouyer err(EXIT_FAILURE, "libdm_task_run: from dmctl_table_reload failed.");
494 1.2.2.2 bouyer
495 1.2.2.2 bouyer libdm_cmd_destroy(cmd);
496 1.2.2.2 bouyer libdm_task_destroy(task);
497 1.2.2.2 bouyer free(params);
498 1.2.2.2 bouyer
499 1.2.2.2 bouyer return 0;
500 1.2.2.2 bouyer }
501 1.2.2.2 bouyer
502 1.2.2.2 bouyer /*
503 1.2.2.2 bouyer * Get table status from device.
504 1.2.2.2 bouyer */
505 1.2.2.2 bouyer static int
506 1.2.2.2 bouyer dmctl_table_status(int argc __unused, char *argv[] __unused, libdm_task_t task)
507 1.2.2.2 bouyer {
508 1.2.2.2 bouyer libdm_cmd_t cmd;
509 1.2.2.2 bouyer libdm_table_t table;
510 1.2.2.2 bouyer libdm_iter_t iter;
511 1.2.2.2 bouyer
512 1.2.2.2 bouyer libdm_task_set_name(dvname, task);
513 1.2.2.2 bouyer libdm_task_set_status_flag(task);
514 1.2.2.2 bouyer
515 1.2.2.2 bouyer if (libdm_task_run(task) != 0)
516 1.2.2.2 bouyer err(EXIT_FAILURE, "libdm_task_run");
517 1.2.2.2 bouyer
518 1.2.2.2 bouyer if ((cmd = libdm_task_get_cmd(task)) == NULL)
519 1.2.2.2 bouyer return ENOENT;
520 1.2.2.2 bouyer
521 1.2.2.2 bouyer iter = libdm_cmd_iter_create(cmd);
522 1.2.2.2 bouyer
523 1.2.2.2 bouyer printf("Getting device table for device %s\n", dvname);
524 1.2.2.2 bouyer
525 1.2.2.2 bouyer while ((table = libdm_cmd_get_table(iter)) != NULL) {
526 1.2.2.2 bouyer printf("%10"PRIu64" %10"PRIu64" %s\n",
527 1.2.2.2 bouyer libdm_table_get_start(table),
528 1.2.2.2 bouyer libdm_table_get_length(table),
529 1.2.2.2 bouyer libdm_table_get_target(table));
530 1.2.2.2 bouyer libdm_table_destroy(table);
531 1.2.2.2 bouyer }
532 1.2.2.2 bouyer
533 1.2.2.2 bouyer libdm_iter_destroy(iter);
534 1.2.2.2 bouyer libdm_cmd_destroy(cmd);
535 1.2.2.2 bouyer libdm_task_destroy(task);
536 1.2.2.2 bouyer
537 1.2.2.2 bouyer return 0;
538 1.2.2.2 bouyer }
539 1.2.2.2 bouyer
540 1.2.2.2 bouyer void
541 1.2.2.2 bouyer usage(void)
542 1.2.2.2 bouyer {
543 1.2.2.2 bouyer int i;
544 1.2.2.2 bouyer
545 1.2.2.2 bouyer (void)fprintf(stderr, "usage: %s command [dm device name]\n"
546 1.2.2.2 bouyer "Available commands are:\n ", getprogname());
547 1.2.2.2 bouyer for (i = 0; commands[i].cmd_name != NULL; i++)
548 1.2.2.2 bouyer (void)fprintf(stderr, "\t%s\t%s\n", commands[i].cmd_name, commands[i].cmd_help);
549 1.2.2.2 bouyer exit(EXIT_FAILURE);
550 1.2.2.2 bouyer }
551 1.2.2.2 bouyer
552 1.2.2.2 bouyer static char *
553 1.2.2.2 bouyer parse_stdin(char *file_path)
554 1.2.2.2 bouyer {
555 1.2.2.2 bouyer char *buf, *lbuf;
556 1.2.2.2 bouyer size_t len;
557 1.2.2.2 bouyer FILE *fp;
558 1.2.2.2 bouyer
559 1.2.2.2 bouyer lbuf = NULL;
560 1.2.2.2 bouyer
561 1.2.2.2 bouyer if (file_path) {
562 1.2.2.2 bouyer if ((fp = fopen(file_path, "r")) == NULL)
563 1.2.2.2 bouyer err(ENOENT, "Cannot open table file\n");
564 1.2.2.2 bouyer } else
565 1.2.2.2 bouyer fp = stdin;
566 1.2.2.2 bouyer
567 1.2.2.2 bouyer if ((buf = fgetln(fp, &len)) == NULL)
568 1.2.2.2 bouyer return NULL;
569 1.2.2.2 bouyer
570 1.2.2.2 bouyer if (buf[len - 1] != '\n')
571 1.2.2.2 bouyer len++;
572 1.2.2.2 bouyer
573 1.2.2.2 bouyer if ((lbuf = malloc(len)) == NULL)
574 1.2.2.2 bouyer err(EXIT_FAILURE, "malloc");
575 1.2.2.2 bouyer
576 1.2.2.2 bouyer memcpy(lbuf, buf, len);
577 1.2.2.2 bouyer lbuf[len - 1] = '\0';
578 1.2.2.2 bouyer
579 1.2.2.2 bouyer return lbuf;
580 1.2.2.2 bouyer }
581