@@ -38,13 +38,6 @@ let native_ext = if is_native then ".opt" else ""
3838let builtin_packages =
3939 List.fold_left (fun a s -> String.Set.add s a) String.Set.empty [_DEPS_]
4040
41- module Fake_preempt =
42- struct
43- let set_max_number_of_threads_queued : int -> unit = fun _ -> ()
44- let get_max_number_of_threads_queued : unit -> int = fun () -> 0
45- let init : int -> int -> (string -> unit) -> unit = fun _ _ _ -> ()
46- end
47-
4841(* Server config: *)
4942let (uploaddir : string option ref) = ref None
5043let logdir = ref (Some ("_LOGDIR_"))
@@ -97,7 +90,7 @@ let set_veryverbose () =
9790let set_minthreads i = minthreads := i
9891let set_maxthreads i = maxthreads := i
9992let set_max_number_of_threads_queued =
100- _PREEMTIMPLEM_ .set_max_number_of_threads_queued
93+ Lwt_preemptive .set_max_number_of_threads_queued
10194let set_max_number_of_connections i = max_number_of_connections := i
10295let set_client_timeout i = silent_client_timeout := i
10396let set_server_timeout i = silent_server_timeout := i
@@ -143,7 +136,7 @@ let get_default_group () = !default_group
143136let get_minthreads () = !minthreads
144137let get_maxthreads () = !maxthreads
145138let get_max_number_of_threads_queued =
146- _PREEMTIMPLEM_ .get_max_number_of_threads_queued
139+ Lwt_preemptive .get_max_number_of_threads_queued
147140let get_max_number_of_connections () = !max_number_of_connections
148141let get_client_timeout () = !silent_client_timeout
149142let get_server_timeout () = !silent_server_timeout
@@ -175,5 +168,4 @@ let display_version () =
175168 print_newline ();
176169 exit 0
177170
178- let init_preempt =
179- _PREEMTIMPLEM_.init
171+ let init_preempt = Lwt_preemptive.init
0 commit comments