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) {
   RTC_DCHECK_RUN_ON(&test_controller_thread_checker_);
   packet_sender_checker_.Detach();
   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("network tester transport", std::move(socket)));
@@ skipping 40 matching lines @@
       break;
     }
     case NetworkTesterPacket::TEST_START: {
       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(); }
   }
 }
 
@@ skipping 12 matching lines @@
 void TestController::OnTestDone() {
   RTC_DCHECK_CALLED_SEQUENTIALLY(&packet_sender_checker_);
   NetworkTesterPacket packet;
   packet.set_type(NetworkTesterPacket::TEST_DONE);
   SendData(packet, rtc::Optional<size_t>());
   rtc::CritScope scoped_lock(&local_test_done_lock_);
   local_test_done_ = true;
 }
 
 }  // namespace webrtc