simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-10 21:24:05 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove dead code

Browse source
This commit is contained in:
Simon Cruanes 2023-10-29 21:12:59 -04:00
parent c4d67f83ca
commit 9f9df9af18
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 0 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/ws_pool.ml
View file

@ -57,7 +57,6 @@ let[@inline] try_wake_someone_ (self : state) : unit =
(** Run [task] as is, on the pool. *) (** Run [task] as is, on the pool. *)
let schedule_task_ (self : state) (w : worker_state option) (task : task) : unit let schedule_task_ (self : state) (w : worker_state option) (task : task) : unit
= =
(* Printf.printf "schedule task now (%d)\n%!" (Thread.id @@ Thread.self ()); *)
match w with match w with
| Some w -> | Some w ->
let pushed = WSQ.push w.q task in let pushed = WSQ.push w.q task in
@ -84,7 +83,6 @@ let schedule_task_ (self : state) (w : worker_state option) (task : task) : unit
(** Run this task, now. Must be called from a worker. *) (** Run this task, now. Must be called from a worker. *)
let run_task_now_ (self : state) ~runner task : unit = let run_task_now_ (self : state) ~runner task : unit =
(* Printf.printf "run task now (%d)\n%!" (Thread.id @@ Thread.self ()); *)
let (AT_pair (before_task, after_task)) = self.around_task in let (AT_pair (before_task, after_task)) = self.around_task in
let _ctx = before_task runner in let _ctx = before_task runner in
(* run the task now, catching errors *) (* run the task now, catching errors *)