ASSERT_TRUE_WAIT instead of EXPECT_TRUE_WAIT in media flow tests.

We've only seen heap-use-after-free issues when the test continues to
run after EXPECT_TRUE_WAIT failures. This may speculatively reduce the
risk of flakes by aborting the test as soon as a failure happens.
Ideally the peer connections would all close due to going out of scope
making frame encoding after this point an impossibility.

Bug: webrtc:15018
Change-Id: I69d8bcf0f76e3bfb591d2ea81b9e9f68b1f11ffe
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/300481
Auto-Submit: Henrik Boström <hbos@webrtc.org>
Commit-Queue: Henrik Boström <hbos@webrtc.org>
Reviewed-by: Jeremy Leconte <jleconte@google.com>
Commit-Queue: Jeremy Leconte <jleconte@google.com>
Cr-Commit-Position: refs/heads/main@{#39782}
diff --git a/pc/peer_connection_simulcast_unittest.cc b/pc/peer_connection_simulcast_unittest.cc
index f975d37..7e7f8a3 100644
--- a/pc/peer_connection_simulcast_unittest.cc
+++ b/pc/peer_connection_simulcast_unittest.cc
@@ -1039,7 +1039,7 @@
     }
     if (!outbound_rtp->frame_height.is_defined() ||
         *outbound_rtp->frame_height != frame_height) {
-      // Sleep to avoid log spam when this is used in EXPECT_TRUE_WAIT().
+      // Sleep to avoid log spam when this is used in ASSERT_TRUE_WAIT().
       rtc::Thread::Current()->SleepMs(1000);
       return false;
     }
@@ -1155,7 +1155,7 @@
   remote_pc_wrapper->WaitForConnection();
 
   // Wait until media is flowing.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
                    kDefaultTimeout.ms());
   EXPECT_TRUE(OutboundRtpResolutionsAreLessThanOrEqualToExpectations(
       local_pc_wrapper, {{"", 1280, 720}}));
@@ -1190,7 +1190,7 @@
 
   // Wait until media is flowing on all three layers.
   // Ramp up time is needed before all three layers are sending.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
                    kLongTimeoutForRampingUp.ms());
   EXPECT_TRUE(OutboundRtpResolutionsAreLessThanOrEqualToExpectations(
       local_pc_wrapper, {{"f", 320, 180}, {"h", 640, 360}, {"q", 1280, 720}}));
@@ -1242,7 +1242,7 @@
   remote_pc_wrapper->WaitForConnection();
 
   // Wait until media is flowing.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
                    kDefaultTimeout.ms());
   // When `scalability_mode` is not set, VP8 defaults to L1T1.
   rtc::scoped_refptr<const RTCStatsReport> report = GetStats(local_pc_wrapper);
@@ -1302,7 +1302,7 @@
 
   // Wait until media is flowing, no significant time needed because we only
   // have one layer.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
                    kDefaultTimeout.ms());
   // GetStats() confirms "L1T2" is used which is different than the "L1T1"
   // default or the "L3T3_KEY" that was attempted.
@@ -1338,7 +1338,7 @@
 
   // Wait until media is flowing on all three layers.
   // Ramp up time is needed before all three layers are sending.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
                    kLongTimeoutForRampingUp.ms());
   EXPECT_TRUE(OutboundRtpResolutionsAreLessThanOrEqualToExpectations(
       local_pc_wrapper, {{"f", 320, 180}, {"h", 640, 360}, {"q", 1280, 720}}));
@@ -1386,11 +1386,11 @@
 
   // Wait until media is flowing. We only expect a single RTP stream.
   // We expect to see bytes flowing almost immediately on the lowest layer.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
                    kDefaultTimeout.ms());
   // Wait until scalability mode is reported and expected resolution reached.
   // Ramp up time may be significant.
-  EXPECT_TRUE_WAIT(HasOutboundRtpWithRidAndScalabilityMode(
+  ASSERT_TRUE_WAIT(HasOutboundRtpWithRidAndScalabilityMode(
                        local_pc_wrapper, "f", "L3T3_KEY", 720),
                    (2 * kLongTimeoutForRampingUp).ms());
 
@@ -1437,7 +1437,7 @@
 
   // Wait until media is flowing. We only expect a single RTP stream.
   // We expect to see bytes flowing almost immediately on the lowest layer.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 1u),
                    kDefaultTimeout.ms());
   EXPECT_TRUE(OutboundRtpResolutionsAreLessThanOrEqualToExpectations(
       local_pc_wrapper, {{"", 1280, 720}}));
@@ -1492,11 +1492,11 @@
 
   // Since the standard API is configuring simulcast we get three outbound-rtps,
   // but only one is active.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u, 1u),
                    kDefaultTimeout.ms());
   // Wait until scalability mode is reported and expected resolution reached.
   // Ramp up time is significant.
-  EXPECT_TRUE_WAIT(HasOutboundRtpWithRidAndScalabilityMode(
+  ASSERT_TRUE_WAIT(HasOutboundRtpWithRidAndScalabilityMode(
                        local_pc_wrapper, "f", "L3T3_KEY", 720),
                    (2 * kLongTimeoutForRampingUp).ms());
 
@@ -1553,7 +1553,7 @@
 
   // Wait until media is flowing on all three layers.
   // Ramp up time is needed before all three layers are sending.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
                    kLongTimeoutForRampingUp.ms());
   EXPECT_TRUE(OutboundRtpResolutionsAreLessThanOrEqualToExpectations(
       local_pc_wrapper, {{"f", 320, 180}, {"h", 640, 360}, {"q", 1280, 720}}));
@@ -1614,11 +1614,11 @@
 
   // Since the standard API is configuring simulcast we get three outbound-rtps,
   // but only one is active.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u, 1u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u, 1u),
                    kDefaultTimeout.ms());
   // Wait until scalability mode is reported and expected resolution reached.
   // Ramp up time may be significant.
-  EXPECT_TRUE_WAIT(HasOutboundRtpWithRidAndScalabilityMode(
+  ASSERT_TRUE_WAIT(HasOutboundRtpWithRidAndScalabilityMode(
                        local_pc_wrapper, "f", "L2T2_KEY", 720 / 2),
                    (2 * kLongTimeoutForRampingUp).ms());
 
@@ -1727,7 +1727,7 @@
   // terrible compared to other codecs.
   // TODO(https://crbug.com/webrtc/15006): Improve the ramp-up time and stop
   // giving this test extra long timeout.
-  EXPECT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
+  ASSERT_TRUE_WAIT(HasOutboundRtpBytesSent(local_pc_wrapper, 3u),
                    (2 * kLongTimeoutForRampingUp).ms());
   EXPECT_TRUE(OutboundRtpResolutionsAreLessThanOrEqualToExpectations(
       local_pc_wrapper, {{"f", 320, 180}, {"h", 640, 360}, {"q", 1280, 720}}));