We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0341843 commit f30e754Copy full SHA for f30e754
1 file changed
ocaml/libs/rate-limit/rate_limit.ml
@@ -49,7 +49,7 @@ let rec worker_loop ~bucket ~process_queue ~process_queue_lock
49
match item_opt with
50
| None ->
51
(* Queue is empty only when termination was signalled *)
52
- ()
+ D.debug "%s: queue empty in deleted rate limiter; exiting" __FUNCTION__
53
| Some (cost, callback) ->
54
process_item cost callback ;
55
worker_loop ~bucket ~process_queue ~process_queue_lock ~worker_thread_cond
@@ -141,5 +141,6 @@ let submit_sync bucket_data ~callback amount =
141
142
callback ()
143
| Some channel ->
144
+ D.debug "%s: rate limiting call" __FUNCTION__ ;
145
Event.sync (Event.receive channel) ;
146
0 commit comments