/external/libchrome/base/test/ |
H A D | test_io_thread.h | 12 #include "base/task_runner.h" 46 scoped_refptr<SingleThreadTaskRunner> task_runner() { function in class:base::TestIOThread 47 return message_loop()->task_runner();
|
/external/libchrome/base/threading/ |
H A D | sequenced_task_runner_handle.cc | 36 scoped_refptr<base::SequencedTaskRunner> task_runner = local 38 if (task_runner) { 40 return task_runner; 55 scoped_refptr<SequencedTaskRunner> task_runner) 56 : task_runner_(std::move(task_runner)) { 54 SequencedTaskRunnerHandle( scoped_refptr<SequencedTaskRunner> task_runner) argument
|
H A D | thread_task_runner_handle.cc | 36 scoped_refptr<SingleThreadTaskRunner> task_runner) 37 : task_runner_(std::move(task_runner)) { 35 ThreadTaskRunnerHandle( scoped_refptr<SingleThreadTaskRunner> task_runner) argument
|
H A D | thread.h | 168 scoped_refptr<SingleThreadTaskRunner> task_runner() const { function in class:base::Thread 169 return message_loop_ ? message_loop_->task_runner() : nullptr;
|
/external/libmojo/mojo/public/cpp/bindings/lib/ |
H A D | associated_group_controller.cc | 12 scoped_refptr<base::SingleThreadTaskRunner> task_runner) 14 task_runner) {} 11 AssociatedGroupController( scoped_refptr<base::SingleThreadTaskRunner> task_runner) argument
|
/external/libchrome/base/files/ |
H A D | file_path_watcher.h | 61 scoped_refptr<base::SingleThreadTaskRunner> task_runner() const { function in class:base::FilePathWatcher::PlatformDelegate
|
H A D | important_file_writer.cc | 25 #include "base/task_runner.h" 130 scoped_refptr<SequencedTaskRunner> task_runner) 133 std::move(task_runner), 138 scoped_refptr<SequencedTaskRunner> task_runner, 141 task_runner_(std::move(task_runner)), 128 ImportantFileWriter( const FilePath& path, scoped_refptr<SequencedTaskRunner> task_runner) argument 136 ImportantFileWriter( const FilePath& path, scoped_refptr<SequencedTaskRunner> task_runner, TimeDelta interval) argument
|
H A D | file_path_watcher_kqueue.cc | 361 SingleThreadTaskRunner* task_runner = io_task_runner_.get(); local 362 if (!task_runner) { 366 if (!task_runner->BelongsToCurrentThread()) { 367 task_runner->PostTask(FROM_HERE,
|
/external/libchrome/base/memory/ |
H A D | ref_counted_delete_on_message_loop.h | 39 // MessageLoop::current()->task_runner(). 41 scoped_refptr<SingleThreadTaskRunner> task_runner) 42 : task_runner_(std::move(task_runner)) { 40 RefCountedDeleteOnMessageLoop( scoped_refptr<SingleThreadTaskRunner> task_runner) argument
|
/external/libchrome/base/metrics/ |
H A D | user_metrics.cc | 68 scoped_refptr<SingleThreadTaskRunner> task_runner) { 69 DCHECK(task_runner->BelongsToCurrentThread()); 71 g_task_runner.Get() = task_runner; 67 SetRecordActionTaskRunner( scoped_refptr<SingleThreadTaskRunner> task_runner) argument
|
/external/libchrome/base/ |
H A D | task_runner_util.h | 11 #include "base/task_runner.h" 49 // target_thread_.task_runner(), 55 TaskRunner* task_runner, 60 return task_runner->PostTaskAndReply( 54 PostTaskAndReplyWithResult( TaskRunner* task_runner, const tracked_objects::Location& from_here, const Callback<TaskReturnType(void)>& task, const Callback<void(ReplyArgType)>& reply) argument
|
H A D | task_runner.cc | 5 #include "base/task_runner.h" 64 void TaskRunnerTraits::Destruct(const TaskRunner* task_runner) { argument 65 task_runner->OnDestruct();
|
H A D | observer_list_threadsafe.h | 187 context->task_runner->PostTask( 201 : task_runner(ThreadTaskRunnerHandle::Get()), list(type) {} 203 scoped_refptr<SingleThreadTaskRunner> task_runner; member in struct:base::ObserverListThreadSafe::ObserverListContext
|
/external/libmojo/mojo/common/ |
H A D | data_pipe_file_utils.cc | 72 base::TaskRunner* task_runner, 74 base::PostTaskAndReplyWithResult(task_runner, FROM_HERE, 69 CopyFromFile(const base::FilePath& source, ScopedDataPipeProducerHandle destination, uint32_t skip, base::TaskRunner* task_runner, const base::Callback<void(bool)>& callback) argument
|
H A D | data_pipe_utils.cc | 121 base::TaskRunner* task_runner, 124 task_runner, 119 CopyToFile(ScopedDataPipeConsumerHandle source, const base::FilePath& destination, base::TaskRunner* task_runner, const base::Callback<void(bool)>& callback) argument
|
/external/libchrome/base/task/ |
H A D | cancelable_task_tracker.h | 71 TaskId PostTask(base::TaskRunner* task_runner, 75 TaskId PostTaskAndReply(base::TaskRunner* task_runner, 82 base::TaskRunner* task_runner, 88 task_runner, 81 PostTaskAndReplyWithResult( base::TaskRunner* task_runner, const tracked_objects::Location& from_here, const base::Callback<TaskReturnType(void)>& task, const base::Callback<void(ReplyArgType)>& reply) argument
|
H A D | cancelable_task_tracker.cc | 18 #include "base/task_runner.h" 51 void RunOrPostToTaskRunner(TaskRunner* task_runner, const Closure& closure) { argument 52 if (task_runner->RunsTasksOnCurrentThread()) 55 task_runner->PostTask(FROM_HERE, closure); 75 TaskRunner* task_runner, 80 return PostTaskAndReply(task_runner, from_here, task, Bind(&base::DoNothing)); 84 TaskRunner* task_runner, 102 task_runner->PostTaskAndReply(from_here, 74 PostTask( TaskRunner* task_runner, const tracked_objects::Location& from_here, const Closure& task) argument 83 PostTaskAndReply( TaskRunner* task_runner, const tracked_objects::Location& from_here, const Closure& task, const Closure& reply) argument
|
/external/libchrome/base/timer/ |
H A D | timer.cc | 96 void Timer::SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner) { argument 99 task_runner_.swap(task_runner);
|
H A D | timer_unittest.cc | 48 void SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner) { argument 50 timer_.SetTaskRunner(task_runner); 331 scoped_refptr<base::TestSimpleTaskRunner> task_runner = local 336 f.SetTaskRunner(task_runner); 340 task_runner->RunUntilIdle();
|
/external/libmojo/mojo/public/cpp/bindings/ |
H A D | connector.h | 145 base::SingleThreadTaskRunner* task_runner() const { function in class:mojo::Connector
|
/external/libchrome/base/message_loop/ |
H A D | message_loop.h | 174 // NOTE: Deprecated; prefer task_runner() and the TaskRunner interfaces. 300 const scoped_refptr<SingleThreadTaskRunner>& task_runner() { function in class:base::MessageLoop 309 void SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner);
|
H A D | message_loop_task_runner_unittest.cc | 41 task_thread_.message_loop()->task_runner()->PostTask( 117 ASSERT_TRUE(task_thread_.task_runner()->PostTaskAndReply( 151 scoped_refptr<SingleThreadTaskRunner> task_runner = local 152 task_thread_.task_runner(); 157 task_runner->PostTaskAndReply(FROM_HERE, Bind(&RecordLoop, task_recoder), 185 ASSERT_TRUE(current_loop_->task_runner()->PostTaskAndReply( 220 task_thread_.task_runner()->PostTaskAndReply( 263 loop_.task_runner()->PostTask(FROM_HERE, 268 ASSERT_TRUE(io_thread_->task_runner()->BelongsToCurrentThread()); 269 ASSERT_EQ(io_thread_->task_runner(), ThreadTaskRunnerHandl 341 scoped_refptr<SingleThreadTaskRunner> task_runner = local 351 scoped_refptr<SingleThreadTaskRunner> task_runner; local [all...] |
/external/libchrome/base/trace_event/ |
H A D | memory_dump_manager.h | 73 // - task_runner: either a SingleThreadTaskRunner or SequencedTaskRunner. All 74 // the calls to |mdp| will be run on the given |task_runner|. If passed 79 scoped_refptr<SingleThreadTaskRunner> task_runner); 82 scoped_refptr<SingleThreadTaskRunner> task_runner, 87 scoped_refptr<SequencedTaskRunner> task_runner, 168 // on tasks running in the |task_runner|, unless the thread has been 172 // Define a total order based on the |task_runner| affinity, so that MDPs 183 scoped_refptr<SequencedTaskRunner> task_runner, 198 const scoped_refptr<SequencedTaskRunner> task_runner; member in struct:base::trace_event::MemoryDumpManager::MemoryDumpProviderInfo 266 // This is essentially |dump_thread_|.task_runner() bu [all...] |
/external/libmojo/mojo/public/cpp/bindings/tests/ |
H A D | bind_task_runner_unittest.cc | 247 scoped_refptr<TestTaskRunner> task_runner) { 249 if (task_runner) 250 task_runner->Quit(); 256 scoped_refptr<TestTaskRunner> task_runner, 259 DoSetFlagAndQuitTaskRunner(flag, task_runner); 265 scoped_refptr<TestTaskRunner> task_runner, 271 task_runner->Quit(); 276 scoped_refptr<TestTaskRunner> task_runner) { 277 return base::Bind(&DoSetFlagAndQuitTaskRunner, flag, task_runner); 283 scoped_refptr<TestTaskRunner> task_runner) { 246 DoSetFlagAndQuitTaskRunner(bool* flag, scoped_refptr<TestTaskRunner> task_runner) argument 253 DoExpectValueSetFlagAndQuitTaskRunner( int32_t expected_value, bool* flag, scoped_refptr<TestTaskRunner> task_runner, int32_t value) argument 262 DoExpectValueSetFlagForwardValueAndQuitTaskRunner( int32_t expected_value, bool* flag, scoped_refptr<TestTaskRunner> task_runner, int32_t value, const IntegerSender::EchoCallback& callback) argument 274 SetFlagAndQuitTaskRunner( bool* flag, scoped_refptr<TestTaskRunner> task_runner) argument 280 ExpectValueSetFlagAndQuitTaskRunner( int32_t expected_value, bool* flag, scoped_refptr<TestTaskRunner> task_runner) argument [all...] |
/external/libmojo/mojo/message_pump/ |
H A D | handle_watcher.cc | 47 : id(0), handle_signals(MOJO_HANDLE_SIGNAL_NONE), task_runner(NULL) {} 54 scoped_refptr<base::SingleThreadTaskRunner> task_runner; member in struct:mojo::common::__anon10883::WatchData 127 data.task_runner->PostTask(FROM_HERE, base::Bind(data.callback, result)); 238 request_data.start_data.task_runner = base::ThreadTaskRunnerHandle::Get(); 273 thread_.task_runner()->PostTask( 280 DCHECK(thread_.task_runner()->BelongsToCurrentThread());
|