Add packet logger and server

webrtc/tools/network_tester/test_controller.cc

 /*
  *  Copyright 2017 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
 #include "webrtc/tools/network_tester/test_controller.h"
 
 namespace webrtc {
 
 TestController::TestController(int min_port,
                                int max_port,
-                               const std::string& config_file_path)
+                               const std::string& config_file_path,
+                               const std::string& log_file_path)
     : config_file_path_(config_file_path),
+      packet_logger_(log_file_path),
       local_test_done_(false),
       remote_test_done_(false) {
   auto socket =
       std::unique_ptr<rtc::AsyncPacketSocket>(socket_factory_.CreateUdpSocket(
           rtc::SocketAddress(rtc::GetAnyIP(AF_INET), 0), min_port, max_port));
   socket->SignalReadPacket.connect(this, &TestController::OnReadPacket);
   udp_transport_.reset(
       new cricket::UdpTransport("signaling transport", std::move(socket)));
 }
 
@@ skipping 32 matching lines @@
       break;
     }
     case NetworkTesterPacket::START_SEND: {
       packet_sender_.reset(new PacketSender(this, config_file_path_));
       packet_sender_->StartSending();
       break;
     }
     case NetworkTesterPacket::TEST_DATA: {
       packet.set_arrival_timestamp(packet_time.timestamp);
       packet.set_packet_size(len);
-      // log packet
+      packet_logger_.LogPacket(packet);
       break;
     }
     case NetworkTesterPacket::TEST_DONE: {
       remote_test_done_ = true;
       break;
     }
     default: { RTC_NOTREACHED(); }
   }
 }
 
 void TestController::SendData(const NetworkTesterPacket& packet,
                               rtc::Optional<size_t> data_size) {
   size_t packet_size = packet.ByteSize();
   send_data_[0] = packet_size;
   packet.SerializeToArray(&send_data_[1], std::numeric_limits<char>::max());
   if (data_size && *data_size > packet_size)
     packet_size = *data_size;
   udp_transport_->SendPacket(send_data_.data(), packet_size + 1,
                              rtc::PacketOptions(), 0);
 }
 
 void TestController::OnTestDone() {
   NetworkTesterPacket packet;
   packet.set_type(NetworkTesterPacket::TEST_DONE);
   SendData(packet, rtc::Optional<size_t>());
   local_test_done_ = true;
 }
 
 }  // namespace webrtc