Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "google_apis/gcm/engine/gservices_settings.h" | 5 #include "google_apis/gcm/engine/gservices_settings.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/strings/string_number_conversions.h" | 8 #include "base/strings/string_number_conversions.h" |
| 9 | 9 |
| 10 namespace { | 10 namespace { |
| 11 // The expected time in seconds between periodic checkins. | 11 // The expected time in seconds between periodic checkins. |
| 12 const char kCheckinIntervalKey[] = "checkin_interval"; | 12 const char kCheckinIntervalKey[] = "checkin_interval"; |
| 13 // The override URL to the checkin server. | 13 // The override URL to the checkin server. |
| 14 const char kCheckinURLKey[] = "checkin_url"; | 14 const char kCheckinURLKey[] = "checkin_url"; |
| 15 // The MCS machine name to connect to. | 15 // The MCS machine name to connect to. |
| 16 const char kMCSHostnameKey[] = "gcm_hostname"; | 16 const char kMCSHostnameKey[] = "gcm_hostname"; |
| 17 // The MCS port to connect to. | 17 // The MCS port to connect to. |
| 18 const char kMCSSecurePortKey[] = "gcm_secure_port"; | 18 const char kMCSSecurePortKey[] = "gcm_secure_port"; |
| 19 // The URL to get MCS registration IDs. | 19 // The URL to get MCS registration IDs. |
| 20 const char kRegistrationURLKey[] = "gcm_registration_url"; | 20 const char kRegistrationURLKey[] = "gcm_registration_url"; |
| 21 | 21 |
| 22 const int64 kDefaultCheckinInterval = 2 * 24 * 60 * 60; // seconds = 2 days. | 22 const int64 kDefaultCheckinInterval = 2 * 24 * 60 * 60; // seconds = 2 days. |
| 23 const int64 kMinimumCheckinInterval = 12 * 60 * 60; // seconds = 12 hours. | |
| 23 const char kDefaultCheckinURL[] = "https://android.clients.google.com/checkin"; | 24 const char kDefaultCheckinURL[] = "https://android.clients.google.com/checkin"; |
| 24 const char kDefaultMCSHostname[] = "https://mtalk.google.com"; | 25 const char kDefaultMCSHostname[] = "https://mtalk.google.com"; |
| 25 const int kDefaultMCSSecurePort = 5228; | 26 const int kDefaultMCSSecurePort = 5228; |
| 26 const char kDefaultRegistrationURL[] = | 27 const char kDefaultRegistrationURL[] = |
| 27 "https://android.clients.google.com/c2dm/register3"; | 28 "https://android.clients.google.com/c2dm/register3"; |
| 28 | 29 |
| 29 } // namespace | 30 } // namespace |
| 30 | 31 |
| 31 namespace gcm { | 32 namespace gcm { |
| 32 | 33 |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 70 } | 71 } |
| 71 | 72 |
| 72 void GServicesSettings::UpdateFromLoadResult( | 73 void GServicesSettings::UpdateFromLoadResult( |
| 73 const GCMStore::LoadResult& load_result) { | 74 const GCMStore::LoadResult& load_result) { |
| 74 if (UpdateSettings(load_result.gservices_settings)) | 75 if (UpdateSettings(load_result.gservices_settings)) |
| 75 digest_ = load_result.gservices_digest; | 76 digest_ = load_result.gservices_digest; |
| 76 } | 77 } |
| 77 | 78 |
| 78 bool GServicesSettings::UpdateSettings( | 79 bool GServicesSettings::UpdateSettings( |
| 79 const std::map<std::string, std::string>& settings) { | 80 const std::map<std::string, std::string>& settings) { |
| 80 int64 new_checkin_interval = 0LL; | 81 int64 new_checkin_interval = kMinimumCheckinInterval; |
| 81 std::map<std::string, std::string>::const_iterator iter = | 82 std::map<std::string, std::string>::const_iterator iter = |
| 82 settings.find(kCheckinIntervalKey); | 83 settings.find(kCheckinIntervalKey); |
| 83 if (iter != settings.end()) { | 84 if (iter == settings.end()) { |
| 84 if (!base::StringToInt64(iter->second, &new_checkin_interval)) { | 85 LOG(ERROR) << "Setting not found: " << kCheckinIntervalKey; |
| 85 LOG(ERROR) << "Failed to parse checkin interval: " << iter->second; | 86 return false; |
| 86 return false; | 87 } |
| 87 } | 88 if (!base::StringToInt64(iter->second, &new_checkin_interval)) { |
| 88 if (new_checkin_interval <= 0LL) { | 89 LOG(ERROR) << "Failed to parse checkin interval: " << iter->second; |
| 89 LOG(ERROR) << "Checkin interval not positive: " << new_checkin_interval; | 90 return false; |
| 90 return false; | 91 } |
| 91 } | 92 if (new_checkin_interval < kMinimumCheckinInterval) { |
|
jianli
2014/04/28 17:33:50
Probably we should use kMinimumCheckinInterval if
fgorski
2014/04/28 17:50:53
Done. I was thinking about that, but it might no l
| |
| 93 LOG(ERROR) << "Checkin interval: " << new_checkin_interval | |
| 94 << " is less than allowed minimum: " << kMinimumCheckinInterval; | |
| 95 return false; | |
| 92 } | 96 } |
| 93 | 97 |
| 94 std::string new_mcs_hostname; | 98 std::string new_mcs_hostname; |
| 99 iter = settings.find(kMCSHostnameKey); | |
| 100 if (iter == settings.end()) { | |
| 101 LOG(ERROR) << "Setting not found: " << kMCSHostnameKey; | |
| 102 return false; | |
| 103 } | |
| 104 new_mcs_hostname = iter->second; | |
| 105 if (new_mcs_hostname.empty()) { | |
| 106 LOG(ERROR) << "Empty MCS hostname provided."; | |
| 107 return false; | |
| 108 } | |
| 109 | |
| 95 int new_mcs_secure_port = -1; | 110 int new_mcs_secure_port = -1; |
| 96 iter = settings.find(kMCSHostnameKey); | 111 iter = settings.find(kMCSSecurePortKey); |
| 97 if (iter != settings.end()) { | 112 if (iter == settings.end()) { |
| 98 new_mcs_hostname = iter->second; | 113 LOG(ERROR) << "Setting not found: " << kMCSSecurePortKey; |
| 99 if (new_mcs_hostname.empty()) { | 114 return false; |
| 100 LOG(ERROR) << "Empty MCS hostname provided."; | 115 } |
| 101 return false; | 116 if (!base::StringToInt(iter->second, &new_mcs_secure_port)) { |
| 102 } | 117 LOG(ERROR) << "Failed to parse MCS secure port: " << iter->second; |
| 103 | 118 return false; |
| 104 iter = settings.find(kMCSSecurePortKey); | 119 } |
| 105 if (iter != settings.end()) { | 120 if (new_mcs_secure_port < 0 || 65535 < new_mcs_secure_port) { |
| 106 if (!base::StringToInt(iter->second, &new_mcs_secure_port)) { | 121 LOG(ERROR) << "Incorrect port value: " << new_mcs_secure_port; |
| 107 LOG(ERROR) << "Failed to parse MCS secure port: " << iter->second; | 122 return false; |
| 108 return false; | |
| 109 } | |
| 110 if (new_mcs_secure_port < 0 || 65535 < new_mcs_secure_port) { | |
| 111 LOG(ERROR) << "Incorrect port value: " << new_mcs_secure_port; | |
| 112 return false; | |
| 113 } | |
| 114 } | |
| 115 } | 123 } |
| 116 | 124 |
| 117 std::string new_checkin_url; | 125 std::string new_checkin_url; |
| 118 iter = settings.find(kCheckinURLKey); | 126 iter = settings.find(kCheckinURLKey); |
| 119 if (iter != settings.end()) { | 127 if (iter == settings.end()) { |
| 120 new_checkin_url = iter->second; | 128 LOG(ERROR) << "Setting not found: " << kCheckinURLKey; |
| 121 if (new_checkin_url.empty()) { | 129 return false; |
| 122 LOG(ERROR) << "Empty checkin URL provided."; | 130 } |
| 123 return false; | 131 new_checkin_url = iter->second; |
| 124 } | 132 if (new_checkin_url.empty()) { |
| 133 LOG(ERROR) << "Empty checkin URL provided."; | |
| 134 return false; | |
| 125 } | 135 } |
| 126 | 136 |
| 127 std::string new_registration_url; | 137 std::string new_registration_url; |
| 128 iter = settings.find(kRegistrationURLKey); | 138 iter = settings.find(kRegistrationURLKey); |
| 129 if (iter != settings.end()) { | 139 if (iter == settings.end()) { |
| 130 new_registration_url = iter->second; | 140 LOG(ERROR) << "Setting not found: " << kRegistrationURLKey; |
| 131 if (new_registration_url.empty()) { | 141 return false; |
| 132 LOG(ERROR) << "Empty registration URL provided."; | 142 } |
| 133 return false; | 143 new_registration_url = iter->second; |
| 134 } | 144 if (new_registration_url.empty()) { |
| 145 LOG(ERROR) << "Empty registration URL provided."; | |
| 146 return false; | |
| 135 } | 147 } |
| 136 | 148 |
| 137 // We only update the settings once all of them are correct. | 149 // We only update the settings once all of them are correct. |
| 138 checkin_interval_ = new_checkin_interval; | 150 checkin_interval_ = new_checkin_interval; |
| 139 mcs_hostname_ = new_mcs_hostname; | 151 mcs_hostname_ = new_mcs_hostname; |
| 140 mcs_secure_port_ = new_mcs_secure_port; | 152 mcs_secure_port_ = new_mcs_secure_port; |
| 141 checkin_url_ = new_checkin_url; | 153 checkin_url_ = new_checkin_url; |
| 142 registration_url_ = new_registration_url; | 154 registration_url_ = new_registration_url; |
| 143 return true; | 155 return true; |
| 144 } | 156 } |
| 145 | 157 |
| 146 void GServicesSettings::SetGServicesSettingsCallback(bool success) { | 158 void GServicesSettings::SetGServicesSettingsCallback(bool success) { |
| 147 DCHECK(success); | 159 DCHECK(success); |
| 148 } | 160 } |
| 149 | 161 |
| 150 } // namespace gcm | 162 } // namespace gcm |
| OLD | NEW |