Lines Matching refs:response_bytes_counter

57     let response_bytes_counter = Arc::new(AtomicUsize::new(0));  in client_enabled_server_enabled()  localVariable
60 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled() localVariable
72 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
97 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_enabled()
115 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled() localVariable
118 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled() localVariable
127 counter: response_bytes_counter.clone(), in client_enabled_server_disabled()
146 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_disabled()
156 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled_multi_encoding() localVariable
159 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled_multi_encoding() localVariable
168 counter: response_bytes_counter.clone(), in client_enabled_server_disabled_multi_encoding()
189 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_disabled_multi_encoding()
230 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled() localVariable
233 let response_bytes_counter = response_bytes_counter.clone(); in client_disabled() localVariable
242 counter: response_bytes_counter.clone(), in client_disabled()
260 let bytes_sent = response_bytes_counter.load(SeqCst); in client_disabled()
324 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in disabling_compression_on_single_response() localVariable
327 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_single_response() localVariable
335 counter: response_bytes_counter.clone(), in disabling_compression_on_single_response()
360 let bytes_sent = response_bytes_counter.load(SeqCst); in disabling_compression_on_single_response()
382 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable
385 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable
393 counter: response_bytes_counter.clone(), in disabling_compression_on_response_but_keeping_compression_on_stream()
425 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in disabling_compression_on_response_but_keeping_compression_on_stream()
432 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in disabling_compression_on_response_but_keeping_compression_on_stream()
451 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in disabling_compression_on_response_from_client_stream() localVariable
454 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_response_from_client_stream() localVariable
462 counter: response_bytes_counter.clone(), in disabling_compression_on_response_from_client_stream()
488 let bytes_sent = response_bytes_counter.load(SeqCst); in disabling_compression_on_response_from_client_stream()