Reland of landing: Implement RTCConfiguration.iceCandidatePoolSize.

webrtc/p2p/base/portallocator.cc

Index: webrtc/p2p/base/portallocator.cc
diff --git a/webrtc/p2p/base/portallocator.cc b/webrtc/p2p/base/portallocator.cc
index 5c4243abf6b66e07c845448c24eed398e49edd02..fdf213b31198abed093a4f6d1c3bc98ccddee3e7 100644
--- a/webrtc/p2p/base/portallocator.cc
+++ b/webrtc/p2p/base/portallocator.cc
@@ -18,23 +18,85 @@
                                            const std::string& ice_ufrag,
                                            const std::string& ice_pwd,
                                            uint32_t flags)
-    : content_name_(content_name),
+    : flags_(flags),
+      generation_(0),
+      content_name_(content_name),
       component_(component),
-      flags_(flags),
-      generation_(0),
       ice_ufrag_(ice_ufrag),
       ice_pwd_(ice_pwd) {
-  RTC_DCHECK(!ice_ufrag.empty());
-  RTC_DCHECK(!ice_pwd.empty());
+  // Pooled sessions are allowed to be created with empty content name,
+  // component, ufrag and password.
+  RTC_DCHECK(ice_ufrag.empty() == ice_pwd.empty());
 }
 
-PortAllocatorSession* PortAllocator::CreateSession(
+void PortAllocator::SetConfiguration(
+    const ServerAddresses& stun_servers,
+    const std::vector<RelayServerConfig>& turn_servers,
+    int candidate_pool_size) {
+  bool ice_servers_changed =
+      (stun_servers != stun_servers_ || turn_servers != turn_servers_);
+  stun_servers_ = stun_servers;
+  turn_servers_ = turn_servers;
+
+  // If ICE servers changed, throw away any existing pooled sessions and create
+  // new ones.
+  if (ice_servers_changed) {
+    pooled_sessions_.clear();
+    allocated_pooled_session_count_ = 0;
+  }
+
+  // If |size| is less than the number of allocated sessions, get rid of the
+  // extras.
+  while (allocated_pooled_session_count_ > candidate_pool_size &&
+         !pooled_sessions_.empty()) {
+    pooled_sessions_.front().reset(nullptr);
+    pooled_sessions_.pop_front();
+    --allocated_pooled_session_count_;
+  }
+  // If |size| is greater than the number of allocated sessions, create new
+  // sessions.
+  while (allocated_pooled_session_count_ < candidate_pool_size) {
+    PortAllocatorSession* pooled_session = CreateSessionInternal("", 0, "", "");
+    pooled_session->StartGettingPorts();
+    pooled_sessions_.push_back(
+        std::unique_ptr<PortAllocatorSession>(pooled_session));
+    ++allocated_pooled_session_count_;
+  }
+  target_pooled_session_count_ = candidate_pool_size;
+}
+
+std::unique_ptr<PortAllocatorSession> PortAllocator::CreateSession(
     const std::string& sid,
     const std::string& content_name,
     int component,
     const std::string& ice_ufrag,
     const std::string& ice_pwd) {
-  return CreateSessionInternal(content_name, component, ice_ufrag, ice_pwd);
+  return std::unique_ptr<PortAllocatorSession>(
+      CreateSessionInternal(content_name, component, ice_ufrag, ice_pwd));
+}
+
+std::unique_ptr<PortAllocatorSession> PortAllocator::TakePooledSession(
+    const std::string& content_name,
+    int component,
+    const std::string& ice_ufrag,
+    const std::string& ice_pwd) {
+  RTC_DCHECK(!ice_ufrag.empty());
+  RTC_DCHECK(!ice_pwd.empty());
+  if (pooled_sessions_.empty()) {
+    return nullptr;
+  }
+  std::unique_ptr<PortAllocatorSession> ret =
+      std::move(pooled_sessions_.front());
+  ret->SetIceParameters(content_name, component, ice_ufrag, ice_pwd);
+  pooled_sessions_.pop_front();
+  return ret;
+}
+
+const PortAllocatorSession* PortAllocator::GetPooledSession() const {
+  if (pooled_sessions_.empty()) {
+    return nullptr;
+  }
+  return pooled_sessions_.front().get();
 }
 
 }  // namespace cricket