Searched refs:request_bytes_counter (Results 1 – 3 of 3) sorted by relevance
18 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled() localVariable45 let request_bytes_counter = request_bytes_counter.clone(); in client_enabled_server_enabled() localVariable55 .layer(measure_request_body_size_layer(request_bytes_counter)) in client_enabled_server_enabled()77 let bytes_sent = request_bytes_counter.load(SeqCst); in client_enabled_server_enabled()98 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled_multi_encoding() localVariable109 let request_bytes_counter = request_bytes_counter.clone(); in client_enabled_server_enabled_multi_encoding() localVariable117 .layer(measure_request_body_size_layer(request_bytes_counter)) in client_enabled_server_enabled_multi_encoding()139 let bytes_sent = request_bytes_counter.load(SeqCst); in client_enabled_server_enabled_multi_encoding()
18 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled() localVariable45 let request_bytes_counter = request_bytes_counter.clone(); in client_enabled_server_enabled() localVariable54 request_bytes_counter.clone(), in client_enabled_server_enabled()74 let bytes_sent = request_bytes_counter.load(SeqCst); in client_enabled_server_enabled()91 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled() localVariable99 let request_bytes_counter = request_bytes_counter.clone(); in client_disabled_server_enabled() localVariable106 request_bytes_counter.clone(), in client_disabled_server_enabled()125 let bytes_sent = request_bytes_counter.load(SeqCst); in client_disabled_server_enabled()
20 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled() localVariable48 let request_bytes_counter = request_bytes_counter.clone(); in client_enabled_server_enabled() localVariable58 request_bytes_counter.clone(), in client_enabled_server_enabled()110 assert!(request_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()