Merge pull request xapi-project#981 from jeromemaloberti/CA-94829-tampa-lcm

CA-94829: Set the TCP timeout properties on the migration fd

Author: jeromemaloberti

ocaml/xenguest/xenguest_main.ml

@@ -276,6 +276,22 @@ type ops = {
 	domain_restore: Unix.file_descr -> int -> int -> int -> bool -> string;
 }
 
+let tcp_keepcnt = 5
+let tcp_keepidle = 30
+let tcp_keepintvl = 2
+
+(* CA-94829: Set the TCP keepalive options if it's a socket *)
+let fix_fd fd =
+  let stats = Unix.fstat fd in
+  if stats.Unix.st_kind = Unix.S_SOCK then begin
+    Unix.setsockopt fd Unix.SO_KEEPALIVE true;
+    Unixext.set_sock_keepalives fd tcp_keepcnt tcp_keepidle tcp_keepintvl;
+    debug "Set socket TCP keepalive values to TCP_KEEPCNT=%d TCP_KEEPIDLE=%d TCP_KEEPINTVL=%d" tcp_keepcnt tcp_keepidle tcp_keepintvl
+  end else begin
+    debug "Skipping TCP keepalive setting as fd is not a socket"
+  end
+    
+
 (* main *)
 let _ =
 	(* Union of all the options required by all modes: *)
@@ -370,7 +386,7 @@ let _ =
 		  and domid = int_of_string (get_param "domid")
 		  and flags = List.concat [ if has_param "live" then [ Xenguest.Live ] else [];
 					    if has_param "debug" then [ Xenguest.Debug ] else [] ] in
-
+		  fix_fd fd;
 		  with_logging (fun () -> ops.domain_save fd domid 0 0 flags hvm)
 	      | Some "hvm_restore"
 	      | Some "restore" ->
@@ -382,6 +398,7 @@ let _ =
 		  and store_port = int_of_string (get_param "store_port")
 		  and console_port = int_of_string (get_param "console_port") in
 
+		  fix_fd fd;
 		  with_logging (fun () -> ops.domain_restore fd domid store_port console_port hvm)
 	      | Some "linux_build" ->
 		  debug "linux_build mode selected";