Remove ports that are not used by any channel after timeout

webrtc/p2p/client/basicportallocator.cc

 /*
  *  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.
  */
 
@@ skipping 688 matching lines @@
   if (CandidatePairable(c, port) && !data->has_pairable_candidate()) {
     data->set_has_pairable_candidate(true);
 
     if (prune_turn_ports_ && port->Type() == RELAY_PORT_TYPE) {
       pruned = PruneTurnPorts(port);
     }
     // If the current port is not pruned yet, SignalPortReady.
     if (!data->pruned()) {
       LOG_J(LS_INFO, port) << "Port ready.";
       SignalPortReady(this, port);
+      port->KeepAliveUntilPruned();
     }
   }
 
   ProtocolType pvalue;
   bool candidate_protocol_enabled =
       StringToProto(c.protocol().c_str(), &pvalue) &&
       data->sequence()->ProtocolEnabled(pvalue);
 
   if (data->ready() && CheckCandidateFilter(c) && candidate_protocol_enabled) {
     std::vector<Candidate> candidates;
@@ skipping 35 matching lines @@
   RTC_CHECK(best_turn_port != nullptr);
 
   bool pruned = false;
   std::vector<PortInterface*> pruned_ports;
   for (PortData& data : ports_) {
     if (data.port()->Network()->name() == network_name &&
         data.port()->Type() == RELAY_PORT_TYPE && !data.pruned() &&
         ComparePort(data.port(), best_turn_port) < 0) {
       data.set_pruned();
       pruned = true;
+      data.port()->Prune();
       if (data.port() != newly_pairable_turn_port) {
         pruned_ports.push_back(data.port());
       }
     }
   }
   if (!pruned_ports.empty()) {
     LOG(LS_INFO) << "Pruned " << pruned_ports.size() << " ports";
     SignalPortsPruned(this, pruned_ports);
   }
   return pruned;
 }
 
+void BasicPortAllocatorSession::PruneAllPorts() {
+  for (PortData& data : ports_) {
+    data.port()->Prune();
+  }
+}
+
 void BasicPortAllocatorSession::OnPortComplete(Port* port) {
   ASSERT(rtc::Thread::Current() == network_thread_);
   LOG_J(LS_INFO, port) << "Port completed gathering candidates.";
   PortData* data = FindPort(port);
   ASSERT(data != NULL);
 
   // Ignore any late signals.
   if (!data->inprogress()) {
     return;
   }
@@ skipping 149 matching lines @@
 // Removes ports and candidates created on a given list of networks.
 void BasicPortAllocatorSession::RemovePortsAndCandidates(
     const std::vector<rtc::Network*>& networks) {
   std::vector<PortInterface*> ports_to_remove;
   std::vector<Candidate> candidates_to_remove;
   for (PortData& data : ports_) {
     if (std::find(networks.begin(), networks.end(),
                   data.sequence()->network()) == networks.end()) {
       continue;
     }
+    // Prune the port so that it may be destroyed.
+    data.port()->Prune();
     ports_to_remove.push_back(data.port());
     if (data.has_pairable_candidate()) {
       GetCandidatesFromPort(data, &candidates_to_remove);
       // Mark the port as having no pairable candidates so that its candidates
       // won't be removed multiple times.
       data.set_has_pairable_candidate(false);
     }
   }
   if (!ports_to_remove.empty()) {
     LOG(LS_INFO) << "Removed " << ports_to_remove.size() << " ports";
@@ skipping 482 matching lines @@
   ServerAddresses servers;
   for (size_t i = 0; i < relays.size(); ++i) {
     if (relays[i].type == turn_type && SupportsProtocol(relays[i], type)) {
       servers.insert(relays[i].ports.front().address);
     }
   }
   return servers;
 }
 
 }  // namespace cricket