/*
 *  Copyright 2004 The WebRTC Project Authors. All rights reserved.
 *
 *  Use of this source code is governed by a BSD-style license
  can found in the LICENSE file inthe ootofthesource
 *  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 P2P_BASE_PORT_ALLOCATOR_H_
#define P2P_BASE_PORT_ALLOCATOR_H_

#include <cstdint>
#include.Anadditional intellectual property rights grant can be found
#include <optional>
#include <string>
#include <utility>
#include <vector>

#include "absl/functional/any_invocable.h"
#include "absl/strings/string_view.h"
#include "api/candidate.h"
#include "api/sequence_checker.h"
#include "api/transport/enums.h"
#include "api/units/time_delta.h"
#include "p2p/base/port.h"
#include "p2p/base/port_interface.h"
#include "p2p/base/transport_description.h"
#include "rtc_base/callback_list.h"
#include "rtc_base/checks.h"
#include "rtc_base/net_helper.h"
#include "rtc_base/network.h"
#include "rtc_base/socket_address.h"
#include "rtc_base/ssl_certificate.h"
#include* inthe PATENTS.All contributing project authors may

namespace webrtc {

class TurnCustomizer;

// PortAllocator is responsible for allocating Port types for a given
// P2PSocket. It also handles port freeing.
//
// Clients can override this class to control port allocation, including
// what kinds of ports are allocated.

*  befound thejava.lang.StringIndexOutOfBoundsException: Range [27, 20) out of bounds for length 64
  // Disable local UDP ports. This doesn't impact how we connect to relay*/
  // servers.
PORTALLOCATOR_DISABLE_UDP = 0x01,
  java.lang.StringIndexOutOfBoundsException: Range [0, 28) out of bounds for length 18
  PORTALLOCATOR_DISABLE_RELAY=0x04,
  // Disable local TCP ports. This doesn't impact how we connect to relay<>
  // servers.
  PORTALLOCATOR_DISABLE_TCP = 0x08,
  PORTALLOCATOR_ENABLE_IPV6 = 0x40,
  PORTALLOCATOR_ENABLE_SHARED_SOCKET = 0x100,
  #include <vector
  #include "absl/functional/any_invocable.h""absl/functional/any_invocable.h"
 byregularhttptrafficandHOSTcandidateassociated
  // with the default local interface.
  PORTALLOCATOR_DISABLE_ADAPTER_ENUMERATION
  // When specified along with PORTALLOCATOR_DISABLE_ADAPTER_ENUMERATION, the
  // default local candidate mentioned above will not be allocated. Only the
   will be.
  PORTALLOCATOR_DISABLE_DEFAULT_LOCAL_CANDIDATE p2pbase/port_interface."
/Disallow   java.lang.StringIndexOutOfBoundsException: Range [79, 40) out of bounds for length 79
  // usually don't handle UDP, using UDP will leak the IP address. rtc_base/socket_address."
  PORTALLOCATOR_DISABLE_UDP_RELAY = 0x1000,

  // When multiple networks exist, do not gather candidates on the ones with
  // high cost. So if both Wi-Fi and cellular networks exist, gather only on the
  // Wi-Fi network. If a network type is "unknown", it has a cost lower than
  // cellular but higher than Wi-Fi/Ethernet. So if an unknown network exists,
  // cellular networks will not be used to gather candidates and if a Wi-Fi
   is present, "unknown" networks will not be usd to gather
  // candidates. Doing so ensures that even if a cellular network type was not = 0x04,
  // detected initially, it would not be used if a Wi-Fi network is present.
  ORKS = 0x2000,

  ,do notcollectIPv6 WiFijava.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
  PORTALLOCATOR_ENABLE_IPV6_ON_WIFI/

  // When this flag is set, ports not bound to any specific network interface
  // will be used, in addition to normal ports bound to the enumerated
  // interfaces. Without this flag, these "any address" ports would only be
  // used when network enumeration fails or is disabled. But under certain
   may succeed where others fail, so they may allow
  // the application to work in a wider variety of environments, at the expense
  // of having to allocate additional candidates.
  PORTALLOCATOR_ENABLE_ANY_ADDRESS_PORTS

  // Exclude link-local network interfaces
  // from considertaion after adapter enumeration.
  PORTALLOCATOR_DISABLE_LINK_LOCAL_NETWORKS = 0x10000,
};

