1 /* SPDX-License-Identifier: LGPL-2.1+ */
9 #include "alloc-util.h"
12 #include "hostname-util.h"
13 #include "import-raw.h"
14 #include "import-tar.h"
15 #include "import-util.h"
16 #include "machine-image.h"
17 #include "main-func.h"
18 #include "signal-util.h"
19 #include "string-util.h"
22 static bool arg_force
= false;
23 static bool arg_read_only
= false;
24 static const char *arg_image_root
= "/var/lib/machines";
26 static int interrupt_signal_handler(sd_event_source
*s
, const struct signalfd_siginfo
*si
, void *userdata
) {
27 log_notice("Transfer aborted.");
28 sd_event_exit(sd_event_source_get_event(s
), EINTR
);
32 static void on_tar_finished(TarImport
*import
, int error
, void *userdata
) {
33 sd_event
*event
= userdata
;
37 log_info("Operation completed successfully.");
39 sd_event_exit(event
, abs(error
));
42 static int import_tar(int argc
, char *argv
[], void *userdata
) {
43 _cleanup_(tar_import_unrefp
) TarImport
*import
= NULL
;
44 _cleanup_(sd_event_unrefp
) sd_event
*event
= NULL
;
45 const char *path
= NULL
, *local
= NULL
;
46 _cleanup_free_
char *ll
= NULL
;
47 _cleanup_close_
int open_fd
= -1;
52 if (isempty(path
) || streq(path
, "-"))
58 local
= basename(path
);
59 if (isempty(local
) || streq(local
, "-"))
63 r
= tar_strip_suffixes(local
, &ll
);
69 if (!machine_name_is_valid(local
)) {
70 log_error("Local image name '%s' is not valid.", local
);
75 r
= image_find(IMAGE_MACHINE
, local
, NULL
);
78 return log_error_errno(r
, "Failed to check whether image '%s' exists: %m", local
);
80 log_error("Image '%s' already exists.", local
);
88 open_fd
= open(path
, O_RDONLY
|O_CLOEXEC
|O_NOCTTY
);
90 return log_error_errno(errno
, "Failed to open tar image to import: %m");
94 log_info("Importing '%s', saving as '%s'.", path
, local
);
96 _cleanup_free_
char *pretty
= NULL
;
100 (void) fd_get_path(fd
, &pretty
);
101 log_info("Importing '%s', saving as '%s'.", strna(pretty
), local
);
104 r
= sd_event_default(&event
);
106 return log_error_errno(r
, "Failed to allocate event loop: %m");
108 assert_se(sigprocmask_many(SIG_BLOCK
, NULL
, SIGTERM
, SIGINT
, -1) >= 0);
109 (void) sd_event_add_signal(event
, NULL
, SIGTERM
, interrupt_signal_handler
, NULL
);
110 (void) sd_event_add_signal(event
, NULL
, SIGINT
, interrupt_signal_handler
, NULL
);
112 r
= tar_import_new(&import
, event
, arg_image_root
, on_tar_finished
, event
);
114 return log_error_errno(r
, "Failed to allocate importer: %m");
116 r
= tar_import_start(import
, fd
, local
, arg_force
, arg_read_only
);
118 return log_error_errno(r
, "Failed to import image: %m");
120 r
= sd_event_loop(event
);
122 return log_error_errno(r
, "Failed to run event loop: %m");
124 log_info("Exiting.");
128 static void on_raw_finished(RawImport
*import
, int error
, void *userdata
) {
129 sd_event
*event
= userdata
;
133 log_info("Operation completed successfully.");
135 sd_event_exit(event
, abs(error
));
138 static int import_raw(int argc
, char *argv
[], void *userdata
) {
139 _cleanup_(raw_import_unrefp
) RawImport
*import
= NULL
;
140 _cleanup_(sd_event_unrefp
) sd_event
*event
= NULL
;
141 const char *path
= NULL
, *local
= NULL
;
142 _cleanup_free_
char *ll
= NULL
;
143 _cleanup_close_
int open_fd
= -1;
148 if (isempty(path
) || streq(path
, "-"))
154 local
= basename(path
);
155 if (isempty(local
) || streq(local
, "-"))
159 r
= raw_strip_suffixes(local
, &ll
);
165 if (!machine_name_is_valid(local
)) {
166 log_error("Local image name '%s' is not valid.", local
);
171 r
= image_find(IMAGE_MACHINE
, local
, NULL
);
174 return log_error_errno(r
, "Failed to check whether image '%s' exists: %m", local
);
176 log_error("Image '%s' already exists.", local
);
184 open_fd
= open(path
, O_RDONLY
|O_CLOEXEC
|O_NOCTTY
);
186 return log_error_errno(errno
, "Failed to open raw image to import: %m");
190 log_info("Importing '%s', saving as '%s'.", path
, local
);
192 _cleanup_free_
char *pretty
= NULL
;
196 (void) fd_get_path(fd
, &pretty
);
197 log_info("Importing '%s', saving as '%s'.", strempty(pretty
), local
);
200 r
= sd_event_default(&event
);
202 return log_error_errno(r
, "Failed to allocate event loop: %m");
204 assert_se(sigprocmask_many(SIG_BLOCK
, NULL
, SIGTERM
, SIGINT
, -1) >= 0);
205 (void) sd_event_add_signal(event
, NULL
, SIGTERM
, interrupt_signal_handler
, NULL
);
206 (void) sd_event_add_signal(event
, NULL
, SIGINT
, interrupt_signal_handler
, NULL
);
208 r
= raw_import_new(&import
, event
, arg_image_root
, on_raw_finished
, event
);
210 return log_error_errno(r
, "Failed to allocate importer: %m");
212 r
= raw_import_start(import
, fd
, local
, arg_force
, arg_read_only
);
214 return log_error_errno(r
, "Failed to import image: %m");
216 r
= sd_event_loop(event
);
218 return log_error_errno(r
, "Failed to run event loop: %m");
220 log_info("Exiting.");
224 static int help(int argc
, char *argv
[], void *userdata
) {
226 printf("%s [OPTIONS...] {COMMAND} ...\n\n"
227 "Import container or virtual machine images.\n\n"
228 " -h --help Show this help\n"
229 " --version Show package version\n"
230 " --force Force creation of image\n"
231 " --image-root=PATH Image root directory\n"
232 " --read-only Create a read-only image\n\n"
234 " tar FILE [NAME] Import a TAR image\n"
235 " raw FILE [NAME] Import a RAW image\n",
236 program_invocation_short_name
);
241 static int parse_argv(int argc
, char *argv
[]) {
250 static const struct option options
[] = {
251 { "help", no_argument
, NULL
, 'h' },
252 { "version", no_argument
, NULL
, ARG_VERSION
},
253 { "force", no_argument
, NULL
, ARG_FORCE
},
254 { "image-root", required_argument
, NULL
, ARG_IMAGE_ROOT
},
255 { "read-only", no_argument
, NULL
, ARG_READ_ONLY
},
264 while ((c
= getopt_long(argc
, argv
, "h", options
, NULL
)) >= 0)
269 return help(0, NULL
, NULL
);
279 arg_image_root
= optarg
;
283 arg_read_only
= true;
290 assert_not_reached("Unhandled option");
296 static int import_main(int argc
, char *argv
[]) {
297 static const Verb verbs
[] = {
298 { "help", VERB_ANY
, VERB_ANY
, 0, help
},
299 { "tar", 2, 3, 0, import_tar
},
300 { "raw", 2, 3, 0, import_raw
},
304 return dispatch_verb(argc
, argv
, verbs
, NULL
);
307 static int run(int argc
, char *argv
[]) {
310 setlocale(LC_ALL
, "");
311 log_parse_environment();
314 r
= parse_argv(argc
, argv
);
318 (void) ignore_signals(SIGPIPE
, -1);
320 return import_main(argc
, argv
);
323 DEFINE_MAIN_FUNCTION(run
);