Index: webrtc/modules/remote_bitrate_estimator/bwe_simulations.cc |
diff --git a/webrtc/modules/remote_bitrate_estimator/bwe_simulations.cc b/webrtc/modules/remote_bitrate_estimator/bwe_simulations.cc |
index f0e8198b0714bf83614b5f845248ca448cc084ec..35b3a862da0627730b45b5add02b4640bfd3ba00 100644 |
--- a/webrtc/modules/remote_bitrate_estimator/bwe_simulations.cc |
+++ b/webrtc/modules/remote_bitrate_estimator/bwe_simulations.cc |
@@ -51,9 +51,10 @@ INSTANTIATE_TEST_CASE_P(VideoSendersTest, |
TEST_P(BweSimulation, SprintUplinkTest) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
VideoSender sender(&uplink_, &source, GetParam()); |
- RateCounterFilter counter1(&uplink_, 0, "sender_output"); |
+ RateCounterFilter counter1(&uplink_, 0, "sender_output", |
+ bwe_names[GetParam()]); |
TraceBasedDeliveryFilter filter(&uplink_, 0, "link_capacity"); |
- RateCounterFilter counter2(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter2(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
ASSERT_TRUE(filter.Init(test::ResourcePath("sprint-uplink", "rx"))); |
RunFor(60 * 1000); |
@@ -62,9 +63,11 @@ TEST_P(BweSimulation, SprintUplinkTest) { |
TEST_P(BweSimulation, Verizon4gDownlinkTest) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
VideoSender sender(&downlink_, &source, GetParam()); |
- RateCounterFilter counter1(&downlink_, 0, "sender_output"); |
+ RateCounterFilter counter1(&downlink_, 0, "sender_output", |
+ bwe_names[GetParam()] + "_up"); |
TraceBasedDeliveryFilter filter(&downlink_, 0, "link_capacity"); |
- RateCounterFilter counter2(&downlink_, 0, "receiver_input"); |
+ RateCounterFilter counter2(&downlink_, 0, "Receiver", |
+ bwe_names[GetParam()] + "_down"); |
PacketReceiver receiver(&downlink_, 0, GetParam(), true, true); |
ASSERT_TRUE(filter.Init(test::ResourcePath("verizon4g-downlink", "rx"))); |
RunFor(22 * 60 * 1000); |
@@ -78,14 +81,16 @@ TEST_P(BweSimulation, Choke1000kbps500kbps1000kbpsBiDirectional) { |
AdaptiveVideoSource source(kFlowIds[0], 30, 300, 0, 0); |
VideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter choke(&uplink_, kFlowIds[0]); |
- RateCounterFilter counter(&uplink_, kFlowIds[0], "receiver_input_0"); |
+ RateCounterFilter counter(&uplink_, kFlowIds[0], "Receiver_0", |
+ bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, kFlowIds[0], GetParam(), true, false); |
AdaptiveVideoSource source2(kFlowIds[1], 30, 300, 0, 0); |
VideoSender sender2(&downlink_, &source2, GetParam()); |
ChokeFilter choke2(&downlink_, kFlowIds[1]); |
DelayFilter delay(&downlink_, CreateFlowIds(kFlowIds, kNumFlows)); |
- RateCounterFilter counter2(&downlink_, kFlowIds[1], "receiver_input_1"); |
+ RateCounterFilter counter2(&downlink_, kFlowIds[1], "Receiver_1", |
+ bwe_names[GetParam()]); |
PacketReceiver receiver2(&downlink_, kFlowIds[1], GetParam(), true, false); |
choke2.set_capacity_kbps(500); |
@@ -105,7 +110,7 @@ TEST_P(BweSimulation, Choke1000kbps500kbps1000kbps) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
VideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter choke(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, false); |
choke.set_capacity_kbps(1000); |
@@ -121,7 +126,7 @@ TEST_P(BweSimulation, PacerChoke1000kbps500kbps1000kbps) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
PacedVideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter filter(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
filter.set_capacity_kbps(1000); |
filter.set_max_delay_ms(500); |
@@ -136,7 +141,7 @@ TEST_P(BweSimulation, PacerChoke10000kbps) { |
PeriodicKeyFrameSource source(0, 30, 300, 0, 0, 1000); |
PacedVideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter filter(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
filter.set_capacity_kbps(10000); |
filter.set_max_delay_ms(500); |
@@ -147,7 +152,7 @@ TEST_P(BweSimulation, PacerChoke200kbps30kbps200kbps) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
PacedVideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter filter(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
filter.set_capacity_kbps(200); |
filter.set_max_delay_ms(500); |
@@ -162,7 +167,7 @@ TEST_P(BweSimulation, Choke200kbps30kbps200kbps) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
VideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter filter(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
filter.set_capacity_kbps(200); |
filter.set_max_delay_ms(500); |
@@ -176,10 +181,11 @@ TEST_P(BweSimulation, Choke200kbps30kbps200kbps) { |
TEST_P(BweSimulation, GoogleWifiTrace3Mbps) { |
AdaptiveVideoSource source(0, 30, 300, 0, 0); |
VideoSender sender(&uplink_, &source, GetParam()); |
- RateCounterFilter counter1(&uplink_, 0, "sender_output"); |
+ RateCounterFilter counter1(&uplink_, 0, "sender_output", |
+ bwe_names[GetParam()]); |
TraceBasedDeliveryFilter filter(&uplink_, 0, "link_capacity"); |
filter.set_max_delay_ms(500); |
- RateCounterFilter counter2(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter2(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); |
RunFor(300 * 1000); |
@@ -189,7 +195,7 @@ TEST_P(BweSimulation, LinearIncreasingCapacity) { |
PeriodicKeyFrameSource source(0, 30, 300, 0, 0, 1000000); |
PacedVideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter filter(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
filter.set_max_delay_ms(500); |
const int kStartingCapacityKbps = 150; |
@@ -208,7 +214,7 @@ TEST_P(BweSimulation, LinearDecreasingCapacity) { |
PeriodicKeyFrameSource source(0, 30, 300, 0, 0, 1000000); |
PacedVideoSender sender(&uplink_, &source, GetParam()); |
ChokeFilter filter(&uplink_, 0); |
- RateCounterFilter counter(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
filter.set_max_delay_ms(500); |
const int kStartingCapacityKbps = 1500; |
@@ -226,10 +232,11 @@ TEST_P(BweSimulation, LinearDecreasingCapacity) { |
TEST_P(BweSimulation, PacerGoogleWifiTrace3Mbps) { |
PeriodicKeyFrameSource source(0, 30, 300, 0, 0, 1000); |
PacedVideoSender sender(&uplink_, &source, GetParam()); |
- RateCounterFilter counter1(&uplink_, 0, "sender_output"); |
+ RateCounterFilter counter1(&uplink_, 0, "sender_output", |
+ bwe_names[GetParam()]); |
TraceBasedDeliveryFilter filter(&uplink_, 0, "link_capacity"); |
filter.set_max_delay_ms(500); |
- RateCounterFilter counter2(&uplink_, 0, "receiver_input"); |
+ RateCounterFilter counter2(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); |
RunFor(300 * 1000); |
@@ -254,12 +261,14 @@ TEST_P(BweSimulation, SelfFairnessTest) { |
rtc::scoped_ptr<RateCounterFilter> rate_counters[kNumFlows]; |
for (size_t i = 0; i < kNumFlows; ++i) { |
- rate_counters[i].reset(new RateCounterFilter( |
- &uplink_, CreateFlowIds(&kAllFlowIds[i], 1), "receiver_input")); |
+ rate_counters[i].reset( |
+ new RateCounterFilter(&uplink_, CreateFlowIds(&kAllFlowIds[i], 1), |
+ "Receiver", bwe_names[GetParam()])); |
} |
RateCounterFilter total_utilization( |
- &uplink_, CreateFlowIds(kAllFlowIds, kNumFlows), "total_utilization"); |
+ &uplink_, CreateFlowIds(kAllFlowIds, kNumFlows), "total_utilization", |
+ "Total_link_utilization"); |
rtc::scoped_ptr<PacketReceiver> receivers[kNumFlows]; |
for (size_t i = 0; i < kNumFlows; ++i) { |