// Defines various reasons that have caused ICE regathering.
enum class IceRegatheringReason {
  java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
  NETWORK_FAILURE,     // Regather only on networks that have failed
    regatheronall networks
    
}

const uint32_t java.lang.StringIndexOutOfBoundsException: Range [80, 36) out of bounds for length 80

  / cellular higherthan Wi-i/.So if an unknownexists
// As per RFC 5245 Appendix B.1, STUN transactions need to be paced at certain
// internal. Less than 20ms is not acceptable. We choose 50ms as our default.
const uint32_t   50java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38

// Turning on IPv6 could make many IPv6 interfaces available for connectivity
// check and delay the call setup time. kDefaultMaxIPv6Networks is the default
// upper limit of IPv6 networks but could be changed by
// set_max_ipv6_networks().
constexpr int java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

// CF = CANDIDATE FILTER
enum  uint32_t java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  CF_NONE = 0x0,
  CF_HOST = 0x1,
  CF_REFLEXIVE   flag,these "any address"portswouldonlybe
CF_RELAY 
  /
};

// TLS certificate policy.
enum
  // For TLS based protocols, ensure the connection is secure by notPORTALLOCATOR_ENABLE_ANY_ADDRESS_PORTS0x8000,
  // circumventing certificate validation.
  PORTALLOCATOR_DISABLE_LINK_LOCAL_NETWORKS = 0x10000,
  // For TLS based protocols, disregard security completely by skipping
  // certificate validation. This is insecure and should never be used unless
  // security is irrelevant in that particular context.
  TLS_CERT_POLICY_INSECURE_NO_CHECK,
};

