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

fix ws_deque: strict bound for shrinking

Browse source
This commit is contained in:
Simon Cruanes 2023-10-25 23:29:47 -04:00
parent 629b66662f
commit 1e3629bc67
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/ws_deque_.ml
View file

@ -89,10 +89,10 @@ let push (self : 'a t) (x : 'a) : unit =
CA.set !arr b x; CA.set !arr b x;
A.set self.bottom (b + 1) A.set self.bottom (b + 1)
let perhaps_shrink (self : _ t) arr ~top ~bottom : unit = let maybe_shrink_ (self : _ t) arr ~top ~bottom : unit =
let size = bottom - top in let size = bottom - top in
let ca_size = CA.size arr in let ca_size = CA.size arr in
if ca_size >= 256 && size <= ca_size / 3 then if ca_size >= 256 && size < ca_size / 3 then
A.set self.arr (CA.shrink arr ~top ~bottom) A.set self.arr (CA.shrink arr ~top ~bottom)
let pop (self : 'a t) : 'a option = let pop (self : 'a t) : 'a option =
@ -112,7 +112,7 @@ let pop (self : 'a t) : 'a option =
) else if size > 0 then ( ) else if size > 0 then (
(* can pop without modifying [top] *) (* can pop without modifying [top] *)
let x = CA.get arr b in let x = CA.get arr b in
perhaps_shrink self arr ~bottom:b ~top:t; maybe_shrink_ self arr ~bottom:b ~top:t;
Some x Some x
) else ( ) else (
assert (size = 0); assert (size = 0);