| Index: remoting/test/fake_socket_factory.cc
|
| diff --git a/remoting/test/fake_socket_factory.cc b/remoting/test/fake_socket_factory.cc
|
| index 39a9e862855a0dce3d809bb1c6925a9cf8070317..4c0748236480d64067737ec225ccedb4c1bf0944 100644
|
| --- a/remoting/test/fake_socket_factory.cc
|
| +++ b/remoting/test/fake_socket_factory.cc
|
| @@ -176,8 +176,7 @@ FakePacketSocketFactory::PendingPacket::PendingPacket(
|
| FakePacketSocketFactory::PendingPacket::PendingPacket(
|
| const PendingPacket& other) = default;
|
|
|
| -FakePacketSocketFactory::PendingPacket::~PendingPacket() {
|
| -}
|
| +FakePacketSocketFactory::PendingPacket::~PendingPacket() {}
|
|
|
| FakePacketSocketFactory::FakePacketSocketFactory(
|
| FakeNetworkDispatcher* dispatcher)
|
| @@ -296,11 +295,17 @@ void FakePacketSocketFactory::ReceivePacket(
|
| if (leaky_bucket_) {
|
| delay = leaky_bucket_->AddPacket(data_size);
|
| if (delay.is_max()) {
|
| + ++total_packets_dropped_;
|
| // Drop the packet.
|
| return;
|
| }
|
| }
|
|
|
| + total_buffer_delay_ += delay;
|
| + if (delay > max_buffer_delay_)
|
| + max_buffer_delay_ = delay;
|
| + ++total_packets_received_;
|
| +
|
| if (latency_average_ > base::TimeDelta()) {
|
| delay += base::TimeDelta::FromMillisecondsD(
|
| GetNormalRandom(latency_average_.InMillisecondsF(),
|
| @@ -347,4 +352,11 @@ void FakePacketSocketFactory::DoReceivePacket() {
|
| iter->second.Run(packet.from, packet.to, packet.data, packet.data_size);
|
| }
|
|
|
| +void FakePacketSocketFactory::ResetStats() {
|
| + total_packets_dropped_ = 0;
|
| + total_packets_received_ = 0;
|
| + total_buffer_delay_ = base::TimeDelta();
|
| + max_buffer_delay_ = base::TimeDelta();
|
| +}
|
| +
|
| } // namespace remoting
|
|
|