Searched refs:counter (Results 1 – 6 of 6) sorted by relevance
| /tonic/tests/compression/src/ |
| H A D | util.rs | 42 pub counter: Arc<AtomicUsize>, field
57 let counter: Arc<AtomicUsize> = this.counter.clone(); in poll_frame() localVariable
61 counter.fetch_add(frame_data_length(&chunk), SeqCst); in poll_frame()
|
| H A D | server_stream.rs | 29 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
94 counter: response_bytes_counter.clone(), in client_disabled_server_enabled()
146 counter: response_bytes_counter.clone(), in client_enabled_server_disabled()
|
| H A D | compressing_response.rs | 72 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
127 counter: response_bytes_counter.clone(), in client_enabled_server_disabled()
168 counter: response_bytes_counter.clone(), in client_enabled_server_disabled_multi_encoding()
242 counter: response_bytes_counter.clone(), in client_disabled()
335 counter: response_bytes_counter.clone(), in disabling_compression_on_single_response()
393 counter: response_bytes_counter.clone(), in disabling_compression_on_response_but_keeping_compression_on_stream()
462 counter: response_bytes_counter.clone(), in disabling_compression_on_response_from_client_stream()
|
| H A D | bidirectional_stream.rs | 63 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
|
| H A D | client_stream.rs | 199 counter: response_bytes_counter.clone(), in compressing_response_from_client_stream()
|
| /tonic/ |
| H A D | CONTRIBUTING.md | 327 reviewers are strictly counter to the Code of Conduct.
|