balsoft/ligo
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Distributed_db: use a record instead of a tuple.

Browse Source
This commit is contained in:
Grégoire Henry 2017-11-08 11:47:08 +01:00 committed by Benjamin Canou
parent f3abee1fdf
commit 2b4e898407
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/node/shell/distributed_db_functors.ml
View File

@ -106,7 +106,8 @@ end = struct
} }
and status = and status =
| Pending of value Lwt.u * param | Pending of { wakener : value Lwt.u ;
param : param }
| Found of value | Found of value
let known s k = let known s k =
@ -157,16 +158,16 @@ end = struct
match Memory_table.find s.memory k with match Memory_table.find s.memory k with
| exception Not_found -> begin | exception Not_found -> begin
let waiter, wakener = Lwt.wait () in let waiter, wakener = Lwt.wait () in
Memory_table.add s.memory k (Pending (wakener, param)) ; Memory_table.add s.memory k (Pending { wakener ; param }) ;
Scheduler.request s.scheduler peer k ; Scheduler.request s.scheduler peer k ;
waiter waiter
end end
| Pending (w, _) -> | Pending { wakener = w ; _ } ->
Scheduler.request s.scheduler peer k ; Scheduler.request s.scheduler peer k ;
Lwt.waiter_of_wakener w Lwt.waiter_of_wakener w
| Found v -> Lwt.return v | Found v -> Lwt.return v
end end
| Pending (w, _) -> | Pending { wakener = w ; _ } ->
Scheduler.request s.scheduler peer k ; Scheduler.request s.scheduler peer k ;
Lwt.waiter_of_wakener w Lwt.waiter_of_wakener w
| Found v -> Lwt.return v | Found v -> Lwt.return v
@ -184,7 +185,7 @@ end = struct
Scheduler.notify_unrequested s.scheduler p k ; Scheduler.notify_unrequested s.scheduler p k ;
Lwt.return_unit Lwt.return_unit
end end
| Pending (w, param) -> begin | Pending { wakener = w ; param } -> begin
match Precheck.precheck k param v with match Precheck.precheck k param v with
| None -> | None ->
Scheduler.notify_invalid s.scheduler p k ; Scheduler.notify_invalid s.scheduler p k ;
@ -219,7 +220,7 @@ end = struct
let clear_or_cancel s k = let clear_or_cancel s k =
match Memory_table.find s.memory k with match Memory_table.find s.memory k with
| exception Not_found -> () | exception Not_found -> ()
| Pending (w, _) -> | Pending { wakener = w ; _ } ->
Scheduler.notify_cancelation s.scheduler k ; Scheduler.notify_cancelation s.scheduler k ;
Memory_table.remove s.memory k ; Memory_table.remove s.memory k ;
Lwt.wakeup_later_exn w Lwt.Canceled Lwt.wakeup_later_exn w Lwt.Canceled