From 72f471f42d7825b9ef370fb5a64acbd155d9140e Mon Sep 17 00:00:00 2001 From: Enrico Tassi Date: Thu, 27 Nov 2014 11:00:46 +0100 Subject: AsyncTaskQueue: parsin can also happen in the workers now --- stm/asyncTaskQueue.ml | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) (limited to 'stm/asyncTaskQueue.ml') diff --git a/stm/asyncTaskQueue.ml b/stm/asyncTaskQueue.ml index d870ff92b..298fa8237 100644 --- a/stm/asyncTaskQueue.ml +++ b/stm/asyncTaskQueue.ml @@ -37,8 +37,7 @@ module type Task = sig val on_marshal_error : string -> task -> unit val on_slave_death : task option -> [ `Exit of int | `Stay ] val on_task_cancellation_or_expiration : task option -> unit - val forward_feedback : - Stateid.t -> Feedback.route_id -> Feedback.feedback_content -> unit + val forward_feedback : Feedback.feedback -> unit (* run by the worker *) val perform : request -> response @@ -193,11 +192,7 @@ module Make(T : Task) = struct (CList.init 10 (fun _ -> Universes.new_univ_level (Global.current_dirpath ())))); loop () - | RespFeedback ({ Feedback.id = Feedback.State state_id; - Feedback.route = rid } as fbk) -> - T.forward_feedback state_id rid fbk.Feedback.content; - loop () - | RespFeedback _ -> Errors.anomaly (str"Parsing in master process") + | RespFeedback fbk -> T.forward_feedback fbk; loop () in loop () with -- cgit v1.2.3