123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502 |
- #ifndef RTC_BASE_NETWORK_H_
- #define RTC_BASE_NETWORK_H_
- #include <stdint.h>
- #include <deque>
- #include <map>
- #include <memory>
- #include <string>
- #include <vector>
- #include "rtc_base/ip_address.h"
- #include "rtc_base/mdns_responder_interface.h"
- #include "rtc_base/message_handler.h"
- #include "rtc_base/network_monitor.h"
- #include "rtc_base/network_monitor_factory.h"
- #include "rtc_base/synchronization/sequence_checker.h"
- #include "rtc_base/system/rtc_export.h"
- #include "rtc_base/third_party/sigslot/sigslot.h"
- #include "rtc_base/thread_annotations.h"
- #if defined(WEBRTC_POSIX)
- struct ifaddrs;
- #endif
- namespace rtc {
- extern const char kPublicIPv4Host[];
- extern const char kPublicIPv6Host[];
- class IfAddrsConverter;
- class Network;
- class NetworkMonitorInterface;
- class Thread;
- const int kDefaultNetworkIgnoreMask = ADAPTER_TYPE_LOOPBACK;
- std::string MakeNetworkKey(const std::string& name,
- const IPAddress& prefix,
- int prefix_length);
- RTC_EXPORT AdapterType GetAdapterTypeFromName(const char* network_name);
- class DefaultLocalAddressProvider {
- public:
- virtual ~DefaultLocalAddressProvider() = default;
-
-
-
- virtual bool GetDefaultLocalAddress(int family, IPAddress* ipaddr) const = 0;
- };
- class MdnsResponderProvider {
- public:
- virtual ~MdnsResponderProvider() = default;
-
-
-
-
- virtual webrtc::MdnsResponderInterface* GetMdnsResponder() const = 0;
- };
- class RTC_EXPORT NetworkManager : public DefaultLocalAddressProvider,
- public MdnsResponderProvider {
- public:
- typedef std::vector<Network*> NetworkList;
-
- enum EnumerationPermission {
- ENUMERATION_ALLOWED,
-
-
- ENUMERATION_BLOCKED,
-
- };
- NetworkManager();
- ~NetworkManager() override;
-
- sigslot::signal0<> SignalNetworksChanged;
-
- sigslot::signal0<> SignalError;
-
-
- virtual void Initialize() {}
-
-
-
-
- virtual void StartUpdating() = 0;
- virtual void StopUpdating() = 0;
-
-
-
-
-
- virtual void GetNetworks(NetworkList* networks) const = 0;
-
- virtual EnumerationPermission enumeration_permission() const;
-
-
-
-
-
-
-
-
-
- virtual void GetAnyAddressNetworks(NetworkList* networks) {}
-
- virtual void DumpNetworks() {}
- bool GetDefaultLocalAddress(int family, IPAddress* ipaddr) const override;
- struct Stats {
- int ipv4_network_count;
- int ipv6_network_count;
- Stats() {
- ipv4_network_count = 0;
- ipv6_network_count = 0;
- }
- };
-
- webrtc::MdnsResponderInterface* GetMdnsResponder() const override;
- };
- class RTC_EXPORT NetworkManagerBase : public NetworkManager {
- public:
- NetworkManagerBase();
- ~NetworkManagerBase() override;
- void GetNetworks(NetworkList* networks) const override;
- void GetAnyAddressNetworks(NetworkList* networks) override;
- EnumerationPermission enumeration_permission() const override;
- bool GetDefaultLocalAddress(int family, IPAddress* ipaddr) const override;
- protected:
- typedef std::map<std::string, Network*> NetworkMap;
-
-
-
-
-
- void MergeNetworkList(const NetworkList& list, bool* changed);
-
- void MergeNetworkList(const NetworkList& list,
- bool* changed,
- NetworkManager::Stats* stats);
- void set_enumeration_permission(EnumerationPermission state) {
- enumeration_permission_ = state;
- }
- void set_default_local_addresses(const IPAddress& ipv4,
- const IPAddress& ipv6);
- private:
- friend class NetworkTest;
- Network* GetNetworkFromAddress(const rtc::IPAddress& ip) const;
- EnumerationPermission enumeration_permission_;
- NetworkList networks_;
- NetworkMap networks_map_;
- std::unique_ptr<rtc::Network> ipv4_any_address_network_;
- std::unique_ptr<rtc::Network> ipv6_any_address_network_;
- IPAddress default_local_ipv4_address_;
- IPAddress default_local_ipv6_address_;
-
-
-
-
- uint16_t next_available_network_id_ = 1;
-
-
- bool signal_network_preference_change_ = false;
- };
- class RTC_EXPORT BasicNetworkManager : public NetworkManagerBase,
- public MessageHandlerAutoCleanup,
- public sigslot::has_slots<> {
- public:
- BasicNetworkManager();
- explicit BasicNetworkManager(NetworkMonitorFactory* network_monitor_factory);
- ~BasicNetworkManager() override;
- void StartUpdating() override;
- void StopUpdating() override;
- void DumpNetworks() override;
-
- void OnMessage(Message* msg) override;
- bool started() { return start_count_ > 0; }
-
-
-
- void set_network_ignore_list(const std::vector<std::string>& list) {
- RTC_DCHECK(thread_ == nullptr);
- network_ignore_list_ = list;
- }
- protected:
- #if defined(WEBRTC_POSIX)
-
- void ConvertIfAddrs(ifaddrs* interfaces,
- IfAddrsConverter* converter,
- bool include_ignored,
- NetworkList* networks) const RTC_RUN_ON(thread_);
- #endif
-
- bool CreateNetworks(bool include_ignored, NetworkList* networks) const
- RTC_RUN_ON(thread_);
-
-
- bool IsIgnoredNetwork(const Network& network) const RTC_RUN_ON(thread_);
-
-
-
- IPAddress QueryDefaultLocalAddress(int family) const RTC_RUN_ON(thread_);
- private:
- friend class NetworkTest;
-
- void StartNetworkMonitor() RTC_RUN_ON(thread_);
-
- void StopNetworkMonitor() RTC_RUN_ON(thread_);
-
- void OnNetworksChanged();
-
- void UpdateNetworksContinually() RTC_RUN_ON(thread_);
-
- void UpdateNetworksOnce() RTC_RUN_ON(thread_);
- Thread* thread_ = nullptr;
- bool sent_first_update_ = true;
- int start_count_ = 0;
- std::vector<std::string> network_ignore_list_;
- NetworkMonitorFactory* network_monitor_factory_ RTC_GUARDED_BY(thread_) =
- nullptr;
- std::unique_ptr<NetworkMonitorInterface> network_monitor_
- RTC_GUARDED_BY(thread_);
- };
- class RTC_EXPORT Network {
- public:
- Network(const std::string& name,
- const std::string& description,
- const IPAddress& prefix,
- int prefix_length);
- Network(const std::string& name,
- const std::string& description,
- const IPAddress& prefix,
- int prefix_length,
- AdapterType type);
- Network(const Network&);
- ~Network();
-
- sigslot::signal1<const Network*> SignalTypeChanged;
-
- sigslot::signal1<const Network*> SignalNetworkPreferenceChanged;
- const DefaultLocalAddressProvider* default_local_address_provider() {
- return default_local_address_provider_;
- }
- void set_default_local_address_provider(
- const DefaultLocalAddressProvider* provider) {
- default_local_address_provider_ = provider;
- }
- void set_mdns_responder_provider(const MdnsResponderProvider* provider) {
- mdns_responder_provider_ = provider;
- }
-
- const std::string& name() const { return name_; }
-
-
- const std::string& description() const { return description_; }
-
- const IPAddress& prefix() const { return prefix_; }
-
- int prefix_length() const { return prefix_length_; }
-
-
- std::string key() const { return key_; }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- IPAddress GetBestIP() const;
-
-
- IPAddress ip() const { return GetBestIP(); }
-
- void AddIP(const InterfaceAddress& ip) { ips_.push_back(ip); }
- void AddIP(const IPAddress& ip) { ips_.push_back(rtc::InterfaceAddress(ip)); }
-
-
- bool SetIPs(const std::vector<InterfaceAddress>& ips, bool already_changed);
-
- const std::vector<InterfaceAddress>& GetIPs() const { return ips_; }
-
- void ClearIPs() { ips_.clear(); }
-
-
-
-
- webrtc::MdnsResponderInterface* GetMdnsResponder() const;
-
-
- int scope_id() const { return scope_id_; }
- void set_scope_id(int id) { scope_id_ = id; }
-
-
- bool ignored() const { return ignored_; }
- void set_ignored(bool ignored) { ignored_ = ignored; }
- AdapterType type() const { return type_; }
-
-
-
-
-
-
- AdapterType underlying_type_for_vpn() const {
- return underlying_type_for_vpn_;
- }
- void set_type(AdapterType type) {
- if (type_ == type) {
- return;
- }
- type_ = type;
- if (type != ADAPTER_TYPE_VPN) {
- underlying_type_for_vpn_ = ADAPTER_TYPE_UNKNOWN;
- }
- SignalTypeChanged(this);
- }
- void set_underlying_type_for_vpn(AdapterType type) {
- if (underlying_type_for_vpn_ == type) {
- return;
- }
- underlying_type_for_vpn_ = type;
- SignalTypeChanged(this);
- }
- bool IsVpn() const { return type_ == ADAPTER_TYPE_VPN; }
- bool IsCellular() const { return IsCellular(type_); }
- static bool IsCellular(AdapterType type) {
- switch (type) {
- case ADAPTER_TYPE_CELLULAR:
- case ADAPTER_TYPE_CELLULAR_2G:
- case ADAPTER_TYPE_CELLULAR_3G:
- case ADAPTER_TYPE_CELLULAR_4G:
- case ADAPTER_TYPE_CELLULAR_5G:
- return true;
- default:
- return false;
- }
- }
- uint16_t GetCost() const;
-
-
- uint16_t id() const { return id_; }
- void set_id(uint16_t id) { id_ = id; }
- int preference() const { return preference_; }
- void set_preference(int preference) { preference_ = preference; }
-
-
-
- bool active() const { return active_; }
- void set_active(bool active) {
- if (active_ != active) {
- active_ = active;
- }
- }
-
-
- NetworkPreference network_preference() const { return network_preference_; }
- void set_network_preference(NetworkPreference val) {
- if (network_preference_ == val) {
- return;
- }
- network_preference_ = val;
- SignalNetworkPreferenceChanged(this);
- }
-
- std::string ToString() const;
- private:
- const DefaultLocalAddressProvider* default_local_address_provider_ = nullptr;
- const MdnsResponderProvider* mdns_responder_provider_ = nullptr;
- std::string name_;
- std::string description_;
- IPAddress prefix_;
- int prefix_length_;
- std::string key_;
- std::vector<InterfaceAddress> ips_;
- int scope_id_;
- bool ignored_;
- AdapterType type_;
- AdapterType underlying_type_for_vpn_ = ADAPTER_TYPE_UNKNOWN;
- int preference_;
- bool active_ = true;
- uint16_t id_ = 0;
- bool use_differentiated_cellular_costs_ = false;
- NetworkPreference network_preference_ = NetworkPreference::NEUTRAL;
- friend class NetworkManager;
- };
- }
- #endif
|