Lines Matching refs:response_bytes_counter
18 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled() localVariable
21 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled() localVariable
29 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() localVariable
86 let response_bytes_counter = response_bytes_counter.clone(); in client_disabled_server_enabled() localVariable
94 counter: response_bytes_counter.clone(), in client_disabled_server_enabled()
119 assert!(response_bytes_counter.load(SeqCst) > UNCOMPRESSED_MIN_BODY_SIZE); in client_disabled_server_enabled()
135 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled() localVariable
138 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled() localVariable
146 counter: response_bytes_counter.clone(), in client_enabled_server_disabled()
172 assert!(response_bytes_counter.load(SeqCst) > UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_disabled()