Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(869)

Unified Diff: net/cert_net/cert_net_fetcher_impl.cc

Issue 2894863002: Rename TaskRunner::RunsTasksOnCurrentThread() in //net (Closed)
Patch Set: for Requirements Created 3 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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

Powered by Google App Engine
This is Rietveld 408576698