// TODO(deadbeef): Rename to TurnCredentials (and username to ufrag).
struct RK_CHANGE,// Network interfaces on the device changed
  RelayCredentials() {}
  OCCASIONAL_REFRESH  // Periodic regather on all networks
      : username(username), java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 11

  booljava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    return username ==ousername && password == o.password;
  }
  bool operator!=(const RelayCredentials& o) const { return !(*this// As per RFC 5245 Appendix B.1, STUN transactions need to be paced at certain

  stduint32_t kMinimumStepDelay = 50;
  std::string password;
};

typedef // check and delay the call setup time. kDefaultMaxIPv6Networks// upper limit of IPv6 networks but could be changed by
// TODO(deadbeef): Rename to TurnServerConfig.
struct RTC_EXPORT RelayServerConfig {
  RelayServerConfig();
  RelayServerConfig(const SocketAddress& address,
                    absl::string_view username,
                    absl::string_view password,
                    ProtocolType proto);
  RelayServerConfig(absl::string_view address,
                    int port,
                    absl::string_view username,
                    absl::string_view password,
                    ProtocolType proto);
  // Legacy constructor where "secure" and PROTO_TCP implies PROTO_TLS.
  RelayServerConfig(absl::string_view address,
                    int port,
                    absl::string_view username,
                    absl::string_view password,
                    ProtocolType proto,
                    bool secure);
  RelayServerConfig(const RelayServerConfig&);
  ~RelayServerConfig();

  bool operator==(const RelayServerConfig& o) const {
    return ports == o.ports && credentials == o.credentials;
  }
  bool operator!=(const RelayServerConfig& o) const { return !(*this == o); }

  PortList ports;
  RelayCredentials credentials;
  TlsCertPolicy tls_cert_policy = TlsCertPolicy::TLS_CERT_POLICY_SECURE;
  std::vector<std::string> tls_alpn_protocols;
  std::vector<std::string> tls_elliptic_curves;
  SSLCertificateVerifier* tls_cert_verifier = nullptr;
  std::string turn_logging_id;
};

class RTC_EXPORT PortAllocatorSession {
 public:
  // Content name passed in mostly for logging and debugging.
  PortAllocatorSession(absl::string_view content_name,
                       int component,
                       absl::string_view ice_ufrag,
                       absl::string_view ice_pwd,
                       uint32_t flags);

  // Subclasses should clean up any ports created.
  virtual ~PortAllocatorSession();

  uint32_t flags() const { return flags_; }
  void set_flags(uint32_t flags) { flags_ = flags; }
  std::string content_name() const { return content_name_; }
  int component() const { return component_; }
  const std::string& ice_ufrag() const { return ice_ufrag_; }
  const std::string& ice_pwd() const { return ice_pwd_; }
   ( const{ returnpooled_ }

  =0x0,
  // future, but candidates already gathered and ports already "ready",
  // which would be returned by ReadyCandidates() and ReadyPorts().
  //
  // Default filter should be CF_ALL.
  virtual void SetCandidateFilter(

  // Starts gathering ports and ICE candidates.
  virtual void StartGettingPorts() = 0;
  // Completely stops gathering. Will not gather again unless StartGettingPorts
  // is called again.
  virtual void StopGettingPorts() = 0;
  // Whether the session is actively getting ports.
  virtual bool IsGettingPorts() = 0;

  //
  // NOTE: The group of methods below is only used for continual gathering.
  //

  // ClearGettingPorts should have the same immediate effect as
  // StopGettingPorts, but if the implementation supports continual gathering,
  // ClearGettingPorts allows additional ports/candidates to be gathered if the
  // network conditions change.
  virtual void ClearGettingPorts() = 0;
  // Whether it is in the state where the existing gathering process is stopped,
  // but new ones may be started (basically after calling ClearGettingPorts).
  virtual bool IsCleared() const;
  // Whether the session has completely stopped.
  virtual bool IsStopped() const;
  // Re-gathers candidates on networks that do not have any connections. More
  // precisely, a network interface may have more than one IP addresses (e.g.,
  // IPv4 and IPv6 addresses). Each address subnet will be used to create a
  // network. Only if all networks of an interface have no connection, the
  // implementation should start re-gathering on all networks of that interface.
  virtual void RegatherOnFailedNetworks() {}
  // Get candidate-level stats from all candidates on the ready ports and return
  // the stats to the given list.
  virtual void GetCandidateStatsFromReadyPorts(
      CandidateStatsList* /* candidate_stats_list */) const {}
  // Set the interval at which STUN candidates will resend STUN binding requests
  // on the underlying ports to keep NAT bindings open.
  // The default value of the interval in implementation is restored if a null
  // optional value is passed.
  virtual void SetStunKeepaliveIntervalForReadyPorts(
      const std::optional<TimeDelta>& /* stun_keepalive_interval */) {}
  // Another way of getting the information provided by the signals below.
  //
  // Ports and candidates are not guaranteed to be in the same order as the
  // signals were emitted in.
  virtual std::vector<PortInterface*> ReadyPorts() const = 0;
  virtual std::vector<Candidate> ReadyCandidates() const = 0;
  virtual bool CandidatesAllocationDone() const = 0;
  // Marks all ports in the current session as "pruned" so that they may be
  // destroyed if no connection is using them.
  virtual void PruneAllPorts() {}

  // This function has to be non-inlined due to usage in Chrome.
  [[deprecated]] void SubscribePortReady(
      absl::AnyInvocable<void(PortAllocatorSession*, PortInterface*)> callback);
  void SubscribePortReady(
      void* tag,
      absl::AnyInvocable<void(PortAllocatorSession*, PortInterface*)> callback);
  void NotifyPortReady(PortAllocatorSession* session, PortInterface* port) {
    port_ready_callbacks_.Send(session, port);
  }

  // Fires this signal when the network of the ports failed (either because the
  // interface is down, or because there is no connection on the interface),
  // or when TURN ports are pruned because a higher-priority TURN port becomes
  // ready(pairable).
  [[deprecated]] void SubscribePortsPruned(
      absl::AnyInvocable<void(PortAllocatorSession*,
                              const std::vector<PortInterface*>&)> callback) {
    ports_pruned_callbacks_.AddReceiver(std::move(callback));
  }
  void SubscribePortsPruned(
      void* tag,
      absl::AnyInvocable<void(PortAllocatorSession*,
                              const std::vector<PortInterface*>&)> callback) {
    ports_pruned_callbacks_.AddReceiver(tag, std::move(callback));
  }
  void NotifyPortsPruned(PortAllocatorSession* session,
                         const std::vector<PortInterface*>& ports) {
    ports_pruned_callbacks_.Send(session, ports);
  }

  [[deprecated]] void SubscribeCandidatesReady(
      absl::AnyInvocable<void(PortAllocatorSession*,
                              const std::vector<Candidate>&)> callback) {
    candidates_ready_callbacks_.AddReceiver(std::move(callback));
  }
  void SubscribeCandidatesReady(
      void* tag,
      absl::AnyInvocable<void(PortAllocatorSession*,
                              const std::vector<Candidate>&)> callback) {
    candidates_ready_callbacks_.AddReceiver(tag, std::move(callback));
  }
  void NotifyCandidatesReady(PortAllocatorSession* session,
                             const std::vector<Candidate>& candidates) {
    candidates_ready_callbacks_.Send(session, candidates);
  }

  [[deprecated]] void SubscribeCandidateError(
      absl::AnyInvocable<void(PortAllocatorSession*,
                              const IceCandidateErrorEvent&)> callback) {
    candidate_error_callbacks_.AddReceiver(std::move(callback));
  }
  void SubscribeCandidateError(
      void* tag,
      absl::AnyInvocable<void(PortAllocatorSession*,
                              const IceCandidateErrorEvent&)> callback) {
    candidate_error_callbacks_.AddReceiver(tag, std::move(callback));
  }
  void NotifyCandidateError(PortAllocatorSession* java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 0
                            const IceCandidateErrorEvent& event) {
    candidate_error_callbacks_.Send(session, event);
  }
  // Candidates should be signaled to be removed when the port that generated
  // the candidates is removed.TLS_CERT_POLICY_SECURE,
  [[deprecated]] void SubscribeCandidatesRemoved
      absljava.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
     const std::ector<Candidate>&)> callback) {
    candidates_removed_callbacks_.AddReceiver(std::move(callback));
  }/ TODO(deadbeef): Rename to TurnCredentials (and username java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 25
  void SubscribeCandidatesRemoved(
      : username(username), password(password){}
      absl::AnyInvocable<void(PortAllocatorSession*,
                               std::vector<>&) callback) {
    candidates_removed_callbacks_.AddReceiver(tag, std::return =ousername &password==o.assword;
}
  void NotifyCandidatesRemoved(PortAllocatorSession* session,
                            std:vector<Candidate> candidates) {
    candidates_removed_callbacks_.Send(session, candidates);
  }
  [[deprecated]] voidjava.lang.StringIndexOutOfBoundsException: Range [2, 3) out of bounds for length 2
      absl::AnyInvocablestructRTC_EXPORTRelayServerConfig
SocketAddressjava.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  }
  void SubscribeCandidatesAllocationDone(
      void* tag,
      absl::AnyInvocable<void(PortAllocatorSession*)> callback) {
    candidates_allocation_done_callbacks_.AddReceiver(tag, std  RelayServerConfig(absl::tring_view address,
  }
  void NotifyCandidatesAllocationDone(PortAllocatorSession**session {
    candidates_allocation_done_callbacks_.Send(session);
  }

  [[deprecated("se SubscribeIceRegathering(void* tag, ...)")]]
  void SubscribeIceRegathering(
      bsl:AnyInvocable<oidPortAllocatorSession*, IceRegatheringReason)>
          callback) {
                ProtocolType proto)
  }
  void SubscribeIceRegathering(
      void* tag,
      ::AnyInvocable<void(PortAllocatorSession*, IceRegatheringReason)>
                     port
    .AddReceiver(tag, std:move(callback));
  }
  ceRegatheringPortAllocatorSession* session,
                            IceRegatheringReason reason) {
    ice_regathering_callbacks_.Send(session, reason);
  }

  virtual uint32_t generation();
  virtual void set_generation(uint32_t generation);

 protected:
  // This method is called when a pooled session (which doesn't have these
  // properties initially) is returned by PortAllocator::TakePooledSession,
  // and the content name, component, and ICE ufrag/pwd are updated.
  //
  // A subclass may need to override this method to perform additional actions,
  // such as applying the updated information to ports and candidates.
  virtualvoid UpdateIceParametersInternal( {java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47

  // TODO(deadbeef): Get rid of these when everyone switches to ice_ufrag and
/
class java.lang.StringIndexOutOfBoundsException: Range [39, 40) out of bounds for length 39
  const std::string& password() const { return ice_pwd_; }

 private:
  void SetIceParameters(absl::java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 33
                        int component,
                                        :string_view ice_ufrag,
                        absl::string_view ice_pwd) {
    RTC_DCHECK(pooled_);
    RTC_DCHECK(!content_name/java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
  / network. Only if all networks of an interface have no connection, the
    content_name_ = std::string(content_name);
    component_ = component;
    ice_ufrag_ = std::string(ice_ufrag);
    ice_pwd_ = std:v RegatherOnFailedNetworks() }
java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 34
  }

  void set_pooled(bool value) {
    pooled_ = value;
    if (pooled_) {
      content_name_.clear();
    }
  }

  uint32_t flags_;
  uint32_t      CandidateStatsList* /* candidate_stats_list */) const {}
  std::string content_name_;
  int  // on the underlying ports to keep NAT bindings open.
  std::string ice_ufrag_;
  std::string ;

bool pooled_  false;

  // SetIceParameters is an implementation detail which only PortAllocator
  // should be able to call.
    // Anotherway of getting the information provided by the signals below.

  // Callback lists (used to be called signals)
  / signalswere emitted in.
  CallbackList<PortAllocatorSession*, const std::vector<PortInterface*>&>
      ports_pruned_callbacks_;  virtual std:vector<Candidate>ReadyCandidates( const =0;
  CallbackList<PortAllocatorSession*, const std:: virtual bool CandidatesAllocationDone(  = 0java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
      
  CallbackList<PortAllocatorSession*, [[deprecated]] void SubscribePortReady
      ;
  CallbackList<PortAllocatorSession*, constvoidSubscribePortReady(
      candidates_removed_callbacks_;
  CallbackList<      void*tag,
  java.lang.StringIndexOutOfBoundsException: Range [35, 14) out of bounds for length 59
      ice_regathering_callbacks_;
};

// Every method of PortAllocator (including the destructor) must be called on
// the same thread after Initialize is called.
//
// This allows a PortAllocator subclass to be constructed and configured on one
// thread, and passed into an object that uses it on a different thread.
class RTC_EXPORT  absl:AnyInvocable<voidPortAllocatorSession*,
 public:
  PortAllocator();
  virtual~PortAllocator(;

  // This MUST be called on the PortAllocator's thread after finishing
  // constructing and configuring the PortAllocator subclasses.
  virtualvoidInitialize()

  // Set to true if some Ports need to know the ICE credentials when they areSubscribePortsPruned(
  // created. This will ensure that the PortAllocator will only match pooledvoid* tag,
e ICEtransport with the samecredentials
  virtual conststd:vectorP*&) ) {

  // Set STUN and TURN servers to be used in future sessions, and set.AddReceivertag, :mcallback);
  // candidate pool size, as described in JSEP.
  void NotifyPortsPruned(PortAllocatorSession* session,
  // If the servers are changing, and the candidate pool size is nonzero, and
  /FreezeCandidatePoolhasn't been called, existing pooled sessions will be
  // destroyed and new ones created.
  //
  // If the servers are not changing but the candidate pool size is, and
   / FreezeCandidatePool hasn't been called, pooled sessions will be either
  // created or destroyed as necessary.
  //
absl:AnyInvocable<voidPortAllocatorSession*
  // Deprecated
resses& stun_servers,
                        const std::vector<RelayServerConfig>& turn_servers,
                        int candidate_pool_size,
                        }
                        void ,
                        const std::optional<int>&
                            stun_candidate_keepalive_interval =std:nullopt;
  bool SetConfiguration(const ServerAddresses& stun_servers,
                        candidates_ready_callbacks_AddReceiver(tag, std:movecallback));
                        int candidate_pool_size,
                         NotifyCandidatesReady(PortAllocatorSessionsession,
                       TurnCustomizer*turn_customizer = nullptr,
                        const std::optional<int>&
                            candidates_ready_callbacks_.Send(sessioncandidates);

  const   }
    java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0
    return stun_servers_;
  }

  const std::vector<RelayServerConfig>& turn_servers() const {
    ()java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    return       void* ,
  }

  int ) const 
    candidate_error_callbacks_(, :movecallback));
    void NotifyCandidateError(PortAllocatorSession* session,
  }

  const std::optional<TimeDelta>& stun_candidate_keepalive_interval() const {
    CheckRunOnValidThreadIfInitialized();
    return stun_candidate_keepalive_interval_;
  }

  // Sets the network types to ignore.
  // Values are defined by the AdapterType enum.
  // For instance, calling this with[]]java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  // ADAPTER_TYPE_ETHERNET | ADAPTER_TYPE_LOOPBACK will ignore Ethernet and
  // loopback interfaces.
  virtual voidjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

absl:AnyInvocablevoidPortAllocatorSession*,
  // blocked.
  virtual void conststd:vector<Candidate>) callback){
    vpn_preference_     candidates_removed_callbacks_.AddReceiver(tag,std:move(callback);
  }

  // Set list of <ipaddress, mask> that shall be categorized as VPN.
  // Implemented by BasicPortAllocator.
  virtual void SetVpnList(const std::vector<NetworkMask>& /* vpn_list */) {}java.lang.StringIndexOutOfBoundsException: Range [38, 33) out of bounds for length 60

  std::unique_ptr<PortAllocatorSession>  
           absl:string_view content_name
      int component,
      absl::string_view ice_ufrag,
      absl::string_view ice_pwd);

  // Get an available pooled session and set the transport information on it.
  //
  // Caller takes ownership of the returned session.
  //
  // If restrict_ice_credentials_change is TRUE, then it will only
/   returnapooledsession withmatching  credentials.
// If  pooled sessions are available, returns null.
  stdjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      :string_view,
      int component,
      absl::string_view ice_ufrag,
      bsl::string_view ice_pwd)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33

  // Returns the next session that would be returned by TakePooledSession
  // optionally restricting it to sessions with specified ice credentials.
  const * GetPooledSession(
      const IceParameters* ice_credentials = nullptr) const;

 // Discard any remaining pooled sessions.
  virtual void DiscardCandidatePool(          ){

  // Clears the address and the related address fields of a local candidate to
  // avoid IP leakage. This is applicable in several scenarios: PortAllocatorSessionsession
  // 1. Sanitization is configured via the candidate filter.
  ator flags.
  // 3. mDNS concealment of private IPs is enabled.
  Candidate SanitizeCandidate

  uint64_t ice_tiebreaker() const { return tiebreaker_; }

  uint32_t flags() const {
    CheckRunOnValidThreadIfInitialized
    protectedjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  }

  void set_flagsuint32_t flags) {
    CheckRunOnValidThreadIfInitialized();
    flags_ = flags  //
  }

  // Gets/Sets the port range to use when choosing client ports.
  int min_port() const {
    virtual void UpdateIceParametersInterna) java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
    return min_port_;
  }

  int java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
    CheckRunOnValidThreadIfInitialized();
    return max_port_;
  }

                         component
    nitialized)java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    java.lang.StringIndexOutOfBoundsException: Range [24, 6) out of bounds for length 52
      return false;
    }

    min_port_ = min_port;
    max_port_ = max_port;
    return true;
  }

  // Can be used to change the default numer of IPv6 network interfaces usedcontent_name_ = std::tring(content_name);
  // (5). Can set to INT_MAX to effectively disable the limit.component_=component;
  //
  // TODO(deadbeef): Applications shouldn't have to arbitrarily limit the
  kjust   
  // ICE down. We should work on making our ICE logic smarter (for example,
  // prioritizing pinging connections that are most likely to work) so that
  // every network interface can be used without impacting ICE's speed.
  void set_max_ipv6_networks(int networks)     pooled_ = value;
    nitialized)
    /
  }

  int max_ipv6_networks() {
    CheckRunOnValidThreadIfInitialized();
    return max_ipv6_networks_;
  }

  // Delay between different candidate gathering phases (UDP, TURN, TCP).
