···

       
645
       
645
       
 
       


     

       
646
       
646
       
 
       
(** {1 Public API - Pool Management} *)

     

       
647
       
647
       
 
       


     

       
648
       
648
       
-
       
let close_idle_connections (pool : ('clock Eio.Time.clock, 'net Eio.Net.t) t) endpoint =

     

       
649
       
649
       
-
       
  match Hashtbl.find_opt pool.endpoints endpoint with

     

       
650
       
650
       
-
       
  | Some _ep_pool ->

     

       
651
       
651
       
-
       
      (* This is complex to implement correctly with Eio.Pool *)

     

       
652
       
652
       
-
       
      (* Would need to track idle connections separately *)

     

       
653
       
653
       
-
       
      failwith "close_idle_connections: not yet implemented"

     

       
654
       
654
       
-
       
  | None ->

     

       
655
       
655
       
-
       
      () (* No connections to close *)

     

       
656
       
656
       
-
       


     

       
657
       
648
       
 
       
let close_all_connections (pool : ('clock Eio.Time.clock, 'net Eio.Net.t) t) endpoint =

     

       
658
       
649
       
 
       
  match Hashtbl.find_opt pool.endpoints endpoint with

     

       
659
       
650
       
 
       
  | Some _ep_pool ->

     

···

       
267
       
267
       
 
       


     

       
268
       
268
       
 
       
(** {1 Pool Management} *)

     

       
269
       
269
       
 
       


     

       
270
       
270
       
-
       
val close_idle_connections :

     

       
271
       
271
       
-
       
  ('clock Eio.Time.clock, 'net Eio.Net.t) t ->

     

       
272
       
272
       
-
       
  Endpoint.t ->

     

       
273
       
273
       
-
       
  unit

     

       
274
       
270
       
 
       
(** Close all idle connections for endpoint (keeps active ones) *)

     

       
275
       
275
       
-
       


     

       
276
       
271
       
 
       
val close_all_connections :

     

       
277
       
272
       
 
       
  ('clock Eio.Time.clock, 'net Eio.Net.t) t ->

     

       
278
       
273
       
 
       
  Endpoint.t ->

     

···

       
122
       
122
       
 
       
  let start_time = Unix.gettimeofday () in

     

       
123
       
123
       
 
       


     

       
124
       
124
       
 
       
  let method_str = Method.to_string method_ in

     

       
125
       
125
       
-
       
  Log.info (fun m -> m "Making %s request to %s" method_str url);

     

       
125
       
125
       
+
       
  Log.debug (fun m -> m "[One] Executing %s request to %s" method_str url);

     

       
126
       
126
       
 
       


     

       
127
       
127
       
 
       
  (* Prepare headers *)

     

       
128
       
128
       
 
       
  let headers = match headers with