| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 #include "chrome/browser/chromeos/cros/network_library.h" | 5 #include "chrome/browser/chromeos/cros/network_library.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/string_number_conversions.h" | 9 #include "base/string_number_conversions.h" |
| 10 #include "base/string_util.h" | 10 #include "base/string_util.h" |
| 11 #include "base/utf_string_conversions.h" | 11 #include "base/utf_string_conversions.h" |
| 12 #include "chrome/browser/chrome_thread.h" | 12 #include "chrome/browser/chrome_thread.h" |
| 13 #include "chrome/browser/chromeos/cros/cros_library.h" | 13 #include "chrome/browser/chromeos/cros/cros_library.h" |
| 14 #include "net/url_request/url_request_job.h" | |
| 15 | 14 |
| 16 namespace chromeos { | 15 namespace chromeos { |
| 17 | 16 |
| 18 static const std::string kGoogleWifi = "Google"; | 17 static const std::string kGoogleWifi = "Google"; |
| 19 static const std::string kGoogleAWifi = "Google-A"; | 18 static const std::string kGoogleAWifi = "Google-A"; |
| 20 | 19 |
| 21 // Helper function to wrap Html with <th> tag. | 20 // Helper function to wrap Html with <th> tag. |
| 22 static std::string WrapWithTH(std::string text) { | 21 static std::string WrapWithTH(std::string text) { |
| 23 return "<th>" + text + "</th>"; | 22 return "<th>" + text + "</th>"; |
| 24 } | 23 } |
| (...skipping 173 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 198 case SECURITY_RSN: | 197 case SECURITY_RSN: |
| 199 return "RSN"; | 198 return "RSN"; |
| 200 case SECURITY_8021X: | 199 case SECURITY_8021X: |
| 201 return "8021X"; | 200 return "8021X"; |
| 202 } | 201 } |
| 203 return "Unknown";} | 202 return "Unknown";} |
| 204 | 203 |
| 205 //////////////////////////////////////////////////////////////////////////////// | 204 //////////////////////////////////////////////////////////////////////////////// |
| 206 // NetworkLibrary | 205 // NetworkLibrary |
| 207 | 206 |
| 208 class NetworkLibraryImpl : public NetworkLibrary, | 207 class NetworkLibraryImpl : public NetworkLibrary { |
| 209 public URLRequestJobTracker::JobObserver { | |
| 210 public: | 208 public: |
| 211 NetworkLibraryImpl() | 209 NetworkLibraryImpl() |
| 212 : traffic_type_(0), | 210 : network_status_connection_(NULL), |
| 213 network_status_connection_(NULL), | |
| 214 available_devices_(0), | 211 available_devices_(0), |
| 215 enabled_devices_(0), | 212 enabled_devices_(0), |
| 216 connected_devices_(0), | 213 connected_devices_(0), |
| 217 offline_mode_(false) { | 214 offline_mode_(false) { |
| 218 if (CrosLibrary::Get()->EnsureLoaded()) { | 215 if (CrosLibrary::Get()->EnsureLoaded()) { |
| 219 Init(); | 216 Init(); |
| 220 } else { | 217 } else { |
| 221 InitTestData(); | 218 InitTestData(); |
| 222 } | 219 } |
| 223 g_url_request_job_tracker.AddObserver(this); | |
| 224 } | 220 } |
| 225 | 221 |
| 226 ~NetworkLibraryImpl() { | 222 ~NetworkLibraryImpl() { |
| 227 if (network_status_connection_) { | 223 if (network_status_connection_) { |
| 228 DisconnectMonitorNetwork(network_status_connection_); | 224 DisconnectMonitorNetwork(network_status_connection_); |
| 229 } | 225 } |
| 230 g_url_request_job_tracker.RemoveObserver(this); | |
| 231 } | |
| 232 | |
| 233 ///////////////////////////////////////////////////////////////////////////// | |
| 234 // NetworkLibraryImpl, URLRequestJobTracker::JobObserver implementation: | |
| 235 | |
| 236 void OnJobAdded(URLRequestJob* job) { | |
| 237 CheckNetworkTraffic(false); | |
| 238 } | |
| 239 | |
| 240 void OnJobRemoved(URLRequestJob* job) { | |
| 241 CheckNetworkTraffic(false); | |
| 242 } | |
| 243 | |
| 244 void OnJobDone(URLRequestJob* job, const URLRequestStatus& status) { | |
| 245 CheckNetworkTraffic(false); | |
| 246 } | |
| 247 | |
| 248 void OnJobRedirect( | |
| 249 URLRequestJob* job, const GURL& location, int status_code) { | |
| 250 CheckNetworkTraffic(false); | |
| 251 } | |
| 252 | |
| 253 void OnBytesRead(URLRequestJob* job, const char* buf, int byte_count) { | |
| 254 CheckNetworkTraffic(true); | |
| 255 } | 226 } |
| 256 | 227 |
| 257 void AddObserver(Observer* observer) { | 228 void AddObserver(Observer* observer) { |
| 258 observers_.AddObserver(observer); | 229 observers_.AddObserver(observer); |
| 259 } | 230 } |
| 260 | 231 |
| 261 void RemoveObserver(Observer* observer) { | 232 void RemoveObserver(Observer* observer) { |
| 262 observers_.RemoveObserver(observer); | 233 observers_.RemoveObserver(observer); |
| 263 } | 234 } |
| 264 | 235 |
| (...skipping 640 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 905 | 876 |
| 906 available_devices_ = system->available_technologies; | 877 available_devices_ = system->available_technologies; |
| 907 enabled_devices_ = system->enabled_technologies; | 878 enabled_devices_ = system->enabled_technologies; |
| 908 connected_devices_ = system->connected_technologies; | 879 connected_devices_ = system->connected_technologies; |
| 909 offline_mode_ = system->offline_mode; | 880 offline_mode_ = system->offline_mode; |
| 910 | 881 |
| 911 FOR_EACH_OBSERVER(Observer, observers_, NetworkChanged(this)); | 882 FOR_EACH_OBSERVER(Observer, observers_, NetworkChanged(this)); |
| 912 FreeSystemInfo(system); | 883 FreeSystemInfo(system); |
| 913 } | 884 } |
| 914 | 885 |
| 915 void CheckNetworkTraffic(bool download) { | |
| 916 // If we already have a pending upload and download notification, then | |
| 917 // shortcut and return. | |
| 918 if (traffic_type_ == | |
| 919 (Observer::TRAFFIC_DOWNLOAD | Observer::TRAFFIC_UPLOAD)) { | |
| 920 return; | |
| 921 } | |
| 922 // Figure out if we are uploading and/or downloading. We are downloading | |
| 923 // if download == true. We are uploading if we have upload progress. | |
| 924 if (download) | |
| 925 traffic_type_ |= Observer::TRAFFIC_DOWNLOAD; | |
| 926 if ((traffic_type_ & Observer::TRAFFIC_UPLOAD) == 0) { | |
| 927 URLRequestJobTracker::JobIterator it; | |
| 928 for (it = g_url_request_job_tracker.begin(); | |
| 929 it != g_url_request_job_tracker.end(); | |
| 930 ++it) { | |
| 931 URLRequestJob* job = *it; | |
| 932 if (job->GetUploadProgress() > 0) { | |
| 933 traffic_type_ |= Observer::TRAFFIC_UPLOAD; | |
| 934 break; | |
| 935 } | |
| 936 } | |
| 937 } | |
| 938 // If we have new traffic data to send out and the timer is not currently | |
| 939 // running, then start a new timer. | |
| 940 if (traffic_type_ && !timer_.IsRunning()) { | |
| 941 timer_.Start(base::TimeDelta::FromSeconds(kNetworkTrafficeTimerSecs), | |
| 942 this, | |
| 943 &NetworkLibraryImpl::NetworkTrafficTimerFired); | |
| 944 } | |
| 945 } | |
| 946 | |
| 947 void NetworkTrafficTimerFired() { | |
| 948 ChromeThread::PostTask( | |
| 949 ChromeThread::UI, FROM_HERE, | |
| 950 NewRunnableMethod(this, &NetworkLibraryImpl::NotifyNetworkTraffic, | |
| 951 traffic_type_)); | |
| 952 // Reset traffic type so that we don't send the same data next time. | |
| 953 traffic_type_ = 0; | |
| 954 } | |
| 955 | |
| 956 void NotifyNetworkTraffic(int traffic_type) { | |
| 957 FOR_EACH_OBSERVER(Observer, observers_, NetworkTraffic(this, traffic_type)); | |
| 958 } | |
| 959 | |
| 960 ObserverList<Observer> observers_; | 886 ObserverList<Observer> observers_; |
| 961 | 887 |
| 962 // The amount of time to wait between each NetworkTraffic notifications. | |
| 963 static const int kNetworkTrafficeTimerSecs = 1; | |
| 964 | |
| 965 // Timer for sending NetworkTraffic notification every | |
| 966 // kNetworkTrafficeTimerSecs seconds. | |
| 967 base::OneShotTimer<NetworkLibraryImpl> timer_; | |
| 968 | |
| 969 // The current traffic type that will be sent out for the next NetworkTraffic | |
| 970 // notification. This is a bitfield of TrafficTypeMasks. | |
| 971 int traffic_type_; | |
| 972 | |
| 973 // The network status connection for monitoring network status changes. | 888 // The network status connection for monitoring network status changes. |
| 974 MonitorNetworkConnection network_status_connection_; | 889 MonitorNetworkConnection network_status_connection_; |
| 975 | 890 |
| 976 // The ethernet network. | 891 // The ethernet network. |
| 977 EthernetNetwork ethernet_; | 892 EthernetNetwork ethernet_; |
| 978 | 893 |
| 979 // The list of available wifi networks. | 894 // The list of available wifi networks. |
| 980 WifiNetworkVector wifi_networks_; | 895 WifiNetworkVector wifi_networks_; |
| 981 | 896 |
| 982 // The current connected (or connecting) wifi network. | 897 // The current connected (or connecting) wifi network. |
| (...skipping 22 matching lines...) Expand all Loading... |
| 1005 | 920 |
| 1006 bool offline_mode_; | 921 bool offline_mode_; |
| 1007 | 922 |
| 1008 DISALLOW_COPY_AND_ASSIGN(NetworkLibraryImpl); | 923 DISALLOW_COPY_AND_ASSIGN(NetworkLibraryImpl); |
| 1009 }; | 924 }; |
| 1010 | 925 |
| 1011 class NetworkLibraryStubImpl : public NetworkLibrary { | 926 class NetworkLibraryStubImpl : public NetworkLibrary { |
| 1012 public: | 927 public: |
| 1013 NetworkLibraryStubImpl() : ip_address_("1.1.1.1") {} | 928 NetworkLibraryStubImpl() : ip_address_("1.1.1.1") {} |
| 1014 ~NetworkLibraryStubImpl() {} | 929 ~NetworkLibraryStubImpl() {} |
| 1015 void OnJobAdded(URLRequestJob* job) {} | |
| 1016 void OnJobRemoved(URLRequestJob* job) {} | |
| 1017 void OnJobDone(URLRequestJob* job, const URLRequestStatus& status) {} | |
| 1018 void OnJobRedirect( | |
| 1019 URLRequestJob* job, const GURL& location, int status_code) {} | |
| 1020 void OnBytesRead(URLRequestJob* job, const char* buf, int byte_count) {} | |
| 1021 void AddObserver(Observer* observer) {} | 930 void AddObserver(Observer* observer) {} |
| 1022 void RemoveObserver(Observer* observer) {} | 931 void RemoveObserver(Observer* observer) {} |
| 1023 virtual const EthernetNetwork& ethernet_network() const { | 932 virtual const EthernetNetwork& ethernet_network() const { |
| 1024 return ethernet_; | 933 return ethernet_; |
| 1025 } | 934 } |
| 1026 virtual bool ethernet_connecting() const { return false; } | 935 virtual bool ethernet_connecting() const { return false; } |
| 1027 virtual bool ethernet_connected() const { return true; } | 936 virtual bool ethernet_connected() const { return true; } |
| 1028 virtual const std::string& wifi_name() const { return EmptyString(); } | 937 virtual const std::string& wifi_name() const { return EmptyString(); } |
| 1029 virtual bool wifi_connecting() const { return false; } | 938 virtual bool wifi_connecting() const { return false; } |
| 1030 virtual bool wifi_connected() const { return false; } | 939 virtual bool wifi_connected() const { return false; } |
| (...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1106 return new NetworkLibraryStubImpl(); | 1015 return new NetworkLibraryStubImpl(); |
| 1107 else | 1016 else |
| 1108 return new NetworkLibraryImpl(); | 1017 return new NetworkLibraryImpl(); |
| 1109 } | 1018 } |
| 1110 | 1019 |
| 1111 } // namespace chromeos | 1020 } // namespace chromeos |
| 1112 | 1021 |
| 1113 // Allows InvokeLater without adding refcounting. This class is a Singleton and | 1022 // Allows InvokeLater without adding refcounting. This class is a Singleton and |
| 1114 // won't be deleted until it's last InvokeLater is run. | 1023 // won't be deleted until it's last InvokeLater is run. |
| 1115 DISABLE_RUNNABLE_METHOD_REFCOUNT(chromeos::NetworkLibraryImpl); | 1024 DISABLE_RUNNABLE_METHOD_REFCOUNT(chromeos::NetworkLibraryImpl); |
| OLD | NEW |