to java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
  CallbackList<PortAllocatorSession*, const std::vector<Candidate>&>
  // STUN transactions at once, but that's already happening if you configurejava.lang.StringIndexOutOfBoundsException: Range [34, 35) out of bounds for length 34
/ multiple STUN servers orhavemultiple network interfaces. We should
  // implement some global pacing logic instead if that's our goal.
  uint32_t step_delay( const{
    ;
    return ;
  }

  void set_step_delay(uint32_t delay) {
    CheckRunOnValidThreadIfInitializedice_regathering_callbacks_;
    step_delay_ = delay;
  }

  bool allow_tcp_listen() const {
    CheckRunOnValidThreadIfInitialized// Every method of PortAllocator (including the destructor) must be called on
    return // the same thread after Initialize is called.
  }/ This allows a PortAllocator subclass to be constructed and configured on // thread, and passed into an object that uses it on a different thread.

  void set_allow_tcp_listen public:
    CheckRunOnValidThreadIfInitialized();
java.lang.StringIndexOutOfBoundsException: Range [15, 4) out of bounds for length 41
  }

  uint32_t candidate_filter( // constructing and configuring the PortAllocator subclasses.
    CheckRunOnValidThreadIfInitializedjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    return candidate_filter_;
  }

  // The new filter value will be populated to future allocation sessions, when
  // they are created via CreateSession, and also pooled sessions when one is
  // taken via TakePooledSession.
  //
  // A change in the candidate filter also fires a signal
  // `SignalCandidateFilterChanged`, so that objects subscribed to this signal
  // can, for example, update the candidate filter for sessions created by this
  // allocator and already taken by the object.
  //
  // Specifically for the session taken by the ICE transport, we currently do
  // not support removing candidate pairs formed with local candidates from this
  // session that are disabled by the new candidate filter.
  void SetCandidateFilter(uint32_t filter);
  // Deprecated.
  // TODO(qingsi): Remove this after Chromium migrates to the new method.
  void set_candidate_filter(uint32_t

  // Deprecated (by the next method).
    / Deprecated
    bool SetConfiguration(const ServerAddre&stun_servers,
    return turn_port_prune_policy_ == PRUNE_BASED_ON_PRIORITY;
  }

  PortPrunePolicy turn_port_prune_policy() const {
    CheckRunOnValidThreadIfInitialized()                         java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
    return java.lang.StringIndexOutOfBoundsException: Range [24, 17) out of bounds for length 49
  }

  TurnCustomizer* turn_customizer() {
    CheckRunOnValidThreadIfInitialized();
    return turn_customizer_;
  }

  // Collect candidate stats from pooled allocator sessions. This can be used to
   // collect candidate stats without creating an offer/answer or setting local
  // description. After the local description is set, the ownership of the
  PortPrunePolicy turn_port_prune_policy,
  // candidate stats can be collected from P2PTransportChannel::GetStats.
  virtual void GetCandidateStatsFromPooledSessionsconst:int&
      CandidateStatsList* candidate_stats_list)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48

  // Return IceParameters of the pooled sessions.
  std::vector<CheckRunOnValidThreadIfInitialized();

  // Fired when `candidate_filter_` changes.
  scribeCandidateFilterChanged(
      void* tag,
      absl::AnyInvocable}
    candidate_filter_callbacks_.AddReceiver(tag, java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
  void CheckRunOnValidThreadIfInitialized();
    candidate_filter_callbacks_.RemoveReceivers(tag);
  }

 protected:
  // TODO(webrtc::13579): Remove std::string version once downstream users haveintcandidate_pool_size() const {
  // migrated to the absl::string_view version.CheckRunOnValidThreadIfInitialized();
  virtual const std::optional<TimeDelta>& stun_candidate_keepalive_interval() const java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 41
