| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/component_updater/component_updater_service.h" | 5 #include "chrome/browser/component_updater/component_updater_service.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/at_exit.h" | 10 #include "base/at_exit.h" |
| (...skipping 10 matching lines...) Expand all Loading... |
| 21 #include "base/timer.h" | 21 #include "base/timer.h" |
| 22 #include "chrome/browser/browser_process.h" | 22 #include "chrome/browser/browser_process.h" |
| 23 #include "chrome/browser/component_updater/component_unpacker.h" | 23 #include "chrome/browser/component_updater/component_unpacker.h" |
| 24 #include "chrome/common/chrome_notification_types.h" | 24 #include "chrome/common/chrome_notification_types.h" |
| 25 #include "chrome/common/chrome_utility_messages.h" | 25 #include "chrome/common/chrome_utility_messages.h" |
| 26 #include "chrome/common/chrome_version_info.h" | 26 #include "chrome/common/chrome_version_info.h" |
| 27 #include "chrome/common/extensions/extension.h" | 27 #include "chrome/common/extensions/extension.h" |
| 28 #include "content/public/browser/notification_service.h" | 28 #include "content/public/browser/notification_service.h" |
| 29 #include "content/public/browser/utility_process_host.h" | 29 #include "content/public/browser/utility_process_host.h" |
| 30 #include "content/public/browser/utility_process_host_client.h" | 30 #include "content/public/browser/utility_process_host_client.h" |
| 31 #include "content/public/common/url_fetcher.h" | |
| 32 #include "googleurl/src/gurl.h" | 31 #include "googleurl/src/gurl.h" |
| 33 #include "net/base/escape.h" | 32 #include "net/base/escape.h" |
| 34 #include "net/base/load_flags.h" | 33 #include "net/base/load_flags.h" |
| 34 #include "net/url_request/url_fetcher.h" |
| 35 #include "net/url_request/url_fetcher_delegate.h" | 35 #include "net/url_request/url_fetcher_delegate.h" |
| 36 | 36 |
| 37 using content::BrowserThread; | 37 using content::BrowserThread; |
| 38 using content::UtilityProcessHost; | 38 using content::UtilityProcessHost; |
| 39 using content::UtilityProcessHostClient; | 39 using content::UtilityProcessHostClient; |
| 40 using extensions::Extension; | 40 using extensions::Extension; |
| 41 | 41 |
| 42 // The component updater is designed to live until process shutdown, so | 42 // The component updater is designed to live until process shutdown, so |
| 43 // base::Bind() calls are not refcounted. | 43 // base::Bind() calls are not refcounted. |
| 44 | 44 |
| (...skipping 454 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 499 it != work_items_.end(); ++it) { | 499 it != work_items_.end(); ++it) { |
| 500 CrxUpdateItem* item = *it; | 500 CrxUpdateItem* item = *it; |
| 501 if (item->status != CrxUpdateItem::kCanUpdate) | 501 if (item->status != CrxUpdateItem::kCanUpdate) |
| 502 continue; | 502 continue; |
| 503 // Found component to update, start the process. | 503 // Found component to update, start the process. |
| 504 item->status = CrxUpdateItem::kDownloading; | 504 item->status = CrxUpdateItem::kDownloading; |
| 505 CRXContext* context = new CRXContext; | 505 CRXContext* context = new CRXContext; |
| 506 context->pk_hash = item->component.pk_hash; | 506 context->pk_hash = item->component.pk_hash; |
| 507 context->id = item->id; | 507 context->id = item->id; |
| 508 context->installer = item->component.installer; | 508 context->installer = item->component.installer; |
| 509 url_fetcher_.reset(content::URLFetcher::Create( | 509 url_fetcher_.reset(net::URLFetcher::Create( |
| 510 0, item->crx_url, net::URLFetcher::GET, | 510 0, item->crx_url, net::URLFetcher::GET, |
| 511 MakeContextDelegate(this, context))); | 511 MakeContextDelegate(this, context))); |
| 512 StartFetch(url_fetcher_.get(), config_->RequestContext(), true); | 512 StartFetch(url_fetcher_.get(), config_->RequestContext(), true); |
| 513 return; | 513 return; |
| 514 } | 514 } |
| 515 | 515 |
| 516 std::string query; | 516 std::string query; |
| 517 // If no pending upgrades, we check the if there are new | 517 // If no pending upgrades, we check the if there are new |
| 518 // components we have not checked against the server. We | 518 // components we have not checked against the server. We |
| 519 // can batch a bunch in a single url request. | 519 // can batch a bunch in a single url request. |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 560 if (query.empty()) { | 560 if (query.empty()) { |
| 561 // Next check after the long sleep. | 561 // Next check after the long sleep. |
| 562 ScheduleNextRun(false); | 562 ScheduleNextRun(false); |
| 563 return; | 563 return; |
| 564 } | 564 } |
| 565 | 565 |
| 566 // We got components to check. Start the url request. | 566 // We got components to check. Start the url request. |
| 567 const std::string full_query = MakeFinalQuery(config_->UpdateUrl().spec(), | 567 const std::string full_query = MakeFinalQuery(config_->UpdateUrl().spec(), |
| 568 query, | 568 query, |
| 569 config_->ExtraRequestParams()); | 569 config_->ExtraRequestParams()); |
| 570 url_fetcher_.reset(content::URLFetcher::Create( | 570 url_fetcher_.reset(net::URLFetcher::Create( |
| 571 0, GURL(full_query), net::URLFetcher::GET, | 571 0, GURL(full_query), net::URLFetcher::GET, |
| 572 MakeContextDelegate(this, new UpdateContext()))); | 572 MakeContextDelegate(this, new UpdateContext()))); |
| 573 StartFetch(url_fetcher_.get(), config_->RequestContext(), false); | 573 StartFetch(url_fetcher_.get(), config_->RequestContext(), false); |
| 574 } | 574 } |
| 575 | 575 |
| 576 // Caled when we got a response from the update server. It consists of an xml | 576 // Caled when we got a response from the update server. It consists of an xml |
| 577 // document following the omaha update scheme. | 577 // document following the omaha update scheme. |
| 578 void CrxUpdateService::OnURLFetchComplete(const net::URLFetcher* source, | 578 void CrxUpdateService::OnURLFetchComplete(const net::URLFetcher* source, |
| 579 UpdateContext* context) { | 579 UpdateContext* context) { |
| 580 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 580 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| (...skipping 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 769 ScheduleNextRun(false); | 769 ScheduleNextRun(false); |
| 770 } | 770 } |
| 771 | 771 |
| 772 // The component update factory. Using the component updater as a singleton | 772 // The component update factory. Using the component updater as a singleton |
| 773 // is the job of the browser process. | 773 // is the job of the browser process. |
| 774 ComponentUpdateService* ComponentUpdateServiceFactory( | 774 ComponentUpdateService* ComponentUpdateServiceFactory( |
| 775 ComponentUpdateService::Configurator* config) { | 775 ComponentUpdateService::Configurator* config) { |
| 776 DCHECK(config); | 776 DCHECK(config); |
| 777 return new CrxUpdateService(config); | 777 return new CrxUpdateService(config); |
| 778 } | 778 } |
| OLD | NEW |