| // Copyright (c) 2012 The Chromium OS Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "shill/wifi_service.h" |
| |
| #include <algorithm> |
| #include <limits> |
| #include <string> |
| #include <utility> |
| |
| #include <base/strings/stringprintf.h> |
| #include <base/strings/string_number_conversions.h> |
| #include <base/strings/string_split.h> |
| #include <base/strings/string_util.h> |
| #include <chromeos/dbus/service_constants.h> |
| #include <dbus/dbus.h> |
| |
| #include "shill/adaptor_interfaces.h" |
| #include "shill/certificate_file.h" |
| #include "shill/control_interface.h" |
| #include "shill/dbus_adaptor.h" |
| #include "shill/device.h" |
| #include "shill/eap_credentials.h" |
| #include "shill/error.h" |
| #include "shill/event_dispatcher.h" |
| #include "shill/ieee80211.h" |
| #include "shill/logging.h" |
| #include "shill/manager.h" |
| #include "shill/metrics.h" |
| #include "shill/property_accessor.h" |
| #include "shill/store_interface.h" |
| #include "shill/wifi.h" |
| #include "shill/wifi_endpoint.h" |
| #include "shill/wifi_provider.h" |
| #include "shill/wpa_supplicant.h" |
| |
| using std::map; |
| using std::set; |
| using std::string; |
| using std::vector; |
| |
| namespace shill { |
| |
| const char WiFiService::kAutoConnNoEndpoint[] = "no endpoints"; |
| const char WiFiService::kAnyDeviceAddress[] = "any"; |
| const int WiFiService::kSuspectedCredentialFailureThreshold = 3; |
| |
| const char WiFiService::kStorageHiddenSSID[] = "WiFi.HiddenSSID"; |
| const char WiFiService::kStorageMode[] = "WiFi.Mode"; |
| const char WiFiService::kStoragePassphrase[] = "Passphrase"; |
| const char WiFiService::kStorageSecurity[] = "WiFi.Security"; |
| const char WiFiService::kStorageSecurityClass[] = "WiFi.SecurityClass"; |
| const char WiFiService::kStorageSSID[] = "SSID"; |
| bool WiFiService::logged_signal_warning = false; |
| |
| WiFiService::WiFiService(ControlInterface *control_interface, |
| EventDispatcher *dispatcher, |
| Metrics *metrics, |
| Manager *manager, |
| WiFiProvider *provider, |
| const vector<uint8_t> &ssid, |
| const string &mode, |
| const string &security, |
| bool hidden_ssid) |
| : Service(control_interface, dispatcher, metrics, manager, |
| Technology::kWifi), |
| need_passphrase_(false), |
| security_(security), |
| mode_(mode), |
| hidden_ssid_(hidden_ssid), |
| frequency_(0), |
| physical_mode_(Metrics::kWiFiNetworkPhyModeUndef), |
| raw_signal_strength_(0), |
| cipher_8021x_(kCryptoNone), |
| suspected_credential_failures_(0), |
| ssid_(ssid), |
| ieee80211w_required_(false), |
| expecting_disconnect_(false), |
| certificate_file_(new CertificateFile()), |
| provider_(provider) { |
| PropertyStore *store = this->mutable_store(); |
| store->RegisterConstString(kModeProperty, &mode_); |
| HelpRegisterWriteOnlyDerivedString(kPassphraseProperty, |
| &WiFiService::SetPassphrase, |
| &WiFiService::ClearPassphrase, |
| NULL); |
| store->RegisterBool(kPassphraseRequiredProperty, &need_passphrase_); |
| HelpRegisterDerivedString(kSecurityProperty, |
| &WiFiService::GetSecurity, |
| NULL); |
| |
| store->RegisterConstString(kWifiAuthMode, &auth_mode_); |
| store->RegisterBool(kWifiHiddenSsid, &hidden_ssid_); |
| store->RegisterConstUint16(kWifiFrequency, &frequency_); |
| store->RegisterConstUint16s(kWifiFrequencyListProperty, &frequency_list_); |
| store->RegisterConstUint16(kWifiPhyMode, &physical_mode_); |
| store->RegisterConstString(kWifiBSsid, &bssid_); |
| store->RegisterConstString(kCountryProperty, &country_code_); |
| store->RegisterConstStringmap(kWifiVendorInformationProperty, |
| &vendor_information_); |
| store->RegisterConstBool(kWifiProtectedManagementFrameRequiredProperty, |
| &ieee80211w_required_); |
| |
| hex_ssid_ = base::HexEncode(ssid_.data(), ssid_.size()); |
| store->RegisterConstString(kWifiHexSsid, &hex_ssid_); |
| |
| string ssid_string( |
| reinterpret_cast<const char *>(ssid_.data()), ssid_.size()); |
| WiFi::SanitizeSSID(&ssid_string); |
| set_friendly_name(ssid_string); |
| |
| SetEapCredentials(new EapCredentials()); |
| |
| // TODO(quiche): determine if it is okay to set EAP.KeyManagement for |
| // a service that is not 802.1x. |
| if (Is8021x()) { |
| // Passphrases are not mandatory for 802.1X. |
| need_passphrase_ = false; |
| } else if (security_ == kSecurityPsk) { |
| SetEAPKeyManagement("WPA-PSK"); |
| } else if (security_ == kSecurityRsn) { |
| SetEAPKeyManagement("WPA-PSK"); |
| } else if (security_ == kSecurityWpa) { |
| SetEAPKeyManagement("WPA-PSK"); |
| } else if (security_ == kSecurityWep) { |
| SetEAPKeyManagement("NONE"); |
| } else if (security_ == kSecurityNone) { |
| SetEAPKeyManagement("NONE"); |
| } else { |
| LOG(ERROR) << "Unsupported security method " << security_; |
| } |
| |
| // Until we know better (at Profile load time), use the generic name. |
| storage_identifier_ = GetDefaultStorageIdentifier(); |
| UpdateConnectable(); |
| UpdateSecurity(); |
| |
| // Now that |this| is a fully constructed WiFiService, synchronize observers |
| // with our current state, and emit the appropriate change notifications. |
| // (Initial observer state may have been set in our base class.) |
| NotifyPropertyChanges(); |
| |
| IgnoreParameterForConfigure(kModeProperty); |
| IgnoreParameterForConfigure(kSSIDProperty); |
| IgnoreParameterForConfigure(kSecurityProperty); |
| IgnoreParameterForConfigure(kWifiHexSsid); |
| |
| InitializeCustomMetrics(); |
| |
| // Log the |unique_name| to |friendly_name| mapping for debugging purposes. |
| // The latter will be tagged for scrubbing. |
| LOG(INFO) << "Constructed WiFi service " << unique_name() |
| << " name: " << WiFi::LogSSID(friendly_name()); |
| } |
| |
| WiFiService::~WiFiService() {} |
| |
| bool WiFiService::IsAutoConnectable(const char **reason) const { |
| if (!Service::IsAutoConnectable(reason)) { |
| return false; |
| } |
| |
| // Only auto-connect to Services which have visible Endpoints. |
| // (Needed because hidden Services may remain registered with |
| // Manager even without visible Endpoints.) |
| if (!HasEndpoints()) { |
| *reason = kAutoConnNoEndpoint; |
| return false; |
| } |
| |
| CHECK(wifi_) << "We have endpoints but no WiFi device is selected?"; |
| |
| // Do not preempt an existing connection (whether pending, or |
| // connected, and whether to this service, or another). |
| if (!wifi_->IsIdle()) { |
| *reason = kAutoConnBusy; |
| return false; |
| } |
| |
| return true; |
| } |
| |
| void WiFiService::SetEAPKeyManagement(const string &key_management) { |
| Service::SetEAPKeyManagement(key_management); |
| UpdateSecurity(); |
| } |
| |
| void WiFiService::AddEndpoint(const WiFiEndpointConstRefPtr &endpoint) { |
| DCHECK(endpoint->ssid() == ssid()); |
| endpoints_.insert(endpoint); |
| UpdateFromEndpoints(); |
| } |
| |
| void WiFiService::RemoveEndpoint(const WiFiEndpointConstRefPtr &endpoint) { |
| set<WiFiEndpointConstRefPtr>::iterator i = endpoints_.find(endpoint); |
| DCHECK(i != endpoints_.end()); |
| if (i == endpoints_.end()) { |
| LOG(WARNING) << "In " << __func__ << "(): " |
| << "ignoring non-existent endpoint " |
| << endpoint->bssid_string(); |
| return; |
| } |
| endpoints_.erase(i); |
| if (current_endpoint_ == endpoint) { |
| current_endpoint_ = NULL; |
| } |
| UpdateFromEndpoints(); |
| } |
| |
| void WiFiService::NotifyCurrentEndpoint( |
| const WiFiEndpointConstRefPtr &endpoint) { |
| DCHECK(!endpoint || (endpoints_.find(endpoint) != endpoints_.end())); |
| current_endpoint_ = endpoint; |
| UpdateFromEndpoints(); |
| } |
| |
| void WiFiService::NotifyEndpointUpdated( |
| const WiFiEndpointConstRefPtr &endpoint) { |
| DCHECK(endpoints_.find(endpoint) != endpoints_.end()); |
| UpdateFromEndpoints(); |
| } |
| |
| string WiFiService::GetStorageIdentifier() const { |
| return storage_identifier_; |
| } |
| |
| bool WiFiService::SetPassphrase(const string &passphrase, Error *error) { |
| if (security_ == kSecurityWep) { |
| ValidateWEPPassphrase(passphrase, error); |
| } else if (security_ == kSecurityPsk || |
| security_ == kSecurityWpa || |
| security_ == kSecurityRsn) { |
| ValidateWPAPassphrase(passphrase, error); |
| } else { |
| error->Populate(Error::kNotSupported); |
| } |
| |
| if (!error->IsSuccess()) { |
| return false; |
| } |
| if (passphrase_ == passphrase) { |
| // After a user logs in, Chrome may reconfigure a Service with the |
| // same credentials as before login. When that occurs, we don't |
| // want to bump the user off the network. Hence, we MUST return |
| // early. (See crbug.com/231456#c17) |
| return false; |
| } |
| |
| passphrase_ = passphrase; |
| ClearCachedCredentials(); |
| UpdateConnectable(); |
| return true; |
| } |
| |
| // ClearPassphrase is separate from SetPassphrase, because the default |
| // value for |passphrase_| would not pass validation. |
| void WiFiService::ClearPassphrase(Error */*error*/) { |
| passphrase_.clear(); |
| ClearCachedCredentials(); |
| UpdateConnectable(); |
| } |
| |
| string WiFiService::GetTethering(Error */*error*/) const { |
| if (IsConnected() && wifi_ && wifi_->IsConnectedViaTether()) { |
| return kTetheringConfirmedState; |
| } |
| |
| // Only perform BSSID tests if there is exactly one matching endpoint, |
| // so we ignore campuses that may use locally administered BSSIDs. |
| if (endpoints_.size() == 1 && |
| (*endpoints_.begin())->has_tethering_signature()) { |
| return kTetheringSuspectedState; |
| } |
| |
| return kTetheringNotDetectedState; |
| } |
| |
| string WiFiService::GetLoadableStorageIdentifier( |
| const StoreInterface &storage) const { |
| set<string> groups = storage.GetGroupsWithProperties(GetStorageProperties()); |
| if (groups.empty()) { |
| LOG(WARNING) << "Configuration for service " |
| << unique_name() |
| << " is not available in the persistent store"; |
| return ""; |
| } |
| if (groups.size() > 1) { |
| LOG(WARNING) << "More than one configuration for service " |
| << unique_name() |
| << " is available; choosing the first."; |
| } |
| return *groups.begin(); |
| } |
| |
| bool WiFiService::IsLoadableFrom(const StoreInterface &storage) const { |
| return !storage.GetGroupsWithProperties(GetStorageProperties()).empty(); |
| } |
| |
| bool WiFiService::IsVisible() const { |
| // WiFi Services should be displayed only if they are in range (have |
| // endpoints that have shown up in a scan) or if the service is actively |
| // being connected. |
| return HasEndpoints() || IsConnected() || IsConnecting(); |
| } |
| |
| bool WiFiService::Load(StoreInterface *storage) { |
| string id = GetLoadableStorageIdentifier(*storage); |
| if (id.empty()) { |
| return false; |
| } |
| |
| // Set our storage identifier to match the storage name in the Profile. |
| storage_identifier_ = id; |
| |
| // Load properties common to all Services. |
| if (!Service::Load(storage)) { |
| return false; |
| } |
| |
| // Load properties specific to WiFi services. |
| storage->GetBool(id, kStorageHiddenSSID, &hidden_ssid_); |
| |
| // NB: mode, security and ssid parameters are never read in from |
| // Load() as they are provided from the scan. |
| |
| string passphrase; |
| if (storage->GetCryptedString(id, kStoragePassphrase, &passphrase)) { |
| Error error; |
| SetPassphrase(passphrase, &error); |
| if (!error.IsSuccess() && |
| !(passphrase.empty() && error.type() == Error::kNotSupported)) { |
| LOG(ERROR) << "Passphrase could not be set: " << error; |
| } |
| } |
| |
| expecting_disconnect_ = false; |
| return true; |
| } |
| |
| bool WiFiService::Save(StoreInterface *storage) { |
| // Save properties common to all Services. |
| if (!Service::Save(storage)) { |
| return false; |
| } |
| |
| // Save properties specific to WiFi services. |
| const string id = GetStorageIdentifier(); |
| storage->SetBool(id, kStorageHiddenSSID, hidden_ssid_); |
| storage->SetString(id, kStorageMode, mode_); |
| storage->SetCryptedString(id, kStoragePassphrase, passphrase_); |
| storage->SetString(id, kStorageSecurity, security_); |
| storage->SetString(id, kStorageSecurityClass, GetSecurityClass(security_)); |
| storage->SetString(id, kStorageSSID, hex_ssid_); |
| |
| return true; |
| } |
| |
| bool WiFiService::Unload() { |
| // Expect the service to be disconnected if is currently connected or |
| // in the process of connecting. |
| if (IsConnected() || IsConnecting()) { |
| expecting_disconnect_ = true; |
| } else { |
| expecting_disconnect_ = false; |
| } |
| Service::Unload(); |
| if (wifi_) { |
| wifi_->DestroyServiceLease(*this); |
| } |
| hidden_ssid_ = false; |
| ResetSuspectedCredentialFailures(); |
| Error unused_error; |
| ClearPassphrase(&unused_error); |
| return provider_->OnServiceUnloaded(this); |
| } |
| |
| void WiFiService::SetState(ConnectState state) { |
| Service::SetState(state); |
| NotifyPropertyChanges(); |
| } |
| |
| bool WiFiService::IsSecurityMatch(const string &security) const { |
| return GetSecurityClass(security) == GetSecurityClass(security_); |
| } |
| |
| bool WiFiService::AddSuspectedCredentialFailure() { |
| if (!has_ever_connected()) { |
| return true; |
| } |
| ++suspected_credential_failures_; |
| return suspected_credential_failures_ >= kSuspectedCredentialFailureThreshold; |
| } |
| |
| void WiFiService::ResetSuspectedCredentialFailures() { |
| suspected_credential_failures_ = 0; |
| } |
| |
| void WiFiService::InitializeCustomMetrics() const { |
| SLOG(Metrics, 2) << __func__ << " for " << unique_name(); |
| string histogram = metrics()->GetFullMetricName( |
| Metrics::kMetricTimeToJoinMillisecondsSuffix, |
| technology()); |
| metrics()->AddServiceStateTransitionTimer(*this, |
| histogram, |
| Service::kStateAssociating, |
| Service::kStateConfiguring); |
| } |
| |
| void WiFiService::SendPostReadyStateMetrics( |
| int64 time_resume_to_ready_milliseconds) const { |
| metrics()->SendEnumToUMA( |
| metrics()->GetFullMetricName(Metrics::kMetricNetworkChannelSuffix, |
| technology()), |
| Metrics::WiFiFrequencyToChannel(frequency_), |
| Metrics::kMetricNetworkChannelMax); |
| |
| DCHECK(physical_mode_ < Metrics::kWiFiNetworkPhyModeMax); |
| metrics()->SendEnumToUMA( |
| metrics()->GetFullMetricName(Metrics::kMetricNetworkPhyModeSuffix, |
| technology()), |
| static_cast<Metrics::WiFiNetworkPhyMode>(physical_mode_), |
| Metrics::kWiFiNetworkPhyModeMax); |
| |
| string security_mode = security_; |
| if (current_endpoint_) { |
| security_mode = current_endpoint_->security_mode(); |
| } |
| Metrics::WiFiSecurity security_uma = |
| Metrics::WiFiSecurityStringToEnum(security_mode); |
| DCHECK(security_uma != Metrics::kWiFiSecurityUnknown); |
| metrics()->SendEnumToUMA( |
| metrics()->GetFullMetricName(Metrics::kMetricNetworkSecuritySuffix, |
| technology()), |
| security_uma, |
| Metrics::kMetricNetworkSecurityMax); |
| |
| if (Is8021x()) { |
| eap()->OutputConnectionMetrics(metrics(), technology()); |
| } |
| |
| // We invert the sign of the signal strength value, since UMA histograms |
| // cannot represent negative numbers (it stores them but cannot display |
| // them), and dBm values of interest start at 0 and go negative from there. |
| metrics()->SendToUMA( |
| metrics()->GetFullMetricName(Metrics::kMetricNetworkSignalStrengthSuffix, |
| technology()), |
| -raw_signal_strength_, |
| Metrics::kMetricNetworkSignalStrengthMin, |
| Metrics::kMetricNetworkSignalStrengthMax, |
| Metrics::kMetricNetworkSignalStrengthNumBuckets); |
| |
| if (time_resume_to_ready_milliseconds > 0) { |
| metrics()->SendToUMA( |
| metrics()->GetFullMetricName( |
| Metrics::kMetricTimeResumeToReadyMillisecondsSuffix, technology()), |
| time_resume_to_ready_milliseconds, |
| Metrics::kTimerHistogramMillisecondsMin, |
| Metrics::kTimerHistogramMillisecondsMax, |
| Metrics::kTimerHistogramNumBuckets); |
| } |
| |
| Metrics::WiFiApMode ap_mode_uma = Metrics::WiFiApModeStringToEnum(mode_); |
| metrics()->SendEnumToUMA( |
| metrics()->GetFullMetricName(Metrics::kMetricNetworkApModeSuffix, |
| technology()), |
| ap_mode_uma, |
| Metrics::kWiFiApModeMax); |
| } |
| |
| // private methods |
| void WiFiService::HelpRegisterConstDerivedString( |
| const string &name, |
| string(WiFiService::*get)(Error *)) { |
| mutable_store()->RegisterDerivedString( |
| name, |
| StringAccessor( |
| new CustomAccessor<WiFiService, string>(this, get, NULL))); |
| } |
| |
| void WiFiService::HelpRegisterDerivedString( |
| const string &name, |
| string(WiFiService::*get)(Error *error), |
| bool(WiFiService::*set)(const string &, Error *)) { |
| mutable_store()->RegisterDerivedString( |
| name, |
| StringAccessor(new CustomAccessor<WiFiService, string>(this, get, set))); |
| } |
| |
| void WiFiService::HelpRegisterWriteOnlyDerivedString( |
| const string &name, |
| bool(WiFiService::*set)(const string &, Error *), |
| void(WiFiService::*clear)(Error *error), |
| const string *default_value) { |
| mutable_store()->RegisterDerivedString( |
| name, |
| StringAccessor( |
| new CustomWriteOnlyAccessor<WiFiService, string>( |
| this, set, clear, default_value))); |
| } |
| |
| void WiFiService::Connect(Error *error, const char *reason) { |
| if (!connectable()) { |
| LOG(ERROR) << "Can't connect. Service " << unique_name() |
| << " is not connectable."; |
| Error::PopulateAndLog(error, |
| Error::kOperationFailed, |
| Error::GetDefaultMessage(Error::kOperationFailed)); |
| return; |
| } |
| if (IsConnecting() || IsConnected()) { |
| LOG(WARNING) << "Can't connect. Service " << unique_name() |
| << " is already connecting or connected."; |
| Error::PopulateAndLog(error, |
| Error::kAlreadyConnected, |
| Error::GetDefaultMessage(Error::kAlreadyConnected)); |
| return; |
| } |
| |
| WiFiRefPtr wifi = wifi_; |
| if (!wifi) { |
| // If this is a hidden service before it has been found in a scan, we |
| // may need to late-bind to any available WiFi Device. We don't actually |
| // set |wifi_| in this case since we do not yet see any endpoints. This |
| // will mean this service is not disconnectable until an endpoint is |
| // found. |
| wifi = ChooseDevice(); |
| if (!wifi) { |
| LOG(ERROR) << "Can't connect. Service " << unique_name() |
| << " cannot find a WiFi device."; |
| Error::PopulateAndLog(error, |
| Error::kOperationFailed, |
| Error::GetDefaultMessage(Error::kOperationFailed)); |
| return; |
| } |
| } |
| |
| if (wifi->IsCurrentService(this)) { |
| LOG(WARNING) << "Can't connect. Service " << unique_name() |
| << " is the current service (but, in " << GetStateString() |
| << " state, not connected)."; |
| Error::PopulateAndLog(error, |
| Error::kInProgress, |
| Error::GetDefaultMessage(Error::kInProgress)); |
| return; |
| } |
| |
| // Report number of BSSes available for this service. |
| metrics()->NotifyWifiAvailableBSSes(endpoints_.size()); |
| |
| if (Is8021x()) { |
| // If EAP key management is not set, set to a default. |
| if (GetEAPKeyManagement().empty()) |
| SetEAPKeyManagement("WPA-EAP"); |
| ClearEAPCertification(); |
| } |
| |
| expecting_disconnect_ = false; |
| Service::Connect(error, reason); |
| wifi->ConnectTo(this); |
| } |
| |
| DBusPropertiesMap WiFiService::GetSupplicantConfigurationParameters() const { |
| DBusPropertiesMap params; |
| DBus::MessageIter writer; |
| |
| params[WPASupplicant::kNetworkPropertyMode].writer(). |
| append_uint32(WiFiEndpoint::ModeStringToUint(mode_)); |
| |
| if (mode_ == kModeAdhoc && frequency_ != 0) { |
| // Frequency is required in order to successfully connect to an IBSS |
| // with wpa_supplicant. If we have one from our endpoint, insert it |
| // here. |
| params[WPASupplicant::kNetworkPropertyFrequency].writer(). |
| append_int32(frequency_); |
| } |
| |
| if (Is8021x()) { |
| eap()->PopulateSupplicantProperties(certificate_file_.get(), ¶ms); |
| } else if (security_ == kSecurityPsk || |
| security_ == kSecurityRsn || |
| security_ == kSecurityWpa) { |
| const string psk_proto = |
| base::StringPrintf("%s %s", |
| WPASupplicant::kSecurityModeWPA, |
| WPASupplicant::kSecurityModeRSN); |
| params[WPASupplicant::kPropertySecurityProtocol].writer(). |
| append_string(psk_proto.c_str()); |
| params[WPASupplicant::kPropertyPreSharedKey].writer(). |
| append_string(passphrase_.c_str()); |
| } else if (security_ == kSecurityWep) { |
| params[WPASupplicant::kPropertyAuthAlg].writer(). |
| append_string(WPASupplicant::kSecurityAuthAlg); |
| Error unused_error; |
| int key_index; |
| std::vector<uint8> password_bytes; |
| ParseWEPPassphrase(passphrase_, &key_index, &password_bytes, &unused_error); |
| writer = params[WPASupplicant::kPropertyWEPKey + |
| base::IntToString(key_index)].writer(); |
| writer << password_bytes; |
| params[WPASupplicant::kPropertyWEPTxKeyIndex].writer(). |
| append_uint32(key_index); |
| } else if (security_ == kSecurityNone) { |
| // Nothing special to do here. |
| } else { |
| NOTIMPLEMENTED() << "Unsupported security method " << security_; |
| } |
| |
| params[WPASupplicant::kNetworkPropertyEapKeyManagement].writer(). |
| append_string(key_management().c_str()); |
| |
| if (ieee80211w_required_) { |
| // TODO(pstew): We should also enable IEEE 802.11w if the user |
| // explicitly enables support for this through a service / device |
| // property. crbug.com/219950 |
| params[WPASupplicant::kNetworkPropertyIeee80211w].writer(). |
| append_uint32(WPASupplicant::kNetworkIeee80211wEnabled); |
| } |
| |
| // See note in dbus_adaptor.cc on why we need to use a local. |
| writer = params[WPASupplicant::kNetworkPropertySSID].writer(); |
| writer << ssid_; |
| |
| return params; |
| } |
| |
| |
| void WiFiService::Disconnect(Error *error) { |
| Service::Disconnect(error); |
| if (!wifi_) { |
| // If we are connecting to a hidden service, but have not yet found |
| // any endpoints, we could end up with a disconnect request without |
| // a wifi_ reference. This is not a fatal error. |
| LOG_IF(ERROR, IsConnecting()) |
| << "WiFi endpoints do not (yet) exist. Cannot disconnect service " |
| << unique_name(); |
| LOG_IF(FATAL, IsConnected()) |
| << "WiFi device does not exist. Cannot disconnect service " |
| << unique_name(); |
| error->Populate(Error::kOperationFailed); |
| return; |
| } |
| wifi_->DisconnectFrom(this); |
| } |
| |
| string WiFiService::GetDeviceRpcId(Error *error) const { |
| if (!wifi_) { |
| error->Populate(Error::kNotFound, "Not associated with a device"); |
| return DBusAdaptor::kNullPath; |
| } |
| return wifi_->GetRpcIdentifier(); |
| } |
| |
| void WiFiService::UpdateConnectable() { |
| bool is_connectable = false; |
| if (security_ == kSecurityNone) { |
| DCHECK(passphrase_.empty()); |
| need_passphrase_ = false; |
| is_connectable = true; |
| } else if (Is8021x()) { |
| is_connectable = Is8021xConnectable(); |
| } else if (security_ == kSecurityWep || |
| security_ == kSecurityWpa || |
| security_ == kSecurityPsk || |
| security_ == kSecurityRsn) { |
| need_passphrase_ = passphrase_.empty(); |
| is_connectable = !need_passphrase_; |
| } |
| SetConnectable(is_connectable); |
| } |
| |
| void WiFiService::UpdateFromEndpoints() { |
| const WiFiEndpoint *representative_endpoint = NULL; |
| |
| if (current_endpoint_) { |
| representative_endpoint = current_endpoint_; |
| } else { |
| int16 best_signal = std::numeric_limits<int16>::min(); |
| for (const auto &endpoint : endpoints_) { |
| if (endpoint->signal_strength() >= best_signal) { |
| best_signal = endpoint->signal_strength(); |
| representative_endpoint = endpoint; |
| } |
| } |
| } |
| |
| WiFiRefPtr wifi; |
| if (representative_endpoint) { |
| wifi = representative_endpoint->device(); |
| } else if (IsConnected() || IsConnecting()) { |
| LOG(WARNING) << "Service " << unique_name() |
| << " will disconnect due to no remaining endpoints."; |
| } |
| |
| SetWiFi(wifi); |
| |
| for (const auto &endpoint : endpoints_) { |
| if (endpoint->ieee80211w_required()) { |
| // Never reset ieee80211w_required_ to false, so we track whether we have |
| // ever seen an AP that requires 802.11w. |
| ieee80211w_required_ = true; |
| } |
| } |
| |
| set<uint16> frequency_set; |
| for (const auto &endpoint : endpoints_) { |
| frequency_set.insert(endpoint->frequency()); |
| } |
| frequency_list_.assign(frequency_set.begin(), frequency_set.end()); |
| |
| if (Is8021x()) |
| cipher_8021x_ = ComputeCipher8021x(endpoints_); |
| |
| uint16 frequency = 0; |
| int16 signal = std::numeric_limits<int16>::min(); |
| string bssid; |
| string country_code; |
| Stringmap vendor_information; |
| uint16 physical_mode = Metrics::kWiFiNetworkPhyModeUndef; |
| // Represent "unknown raw signal strength" as 0. |
| raw_signal_strength_ = 0; |
| if (representative_endpoint) { |
| frequency = representative_endpoint->frequency(); |
| signal = representative_endpoint->signal_strength(); |
| raw_signal_strength_ = signal; |
| bssid = representative_endpoint->bssid_string(); |
| country_code = representative_endpoint->country_code(); |
| vendor_information = representative_endpoint->GetVendorInformation(); |
| physical_mode = representative_endpoint->physical_mode(); |
| } |
| |
| if (frequency_ != frequency) { |
| frequency_ = frequency; |
| adaptor()->EmitUint16Changed(kWifiFrequency, frequency_); |
| } |
| if (bssid_ != bssid) { |
| bssid_ = bssid; |
| adaptor()->EmitStringChanged(kWifiBSsid, bssid_); |
| } |
| if (country_code_ != country_code) { |
| country_code_ = country_code; |
| adaptor()->EmitStringChanged(kCountryProperty, country_code_); |
| } |
| if (vendor_information_ != vendor_information) { |
| vendor_information_ = vendor_information; |
| adaptor()->EmitStringmapChanged(kWifiVendorInformationProperty, |
| vendor_information_); |
| } |
| if (physical_mode_ != physical_mode) { |
| physical_mode_ = physical_mode; |
| adaptor()->EmitUint16Changed(kWifiPhyMode, physical_mode_); |
| } |
| adaptor()->EmitUint16sChanged(kWifiFrequencyListProperty, frequency_list_); |
| SetStrength(SignalToStrength(signal)); |
| UpdateSecurity(); |
| NotifyPropertyChanges(); |
| } |
| |
| void WiFiService::UpdateSecurity() { |
| CryptoAlgorithm algorithm = kCryptoNone; |
| bool key_rotation = false; |
| bool endpoint_auth = false; |
| |
| if (security_ == kSecurityNone) { |
| // initial values apply |
| } else if (security_ == kSecurityWep) { |
| algorithm = kCryptoRc4; |
| key_rotation = Is8021x(); |
| endpoint_auth = Is8021x(); |
| } else if (security_ == kSecurityPsk || |
| security_ == kSecurityWpa) { |
| algorithm = kCryptoRc4; |
| key_rotation = true; |
| endpoint_auth = false; |
| } else if (security_ == kSecurityRsn) { |
| algorithm = kCryptoAes; |
| key_rotation = true; |
| endpoint_auth = false; |
| } else if (security_ == kSecurity8021x) { |
| algorithm = cipher_8021x_; |
| key_rotation = true; |
| endpoint_auth = true; |
| } |
| SetSecurity(algorithm, key_rotation, endpoint_auth); |
| } |
| |
| // static |
| Service::CryptoAlgorithm WiFiService::ComputeCipher8021x( |
| const set<WiFiEndpointConstRefPtr> &endpoints) { |
| |
| if (endpoints.empty()) |
| return kCryptoNone; // Will update after scan results. |
| |
| // Find weakest cipher (across endpoints) of the strongest ciphers |
| // (per endpoint). |
| Service::CryptoAlgorithm cipher = Service::kCryptoAes; |
| for (const auto &endpoint : endpoints) { |
| Service::CryptoAlgorithm endpoint_cipher; |
| if (endpoint->has_rsn_property()) { |
| endpoint_cipher = Service::kCryptoAes; |
| } else if (endpoint->has_wpa_property()) { |
| endpoint_cipher = Service::kCryptoRc4; |
| } else { |
| // We could be in the Dynamic WEP case here. But that's okay, |
| // because |cipher_8021x_| is not defined in that case. |
| endpoint_cipher = Service::kCryptoNone; |
| } |
| cipher = std::min(cipher, endpoint_cipher); |
| } |
| return cipher; |
| } |
| |
| // static |
| void WiFiService::ValidateWEPPassphrase(const std::string &passphrase, |
| Error *error) { |
| ParseWEPPassphrase(passphrase, NULL, NULL, error); |
| } |
| |
| // static |
| void WiFiService::ValidateWPAPassphrase(const std::string &passphrase, |
| Error *error) { |
| unsigned int length = passphrase.length(); |
| vector<uint8> passphrase_bytes; |
| |
| if (base::HexStringToBytes(passphrase, &passphrase_bytes)) { |
| if (length != IEEE_80211::kWPAHexLen && |
| (length < IEEE_80211::kWPAAsciiMinLen || |
| length > IEEE_80211::kWPAAsciiMaxLen)) { |
| error->Populate(Error::kInvalidPassphrase); |
| } |
| } else { |
| if (length < IEEE_80211::kWPAAsciiMinLen || |
| length > IEEE_80211::kWPAAsciiMaxLen) { |
| error->Populate(Error::kInvalidPassphrase); |
| } |
| } |
| } |
| |
| // static |
| void WiFiService::ParseWEPPassphrase(const string &passphrase, |
| int *key_index, |
| std::vector<uint8> *password_bytes, |
| Error *error) { |
| unsigned int length = passphrase.length(); |
| int key_index_local; |
| std::string password_text; |
| bool is_hex = false; |
| |
| switch (length) { |
| case IEEE_80211::kWEP40AsciiLen: |
| case IEEE_80211::kWEP104AsciiLen: |
| key_index_local = 0; |
| password_text = passphrase; |
| break; |
| case IEEE_80211::kWEP40AsciiLen + 2: |
| case IEEE_80211::kWEP104AsciiLen + 2: |
| if (CheckWEPKeyIndex(passphrase, error)) { |
| base::StringToInt(passphrase.substr(0, 1), &key_index_local); |
| password_text = passphrase.substr(2); |
| } |
| break; |
| case IEEE_80211::kWEP40HexLen: |
| case IEEE_80211::kWEP104HexLen: |
| if (CheckWEPIsHex(passphrase, error)) { |
| key_index_local = 0; |
| password_text = passphrase; |
| is_hex = true; |
| } |
| break; |
| case IEEE_80211::kWEP40HexLen + 2: |
| case IEEE_80211::kWEP104HexLen + 2: |
| if (CheckWEPKeyIndex(passphrase, error) && |
| CheckWEPIsHex(passphrase.substr(2), error)) { |
| base::StringToInt(passphrase.substr(0, 1), &key_index_local); |
| password_text = passphrase.substr(2); |
| is_hex = true; |
| } else if (CheckWEPPrefix(passphrase, error) && |
| CheckWEPIsHex(passphrase.substr(2), error)) { |
| key_index_local = 0; |
| password_text = passphrase.substr(2); |
| is_hex = true; |
| } |
| break; |
| case IEEE_80211::kWEP40HexLen + 4: |
| case IEEE_80211::kWEP104HexLen + 4: |
| if (CheckWEPKeyIndex(passphrase, error) && |
| CheckWEPPrefix(passphrase.substr(2), error) && |
| CheckWEPIsHex(passphrase.substr(4), error)) { |
| base::StringToInt(passphrase.substr(0, 1), &key_index_local); |
| password_text = passphrase.substr(4); |
| is_hex = true; |
| } |
| break; |
| default: |
| error->Populate(Error::kInvalidPassphrase); |
| break; |
| } |
| |
| if (error->IsSuccess()) { |
| if (key_index) |
| *key_index = key_index_local; |
| if (password_bytes) { |
| if (is_hex) |
| base::HexStringToBytes(password_text, password_bytes); |
| else |
| password_bytes->insert(password_bytes->end(), |
| password_text.begin(), |
| password_text.end()); |
| } |
| } |
| } |
| |
| // static |
| bool WiFiService::CheckWEPIsHex(const string &passphrase, Error *error) { |
| vector<uint8> passphrase_bytes; |
| if (base::HexStringToBytes(passphrase, &passphrase_bytes)) { |
| return true; |
| } else { |
| error->Populate(Error::kInvalidPassphrase); |
| return false; |
| } |
| } |
| |
| // static |
| bool WiFiService::CheckWEPKeyIndex(const string &passphrase, Error *error) { |
| if (StartsWithASCII(passphrase, "0:", false) || |
| StartsWithASCII(passphrase, "1:", false) || |
| StartsWithASCII(passphrase, "2:", false) || |
| StartsWithASCII(passphrase, "3:", false)) { |
| return true; |
| } else { |
| error->Populate(Error::kInvalidPassphrase); |
| return false; |
| } |
| } |
| |
| // static |
| bool WiFiService::CheckWEPPrefix(const string &passphrase, Error *error) { |
| if (StartsWithASCII(passphrase, "0x", false)) { |
| return true; |
| } else { |
| error->Populate(Error::kInvalidPassphrase); |
| return false; |
| } |
| } |
| |
| // static |
| string WiFiService::GetSecurityClass(const string &security) { |
| if (security == kSecurityRsn || |
| security == kSecurityWpa) { |
| return kSecurityPsk; |
| } else { |
| return security; |
| } |
| } |
| |
| |
| int16 WiFiService::SignalLevel() const { |
| return current_endpoint_ ? current_endpoint_->signal_strength() : |
| std::numeric_limits<int16>::min(); |
| } |
| |
| // static |
| bool WiFiService::ParseStorageIdentifier(const string &storage_name, |
| string *address, |
| string *mode, |
| string *security) { |
| vector<string> wifi_parts; |
| base::SplitString(storage_name, '_', &wifi_parts); |
| if ((wifi_parts.size() != 5 && wifi_parts.size() != 6) || |
| wifi_parts[0] != kTypeWifi) { |
| return false; |
| } |
| *address = wifi_parts[1]; |
| *mode = wifi_parts[3]; |
| if (wifi_parts.size() == 5) { |
| *security = wifi_parts[4]; |
| } else { |
| // Account for security type "802_1x" which got split up above. |
| *security = wifi_parts[4] + "_" + wifi_parts[5]; |
| } |
| return true; |
| } |
| |
| // static |
| bool WiFiService::FixupServiceEntries(StoreInterface *storage) { |
| bool fixed_entry = false; |
| set<string> groups = storage->GetGroups(); |
| for (const auto &id : groups) { |
| string device_address, network_mode, security; |
| if (!ParseStorageIdentifier(id, &device_address, |
| &network_mode, &security)) { |
| continue; |
| } |
| if (!storage->GetString(id, kStorageType, NULL)) { |
| storage->SetString(id, kStorageType, kTypeWifi); |
| fixed_entry = true; |
| } |
| if (!storage->GetString(id, kStorageMode, NULL)) { |
| storage->SetString(id, kStorageMode, network_mode); |
| fixed_entry = true; |
| } |
| if (!storage->GetString(id, kStorageSecurity, NULL)) { |
| storage->SetString(id, kStorageSecurity, security); |
| fixed_entry = true; |
| } |
| if (!storage->GetString(id, kStorageSecurityClass, NULL)) { |
| storage->SetString(id, kStorageSecurityClass, GetSecurityClass(security)); |
| fixed_entry = true; |
| } |
| } |
| return fixed_entry; |
| } |
| |
| // static |
| bool WiFiService::IsValidMode(const string &mode) { |
| return mode == kModeManaged || mode == kModeAdhoc; |
| } |
| |
| // static |
| bool WiFiService::IsValidSecurityMethod(const string &method) { |
| return method == kSecurityNone || |
| method == kSecurityWep || |
| method == kSecurityPsk || |
| method == kSecurityWpa || |
| method == kSecurityRsn || |
| method == kSecurity8021x; |
| } |
| |
| // static |
| uint8 WiFiService::SignalToStrength(int16 signal_dbm) { |
| int16 strength; |
| if (signal_dbm > 0) { |
| if (!logged_signal_warning) { |
| LOG(WARNING) << "Signal strength is suspiciously high. " |
| << "Assuming value " << signal_dbm << " is not in dBm."; |
| logged_signal_warning = true; |
| } |
| strength = signal_dbm; |
| } else { |
| strength = 120 + signal_dbm; // Call -20dBm "perfect". |
| } |
| |
| if (strength > kStrengthMax) { |
| strength = kStrengthMax; |
| } else if (strength < kStrengthMin) { |
| strength = kStrengthMin; |
| } |
| return strength; |
| } |
| |
| KeyValueStore WiFiService::GetStorageProperties() const { |
| KeyValueStore args; |
| args.SetString(kStorageType, kTypeWifi); |
| args.SetString(kStorageSSID, hex_ssid_); |
| args.SetString(kStorageMode, mode_); |
| args.SetString(kStorageSecurityClass, GetSecurityClass(security_)); |
| return args; |
| } |
| |
| string WiFiService::GetDefaultStorageIdentifier() const { |
| string security = GetSecurityClass(security_); |
| return StringToLowerASCII(base::StringPrintf("%s_%s_%s_%s_%s", |
| kTypeWifi, |
| kAnyDeviceAddress, |
| hex_ssid_.c_str(), |
| mode_.c_str(), |
| security.c_str())); |
| } |
| |
| string WiFiService::GetSecurity(Error */*error*/) { |
| if (current_endpoint_) { |
| return current_endpoint_->security_mode(); |
| } |
| return security_; |
| } |
| |
| void WiFiService::ClearCachedCredentials() { |
| if (wifi_) { |
| wifi_->ClearCachedCredentials(this); |
| } |
| } |
| |
| void WiFiService::OnEapCredentialsChanged() { |
| ClearCachedCredentials(); |
| UpdateConnectable(); |
| } |
| |
| void WiFiService::OnProfileConfigured() { |
| if (profile() || !hidden_ssid()) { |
| return; |
| } |
| // This situation occurs when a hidden WiFi service created via GetService |
| // has been persisted to a profile in Manager::ConfigureService(). Now |
| // that configuration is saved, we must join the service with its profile, |
| // which will make this SSID eligible for directed probes during scans. |
| manager()->RegisterService(this); |
| } |
| |
| bool WiFiService::Is8021x() const { |
| if (security_ == kSecurity8021x) |
| return true; |
| |
| // Dynamic WEP + 802.1x. |
| if (security_ == kSecurityWep && |
| GetEAPKeyManagement() == WPASupplicant::kKeyManagementIeee8021X) |
| return true; |
| return false; |
| } |
| |
| WiFiRefPtr WiFiService::ChooseDevice() { |
| // TODO(pstew): Style frowns on dynamic_cast. crbug.com/220387 |
| DeviceRefPtr device = |
| manager()->GetEnabledDeviceWithTechnology(Technology::kWifi); |
| return dynamic_cast<WiFi *>(device.get()); |
| } |
| |
| void WiFiService::ResetWiFi() { |
| SetWiFi(NULL); |
| } |
| |
| void WiFiService::SetWiFi(const WiFiRefPtr &new_wifi) { |
| if (wifi_ == new_wifi) { |
| return; |
| } |
| ClearCachedCredentials(); |
| if (wifi_) { |
| wifi_->DisassociateFromService(this); |
| } |
| if (new_wifi) { |
| adaptor()->EmitRpcIdentifierChanged(kDeviceProperty, |
| new_wifi->GetRpcIdentifier()); |
| } else { |
| adaptor()->EmitRpcIdentifierChanged(kDeviceProperty, |
| DBusAdaptor::kNullPath); |
| } |
| wifi_ = new_wifi; |
| } |
| |
| } // namespace shill |