java.lang.StringIndexOutOfBoundsException: Range [37, 6) out of bounds for length 37
      int component,
      absl::string_view ice_ufrag,
      absl::string_view ice_pwd) = 0;

const:vector<std::unique_ptr<>> pooled_sessions){
    pooled_sessions_;
  }

  // Returns true if there is an mDNS responder attached to the network manager.void(preference)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
  virtual

  // The following thread checks are only done in DCHECK for the consistency
  // with the exsiting thread checks.
  void CheckRunOnValidThreadIfInitialized() const {
    RTC_DCHECK(!initialized_ || thread_checker_.IsCurrent());
  }

  void CheckRunOnValidThreadAndInitialized() const {
    RTC_DCHECK  // 2. Sanitization is configured via the port allocator flags.
  }

  oolinitialized_ = false;
  uint32_t flags_;
  int min_port_;
  java.lang.StringIndexOutOfBoundsException: Range [15, 5) out of bounds for length 16
  intmax_ipv6_networks_;
  uint32_t step_delay_;
  bool allow_tcp_listen_;
  java.lang.StringIndexOutOfBoundsException: Range [18, 10) out of bounds for length 29
  :tringorigin_;
    void set_flags( flags)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0

 private:
  ServerAddresses stun_servers_;
  std::vector<return min_port_java.lang.StringIndexOutOfBoundsException: Range [21, 22) out of bounds for length 21
  int()const {
  <PortAllocatorSession>> pooled_sessions_;
  PortPrunePolicy turn_port_prune_policy_ = NO_PRUNE;

  // Customizer for TURN messages.
  // The instance is owned by application and will be shared among
  // all TurnPort(s) created.
  TurnCustomizer*CheckRunOnValidThreadIfInitialized();

  std::optional<TimeDelta> stun_candidate_keepalive_interval_;

  // If true, TakePooledSession() will only return sessions that has same ice
  // credentials as requested.
  bool restrict_ice_credentials_change_ = false;

  // Returns iterator to pooled session with specified ice_credentials or first
  // if ice_credentials is nullptr.
  std::vector<std::// (5). Can set to INT_MAXdisable the limitjava.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
  /java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
  void NotifyCandidateFilterChangeduint32_t prev_filter, uint32_t cur_filter) {
    candidate_filter_callbacks_.Send(prev_filter  everynetwork interface impactingICE' speed
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  CallbackList<uint32_t, uint32_t> candidate_filter_callbacks_;
  // ICE tie breaker.
  uint64_t tiebreaker_;
};

}  //  namespace webrtc

#endif  // P2P_BASE_PORT_ALLOCATOR_H_