jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-10-28 21:11:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(acp): ignore heartbeat frames in wake replay assertion

Browse Source 
Signed-off-by: Logan Johnson <loganj@squareup.com>
This commit is contained in:
Logan Johnson
2026-09-01 13:09:10 -04:00
parent 6db59cc192
commit 2e370d59b2
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/buzz-acp/src/workflow_wake_recovery_tests.rs
View File

@@ -332,7 +332,9 @@ async fn assert_identity_ingress(missing: bool) {
let start = tokio::time::Instant::now();
assert!(crate::workflow_wake::authenticate_for_listener(&mut gate, &harness, &rest, &received).await.is_none());
if missing {
assert!(timeout(Duration::from_millis(100), server.next()).await.is_err(), "terminal absence must not issue replay REQ");
// The transport heartbeat can send Ping independently of replay.
// Answer control frames and assert that no application REQ is sent.
assert!(timeout(Duration::from_millis(100), next_data_frame(&mut server)).await.is_err(), "terminal absence must not issue replay REQ");
assert_eq!(probes.load(Ordering::SeqCst), 2);
} else {
assert!(start.elapsed() >= Duration::from_secs(1), "immediate discovery failures must be paced");