8:08 a.m.
In this mode, converting of the VM configuration, setting up the
rollback path for error cases, transforming the VM storage and so on is
taken care of by a third-party toolset, and virt-v2v is only supposed to
tune up the guest OS directly inside the source VM, to enable it to boot
and run under the input hypervisor.
Signed-off-by: Roman Kagan <rkagan(a)virtuozzo.com>
---
v2v/cmdline.ml | 7 ++++-
v2v/v2v.ml | 87 ++++++++++++++++++++++++++++++++++++++++++----------------
2 files changed, 70 insertions(+), 24 deletions(-)
diff --git a/v2v/cmdline.ml b/v2v/cmdline.ml
index 3e04c48..d4bddce 100644
--- a/v2v/cmdline.ml
+++ b/v2v/cmdline.ml
@@ -36,6 +36,7 @@ let parse_cmdline () =
let dcpath = ref None in
let input_conn = ref None in
let input_format = ref None in
+ let in_place = ref false in
let output_conn = ref None in
let output_format = ref None in
let output_name = ref None in
@@ -159,6 +160,7 @@ let parse_cmdline () =
"uri " ^ s_"Libvirt
URI";
"-if", Arg.String (set_string_option_once "-if"
input_format),
"format " ^ s_"Input format
(for -i disk)";
+ "--in-place", Arg.Set in_place, " " ^ s_"Only tune
the guest in the input VM";
"--machine-readable", Arg.Set machine_readable, " " ^
s_"Make output machine readable";
"-n", Arg.String add_network, "in:out " ^ s_"Map
network 'in' to 'out'";
"--network", Arg.String add_network, "in:out " ^ ditto;
@@ -224,6 +226,7 @@ read the man page virt-v2v(1).
let input_conn = !input_conn in
let input_format = !input_format in
let input_mode = !input_mode in
+ let in_place = !in_place in
let machine_readable = !machine_readable in
let network_map = !network_map in
let no_trim = !no_trim in
@@ -313,6 +316,8 @@ read the man page virt-v2v(1).
Input_ova.input_ova filename in
(* Parse the output mode. *)
+ if output_mode <> `Not_set && in_place then
+ error (f_"-o and --in-place cannot be used at the same time");
let output =
match output_mode with
| `Glance ->
@@ -409,6 +414,6 @@ read the man page virt-v2v(1).
Output_vdsm.output_vdsm os vdsm_params vmtype output_alloc in
input, output,
- debug_overlays, do_copy, network_map, no_trim,
+ debug_overlays, do_copy, in_place, network_map, no_trim,
output_alloc, output_format, output_name,
print_source, root_choice
diff --git a/v2v/v2v.ml b/v2v/v2v.ml
index 23bd708..26a9b64 100644
--- a/v2v/v2v.ml
+++ b/v2v/v2v.ml
@@ -41,12 +41,16 @@ let print_mpstat chan { mp_dev = dev; mp_path = path;
fprintf chan " bsize=%Ld blocks=%Ld bfree=%Ld bavail=%Ld\n"
s.G.bsize s.G.blocks s.G.bfree s.G.bavail
+type conversion_mode =
+ | Copying of overlay list * target list
+ | In_place
+
let () = Random.self_init ()
let rec main () =
(* Handle the command line. *)
let input, output,
- debug_overlays, do_copy, network_map, no_trim,
+ debug_overlays, do_copy, in_place, network_map, no_trim,
output_alloc, output_format, output_name, print_source, root_choice =
Cmdline.parse_cmdline () in
@@ -57,12 +61,26 @@ let rec main () =
let source = open_source input print_source in
let source = amend_source source output_name network_map in
- let overlays = create_overlays source.s_disks in
- let targets = init_targets overlays source output output_format in
- message (f_"Opening the overlay");
+ let conversion_mode =
+ if not in_place then (
+ let overlays = create_overlays source.s_disks in
+ let targets = init_targets overlays source output output_format in
+ Copying (overlays, targets)
+ )
+ else In_place in
+
+ let guestfs_kind = (match conversion_mode with
+ | Copying (_, _) -> "overlay"
+ | In_place -> "source VM"
+ ) in
+
+ message (f_"Opening the %s") guestfs_kind;
let g = open_guestfs () in
- populate_overlays g overlays;
+ (match conversion_mode with
+ | Copying (overlays, _) -> populate_overlays g overlays
+ | In_place -> populate_disks g source.s_disks
+ );
g#launch ();
@@ -72,9 +90,16 @@ let rec main () =
let mpstats = get_mpstats g in
check_free_space mpstats;
- check_target_free_space mpstats source targets output;
+ (match conversion_mode with
+ | Copying (_, targets) ->
+ check_target_free_space mpstats source targets output
+ | In_place -> ()
+ );
- let keep_serial_console = output#keep_serial_console in
+ let keep_serial_console = (match conversion_mode with
+ | Copying (_, _) -> output#keep_serial_console
+ | In_place -> true
+ ) in
let guestcaps = do_convert g inspect source keep_serial_console in
if no_trim <> ["*"] && (do_copy || debug_overlays) then (
@@ -86,29 +111,34 @@ let rec main () =
do_fstrim g no_trim inspect;
);
- message (f_"Closing the overlay");
+ message (f_"Closing the %s") guestfs_kind;
g#close ();
- let target_firmware = get_target_firmware inspect guestcaps source output in
+ (match conversion_mode with
+ | In_place -> ()
+ | Copying (overlays, targets) ->
+ let target_firmware =
+ get_target_firmware inspect guestcaps source output in
- message (f_"Assigning disks to buses");
- let target_buses = target_bus_assignment source targets guestcaps in
- if verbose () then
- printf "%s%!" (string_of_target_buses target_buses);
+ message (f_"Assigning disks to buses");
+ let target_buses = target_bus_assignment source targets guestcaps in
+ if verbose () then
+ printf "%s%!" (string_of_target_buses target_buses);
- let targets =
- if not do_copy then targets
- else copy_targets targets input output output_alloc in
+ let targets =
+ if not do_copy then targets
+ else copy_targets targets input output output_alloc in
- (* Create output metadata. *)
- message (f_"Creating output metadata");
- output#create_metadata source targets target_buses guestcaps inspect
- target_firmware;
+ (* Create output metadata. *)
+ message (f_"Creating output metadata");
+ output#create_metadata source targets target_buses guestcaps inspect
+ target_firmware;
- if debug_overlays then preserve_overlays overlays source.s_name;
+ if debug_overlays then preserve_overlays overlays source.s_name;
- message (f_"Finishing off");
- delete_target_on_exit := false (* Don't delete target on exit. *)
+ delete_target_on_exit := false (* Don't delete target on exit. *)
+ );
+ message (f_"Finishing off")
and open_source input print_source =
message (f_"Opening the source %s") input#as_options;
@@ -269,6 +299,17 @@ and populate_overlays (g:G.guestfs) overlays =
~copyonread:true
) overlays
+and populate_disks (g:G.guestfs) src_disks =
+ List.iter (
+ fun ({s_qemu_uri = qemu_uri; s_format = format}) ->
+ match format with
+ | None ->
+ g#add_drive_opts qemu_uri ~cachemode:"unsafe"
~discard:"besteffort"
+ | Some fmt ->
+ g#add_drive_opts qemu_uri ~format:fmt ~cachemode:"unsafe"
+ ~discard:"besteffort"
+ ) src_disks
+
and inspect_source g root_choice =
let roots = g#inspect_os () in
let roots = Array.to_list roots in
--
2.4.3