Add network tester client [android]

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& log_file_path)
-    : config_file_path_(config_file_path),
+    : socket_factory_(rtc::ThreadManager::Instance()->WrapCurrentThread()),
+      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(
@@ skipping 34 matching lines @@
       udp_transport_->SetRemoteAddress(remote_addr);
       SendData(packet, rtc::Optional<size_t>());
       packet_sender_.reset(new PacketSender(this, config_file_path_));
       packet_sender_->StartSending();
       rtc::CritScope scoped_lock(&local_test_done_lock_);
       local_test_done_ = false;
       remote_test_done_ = false;
       break;
     }
     case NetworkTesterPacket::TEST_START: {
+      local_test_done_ = false;
+      remote_test_done_ = false;
       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);
       packet_logger_.LogPacket(packet);
       break;
     }
@@ skipping 20 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