astelm/telemt
1
0
Fork 0
mirror of https://github.com/telemt/telemt.git synced 2026-04-23 05:24:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

Rustfmt

Browse Source
This commit is contained in:
Alexey
2026-04-21 13:31:24 +03:00
parent db114f09c3
commit 4ce6b14bd8
3 changed files with 7 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/proxy/tests/masking_production_cap_regression_security_tests.rs
View File

@@ -175,14 +175,8 @@ async fn copy_with_zero_cap_drains_until_eof() {
let mut reader = FinitePatternReader::new(payload, 3072, read_calls); let mut reader = FinitePatternReader::new(payload, 3072, read_calls);
let mut writer = CountingWriter::default(); let mut writer = CountingWriter::default();
let outcome = copy_with_idle_timeout( let outcome =
&mut reader, copy_with_idle_timeout(&mut reader, &mut writer, 0, true, MASK_RELAY_IDLE_TIMEOUT).await;
&mut writer,
0,
true,
MASK_RELAY_IDLE_TIMEOUT,
)
.await;
assert_eq!(outcome.total, payload); assert_eq!(outcome.total, payload);
assert_eq!(writer.written, payload); assert_eq!(writer.written, payload);

6
src/transport/middle_proxy/pool_writer.rs
View File

@@ -436,10 +436,8 @@ impl MePool {
let cancel_signal = cancel.clone(); let cancel_signal = cancel.clone();
let cancel_select = cancel.clone(); let cancel_select = cancel.clone();
let cancel_cleanup = cancel.clone(); let cancel_cleanup = cancel.clone();
let route_backpressure_enabled = self let route_backpressure_enabled =
.transport_policy self.transport_policy.me_route_backpressure_enabled.clone();
.me_route_backpressure_enabled
.clone();
let route_fairshare_enabled = self.transport_policy.me_route_fairshare_enabled.clone(); let route_fairshare_enabled = self.transport_policy.me_route_fairshare_enabled.clone();
let reader_route_data_wait_ms = self.transport_policy.me_reader_route_data_wait_ms.clone(); let reader_route_data_wait_ms = self.transport_policy.me_reader_route_data_wait_ms.clone();

5
src/transport/middle_proxy/reader.rs
View File

@@ -544,8 +544,9 @@ mod tests {
use super::{ use super::{
MeResponse, RouteResult, WorkerFairnessSnapshot, fairness_retry_delay, MeResponse, RouteResult, WorkerFairnessSnapshot, fairness_retry_delay,
is_data_route_queue_full, route_data_with_retry, should_close_on_queue_full_streak_with_policy, is_data_route_queue_full, route_data_with_retry,
should_close_on_route_result_for_ack, should_close_on_route_result_for_data, should_schedule_fairness_retry, should_close_on_queue_full_streak_with_policy, should_close_on_route_result_for_ack,
should_close_on_route_result_for_data, should_schedule_fairness_retry,
}; };
#[test] #[test]