Rename TaskRunner::RunsTasksOnCurrentThread() in //content

content/browser/byte_stream.cc

 // Copyright (c) 2012 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 "content/browser/byte_stream.h"
 
 #include <deque>
 #include <set>
 #include <utility>
 
@@ skipping 173 matching lines @@
       my_task_runner_(task_runner),
       my_lifetime_flag_(lifetime_flag),
       input_contents_size_(0),
       output_size_used_(0),
       peer_(NULL) {
   DCHECK(my_lifetime_flag_.get());
   my_lifetime_flag_->is_alive = true;
 }
 
 ByteStreamWriterImpl::~ByteStreamWriterImpl() {
-  // No RunsTasksOnCurrentThread() check to allow deleting a created writer
+  // No RunsTasksInCurrentSequence() check to allow deleting a created writer
   // before we start using it. Once started, should be deleted on the specified
   // task runner.
   my_lifetime_flag_->is_alive = false;
 }
 
 void ByteStreamWriterImpl::SetPeer(
     ByteStreamReaderImpl* peer,
     scoped_refptr<base::SequencedTaskRunner> peer_task_runner,
     scoped_refptr<LifetimeFlag> peer_lifetime_flag) {
   peer_ = peer;
   peer_task_runner_ = peer_task_runner;
   peer_lifetime_flag_ = peer_lifetime_flag;
 }
 
 bool ByteStreamWriterImpl::Write(
     scoped_refptr<net::IOBuffer> buffer, size_t byte_count) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
 
   // Check overflow.
   //
   // TODO(tyoshino): Discuss with content/browser/download developer and if
   // they're fine with, set smaller limit and make it configurable.
   size_t space_limit = std::numeric_limits<size_t>::max() -
       GetTotalBufferedBytes();
   if (byte_count > space_limit) {
     // TODO(tyoshino): Tell the user that Write() failed.
     // Ignore input.
     return false;
   }
 
   input_contents_.push_back(std::make_pair(buffer, byte_count));
   input_contents_size_ += byte_count;
 
   // Arbitrarily, we buffer to a third of the total size before sending.
   if (input_contents_size_ > total_buffer_size_ / kFractionBufferBeforeSending)
     PostToPeer(false, 0);
 
   return GetTotalBufferedBytes() <= total_buffer_size_;
 }
 
 void ByteStreamWriterImpl::Flush() {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
   if (input_contents_size_ > 0)
     PostToPeer(false, 0);
 }
 
 void ByteStreamWriterImpl::Close(int status) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
   PostToPeer(true, status);
 }
 
 void ByteStreamWriterImpl::RegisterCallback(
     const base::Closure& source_callback) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
   space_available_callback_ = source_callback;
 }
 
 size_t ByteStreamWriterImpl::GetTotalBufferedBytes() const {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
   // This sum doesn't overflow since Write() fails if this sum is going to
   // overflow.
   return input_contents_size_ + output_size_used_;
 }
 
 // static
 void ByteStreamWriterImpl::UpdateWindow(
     scoped_refptr<LifetimeFlag> lifetime_flag, ByteStreamWriterImpl* target,
     size_t bytes_consumed) {
   // If the target object isn't alive anymore, we do nothing.
   if (!lifetime_flag->is_alive) return;
 
   target->UpdateWindowInternal(bytes_consumed);
 }
 
 void ByteStreamWriterImpl::UpdateWindowInternal(size_t bytes_consumed) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
 
   bool was_above_limit = GetTotalBufferedBytes() > total_buffer_size_;
 
   DCHECK_GE(output_size_used_, bytes_consumed);
   output_size_used_ -= bytes_consumed;
 
   // Callback if we were above the limit and we're now <= to it.
   bool no_longer_above_limit = GetTotalBufferedBytes() <= total_buffer_size_;
 
   if (no_longer_above_limit && was_above_limit &&
       !space_available_callback_.is_null())
     space_available_callback_.Run();
 }
 
 void ByteStreamWriterImpl::PostToPeer(bool complete, int status) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
   // Valid contexts in which to call.
   DCHECK(complete || 0 != input_contents_size_);
 
   std::unique_ptr<ContentVector> transfer_buffer;
   size_t buffer_size = 0;
   if (0 != input_contents_size_) {
     transfer_buffer.reset(new ContentVector);
     transfer_buffer->swap(input_contents_);
     buffer_size = input_contents_size_;
     output_size_used_ += input_contents_size_;
@@ skipping 19 matching lines @@
       my_lifetime_flag_(lifetime_flag),
       received_status_(false),
       status_(0),
       unreported_consumed_bytes_(0),
       peer_(NULL) {
   DCHECK(my_lifetime_flag_.get());
   my_lifetime_flag_->is_alive = true;
 }
 
 ByteStreamReaderImpl::~ByteStreamReaderImpl() {
-  // No RunsTasksOnCurrentThread() check to allow deleting a created writer
+  // No RunsTasksInCurrentSequence() check to allow deleting a created writer
   // before we start using it. Once started, should be deleted on the specified
   // task runner.
   my_lifetime_flag_->is_alive = false;
 }
 
 void ByteStreamReaderImpl::SetPeer(
     ByteStreamWriterImpl* peer,
     scoped_refptr<base::SequencedTaskRunner> peer_task_runner,
     scoped_refptr<LifetimeFlag> peer_lifetime_flag) {
   peer_ = peer;
   peer_task_runner_ = peer_task_runner;
   peer_lifetime_flag_ = peer_lifetime_flag;
 }
 
 ByteStreamReaderImpl::StreamState
 ByteStreamReaderImpl::Read(scoped_refptr<net::IOBuffer>* data,
                            size_t* length) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
 
   if (available_contents_.size()) {
     *data = available_contents_.front().first;
     *length = available_contents_.front().second;
     available_contents_.pop_front();
     unreported_consumed_bytes_ += *length;
 
     MaybeUpdateInput();
     return STREAM_HAS_DATA;
   }
   if (received_status_) {
     return STREAM_COMPLETE;
   }
   return STREAM_EMPTY;
 }
 
 int ByteStreamReaderImpl::GetStatus() const {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
   DCHECK(received_status_);
   return status_;
 }
 
 void ByteStreamReaderImpl::RegisterCallback(
     const base::Closure& sink_callback) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
 
   data_available_callback_ = sink_callback;
 }
 
 // static
 void ByteStreamReaderImpl::TransferData(
     scoped_refptr<LifetimeFlag> object_lifetime_flag,
     ByteStreamReaderImpl* target,
     std::unique_ptr<ContentVector> transfer_buffer,
     size_t buffer_size,
     bool source_complete,
     int status) {
   // If our target is no longer alive, do nothing.
   if (!object_lifetime_flag->is_alive) return;
 
   target->TransferDataInternal(std::move(transfer_buffer), buffer_size,
                                source_complete, status);
 }
 
 void ByteStreamReaderImpl::TransferDataInternal(
     std::unique_ptr<ContentVector> transfer_buffer,
     size_t buffer_size,
     bool source_complete,
     int status) {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
 
   bool was_empty = available_contents_.empty();
 
   if (transfer_buffer) {
     available_contents_.insert(available_contents_.end(),
                                transfer_buffer->begin(),
                                transfer_buffer->end());
   }
 
   if (source_complete) {
     received_status_ = true;
     status_ = status;
   }
 
   // Callback on transition from empty to non-empty, or
   // source complete.
   if (((was_empty && !available_contents_.empty()) ||
        source_complete) &&
       !data_available_callback_.is_null())
     data_available_callback_.Run();
 }
 
 // Decide whether or not to send the input a window update.
 // Currently we do that whenever we've got unreported consumption
 // greater than 1/3 of total size.
 void ByteStreamReaderImpl::MaybeUpdateInput() {
-  DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(my_task_runner_->RunsTasksInCurrentSequence());
 
   if (unreported_consumed_bytes_ <=
       total_buffer_size_ / kFractionReadBeforeWindowUpdate)
     return;
 
   peer_task_runner_->PostTask(
       FROM_HERE, base::Bind(
           &ByteStreamWriterImpl::UpdateWindow,
           peer_lifetime_flag_,
           peer_,
@@ skipping 24 matching lines @@
   ByteStreamReaderImpl* out = new ByteStreamReaderImpl(
       output_task_runner, output_flag, buffer_size);
 
   in->SetPeer(out, output_task_runner, output_flag);
   out->SetPeer(in, input_task_runner, input_flag);
   input->reset(in);
   output->reset(out);
 }
 
 }  // namespace content