OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef NET_BASE_ADDRESS_TRACKER_LINUX_H_ | 5 #ifndef NET_BASE_ADDRESS_TRACKER_LINUX_H_ |
6 #define NET_BASE_ADDRESS_TRACKER_LINUX_H_ | 6 #define NET_BASE_ADDRESS_TRACKER_LINUX_H_ |
7 | 7 |
8 #include <sys/socket.h> // Needed to include netlink. | 8 #include <sys/socket.h> // Needed to include netlink. |
9 // Mask superfluous definition of |struct net|. This is fixed in Linux 2.6.38. | 9 // Mask superfluous definition of |struct net|. This is fixed in Linux 2.6.38. |
10 #define net net_kernel | 10 #define net net_kernel |
11 #include <linux/rtnetlink.h> | 11 #include <linux/rtnetlink.h> |
12 #undef net | 12 #undef net |
13 | 13 |
14 #include <map> | 14 #include <map> |
15 | 15 |
16 #include "base/basictypes.h" | 16 #include "base/basictypes.h" |
17 #include "base/callback.h" | 17 #include "base/callback.h" |
18 #include "base/compiler_specific.h" | 18 #include "base/compiler_specific.h" |
19 #include "base/containers/hash_tables.h" | 19 #include "base/containers/hash_tables.h" |
20 #include "base/message_loop/message_loop.h" | 20 #include "base/message_loop/message_loop.h" |
21 #include "base/synchronization/condition_variable.h" | 21 #include "base/synchronization/condition_variable.h" |
22 #include "base/synchronization/lock.h" | 22 #include "base/synchronization/lock.h" |
| 23 #include "base/threading/thread_checker.h" |
23 #include "net/base/net_util.h" | 24 #include "net/base/net_util.h" |
24 #include "net/base/network_change_notifier.h" | 25 #include "net/base/network_change_notifier.h" |
25 | 26 |
26 namespace net { | 27 namespace net { |
27 namespace internal { | 28 namespace internal { |
28 | 29 |
29 // Keeps track of network interface addresses using rtnetlink. Used by | 30 // Keeps track of network interface addresses using rtnetlink. Used by |
30 // NetworkChangeNotifier to provide signals to registered IPAddressObservers. | 31 // NetworkChangeNotifier to provide signals to registered IPAddressObservers. |
31 class NET_EXPORT_PRIVATE AddressTrackerLinux : | 32 class NET_EXPORT_PRIVATE AddressTrackerLinux : |
32 public base::MessageLoopForIO::Watcher { | 33 public base::MessageLoopForIO::Watcher { |
33 public: | 34 public: |
34 typedef std::map<IPAddressNumber, struct ifaddrmsg> AddressMap; | 35 typedef std::map<IPAddressNumber, struct ifaddrmsg> AddressMap; |
35 | 36 |
36 // Will run |address_callback| when the AddressMap changes, |link_callback| | 37 // Non-tracking version constructor: it takes a snapshot of the |
37 // when the list of online links changes, and |tunnel_callback| when the list | 38 // current system configuration. Once Init() returns, the |
38 // of online tunnels changes. | 39 // configuration is available through GetOnlineLinks() and |
| 40 // GetAddressMap(). |
| 41 AddressTrackerLinux(); |
| 42 |
| 43 // Tracking version constructor: it will run |address_callback| when |
| 44 // the AddressMap changes, |link_callback| when the list of online |
| 45 // links changes, and |tunnel_callback| when the list of online |
| 46 // tunnels changes. |
39 AddressTrackerLinux(const base::Closure& address_callback, | 47 AddressTrackerLinux(const base::Closure& address_callback, |
40 const base::Closure& link_callback, | 48 const base::Closure& link_callback, |
41 const base::Closure& tunnel_callback); | 49 const base::Closure& tunnel_callback); |
42 virtual ~AddressTrackerLinux(); | 50 virtual ~AddressTrackerLinux(); |
43 | 51 |
44 // Starts watching system configuration for changes. The current thread must | 52 // In tracking mode, it starts watching the system configuration for |
45 // have a MessageLoopForIO. | 53 // changes. The current thread must have a MessageLoopForIO. In |
| 54 // non-tracking mode, once Init() returns, a snapshot of the system |
| 55 // configuration is available through GetOnlineLinks() and |
| 56 // GetAddressMap(). |
46 void Init(); | 57 void Init(); |
47 | 58 |
48 AddressMap GetAddressMap() const; | 59 AddressMap GetAddressMap() const; |
49 | 60 |
| 61 // Returns set of interface indicies for online interfaces. |
| 62 base::hash_set<int> GetOnlineLinks() const; |
| 63 |
50 // Implementation of NetworkChangeNotifierLinux::GetCurrentConnectionType(). | 64 // Implementation of NetworkChangeNotifierLinux::GetCurrentConnectionType(). |
51 // Safe to call from any thread, but will block until Init() has completed. | 65 // Safe to call from any thread, but will block until Init() has completed. |
52 NetworkChangeNotifier::ConnectionType GetCurrentConnectionType(); | 66 NetworkChangeNotifier::ConnectionType GetCurrentConnectionType(); |
53 | 67 |
54 private: | 68 private: |
55 friend class AddressTrackerLinuxTest; | 69 friend class AddressTrackerLinuxTest; |
56 | 70 |
| 71 // In tracking mode, holds |lock| while alive. In non-tracking mode, |
| 72 // enforces single-threaded access. |
| 73 class AddressTrackerAutoLock { |
| 74 public: |
| 75 AddressTrackerAutoLock(const AddressTrackerLinux& tracker, |
| 76 base::Lock& lock); |
| 77 ~AddressTrackerAutoLock(); |
| 78 |
| 79 private: |
| 80 const AddressTrackerLinux& tracker_; |
| 81 base::Lock& lock_; |
| 82 DISALLOW_COPY_AND_ASSIGN(AddressTrackerAutoLock); |
| 83 }; |
| 84 |
57 // A function that returns the name of an interface given the interface index | 85 // A function that returns the name of an interface given the interface index |
58 // in |interface_index|. | 86 // in |interface_index|. |
59 typedef const char* (*GetInterfaceNameFunction)(int interface_index); | 87 typedef const char* (*GetInterfaceNameFunction)(int interface_index); |
60 | 88 |
61 // Sets |*address_changed| to indicate whether |address_map_| changed and | 89 // Sets |*address_changed| to indicate whether |address_map_| changed and |
62 // sets |*link_changed| to indicate if |online_links_| changed and sets | 90 // sets |*link_changed| to indicate if |online_links_| changed and sets |
63 // |*tunnel_changed| to indicate if |online_links_| changed with regards to a | 91 // |*tunnel_changed| to indicate if |online_links_| changed with regards to a |
64 // tunnel interface while reading messages from |netlink_fd_|. | 92 // tunnel interface while reading messages from |netlink_fd_|. |
65 void ReadMessages(bool* address_changed, | 93 void ReadMessages(bool* address_changed, |
66 bool* link_changed, | 94 bool* link_changed, |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
98 base::Closure link_callback_; | 126 base::Closure link_callback_; |
99 base::Closure tunnel_callback_; | 127 base::Closure tunnel_callback_; |
100 | 128 |
101 int netlink_fd_; | 129 int netlink_fd_; |
102 base::MessageLoopForIO::FileDescriptorWatcher watcher_; | 130 base::MessageLoopForIO::FileDescriptorWatcher watcher_; |
103 | 131 |
104 mutable base::Lock address_map_lock_; | 132 mutable base::Lock address_map_lock_; |
105 AddressMap address_map_; | 133 AddressMap address_map_; |
106 | 134 |
107 // Set of interface indices for links that are currently online. | 135 // Set of interface indices for links that are currently online. |
| 136 mutable base::Lock online_links_lock_; |
108 base::hash_set<int> online_links_; | 137 base::hash_set<int> online_links_; |
109 | 138 |
110 base::Lock is_offline_lock_; | 139 base::Lock is_offline_lock_; |
111 bool is_offline_; | 140 bool is_offline_; |
112 bool is_offline_initialized_; | 141 bool is_offline_initialized_; |
113 base::ConditionVariable is_offline_initialized_cv_; | 142 base::ConditionVariable is_offline_initialized_cv_; |
| 143 bool tracking_; |
| 144 |
| 145 // Used to verify single-threaded access in non-tracking mode. |
| 146 base::ThreadChecker thread_checker_; |
114 }; | 147 }; |
115 | 148 |
116 } // namespace internal | 149 } // namespace internal |
117 } // namespace net | 150 } // namespace net |
118 | 151 |
119 #endif // NET_BASE_ADDRESS_TRACKER_LINUX_H_ | 152 #endif // NET_BASE_ADDRESS_TRACKER_LINUX_H_ |
OLD | NEW |