| /external/libweave/src/ |
| streams_unittest.cc | 18 provider::test::FakeTaskRunner task_runner; local
22 MemoryStream source{test_data, &task_runner};
23 MemoryStream destination{{}, &task_runner};
36 task_runner.Run(test_data.size());
|
| /external/chromium-trace/catapult/dashboard/dashboard/ |
| task_runner_test.py | 7 from dashboard import task_runner namespace
34 @mock.patch.object(task_runner, '_AddReportToLog')
40 task_runner.Run(SampleTask)
42 self.ExecuteDeferredTasks(task_runner._TASK_QUEUE_NAME)
|
| /external/libchrome/base/test/ |
| 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/files/ |
| file_path_watcher.h | 61 scoped_refptr<base::SingleThreadTaskRunner> task_runner() const { function in class:base::FilePathWatcher::PlatformDelegate
|
| 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/libweave/examples/provider/ |
| ssl_stream.cc | 11 #include <weave/provider/task_runner.h>
29 void RetryAsyncTask(provider::TaskRunner* task_runner,
32 task_runner->PostDelayedTask(FROM_HERE, task,
50 SSLStream::SSLStream(provider::TaskRunner* task_runner,
52 : task_runner_{task_runner} {
144 provider::TaskRunner* task_runner,
158 new SSLStream{task_runner, std::move(stream_bio)}};
169 auto task_runner = stream->task_runner_;
172 task_runner, FROM_HERE,
178 task_runner->PostDelayedTask
186 auto task_runner = stream->task_runner_; local
[all...] |
| /external/libchrome/base/ |
| observer_list_threadsafe.h | 186 context->task_runner->PostTask(
200 : task_runner(ThreadTaskRunnerHandle::Get()), list(type) {}
202 scoped_refptr<SingleThreadTaskRunner> task_runner; member in struct:base::ObserverListThreadSafe::ObserverListContext
|
| /external/libchrome/base/threading/ |
| thread.h | 167 scoped_refptr<SingleThreadTaskRunner> task_runner() const { function in class:base::Thread
168 return message_loop_ ? message_loop_->task_runner() : nullptr;
|
| /external/libchrome/base/message_loop/ |
| message_loop.h | 160 // NOTE: Deprecated; prefer task_runner() and the TaskRunner interfaces.
295 const scoped_refptr<SingleThreadTaskRunner>& task_runner() { function in class:base::MessageLoop
304 void SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner);
|
| message_loop_task_runner_unittest.cc | 112 ASSERT_TRUE(task_thread_.task_runner()->PostTaskAndReply(
146 scoped_refptr<SingleThreadTaskRunner> task_runner = local
147 task_thread_.task_runner();
152 task_runner->PostTaskAndReply(FROM_HERE, Bind(&RecordLoop, task_recoder),
180 ASSERT_TRUE(current_loop_->task_runner()->PostTaskAndReply(
213 task_thread_.task_runner()->PostTaskAndReply(
260 ASSERT_TRUE(io_thread_->task_runner()->BelongsToCurrentThread());
261 ASSERT_EQ(io_thread_->task_runner(), ThreadTaskRunnerHandle::Get());
265 ASSERT_TRUE(file_thread_->task_runner()->BelongsToCurrentThread());
266 ASSERT_EQ(file_thread_->task_runner(), ThreadTaskRunnerHandle::Get())
333 scoped_refptr<SingleThreadTaskRunner> task_runner = local
343 scoped_refptr<SingleThreadTaskRunner> task_runner; local
[all...] |
| /external/libchrome/base/timer/ |
| timer_unittest.cc | 44 void SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner) {
46 timer_.SetTaskRunner(task_runner);
327 scoped_refptr<base::TestSimpleTaskRunner> task_runner = local
332 f.SetTaskRunner(task_runner);
336 task_runner->RunUntilIdle();
|
| /external/libchrome/base/trace_event/ |
| memory_dump_manager.h | 72 // - task_runner: if non-null, all the calls to |mdp| will be
79 const scoped_refptr<SingleThreadTaskRunner>& task_runner);
83 const scoped_refptr<SingleThreadTaskRunner>& task_runner,
159 // in the |task_runner| thread, unless the thread has been destroyed.
162 // Define a total order based on the thread (i.e. |task_runner|) affinity,
174 const scoped_refptr<SingleThreadTaskRunner>& task_runner,
186 // The task_runner affinity. Can be nullptr, in which case the dump provider
188 const scoped_refptr<SingleThreadTaskRunner> task_runner; member in struct:base::trace_event::MemoryDumpManager::MemoryDumpProviderInfo
247 // This is essentially |dump_thread_|.task_runner() but needs to be kept
|
| memory_dump_manager_unittest.cc | 52 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
56 mdm->RegisterDumpProvider(mdp, "TestDumpProvider", task_runner, options);
133 void DumpCallbackAdapter(scoped_refptr<SingleThreadTaskRunner> task_runner,
138 task_runner->PostTask(FROM_HERE, closure);
152 MessageLoop::current()->task_runner(), run_loop.QuitClosure());
383 // MemoryDumpProvider specifies a task_runner(). The test starts creating 8
400 scoped_refptr<SingleThreadTaskRunner> task_runner = thread->task_runner(); local
403 RegisterDumpProvider(mdp, task_runner, kDefaultOptions);
407 [task_runner](const MemoryDumpArgs&, ProcessMemoryDump*) -> bool
[all...] |
| memory_dump_manager.cc | 191 const scoped_refptr<SingleThreadTaskRunner>& task_runner,
197 new MemoryDumpProviderInfo(mdp, name, task_runner, options);
215 const scoped_refptr<SingleThreadTaskRunner>& task_runner) {
216 RegisterDumpProvider(mdp, name, task_runner, MemoryDumpProvider::Options());
255 // - The MDP has specified a thread affinity (via task_runner()) AND
262 DCHECK((*mdp_iter)->task_runner &&
263 (*mdp_iter)->task_runner->BelongsToCurrentThread())
331 callback, dump_thread_->task_runner()));
388 // PostTask() below will fail, but |task_runner| should always be non-null.
389 SingleThreadTaskRunner* task_runner = mdpinfo->task_runner.get() local
[all...] |
| /external/webrtc/webrtc/base/ |
| task_unittest.cc | 499 DeleteTestTaskRunner task_runner; local
500 HappyTask* happy_task = new HappyTask(&task_runner);
508 task_runner.RunTasks();
515 DeleteTestTaskRunner task_runner; local
516 HappyTask* happy_task = new HappyTask(&task_runner);
529 DeleteTestTaskRunner task_runner; local
530 HappyTask* happy_task = new HappyTask(&task_runner);
539 task_runner.RunTasks();
|
