simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-08 03:47:59 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix bounded queue: try_pop should drain a closed queue

Browse source
This commit is contained in:
Simon Cruanes 2025-12-09 20:51:12 -05:00
parent 0eb27174f0
commit 374a67c97a
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/client/bounded_queue_sync.ml
View file

@ -47,11 +47,13 @@ end = struct
let try_pop (self : 'a t) : 'a BQ.pop_result = let try_pop (self : 'a t) : 'a BQ.pop_result =
UM.protect self.mutex @@ fun () -> UM.protect self.mutex @@ fun () ->
(* first, try to pop the queue. We want to drain it even if it's closed. *)
try `Item (Queue.pop self.q)
with Queue.Empty ->
if self.closed then if self.closed then
`Closed `Closed
else ( else
try `Item (Queue.pop self.q) with Queue.Empty -> `Empty `Empty
)
let push_while_not_full ~high_watermark (self : 'a t) (xs : 'a list) : let push_while_not_full ~high_watermark (self : 'a t) (xs : 'a list) :
push_res = push_res =