| /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/ |
| thread_task_runner_handle.h | 29 // Binds |task_runner| to the current thread. |task_runner| must belong
32 const scoped_refptr<SingleThreadTaskRunner>& task_runner);
|
| task_runner.cc | 5 #include "base/task_runner.h"
64 void TaskRunnerTraits::Destruct(const TaskRunner* task_runner) {
65 task_runner->OnDestruct();
|
| task_runner_util.h | 12 #include "base/task_runner.h"
50 // target_thread_.task_runner(),
56 TaskRunner* task_runner,
61 return task_runner->PostTaskAndReply(
|
| thread_task_runner_handle.cc | 33 const scoped_refptr<SingleThreadTaskRunner>& task_runner)
34 : task_runner_(task_runner) {
|
| task_runner_util_unittest.cc | 74 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE,
87 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE,
101 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE,
115 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE,
|
| task_runner.h | 108 // target_thread_.task_runner()->PostTaskAndReply(
149 static void Destruct(const TaskRunner* task_runner);
|
| /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());
|
| streams.cc | 9 #include <weave/provider/task_runner.h>
17 provider::TaskRunner* task_runner)
18 : data_{data}, task_runner_{task_runner} {}
|
| /external/libweave/src/privet/ |
| device_delegate.cc | 8 #include <weave/provider/task_runner.h>
19 DeviceDelegateImpl(provider::TaskRunner* task_runner,
23 : task_runner_{task_runner},
60 provider::TaskRunner* task_runner,
65 task_runner, http_port, https_port, http_request_timeout));
|
| /external/libchrome/base/memory/ |
| ref_counted_delete_on_message_loop.h | 41 // MessageLoop::current()->task_runner().
43 const scoped_refptr<SingleThreadTaskRunner>& task_runner)
44 : task_runner_(task_runner) {
|
| /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();
|
| test_io_thread.cc | 54 task_runner()->PostTask(from_here, task);
60 task_runner()->PostTask(from_here,
|
| /external/libchrome/base/task/ |
| 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,
|
| cancelable_task_tracker.cc | 18 #include "base/task_runner.h"
51 void RunOrPostToTaskRunner(TaskRunner* task_runner, const Closure& closure) {
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,
|
| /external/libchrome/base/message_loop/ |
| 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/libweave/src/test/ |
| fake_stream.cc | 9 #include <weave/provider/task_runner.h>
14 FakeStream::FakeStream(provider::TaskRunner* task_runner)
15 : task_runner_{task_runner} {}
16 FakeStream::FakeStream(provider::TaskRunner* task_runner,
18 : task_runner_{task_runner}, read_data_{read_data} {}
|
| /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...] |
| file_config_store.h | 13 #include <weave/provider/task_runner.h>
21 provider::TaskRunner* task_runner);
|
| /external/libchrome/base/files/ |
| important_file_writer.h | 62 // |task_runner| is the SequencedTaskRunner instance where on which we will
66 const scoped_refptr<SequencedTaskRunner>& task_runner);
70 const scoped_refptr<SequencedTaskRunner>& task_runner,
|
| /external/libweave/include/weave/test/ |
| fake_stream.h | 25 explicit FakeStream(provider::TaskRunner* task_runner);
26 FakeStream(provider::TaskRunner* task_runner, const std::string& read_data);
|
| /system/tpm/trunks/ |
| background_command_transceiver.cc | 37 // A callback which posts another |callback| to a given |task_runner|.
40 scoped_refptr<base::SingleThreadTaskRunner> task_runner,
43 task_runner->PostTask(FROM_HERE, task);
52 const scoped_refptr<base::SequencedTaskRunner>& task_runner)
54 task_runner_(task_runner),
|
| /external/libweave/src/notification/ |
| pull_channel.cc | 9 #include <weave/provider/task_runner.h>
18 provider::TaskRunner* task_runner)
19 : pull_interval_{pull_interval}, task_runner_{task_runner} {}
|
| /external/libchrome/base/trace_event/ |
| 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...] |
| trace_event_system_stats_monitor.h | 32 // |task_runner| must be the primary thread for the client
35 scoped_refptr<SingleThreadTaskRunner> task_runner);
|
