| Index: chrome/browser/component_updater/component_updater_ping_manager.cc
|
| diff --git a/chrome/browser/component_updater/component_updater_ping_manager.cc b/chrome/browser/component_updater/component_updater_ping_manager.cc
|
| deleted file mode 100644
|
| index eb98f65d50cd034842bf0931a0d894c41b1819f9..0000000000000000000000000000000000000000
|
| --- a/chrome/browser/component_updater/component_updater_ping_manager.cc
|
| +++ /dev/null
|
| @@ -1,205 +0,0 @@
|
| -// Copyright 2013 The Chromium 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 "chrome/browser/component_updater/component_updater_ping_manager.h"
|
| -
|
| -#include <string>
|
| -
|
| -#include "base/compiler_specific.h"
|
| -#include "base/guid.h"
|
| -#include "base/logging.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/string_util.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "chrome/browser/component_updater/component_updater_configurator.h"
|
| -#include "chrome/browser/component_updater/component_updater_utils.h"
|
| -#include "chrome/browser/component_updater/crx_update_item.h"
|
| -#include "net/url_request/url_fetcher.h"
|
| -#include "net/url_request/url_fetcher_delegate.h"
|
| -#include "url/gurl.h"
|
| -
|
| -namespace component_updater {
|
| -
|
| -// Returns a string literal corresponding to the value of the downloader |d|.
|
| -const char* DownloaderToString(CrxDownloader::DownloadMetrics::Downloader d) {
|
| - switch (d) {
|
| - case CrxDownloader::DownloadMetrics::kUrlFetcher:
|
| - return "direct";
|
| - case CrxDownloader::DownloadMetrics::kBits:
|
| - return "bits";
|
| - default:
|
| - return "unknown";
|
| - }
|
| -}
|
| -
|
| -// Sends a fire and forget ping. The instances of this class have no
|
| -// ownership and they self-delete upon completion.
|
| -class PingSender : public net::URLFetcherDelegate {
|
| - public:
|
| - PingSender();
|
| -
|
| - void SendPing(const Configurator& config,
|
| - net::URLRequestContextGetter* url_request_context_getter,
|
| - const CrxUpdateItem* item);
|
| -
|
| - private:
|
| - virtual ~PingSender();
|
| -
|
| - // Overrides for URLFetcherDelegate.
|
| - virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE;
|
| -
|
| - static std::string BuildPing(const Configurator& config,
|
| - const CrxUpdateItem* item);
|
| - static std::string BuildDownloadCompleteEventElements(
|
| - const CrxUpdateItem* item);
|
| - static std::string BuildUpdateCompleteEventElement(const CrxUpdateItem* item);
|
| -
|
| - scoped_ptr<net::URLFetcher> url_fetcher_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(PingSender);
|
| -};
|
| -
|
| -PingSender::PingSender() {
|
| -}
|
| -
|
| -PingSender::~PingSender() {
|
| -}
|
| -
|
| -void PingSender::OnURLFetchComplete(const net::URLFetcher* source) {
|
| - delete this;
|
| -}
|
| -
|
| -void PingSender::SendPing(
|
| - const Configurator& config,
|
| - net::URLRequestContextGetter* url_request_context_getter,
|
| - const CrxUpdateItem* item) {
|
| - DCHECK(item);
|
| -
|
| - if (!config.PingUrl().is_valid())
|
| - return;
|
| -
|
| - url_fetcher_.reset(SendProtocolRequest(config.PingUrl(),
|
| - BuildPing(config, item),
|
| - this,
|
| - url_request_context_getter));
|
| -}
|
| -
|
| -// Builds a ping message for the specified update item.
|
| -std::string PingSender::BuildPing(const Configurator& config,
|
| - const CrxUpdateItem* item) {
|
| - const char app_element_format[] =
|
| - "<app appid=\"%s\" version=\"%s\" nextversion=\"%s\">"
|
| - "%s"
|
| - "%s"
|
| - "</app>";
|
| - const std::string app_element(base::StringPrintf(
|
| - app_element_format,
|
| - item->id.c_str(), // "appid"
|
| - item->previous_version.GetString().c_str(), // "version"
|
| - item->next_version.GetString().c_str(), // "nextversion"
|
| - BuildUpdateCompleteEventElement(item).c_str(), // update event
|
| - BuildDownloadCompleteEventElements(item).c_str())); // download events
|
| -
|
| - return BuildProtocolRequest(config.GetBrowserVersion().GetString(),
|
| - config.GetChannel(),
|
| - config.GetLang(),
|
| - config.GetOSLongName(),
|
| - app_element,
|
| - "");
|
| -}
|
| -
|
| -// Returns a string representing a sequence of download complete events
|
| -// corresponding to each download metrics in |item|.
|
| -std::string PingSender::BuildDownloadCompleteEventElements(
|
| - const CrxUpdateItem* item) {
|
| - using base::StringAppendF;
|
| - std::string download_events;
|
| - for (size_t i = 0; i != item->download_metrics.size(); ++i) {
|
| - const CrxDownloader::DownloadMetrics& metrics = item->download_metrics[i];
|
| - std::string event("<event eventtype=\"14\"");
|
| - StringAppendF(&event, " eventresult=\"%d\"", metrics.error == 0);
|
| - StringAppendF(&event,
|
| - " downloader=\"%s\"",
|
| - DownloaderToString(metrics.downloader));
|
| - if (metrics.error) {
|
| - StringAppendF(&event, " errorcode=\"%d\"", metrics.error);
|
| - }
|
| - StringAppendF(&event, " url=\"%s\"", metrics.url.spec().c_str());
|
| -
|
| - // -1 means that the byte counts are not known.
|
| - if (metrics.downloaded_bytes != -1) {
|
| - StringAppendF(&event,
|
| - " downloaded=\"%s\"",
|
| - base::Int64ToString(metrics.downloaded_bytes).c_str());
|
| - }
|
| - if (metrics.total_bytes != -1) {
|
| - StringAppendF(&event,
|
| - " total=\"%s\"",
|
| - base::Int64ToString(metrics.total_bytes).c_str());
|
| - }
|
| -
|
| - if (metrics.download_time_ms) {
|
| - StringAppendF(&event,
|
| - " download_time_ms=\"%s\"",
|
| - base::Uint64ToString(metrics.download_time_ms).c_str());
|
| - }
|
| - StringAppendF(&event, "/>");
|
| -
|
| - download_events += event;
|
| - }
|
| - return download_events;
|
| -}
|
| -
|
| -// Returns a string representing one ping event xml element for an update item.
|
| -std::string PingSender::BuildUpdateCompleteEventElement(
|
| - const CrxUpdateItem* item) {
|
| - DCHECK(item->status == CrxUpdateItem::kNoUpdate ||
|
| - item->status == CrxUpdateItem::kUpdated);
|
| -
|
| - using base::StringAppendF;
|
| -
|
| - std::string ping_event("<event eventtype=\"3\"");
|
| - const int event_result = item->status == CrxUpdateItem::kUpdated;
|
| - StringAppendF(&ping_event, " eventresult=\"%d\"", event_result);
|
| - if (item->error_category)
|
| - StringAppendF(&ping_event, " errorcat=\"%d\"", item->error_category);
|
| - if (item->error_code)
|
| - StringAppendF(&ping_event, " errorcode=\"%d\"", item->error_code);
|
| - if (item->extra_code1)
|
| - StringAppendF(&ping_event, " extracode1=\"%d\"", item->extra_code1);
|
| - if (HasDiffUpdate(item))
|
| - StringAppendF(&ping_event, " diffresult=\"%d\"", !item->diff_update_failed);
|
| - if (item->diff_error_category) {
|
| - StringAppendF(
|
| - &ping_event, " differrorcat=\"%d\"", item->diff_error_category);
|
| - }
|
| - if (item->diff_error_code)
|
| - StringAppendF(&ping_event, " differrorcode=\"%d\"", item->diff_error_code);
|
| - if (item->diff_extra_code1) {
|
| - StringAppendF(
|
| - &ping_event, " diffextracode1=\"%d\"", item->diff_extra_code1);
|
| - }
|
| - if (!item->previous_fp.empty())
|
| - StringAppendF(&ping_event, " previousfp=\"%s\"", item->previous_fp.c_str());
|
| - if (!item->next_fp.empty())
|
| - StringAppendF(&ping_event, " nextfp=\"%s\"", item->next_fp.c_str());
|
| - StringAppendF(&ping_event, "/>");
|
| - return ping_event;
|
| -}
|
| -
|
| -PingManager::PingManager(const Configurator& config) : config_(config) {
|
| -}
|
| -
|
| -PingManager::~PingManager() {
|
| -}
|
| -
|
| -// Sends a fire and forget ping when the updates are complete. The ping
|
| -// sender object self-deletes after sending the ping.
|
| -void PingManager::OnUpdateComplete(const CrxUpdateItem* item) {
|
| - PingSender* ping_sender(new PingSender);
|
| - ping_sender->SendPing(config_, config_.RequestContext(), item);
|
| -}
|
| -
|
| -} // namespace component_updater
|
|
|