zqz/platform-external-webrtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix params comments in network emulation layer and its usage in scenario framework

Browse Source 
Bug: webrtc:10138
Change-Id: I9273410375cf4914abffa69f7443e13d52e77675
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/130222
Commit-Queue: Artem Titov <titovartem@webrtc.org>
Reviewed-by: Mirko Bonadei <mbonadei@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#27397}
This commit is contained in:
Artem Titov
2019-04-01 15:03:46 +02:00
committed by Commit Bot
parent 612e179a28
commit de83d0c81a
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/scenario/network_node.cc
View File

@ -201,7 +201,7 @@ void CrossTrafficSource::Process(Timestamp at_time, TimeDelta delta) {
pending_size_ += TrafficRate() * delta;
if (pending_size_ > config_.min_packet_size) {
target_->OnPacketReceived(EmulatedIpPacket(
rtc::SocketAddress() /*from*/, receiver_address_,
/*from=*/rtc::SocketAddress(), receiver_address_,
rtc::CopyOnWriteBuffer(pending_size_.bytes()), at_time));
pending_size_ = DataSize::Zero();
}

4
test/scenario/scenario.cc
View File

@ -221,7 +221,7 @@ void Scenario::TriggerPacketBurst(std::vector<EmulatedNetworkNode*> over_nodes,
EmulatedNetworkNode::CreateRoute(route_ip, over_nodes, &null_receiver_);
for (size_t i = 0; i < num_packets; ++i)
over_nodes[0]->OnPacketReceived(EmulatedIpPacket(
rtc::SocketAddress() /*from*/, rtc::SocketAddress(route_ip, 0) /*to*/,
/*from=*/rtc::SocketAddress(), /*to=*/rtc::SocketAddress(route_ip, 0),
rtc::CopyOnWriteBuffer(packet_size), Now()));
}
@ -234,7 +234,7 @@ void Scenario::NetworkDelayedAction(
EmulatedNetworkNode::CreateRoute(route_ip, over_nodes,
action_receivers_.back().get());
over_nodes[0]->OnPacketReceived(EmulatedIpPacket(
rtc::SocketAddress() /*from*/, rtc::SocketAddress(route_ip, 0) /*to*/,
/*from=*/rtc::SocketAddress(), /*to=*/rtc::SocketAddress(route_ip, 0),
rtc::CopyOnWriteBuffer(packet_size), Now()));
}

2
test/scenario/simulated_time.cc
View File

@ -331,7 +331,7 @@ void SimulatedTimeClient::PacerProcess(Timestamp at_time) {
ProcessFrames(at_time);
for (const auto& to_send : sender_.PaceAndPullSendPackets(at_time)) {
sender_.send_node_->OnPacketReceived(EmulatedIpPacket(
rtc::SocketAddress() /*from*/, sender_.send_receiver_address_,
/*from=*/rtc::SocketAddress(), sender_.send_receiver_address_,
to_send.data, at_time));
Update(congestion_controller_->OnSentPacket(to_send.send_info));
}