CP-54471 Add ntp config dbsync

At XAPI start, check the actual NTP config to determine the
ntp mode, ntp enabled, ntp custom servers and store in xapi
DB.

Signed-off-by: Changlei Li <changlei.li@cloud.com>

Author: changlei-li

ocaml/xapi/dbsync_slave.ml

@@ -412,6 +412,9 @@ let update_env __context sync_keys =
   switched_sync Xapi_globs.sync_max_cstate (fun () ->
       Xapi_host.sync_max_cstate ~__context ~host:localhost
   ) ;
+  switched_sync Xapi_globs.sync_ntp_config (fun () ->
+      Xapi_host.sync_ntp_config ~__context ~host:localhost
+  ) ;
 
   switched_sync Xapi_globs.sync_secure_boot (fun () ->
       let result =

ocaml/xapi/xapi_globs.ml

@@ -376,6 +376,8 @@ let sync_ssh_status = "sync_ssh_status"
 
 let sync_max_cstate = "sync_max_cstate"
 
+let sync_ntp_config = "sync_ntp_config"
+
 let sync_secure_boot = "sync_secure_boot"
 
 let sync_pci_devices = "sync_pci_devices"

ocaml/xapi/xapi_host.ml

@@ -3441,3 +3441,23 @@ let enable_ntp ~__context ~self =
 let disable_ntp ~__context ~self =
   Xapi_host_ntp.disable_ntp_service () ;
   Db.Host.set_ntp_enabled ~__context ~self ~value:false
+
+let sync_ntp_config ~__context ~host =
+  let servers = Xapi_host_ntp.get_servers_from_conf () in
+  let is_ntp_dhcp_enabled = Xapi_host_ntp.is_ntp_dhcp_enabled () in
+  let ntp_mode =
+    match (is_ntp_dhcp_enabled, servers) with
+    | true, _ ->
+        `ntp_mode_dhcp
+    | false, s
+      when Xapi_stdext_std.Listext.List.set_equiv s
+             !Xapi_globs.default_ntp_servers ->
+        `ntp_mode_default
+    | false, _ ->
+        `ntp_mode_custom
+  in
+  Db.Host.set_ntp_mode ~__context ~self:host ~value:ntp_mode ;
+  if ntp_mode = `ntp_mode_custom then
+    Db.Host.set_ntp_custom_servers ~__context ~self:host ~value:servers ;
+  let ntp_enabled = Xapi_host_ntp.is_ntp_service_active () in
+  Db.Host.set_ntp_enabled ~__context ~self:host ~value:ntp_enabled

ocaml/xapi/xapi_host.mli

@@ -605,3 +605,5 @@ val set_ntp_custom_servers :
 val enable_ntp : __context:Context.t -> self:API.ref_host -> unit
 
 val disable_ntp : __context:Context.t -> self:API.ref_host -> unit
+
+val sync_ntp_config : __context:Context.t -> host:API.ref_host -> unit

ocaml/xapi/xapi_host_ntp.ml

@@ -79,6 +79,9 @@ let disable_ntp_service () =
   Xapi_systemctl.stop ~wait_until_success:false !Xapi_globs.ntp_service ;
   Xapi_systemctl.disable ~wait_until_success:false !Xapi_globs.ntp_service
 
+let is_ntp_service_active () =
+  Fe_systemctl.is_active ~service:!Xapi_globs.ntp_service
+
 let parse_ntp_conf () =
   try
     Xapi_stdext_unix.Unixext.read_lines ~path:!Xapi_globs.ntp_conf
@@ -99,3 +102,18 @@ let set_servers_in_conf servers =
   write_ntp_conf other servers
 
 let clear_servers_in_conf () = set_servers_in_conf []
+
+let get_servers_from_conf () =
+  let servers, _ = parse_ntp_conf () in
+  List.filter_map
+    (fun line ->
+      try Scanf.sscanf line "server %s@ iburst%!" Option.some with _ -> None
+    )
+    servers
+
+let is_ntp_dhcp_enabled () =
+  (* check ntp_dhcp_script exec permission *)
+  try
+    let stat = Unix.stat !Xapi_globs.ntp_dhcp_script in
+    stat.Unix.st_perm land 0o100 <> 0
+  with _ -> false

ocaml/xapi/xapi_host_ntp.mli

@@ -25,3 +25,9 @@ val restart_ntp_service : unit -> unit
 val enable_ntp_service : unit -> unit
 
 val disable_ntp_service : unit -> unit
+
+val is_ntp_service_active : unit -> bool
+
+val get_servers_from_conf : unit -> string list
+
+val is_ntp_dhcp_enabled : unit -> bool