| Index: chrome/browser/safe_browsing/download_protection_service.cc
|
| diff --git a/chrome/browser/safe_browsing/download_protection_service.cc b/chrome/browser/safe_browsing/download_protection_service.cc
|
| index 1460b2f7606f2ae692db07d66abd5c67f1449cfd..dd4083f9be5172ca354675efe6855b0b0ba61844 100644
|
| --- a/chrome/browser/safe_browsing/download_protection_service.cc
|
| +++ b/chrome/browser/safe_browsing/download_protection_service.cc
|
| @@ -255,7 +255,7 @@ class DownloadUrlSBClient : public DownloadSBClient {
|
| database_manager_(database_manager) { }
|
|
|
| void StartCheck() override {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!database_manager_.get() ||
|
| database_manager_->CheckDownloadUrl(url_chain_, this)) {
|
| CheckDone(SB_THREAT_TYPE_SAFE);
|
| @@ -313,14 +313,14 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| type_(ClientDownloadRequest::WIN_EXECUTABLE),
|
| start_time_(base::TimeTicks::Now()),
|
| weakptr_factory_(this) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| item_->AddObserver(this);
|
| }
|
|
|
| void Start() {
|
| DVLOG(2) << "Starting SafeBrowsing download check for: "
|
| << item_->DebugString(true);
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| // TODO(noelutz): implement some cache to make sure we don't issue the same
|
| // request over and over again if a user downloads the same binary multiple
|
| // times.
|
| @@ -362,7 +362,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| // Start a timeout to cancel the request if it takes too long.
|
| // This should only be called after we have finished accessing the file.
|
| void StartTimeout() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| if (!service_) {
|
| // Request has already been cancelled.
|
| return;
|
| @@ -380,7 +380,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| // Canceling a request will cause us to always report the result as UNKNOWN
|
| // unless a pending request is about to call FinishRequest.
|
| void Cancel() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| if (fetcher_.get()) {
|
| // The DownloadProtectionService is going to release its reference, so we
|
| // might be destroyed before the URLFetcher completes. Cancel the
|
| @@ -404,7 +404,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
|
|
| // From the net::URLFetcherDelegate interface.
|
| void OnURLFetchComplete(const net::URLFetcher* source) override {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| DCHECK_EQ(source, fetcher_.get());
|
| DVLOG(2) << "Received a response for URL: "
|
| << item_->GetUrlChain().back() << ": success="
|
| @@ -504,7 +504,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| friend class base::DeleteHelper<CheckClientDownloadRequest>;
|
|
|
| ~CheckClientDownloadRequest() override {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| DCHECK(item_ == NULL);
|
| }
|
|
|
| @@ -529,7 +529,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| }
|
|
|
| void StartExtractFileFeatures() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| DCHECK(item_); // Called directly from Start(), item should still exist.
|
| // Since we do blocking I/O, offload this to a worker thread.
|
| // The task does not need to block shutdown.
|
| @@ -570,7 +570,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| }
|
|
|
| void StartExtractZipFeatures() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| DCHECK(item_); // Called directly from Start(), item should still exist.
|
| zip_analysis_start_time_ = base::TimeTicks::Now();
|
| // We give the zip analyzer a weak pointer to this object. Since the
|
| @@ -583,7 +583,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| }
|
|
|
| void OnZipAnalysisFinished(const zip_analyzer::Results& results) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| if (!service_)
|
| return;
|
| if (results.success) {
|
| @@ -614,7 +614,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| }
|
|
|
| void CheckWhitelists() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
|
|
| if (!database_manager_.get()) {
|
| PostFinishTask(UNKNOWN, REASON_SB_DISABLED);
|
| @@ -675,7 +675,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| }
|
|
|
| void GetTabRedirects() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| if (!service_)
|
| return;
|
|
|
| @@ -702,7 +702,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
|
|
| void OnGotTabRedirects(const GURL& url,
|
| const history::RedirectList* redirect_list) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| DCHECK_EQ(url, tab_url_);
|
| if (!service_)
|
| return;
|
| @@ -716,7 +716,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
| }
|
|
|
| void SendRequest() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
|
|
| // This is our last chance to check whether the request has been canceled
|
| // before sending it.
|
| @@ -807,7 +807,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
|
|
| void FinishRequest(DownloadCheckResult result,
|
| DownloadCheckResultReason reason) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| if (finished_) {
|
| return;
|
| }
|
| @@ -867,7 +867,7 @@ class DownloadProtectionService::CheckClientDownloadRequest
|
|
|
| bool CertificateChainIsWhitelisted(
|
| const ClientDownloadRequest_CertificateChain& chain) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (chain.element_size() < 2) {
|
| // We need to have both a signing certificate and its issuer certificate
|
| // present to construct a whitelist entry.
|
| @@ -961,12 +961,12 @@ DownloadProtectionService::DownloadProtectionService(
|
| }
|
|
|
| DownloadProtectionService::~DownloadProtectionService() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| CancelPendingRequests();
|
| }
|
|
|
| void DownloadProtectionService::SetEnabled(bool enabled) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| if (enabled == enabled_) {
|
| return;
|
| }
|
| @@ -1022,12 +1022,12 @@ bool DownloadProtectionService::IsSupportedDownload(
|
| DownloadProtectionService::ClientDownloadRequestSubscription
|
| DownloadProtectionService::RegisterClientDownloadRequestCallback(
|
| const ClientDownloadRequestCallback& callback) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| return client_download_request_callbacks_.Add(callback);
|
| }
|
|
|
| void DownloadProtectionService::CancelPendingRequests() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| for (std::set<scoped_refptr<CheckClientDownloadRequest> >::iterator it =
|
| download_requests_.begin();
|
| it != download_requests_.end();) {
|
| @@ -1041,7 +1041,7 @@ void DownloadProtectionService::CancelPendingRequests() {
|
|
|
| void DownloadProtectionService::RequestFinished(
|
| CheckClientDownloadRequest* request) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
| std::set<scoped_refptr<CheckClientDownloadRequest> >::iterator it =
|
| download_requests_.find(request);
|
| DCHECK(it != download_requests_.end());
|
|
|