Searched refs:AtomicUsize (Results 1 – 7 of 7) sorted by relevance
10 atomic::{AtomicUsize, Ordering::SeqCst},42 pub counter: Arc<AtomicUsize>,57 let counter: Arc<AtomicUsize> = this.counter.clone(); in poll_frame()116 bytes_sent_counter: Arc<AtomicUsize>, in measure_request_body_size_layer() argument
18 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()83 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled()135 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled()
57 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()115 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled()156 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled_multi_encoding()230 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled()324 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); 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()451 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in disabling_compression_on_response_from_client_stream()
20 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()21 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
18 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()91 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled()188 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in compressing_response_from_client_stream()
18 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()98 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled_multi_encoding()
8 atomic::{AtomicUsize, Ordering::SeqCst},