Searched defs:task_runner (Results 1 - 25 of 32) sorted by relevance

12

/external/libchrome/base/test/
H A Dtest_io_thread.h12 #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 Dsequenced_task_runner_handle.cc36 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 Dthread_task_runner_handle.cc36 scoped_refptr<SingleThreadTaskRunner> task_runner)
37 : task_runner_(std::move(task_runner)) {
35 ThreadTaskRunnerHandle( scoped_refptr<SingleThreadTaskRunner> task_runner) argument
H A Dthread.h168 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 Dassociated_group_controller.cc12 scoped_refptr<base::SingleThreadTaskRunner> task_runner)
14 task_runner) {}
11 AssociatedGroupController( scoped_refptr<base::SingleThreadTaskRunner> task_runner) argument
/external/libchrome/base/files/
H A Dfile_path_watcher.h61 scoped_refptr<base::SingleThreadTaskRunner> task_runner() const { function in class:base::FilePathWatcher::PlatformDelegate
H A Dimportant_file_writer.cc25 #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 Dfile_path_watcher_kqueue.cc361 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 Dref_counted_delete_on_message_loop.h39 // 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 Duser_metrics.cc68 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 Dtask_runner_util.h11 #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 Dtask_runner.cc5 #include "base/task_runner.h"
64 void TaskRunnerTraits::Destruct(const TaskRunner* task_runner) { argument
65 task_runner->OnDestruct();
H A Dobserver_list_threadsafe.h187 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 Ddata_pipe_file_utils.cc72 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 Ddata_pipe_utils.cc121 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 Dcancelable_task_tracker.h71 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 Dcancelable_task_tracker.cc18 #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 Dtimer.cc96 void Timer::SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner) { argument
99 task_runner_.swap(task_runner);
H A Dtimer_unittest.cc48 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 Dconnector.h145 base::SingleThreadTaskRunner* task_runner() const { function in class:mojo::Connector
/external/libchrome/base/message_loop/
H A Dmessage_loop.h174 // 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 Dmessage_loop_task_runner_unittest.cc41 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 Dmemory_dump_manager.h73 // - 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 Dbind_task_runner_unittest.cc247 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 Dhandle_watcher.cc47 : 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());

Completed in 681 milliseconds

12