Chromium Code Reviews| Index: net/cert_net/cert_net_fetcher_impl.cc |
| diff --git a/net/cert_net/cert_net_fetcher_impl.cc b/net/cert_net/cert_net_fetcher_impl.cc |
| index d579fe884641414d51fb073006b66578573c8924..fcb87a28a270c9f9fb176e4d27c1a557d2fd3c30 100644 |
| --- a/net/cert_net/cert_net_fetcher_impl.cc |
| +++ b/net/cert_net/cert_net_fetcher_impl.cc |
| @@ -205,7 +205,7 @@ class RequestCore : public base::RefCountedThreadSafe<RequestCore> { |
| task_runner_(std::move(task_runner)) {} |
| void AttachedToJob(Job* job) { |
| - DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
| + DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
| DCHECK(!job_); |
| // Requests should not be attached to jobs after they have been signalled |
| // with a cancellation error (which happens via either Cancel() or |
| @@ -217,7 +217,7 @@ class RequestCore : public base::RefCountedThreadSafe<RequestCore> { |
| void OnJobCompleted(Job* job, |
| Error error, |
| const std::vector<uint8_t>& response_body) { |
| - DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
| + DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
| DCHECK_EQ(job_, job); |
| job_ = nullptr; |
| @@ -237,7 +237,7 @@ class RequestCore : public base::RefCountedThreadSafe<RequestCore> { |
| // Should only be called once. |
| void WaitForResult(Error* error, std::vector<uint8_t>* bytes) { |
| - DCHECK(!task_runner_->RunsTasksOnCurrentThread()); |
| + DCHECK(!task_runner_->RunsTasksInCurrentSequence()); |
| completion_event_.Wait(); |
| *bytes = std::move(bytes_); |
| @@ -384,7 +384,7 @@ class Job : public URLRequest::Delegate { |
| }; |
| void RequestCore::CancelJob() { |
| - if (!task_runner_->RunsTasksOnCurrentThread()) { |
| + if (!task_runner_->RunsTasksInCurrentSequence()) { |
| task_runner_->PostTask(FROM_HERE, |
| base::Bind(&RequestCore::CancelJob, this)); |
| return; |
| @@ -711,7 +711,7 @@ class CertNetFetcherImpl : public CertNetFetcher { |
| : task_runner_(base::ThreadTaskRunnerHandle::Get()), context_(context) {} |
| void Shutdown() override { |
| - DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
| + DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
| if (impl_) { |
| impl_->Shutdown(); |
| impl_.reset(); |
| @@ -771,7 +771,7 @@ class CertNetFetcherImpl : public CertNetFetcher { |
| void DoFetchOnNetworkThread(std::unique_ptr<RequestParams> request_params, |
|
Ryan Sleevi
2017/05/22 17:22:13
DoFetchOnNetworkSequence
Yeol Park
2017/05/23 05:26:33
Done.
|
| scoped_refptr<RequestCore> request) { |
| - DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
| + DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
| if (!context_) { |
| // The fetcher might have been shutdown between when this task was posted |