Searched refs:pending_mtu (Results 1 – 2 of 2) sorted by relevance
77 let Ok(pending_mtu) = self.stable_mtu.try_lock() else { in on_outgoing_request()81 self.pending_exchange.replace(Some(pending_mtu)); in on_outgoing_request()151 let pending_mtu = try_await(mtu.snapshot()).await.unwrap_err(); in test_mtu_blocking_snapshot_during_client_negotiation() localVariable156 assert_eq!(pending_mtu.await.unwrap(), NEW_MTU); in test_mtu_blocking_snapshot_during_client_negotiation()243 let pending_mtu = try_await(mtu.snapshot()).await.unwrap_err(); in test_mtu_dropped_while_pending() localVariable248 assert!(pending_mtu.await.is_none()); in test_mtu_dropped_while_pending()
126 let pending_mtu = self.mtu.snapshot(); in send_indication() localVariable139 let mtu = pending_mtu in send_indication()627 let pending_mtu = in test_single_indication_pending_mtu_fail() localVariable638 assert!(matches!(pending_mtu.await, Err(IndicationError::DataExceedsMtu { .. }))); in test_single_indication_pending_mtu_fail()