OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2008 Apple Inc. All Rights Reserved. | 2 * Copyright (C) 2008 Apple Inc. All Rights Reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * 1. Redistributions of source code must retain the above copyright | 7 * 1. Redistributions of source code must retain the above copyright |
8 * notice, this list of conditions and the following disclaimer. | 8 * notice, this list of conditions and the following disclaimer. |
9 * 2. Redistributions in binary form must reproduce the above copyright | 9 * 2. Redistributions in binary form must reproduce the above copyright |
10 * notice, this list of conditions and the following disclaimer in the | 10 * notice, this list of conditions and the following disclaimer in the |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
45 public: | 45 public: |
46 // Will be called on the thread of the context passed in addObserver. | 46 // Will be called on the thread of the context passed in addObserver. |
47 virtual void connectionChange(WebConnectionType, double maxBandwidthMbps
) = 0; | 47 virtual void connectionChange(WebConnectionType, double maxBandwidthMbps
) = 0; |
48 }; | 48 }; |
49 | 49 |
50 NetworkStateNotifier() | 50 NetworkStateNotifier() |
51 : m_initialized(false) | 51 : m_initialized(false) |
52 , m_isOnLine(true) | 52 , m_isOnLine(true) |
53 , m_type(WebConnectionTypeOther) | 53 , m_type(WebConnectionTypeOther) |
54 , m_maxBandwidthMbps(kInvalidMaxBandwidth) | 54 , m_maxBandwidthMbps(kInvalidMaxBandwidth) |
55 , m_testUpdatesOnly(false) | 55 , m_hasOverride(false) |
| 56 , m_overrideOnLine(true) |
| 57 , m_overrideType(WebConnectionTypeOther) |
| 58 , m_overrideMaxBandwidthMbps(kInvalidMaxBandwidth) |
56 { | 59 { |
57 } | 60 } |
58 | 61 |
59 // Can be called on any thread. | 62 // Can be called on any thread. |
60 bool onLine() const | 63 bool onLine() const |
61 { | 64 { |
62 MutexLocker locker(m_mutex); | 65 MutexLocker locker(m_mutex); |
63 ASSERT(m_initialized); | 66 ASSERT(m_initialized); |
64 return m_isOnLine; | 67 return m_hasOverride ? m_overrideOnLine : m_isOnLine; |
65 } | 68 } |
66 | 69 |
67 void setOnLine(bool); | 70 void setOnLine(bool); |
68 | 71 |
69 // Can be called on any thread. | 72 // Can be called on any thread. |
70 WebConnectionType connectionType() const | 73 WebConnectionType connectionType() const |
71 { | 74 { |
72 MutexLocker locker(m_mutex); | 75 MutexLocker locker(m_mutex); |
73 ASSERT(m_initialized); | 76 ASSERT(m_initialized); |
74 return m_type; | 77 return m_hasOverride ? m_overrideType : m_type; |
75 } | 78 } |
76 | 79 |
77 // Can be called on any thread. | 80 // Can be called on any thread. |
78 bool isCellularConnectionType() const | 81 bool isCellularConnectionType() const |
79 { | 82 { |
80 switch (connectionType()) { | 83 switch (connectionType()) { |
81 case WebConnectionTypeCellular2G: | 84 case WebConnectionTypeCellular2G: |
82 case WebConnectionTypeCellular3G: | 85 case WebConnectionTypeCellular3G: |
83 case WebConnectionTypeCellular4G: | 86 case WebConnectionTypeCellular4G: |
84 return true; | 87 return true; |
85 case WebConnectionTypeBluetooth: | 88 case WebConnectionTypeBluetooth: |
86 case WebConnectionTypeEthernet: | 89 case WebConnectionTypeEthernet: |
87 case WebConnectionTypeWifi: | 90 case WebConnectionTypeWifi: |
88 case WebConnectionTypeWimax: | 91 case WebConnectionTypeWimax: |
89 case WebConnectionTypeOther: | 92 case WebConnectionTypeOther: |
90 case WebConnectionTypeNone: | 93 case WebConnectionTypeNone: |
91 case WebConnectionTypeUnknown: | 94 case WebConnectionTypeUnknown: |
92 return false; | 95 return false; |
93 } | 96 } |
94 ASSERT_NOT_REACHED(); | 97 ASSERT_NOT_REACHED(); |
95 return false; | 98 return false; |
96 } | 99 } |
97 | 100 |
98 // Can be called on any thread. | 101 // Can be called on any thread. |
99 double maxBandwidth() const | 102 double maxBandwidth() const |
100 { | 103 { |
101 MutexLocker locker(m_mutex); | 104 MutexLocker locker(m_mutex); |
102 ASSERT(m_initialized); | 105 ASSERT(m_initialized); |
103 return m_maxBandwidthMbps; | 106 return m_hasOverride ? m_overrideMaxBandwidthMbps : m_maxBandwidthMbps; |
104 } | 107 } |
105 | 108 |
106 void setWebConnection(WebConnectionType, double maxBandwidthMbps); | 109 void setWebConnection(WebConnectionType, double maxBandwidthMbps); |
107 | 110 |
| 111 // When called, successive setWebConnectionType/setOnLine calls are ignored, |
| 112 // and supplied overridden values are used instead. |
| 113 // This is used for layout tests (see crbug.com/377736) and inspector emulat
ion. |
| 114 // |
| 115 // Since this class is a singleton, tests must clear override when completed
to |
| 116 // avoid indeterminate state across the test harness. When switching in or o
ut of test |
| 117 // mode, all state will be reset to default values. |
| 118 void setOverride(bool onLine, WebConnectionType, double maxBandwidthMbps); |
| 119 void clearOverride(); |
| 120 |
108 // Must be called on the context's thread. An added observer must be removed | 121 // Must be called on the context's thread. An added observer must be removed |
109 // before its ExecutionContext is deleted. It's possible for an observer to | 122 // before its ExecutionContext is deleted. It's possible for an observer to |
110 // be called twice for the same event if it is first removed and then added | 123 // be called twice for the same event if it is first removed and then added |
111 // during notification. | 124 // during notification. |
112 void addObserver(NetworkStateObserver*, ExecutionContext*); | 125 void addObserver(NetworkStateObserver*, ExecutionContext*); |
113 void removeObserver(NetworkStateObserver*, ExecutionContext*); | 126 void removeObserver(NetworkStateObserver*, ExecutionContext*); |
114 | 127 |
115 // The following functions are for testing purposes. | |
116 | |
117 // When true, setWebConnectionType calls are ignored and only setWebConnecti
onTypeForTest | |
118 // can update the connection type. This is used for layout tests (see crbug.
com/377736). | |
119 // | |
120 // Since this class is a singleton, tests must call this with false when com
pleted to | |
121 // avoid indeterminate state across the test harness. When switching in or o
ut of test | |
122 // mode, all state will be reset to default values. | |
123 void setTestUpdatesOnly(bool); | |
124 // Tests should call this as it will change the type regardless of the value
of m_testUpdatesOnly. | |
125 void setWebConnectionForTest(WebConnectionType, double maxBandwidthMbps); | |
126 | |
127 private: | 128 private: |
128 struct ObserverList { | 129 struct ObserverList { |
129 ObserverList() | 130 ObserverList() |
130 : iterating(false) | 131 : iterating(false) |
131 { | 132 { |
132 } | 133 } |
133 bool iterating; | 134 bool iterating; |
134 Vector<NetworkStateObserver*> observers; | 135 Vector<NetworkStateObserver*> observers; |
135 Vector<size_t> zeroedObservers; // Indices in observers that are 0. | 136 Vector<size_t> zeroedObservers; // Indices in observers that are 0. |
136 }; | 137 }; |
137 | 138 |
138 const int kInvalidMaxBandwidth = -1; | 139 const int kInvalidMaxBandwidth = -1; |
139 | 140 |
140 void setWebConnectionImpl(WebConnectionType, double maxBandwidthMbps); | |
141 void setMaxBandwidthImpl(double maxBandwidthMbps); | |
142 | |
143 // The ObserverListMap is cross-thread accessed, adding/removing Observers r
unning | 141 // The ObserverListMap is cross-thread accessed, adding/removing Observers r
unning |
144 // within an ExecutionContext. Kept off-heap to ease cross-thread allocation
and use; | 142 // within an ExecutionContext. Kept off-heap to ease cross-thread allocation
and use; |
145 // the observers are (already) responsible for explicitly unregistering whil
e finalizing. | 143 // the observers are (already) responsible for explicitly unregistering whil
e finalizing. |
146 using ObserverListMap = HashMap<UntracedMember<ExecutionContext>, std::uniqu
e_ptr<ObserverList>>; | 144 using ObserverListMap = HashMap<UntracedMember<ExecutionContext>, std::uniqu
e_ptr<ObserverList>>; |
147 | 145 |
| 146 void notifyObservers(); |
148 void notifyObserversOfConnectionChangeOnContext(WebConnectionType, double ma
xBandwidthMbps, ExecutionContext*); | 147 void notifyObserversOfConnectionChangeOnContext(WebConnectionType, double ma
xBandwidthMbps, ExecutionContext*); |
149 | 148 |
150 ObserverList* lockAndFindObserverList(ExecutionContext*); | 149 ObserverList* lockAndFindObserverList(ExecutionContext*); |
151 | 150 |
152 // Removed observers are nulled out in the list in case the list is being | 151 // Removed observers are nulled out in the list in case the list is being |
153 // iterated over. Once done iterating, call this to clean up nulled | 152 // iterated over. Once done iterating, call this to clean up nulled |
154 // observers. | 153 // observers. |
155 void collectZeroedObservers(ObserverList*, ExecutionContext*); | 154 void collectZeroedObservers(ObserverList*, ExecutionContext*); |
156 | 155 |
157 mutable Mutex m_mutex; | 156 mutable Mutex m_mutex; |
158 bool m_initialized; | 157 bool m_initialized; |
159 bool m_isOnLine; | 158 bool m_isOnLine; |
160 WebConnectionType m_type; | 159 WebConnectionType m_type; |
161 double m_maxBandwidthMbps; | 160 double m_maxBandwidthMbps; |
162 ObserverListMap m_observers; | 161 ObserverListMap m_observers; |
163 bool m_testUpdatesOnly; | 162 bool m_hasOverride; |
| 163 bool m_overrideOnLine; |
| 164 WebConnectionType m_overrideType; |
| 165 double m_overrideMaxBandwidthMbps; |
164 }; | 166 }; |
165 | 167 |
166 CORE_EXPORT NetworkStateNotifier& networkStateNotifier(); | 168 CORE_EXPORT NetworkStateNotifier& networkStateNotifier(); |
167 | 169 |
168 } // namespace blink | 170 } // namespace blink |
169 | 171 |
170 #endif // NetworkStateNotifier_h | 172 #endif // NetworkStateNotifier_h |
OLD | NEW |