Run ocp-indent -i on all the source code

Author: samoht

src/hostnet/arp.ml

@@ -143,7 +143,7 @@ module Make (Ethif: Mirage_protocols_lwt.ETHIF) = struct
               f "error while reading ARP packet: %a" Ethif.pp_error e);
       end else Lwt.return_unit
     |2 -> (* Reply *)
-       (* the requested address *)
+      (* the requested address *)
       let spa = Ipaddr.V4.of_int32 (get_arp_tpa frame) in
       Log.debug (fun f -> f "ARP ignoring reply %s" (Ipaddr.V4.to_string spa));
       Lwt.return_unit
@@ -156,8 +156,8 @@ module Make (Ethif: Mirage_protocols_lwt.ETHIF) = struct
   let connect ~table ethif =
     let table =
       List.fold_left (fun acc (ip, mac) ->
-        Table.add ip mac acc
-      ) Table.empty table
+          Table.add ip mac acc
+        ) Table.empty table
     in
     { table; ethif }
 

src/hostnet/host.ml

@@ -409,30 +409,30 @@ module Sockets = struct
       let connect ?(read_buffer_size = default_read_buffer_size) (ip, port) =
         let description = Fmt.strf "tcp:%a:%d" Ipaddr.pp_hum ip port in
         let label = match ip with
-          | Ipaddr.V4 _ -> "TCPv4"
-          | Ipaddr.V6 _ -> "TCPv6" in
+        | Ipaddr.V4 _ -> "TCPv4"
+        | Ipaddr.V6 _ -> "TCPv6" in
         register_connection_noexn description
         >>= function
         | None ->
           errorf "Socket.%s.connect %s: hit connection limit" label description
         | Some idx ->
-        let fd =
-          try match ip with
-          | Ipaddr.V4 _ -> Uwt.Tcp.init_ipv4_exn ()
-          | Ipaddr.V6 _ -> Uwt.Tcp.init_ipv6_exn ()
-          with e -> deregister_connection idx; raise e in
-        Lwt.catch (fun () ->
-            let sockaddr = make_sockaddr (ip, port) in
-            Uwt.Tcp.connect fd ~addr:sockaddr >>= fun () ->
-            of_fd ~idx ~label ~read_buffer_size ~description fd
-            |> Lwt_result.return
-          ) (fun e ->
-            deregister_connection idx;
-            log_exception_continue "Tcp.connect Uwt.Tcp.close_wait"
-              (fun () -> Uwt.Tcp.close_wait fd)
-            >>= fun () ->
-            errorf "Socket.%s.connect %s: caught %a" label description Fmt.exn e
-          )
+          let fd =
+            try match ip with
+            | Ipaddr.V4 _ -> Uwt.Tcp.init_ipv4_exn ()
+            | Ipaddr.V6 _ -> Uwt.Tcp.init_ipv6_exn ()
+            with e -> deregister_connection idx; raise e in
+          Lwt.catch (fun () ->
+              let sockaddr = make_sockaddr (ip, port) in
+              Uwt.Tcp.connect fd ~addr:sockaddr >>= fun () ->
+              of_fd ~idx ~label ~read_buffer_size ~description fd
+              |> Lwt_result.return
+            ) (fun e ->
+              deregister_connection idx;
+              log_exception_continue "Tcp.connect Uwt.Tcp.close_wait"
+                (fun () -> Uwt.Tcp.close_wait fd)
+              >>= fun () ->
+              errorf "Socket.%s.connect %s: caught %a" label description Fmt.exn e
+            )
 
       let shutdown_read _ =
         Lwt.return ()

src/hostnet/mux.ml

@@ -93,11 +93,11 @@ module Make (Netif: Mirage_net_lwt.S) = struct
     let t = { netif; rules; default_callback } in
     Lwt.async
       (fun () ->
-        Netif.listen netif @@ callback t >>= function
-        | Ok () -> Lwt.return_unit
-        | Error _e ->
-          Log.err (fun f -> f "Mux.connect calling Netif.listen: failed");
-          Lwt.return_unit
+         Netif.listen netif @@ callback t >>= function
+         | Ok () -> Lwt.return_unit
+         | Error _e ->
+           Log.err (fun f -> f "Mux.connect calling Netif.listen: failed");
+           Lwt.return_unit
       );
     Lwt.return (Ok t)
 

src/hostnet/sig.ml

@@ -4,7 +4,7 @@ module type READ_INTO = sig
 
   val read_into: flow -> Cstruct.t ->
     (unit Mirage_flow.or_eof, error) result Lwt.t
-  (** Completely fills the given buffer with data from [fd] *)
+    (** Completely fills the given buffer with data from [fd] *)
 end
 
 module type FLOW_CLIENT = sig
@@ -14,8 +14,8 @@ module type FLOW_CLIENT = sig
 
   val connect: ?read_buffer_size:int -> address ->
     (flow, [`Msg of string]) result Lwt.t
-  (** [connect address] creates a connection to [address] and returns
-      he connected flow. *)
+    (** [connect address] creates a connection to [address] and returns
+        he connected flow. *)
 end
 
 module type CONN = sig

src/hostnet/slirp.ml

@@ -102,7 +102,7 @@ module Make
 struct
   (* module Tcpip_stack = Tcpip_stack.Make(Vmnet)(Host.Time) *)
 
-module Filteredif = Filter.Make(Vmnet)
+  module Filteredif = Filter.Make(Vmnet)
   module Netif = Capture.Make(Filteredif)
   module Recorder = (Netif: Sig.RECORDER with type t = Netif.t)
   module Switch = Mux.Make(Netif)

src/hostnet/vmnet.ml

@@ -331,7 +331,7 @@ module Make(C: Sig.CONN) = struct
     server_negotiate ~fd:channel ~client_macaddr_of_uuid ~mtu
     >>= fun (client_uuid, client_macaddr) ->
     let t = make ~client_macaddr ~server_macaddr ~mtu ~client_uuid
-      ~log_prefix:server_log_prefix channel in
+        ~log_prefix:server_log_prefix channel in
     Lwt_result.return t
 
   let client_of_fd ~uuid ~server_macaddr flow =