TransportController refactoring

webrtc/p2p/base/rawtransportchannel.h

 /*
  *  Copyright 2004 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.
  */
 
 #ifndef WEBRTC_P2P_BASE_RAWTRANSPORTCHANNEL_H_
 #define WEBRTC_P2P_BASE_RAWTRANSPORTCHANNEL_H_
 
 #include <string>
 #include <vector>
 #include "webrtc/p2p/base/candidate.h"
 #include "webrtc/p2p/base/rawtransport.h"
 #include "webrtc/p2p/base/transportchannelimpl.h"
 #include "webrtc/base/messagequeue.h"
 
 #if defined(FEATURE_ENABLE_PSTN)
 
-namespace rtc {
-class Thread;
-}
-
 namespace cricket {
 
 class Connection;
 class PortAllocator;
 class PortAllocatorSession;
 class PortInterface;
 class RelayPort;
 class StunPort;
 
 // Implements a channel that just sends bare packets once we have received the
 // address of the other side.  We pick a single address to send them based on
 // a simple investigation of NAT type.
-class RawTransportChannel : public TransportChannelImpl,
-    public rtc::MessageHandler {
+class RawTransportChannel : public TransportChannelImpl {
  public:
   RawTransportChannel(const std::string& content_name,
                       int component,
                       RawTransport* transport,
-                      rtc::Thread *worker_thread,
-                      PortAllocator *allocator);
+                      PortAllocator* allocator);
   virtual ~RawTransportChannel();
 
   // Implementation of normal channel packet sending.
   virtual int SendPacket(const char *data, size_t len,
                          const rtc::PacketOptions& options, int flags);
   virtual int SetOption(rtc::Socket::Option opt, int value);
   virtual bool GetOption(rtc::Socket::Option opt, int* value);
   virtual int GetError();
 
   // Implements TransportChannelImpl.
   virtual Transport* GetTransport() { return raw_transport_; }
   virtual TransportChannelState GetState() const {
     return TransportChannelState::STATE_COMPLETED;
   }
   virtual void SetIceCredentials(const std::string& ice_ufrag,
                                  const std::string& ice_pwd) {}
   virtual void SetRemoteIceCredentials(const std::string& ice_ufrag,
                                        const std::string& ice_pwd) {}
 
   // Creates an allocator session to start figuring out which type of
   // port we should send to the other client.  This will send
   // SignalAvailableCandidate once we have decided.
   virtual void Connect();
 
+  virtual GatheringState gathering_state() const { return kGatheringNew; }
+
   // Resets state back to unconnected.
   virtual void Reset();
 
-  // We don't actually worry about signaling since we can't send new candidates.
-  virtual void OnSignalingReady() {}
-
   // Handles a message setting the remote address.  We are writable once we
   // have this since we now know where to send.
   virtual void OnCandidate(const Candidate& candidate);
 
   void OnRemoteAddress(const rtc::SocketAddress& remote_address);
 
   // Below ICE specific virtual methods not implemented.
   virtual IceRole GetIceRole() const { return ICEROLE_UNKNOWN; }
   virtual void SetIceRole(IceRole role) {}
   virtual void SetIceTiebreaker(uint64 tiebreaker) {}
@@ skipping 66 matching lines @@
     const std::string& digest_alg,
     const uint8* digest,
     size_t digest_len) {
     return false;
   }
 
   void SetReceivingTimeout(int timeout) override {}
 
  private:
   RawTransport* raw_transport_;
-  rtc::Thread *worker_thread_;
   PortAllocator* allocator_;
   PortAllocatorSession* allocator_session_;
   StunPort* stun_port_;
   RelayPort* relay_port_;
   PortInterface* port_;
   bool use_relay_;
   rtc::SocketAddress remote_address_;
 
   // Called when the allocator creates another port.
   void OnPortReady(PortAllocatorSession* session, PortInterface* port);
 
   // Called when one of the ports we are using has determined its address.
   void OnCandidatesReady(PortAllocatorSession *session,
                          const std::vector<Candidate>& candidates);
 
   // Called once we have chosen the port to use for communication with the
   // other client.  This will send its address and prepare the port for use.
   void SetPort(PortInterface* port);
 
   // Called once we have a port and a remote address.  This will set mark the
   // channel as writable and signal the route to the client.
   void SetWritable();
 
   // Called when we receive a packet from the other client.
   void OnReadPacket(PortInterface* port, const char* data, size_t size,
                     const rtc::SocketAddress& addr);
 
-  // Handles a message to destroy unused ports.
-  virtual void OnMessage(rtc::Message *msg);
+  void DestroyUnusedPorts();
 
   DISALLOW_COPY_AND_ASSIGN(RawTransportChannel);
 };
 
 }  // namespace cricket
 
 #endif  // defined(FEATURE_ENABLE_PSTN)
 #endif  // WEBRTC_P2P_BASE_RAWTRANSPORTCHANNEL_H_