andrei/telemt
1
0
Fork 0
mirror of https://github.com/telemt/telemt.git synced 2026-06-19 02:00:08 +07:00
Code Issues Packages Projects Releases Wiki Activity

Fix fallback test record iterator lifetime

Browse Source 
Co-Authored-By: brekotis <93345790+brekotis@users.noreply.github.com>
This commit is contained in:
Alexey
2026-06-11 17:56:21 +03:00
parent 4e66933a35
commit 0f8aca56d9
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/proxy/tests/client_tls_mtproto_fallback_security_tests.rs
+4 -3
View File
@@ -1390,9 +1390,10 @@ async fn tls_bad_mtproto_fallback_large_multi_record_chaos_under_backpressure()
assert_eq!(tls_response_head[0], 0x16); assert_eq!(tls_response_head[0], 0x16);
let chaos = [5usize, 23, 11, 47, 3, 19, 29, 13, 7, 31]; let chaos = [5usize, 23, 11, 47, 3, 19, 29, 13, 7, 31];
let mut records = [&a, &b, &c].iter().copied(); let records = [&a, &b, &c];
let mut records_iter = records.iter().copied();
let mut client_payload = invalid_mtproto_record; let mut client_payload = invalid_mtproto_record;
if let Some(first_record) = records.next() { if let Some(first_record) = records_iter.next() {
let first_step = chaos[0].min(first_record.len()); let first_step = chaos[0].min(first_record.len());
client_payload.extend_from_slice(&first_record[..first_step]); client_payload.extend_from_slice(&first_record[..first_step]);
client_side.write_all(&client_payload).await.unwrap(); client_side.write_all(&client_payload).await.unwrap();
@@ -1410,7 +1411,7 @@ async fn tls_bad_mtproto_fallback_large_multi_record_chaos_under_backpressure()
idx += 1; idx += 1;
} }
} }
for record in records { for record in records_iter {
let mut pos = 0usize; let mut pos = 0usize;
let mut idx = 0usize; let mut idx = 0usize;
while pos < record.len() { while pos < record.len() {