Searched refs:load (Results 1 – 14 of 14) sorted by relevance
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()119 assert!(response_bytes_counter.load(SeqCst) > UNCOMPRESSED_MIN_BODY_SIZE); in client_disabled_server_enabled()172 assert!(response_bytes_counter.load(SeqCst) > UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_disabled()
97 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_enabled()146 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_disabled()189 let bytes_sent = response_bytes_counter.load(SeqCst); in client_enabled_server_disabled_multi_encoding()260 let bytes_sent = response_bytes_counter.load(SeqCst); in client_disabled()360 let bytes_sent = response_bytes_counter.load(SeqCst); in disabling_compression_on_single_response()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()488 let bytes_sent = response_bytes_counter.load(SeqCst); in disabling_compression_on_response_from_client_stream()
110 assert!(request_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()111 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
74 let bytes_sent = request_bytes_counter.load(SeqCst); in client_enabled_server_enabled()125 let bytes_sent = request_bytes_counter.load(SeqCst); in client_disabled_server_enabled()224 let bytes_sent = response_bytes_counter.load(SeqCst); in compressing_response_from_client_stream()
77 let bytes_sent = request_bytes_counter.load(SeqCst); in client_enabled_server_enabled()139 let bytes_sent = request_bytes_counter.load(SeqCst); in client_enabled_server_enabled_multi_encoding()
76 $ cargo run --bin load-balance-client82 $ cargo run --bin load-balance-server90 $ cargo run --bin dynamic-load-balance-client96 $ cargo run --bin dynamic-load-balance-server
42 name = "load-balance-client"46 name = "load-balance-server"50 name = "dynamic-load-balance-client"54 name = "dynamic-load-balance-server"
332 the corresponding `data` module to load and deserialize it in544 features: Arc::new(data::load()),
17 pub fn load() -> Vec<crate::routeguide::Feature> { in load() function
141 features: Arc::new(data::load()), in main()
14 use tower::load::Load;121 fn load(&self) -> Self::Metric { in load() method
63 while !done.load(SeqCst) { in main()
70 - [`examples`]: Example gRPC implementations showing off tls, load balancing and bi-directional str…
474 * **transport:** Connect lazily in the load balanced channel ([#493](https://github.com/hyperium/to…516 * **transport:** Dynamic load balancing ([#341](https://github.com/hyperium/tonic/issues/341)) ([85…711 * **transport:** Attempt to load RSA private keys in rustls ([#39](https://github.com/hyperium/toni…