+ (* Signals. *)
+ let connect_kvm_signal = new GUtil.signal () in
+ let connect_xen_signal = new GUtil.signal () in
+ let connect_none_signal = new GUtil.signal () in
+ let connect_uri_signal = new GUtil.signal () in
+ let reopen_signal = new GUtil.signal () in
+ let inspection_signal = new GUtil.signal () in
+
+object (self)
+ inherit GUtil.ml_signals [connect_kvm_signal#disconnect;
+ connect_xen_signal#disconnect;
+ connect_none_signal#disconnect;
+ connect_uri_signal#disconnect;
+ reopen_signal#disconnect;
+ inspection_signal#disconnect]
+
+ method connect_kvm_signal = connect_kvm_signal#connect ~after
+ method connect_xen_signal = connect_xen_signal#connect ~after
+ method connect_none_signal = connect_none_signal#connect ~after
+ method connect_uri_signal = connect_uri_signal#connect ~after
+ method reopen_signal = reopen_signal#connect ~after
+ method inspection_signal = inspection_signal#connect ~after
+
+ initializer
+ ignore (statusbar_context#push title);
+ window#show ();
+
+ (* Quit. *)
+ let quit _ = GMain.quit (); false in
+ ignore (window#connect#destroy ~callback:GMain.quit);
+ ignore (window#event#connect#delete ~callback:quit);
+ ignore (connect_menu.quit_item#connect#activate
+ ~callback:(fun () -> ignore (quit ()); ()));
+
+ (* Accel_group. *)
+ window#add_accel_group accel_group;
+
+ (* Menu entries emit signals. *)
+ ignore (connect_menu.connect_kvm_item#connect#activate
+ ~callback:connect_kvm_signal#call);
+ ignore (connect_menu.connect_xen_item#connect#activate
+ ~callback:connect_xen_signal#call);
+ ignore (connect_menu.connect_none_item#connect#activate
+ ~callback:connect_none_signal#call);
+ ignore (connect_menu.connect_uri_item#connect#activate
+ ~callback:connect_uri_signal#call);
+ ignore (connect_menu.reopen_item#connect#activate
+ ~callback:reopen_signal#call);
+ ignore (guest_menu.guest_inspection_item#connect#activate
+ ~callback:inspection_signal#call);
+
+ (* VM combo box when changed by the user.
+ * The refresh button acts like changing the VM combo too.
+ *)
+ let combo, (model, column) = vmcombo in
+ ignore (
+ combo#connect#changed
+ ~callback:(
+ fun () ->
+ match combo#active_iter with
+ | None -> () (* nothing selected *)
+ | Some row -> self#open_domain (model#get ~row ~column)
+ )
+ );
+ ignore (
+ refresh_button#connect#clicked
+ ~callback:(
+ fun () ->
+ match combo#active_iter with
+ | None -> () (* nothing selected *)
+ | Some row -> self#open_domain (model#get ~row ~column)
+ )
+ )
+
+ (* Set the statusbar text. *)
+ method set_statusbar msg =
+ statusbar_context#pop ();
+ ignore (statusbar_context#push msg)
+
+ (* Return the filetree. *)
+ method tree = tree
+
+ (* Connect to the given URI. *)
+ method connect_to uri () =
+ tree#clear ();
+ Slave.discard_command_queue ();
+ Slave.connect uri (self#when_connected uri)
+
+ (* Called back when connected to a new hypervisor. *)
+ method private when_connected uri doms =
+ self#populate_vmcombo doms
+
+ (* Populate the VM combo box. *)
+ method private populate_vmcombo doms =
+ let combo, (model, column) = vmcombo in
+ model#clear ();
+ List.iter (
+ fun { dom_name = name } ->
+ let row = model#append () in
+ model#set ~row ~column name
+ ) doms
+
+ (* When a new domain is selected by the user, eg through vmcombo. *)
+ method private open_domain name =
+ tree#clear ();
+ Slave.discard_command_queue ();
+ Slave.open_domain name (self#when_opened_domain name)
+
+ (* Called back when domain was opened successfully. *)
+ method private when_opened_domain name data =
+ debug "when_opened_domain callback";
+ self#when_opened_common name data
+
+ (* When a set of disk images is selected by the user. *)
+ method private open_disk_images images =
+ match images with
+ | [] -> ()
+ | images ->
+ tree#clear ();
+ Slave.discard_command_queue ();
+ Slave.open_images images (self#when_opened_disk_images images)
+
+ (* Called back when disk image(s) were opened successfully. *)
+ method private when_opened_disk_images images data =
+ match images with
+ | [] -> ()
+ | (image, _) :: _ ->
+ debug "when_opened_disk_images callback";
+ self#when_opened_common image data
+
+ (* Called to reopen the handle. *)
+ method reopen () =
+ tree#clear ();
+ Slave.discard_command_queue ();
+ Slave.reopen self#when_reopened
+
+ method private when_reopened data =
+ debug "when_reopened callback";
+ self#when_opened_common "Reopened"(*XXX we lost the original name*) data
+
+ (* Common code for when_opened_domain/when_opened_disk_images. *)
+ method private when_opened_common name data =
+ (* Dump some of the inspection data in debug messages. *)
+ List.iter (fun (dev, t) -> debug "filesystem: %s: %s" dev t)
+ data.insp_all_filesystems;
+ List.iter (
+ fun { insp_root = root; insp_type = typ; insp_distro = distro;
+ insp_major_version = major; insp_minor_version = minor } ->
+ debug "root device %s contains %s %s %d.%d" root typ distro major minor;
+ ) data.insp_oses;
+
+ tree#add_os name data
+
+ (* Public callbacks. *)
+ method throbber_busy () =
+ throbber#set_pixbuf throbber_animation
+
+ method throbber_idle () =
+ throbber#set_pixbuf throbber_static
+
+ method progress (position, total) =
+ if position = 0L && total = 1L then
+ progress_bar#pulse ()
+ else (
+ let frac = Int64.to_float position /. Int64.to_float total in
+ if frac < 0. || frac > 1. then
+ eprintf "warning: progress bar out of range: %Ld / %Ld (%g)\n"
+ position total frac;
+ let frac = if frac < 0. then 0. else if frac > 1. then 1. else frac in
+ progress_bar#set_fraction frac
+ )
+
+ (* This is called in the main thread whenever a command fails in the
+ * slave thread. The command queue has been cleared before this is
+ * called, so our job here is to reset the main window, and if
+ * necessary to turn the exception into an error message.
+ *)
+ method failure exn =
+ let raw_msg = Printexc.to_string exn in
+ debug "failure hook: %s" raw_msg;
+
+ let title, msg = pretty_string_of_exn exn in
+ let icon = GMisc.image () in
+ icon#set_stock `DIALOG_ERROR;
+ icon#set_icon_size `DIALOG;
+ GToolbox.message_box ~title ~icon msg
+
+ (* Do what the user asked on the command line. *)
+ method run_cli_request = function
+ | Cmdline.Empty_window -> ()
+ | Cmdline.Open_images images ->
+ self#open_disk_images images
+ | Cmdline.Open_guest guest ->
+ (* Open libvirt connection, and in the callback open the guest. *)
+ let uri = connect_uri () in
+ Slave.connect uri (self#when_connected_cli_request guest)
+
+ method private when_connected_cli_request guest doms =
+ self#populate_vmcombo doms;
+
+ (* "guest" should match a domain in "doms". Check this and
+ * get the index of it.
+ *)
+ let rec loop i = function
+ | [] ->
+ failwith "guest %s not found (do you need to use --connect?)" guest
+ | d::ds when d = guest -> i
+ | _::ds -> loop (i+1) ds
+ in
+ let i = loop 0 (List.map (fun { dom_name = name } -> name) doms) in
+
+ let combo, _ = vmcombo in
+ combo#set_active i
+
+end