Searched refs:response_bytes_counter (Results 1 – 4 of 4) sorted by relevance
18 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled() localVariable21 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled() localVariable29 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()61 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()68 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()83 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled() localVariable86 let response_bytes_counter = response_bytes_counter.clone(); in client_disabled_server_enabled() localVariable94 counter: response_bytes_counter.clone(), in client_disabled_server_enabled()135 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled() localVariable138 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled() localVariable[all …]
60 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled() localVariable118 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled() localVariable146 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_disabled()159 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled_multi_encoding() localVariable189 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_disabled_multi_encoding()233 let response_bytes_counter = response_bytes_counter.clone(); in client_disabled() localVariable260 let bytes_sent = response_bytes_counter.load(SeqCst); in client_disabled()327 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_single_response() localVariable360 let bytes_sent = response_bytes_counter.load(SeqCst); in disabling_compression_on_single_response()385 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable[all …]
21 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled() localVariable49 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled() localVariable63 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()111 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
188 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in compressing_response_from_client_stream() localVariable191 let response_bytes_counter = response_bytes_counter.clone(); in compressing_response_from_client_stream() localVariable199 counter: response_bytes_counter.clone(), in compressing_response_from_client_stream()224 let bytes_sent = response_bytes_counter.load(SeqCst); in compressing_response_from_client_stream()