| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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 "components/ukm/ukm_service.h" | 5 #include "components/ukm/ukm_service.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <string> | 8 #include <string> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 259 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 270 if (!persisted_logs_.has_unsent_logs()) { | 270 if (!persisted_logs_.has_unsent_logs()) { |
| 271 // No logs to send, so early out and schedule the next rotation. | 271 // No logs to send, so early out and schedule the next rotation. |
| 272 scheduler_->UploadFinished(true, /* has_unsent_logs */ false); | 272 scheduler_->UploadFinished(true, /* has_unsent_logs */ false); |
| 273 return; | 273 return; |
| 274 } | 274 } |
| 275 if (!persisted_logs_.has_staged_log()) | 275 if (!persisted_logs_.has_staged_log()) |
| 276 persisted_logs_.StageNextLog(); | 276 persisted_logs_.StageNextLog(); |
| 277 // TODO(holte): Handle data usage on cellular, etc. | 277 // TODO(holte): Handle data usage on cellular, etc. |
| 278 if (!log_uploader_) { | 278 if (!log_uploader_) { |
| 279 log_uploader_ = client_->CreateUploader( | 279 log_uploader_ = client_->CreateUploader( |
| 280 GetServerUrl(), kMimeType, base::Bind(&UkmService::OnLogUploadComplete, | 280 GetServerUrl(), kMimeType, metrics::MetricsLogUploader::UKM, |
| 281 self_ptr_factory_.GetWeakPtr())); | 281 base::Bind(&UkmService::OnLogUploadComplete, |
| 282 self_ptr_factory_.GetWeakPtr())); |
| 282 } | 283 } |
| 283 log_upload_in_progress_ = true; | 284 log_upload_in_progress_ = true; |
| 284 | 285 |
| 285 const std::string hash = | 286 const std::string hash = |
| 286 base::HexEncode(persisted_logs_.staged_log_hash().data(), | 287 base::HexEncode(persisted_logs_.staged_log_hash().data(), |
| 287 persisted_logs_.staged_log_hash().size()); | 288 persisted_logs_.staged_log_hash().size()); |
| 288 log_uploader_->UploadLog(persisted_logs_.staged_log(), hash); | 289 log_uploader_->UploadLog(persisted_logs_.staged_log(), hash); |
| 289 } | 290 } |
| 290 | 291 |
| 291 void UkmService::OnLogUploadComplete(int response_code) { | 292 void UkmService::OnLogUploadComplete(int response_code) { |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 328 } | 329 } |
| 329 if (sources_.size() >= kMaxSources) { | 330 if (sources_.size() >= kMaxSources) { |
| 330 RecordDroppedSource(DroppedSourceReason::MAX_SOURCES_HIT); | 331 RecordDroppedSource(DroppedSourceReason::MAX_SOURCES_HIT); |
| 331 return; | 332 return; |
| 332 } | 333 } |
| 333 | 334 |
| 334 sources_.push_back(std::move(source)); | 335 sources_.push_back(std::move(source)); |
| 335 } | 336 } |
| 336 | 337 |
| 337 } // namespace ukm | 338 } // namespace ukm |
| OLD | NEW |