Network thread

webrtc/p2p/base/faketransportcontroller.h

 /*
  *  Copyright 2009 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.
  */
 
@@ skipping 195 matching lines @@
       rtc::Thread::Current()->Post(this, 0, packet);
     } else {
       rtc::Thread::Current()->Send(this, 0, packet);
     }
     rtc::SentPacket sent_packet(options.packet_id, rtc::Time64());
     SignalSentPacket(this, sent_packet);
     return static_cast<int>(len);
   }
   int SetOption(rtc::Socket::Option opt, int value) override { return true; }
   bool GetOption(rtc::Socket::Option opt, int* value) override { return true; }
-  int GetError() override { return 0; }
+  int GetError() override { return -1; }
 
   void AddRemoteCandidate(const Candidate& candidate) override {
     remote_candidates_.push_back(candidate);
   }
 
   void RemoveRemoteCandidate(const Candidate& candidate) override {}
 
   const Candidates& remote_candidates() const { return remote_candidates_; }
 
   void OnMessage(rtc::Message* msg) override {
@@ skipping 269 matching lines @@
   explicit FakeTransportController(rtc::Thread* worker_thread)
       : TransportController(rtc::Thread::Current(), worker_thread, nullptr),
         fail_create_channel_(false) {}
 
   FakeTransportController(rtc::Thread* worker_thread, IceRole role)
       : TransportController(rtc::Thread::Current(), worker_thread, nullptr),
         fail_create_channel_(false) {
     SetIceRole(role);
   }
 
-  FakeTransport* GetTransport_w(const std::string& transport_name) {
+  FakeTransport* GetTransport_n(const std::string& transport_name) {
     return static_cast<FakeTransport*>(
-        TransportController::GetTransport_w(transport_name));
+        TransportController::GetTransport_n(transport_name));
   }
 
   void Connect(FakeTransportController* dest) {
-    worker_thread()->Invoke<void>(
-        rtc::Bind(&FakeTransportController::Connect_w, this, dest));
+    network_thread()->Invoke<void>(
+        rtc::Bind(&FakeTransportController::Connect_n, this, dest));
   }
 
-  TransportChannel* CreateTransportChannel_w(const std::string& transport_name,
+  TransportChannel* CreateTransportChannel_n(const std::string& transport_name,
                                              int component) override {
     if (fail_create_channel_) {
       return nullptr;
     }
-    return TransportController::CreateTransportChannel_w(transport_name,
+    return TransportController::CreateTransportChannel_n(transport_name,
                                                          component);
   }
 
   FakeCandidatePair* CreateFakeCandidatePair(
       const rtc::SocketAddress& local_address,
       int16_t local_network_id,
       const rtc::SocketAddress& remote_address,
       int16_t remote_network_id) {
     Candidate local_candidate(0, "udp", local_address, 0u, "", "", "local", 0,
                               "foundation", local_network_id, 0);
     Candidate remote_candidate(0, "udp", remote_address, 0u, "", "", "local", 0,
                                "foundation", remote_network_id, 0);
     return new FakeCandidatePair(local_candidate, remote_candidate);
   }
 
   void set_fail_channel_creation(bool fail_channel_creation) {
     fail_create_channel_ = fail_channel_creation;
   }
 
  protected:
-  Transport* CreateTransport_w(const std::string& transport_name) override {
+  Transport* CreateTransport_n(const std::string& transport_name) override {
     return new FakeTransport(transport_name);
   }
 
-  void Connect_w(FakeTransportController* dest) {
+  void Connect_n(FakeTransportController* dest) {
     // Simulate the exchange of candidates.
-    ConnectChannels_w();
-    dest->ConnectChannels_w();
+    ConnectChannels_n();
+    dest->ConnectChannels_n();
     for (auto& kv : transports()) {
       FakeTransport* transport = static_cast<FakeTransport*>(kv.second);
-      transport->SetDestination(dest->GetTransport_w(kv.first));
+      transport->SetDestination(dest->GetTransport_n(kv.first));
     }
   }
 
-  void ConnectChannels_w() {
+  void ConnectChannels_n() {
     TransportDescription faketransport_desc(
         std::vector<std::string>(),
         rtc::CreateRandomString(cricket::ICE_UFRAG_LENGTH),
         rtc::CreateRandomString(cricket::ICE_PWD_LENGTH), cricket::ICEMODE_FULL,
         cricket::CONNECTIONROLE_NONE, nullptr);
     for (auto& kv : transports()) {
       FakeTransport* transport = static_cast<FakeTransport*>(kv.second);
       // Set local transport description for FakeTransport before connecting.
       // Otherwise, the RTC_CHECK in Transport.ConnectChannel will fail.
       if (!transport->local_description()) {
         transport->SetLocalTransportDescription(faketransport_desc,
                                                 cricket::CA_OFFER, nullptr);
       }
       transport->ConnectChannels();
       transport->MaybeStartGathering();
     }
   }
 
  private:
   bool fail_create_channel_;
 };
 
 }  // namespace cricket
 
 #endif  // WEBRTC_P2P_BASE_FAKETRANSPORTCONTROLLER_H_