Searched refs:task_runner (Results 1 - 25 of 100) sorted by relevance

1234

/external/chromium-trace/catapult/dashboard/dashboard/
H A Dtask_runner_test.py7 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/libweave/src/
H A Dstreams_unittest.cc18 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());
H A Dstreams.cc9 #include <weave/provider/task_runner.h>
17 provider::TaskRunner* task_runner)
18 : data_{data}, task_runner_{task_runner} {}
16 MemoryStream(const std::vector<uint8_t>& data, provider::TaskRunner* task_runner) argument
/external/libweave/src/privet/
H A Ddevice_delegate.cc8 #include <weave/provider/task_runner.h>
19 DeviceDelegateImpl(provider::TaskRunner* task_runner, argument
23 : task_runner_{task_runner},
60 provider::TaskRunner* task_runner,
65 task_runner, http_port, https_port, http_request_timeout));
59 CreateDefault( provider::TaskRunner* task_runner, uint16_t http_port, uint16_t https_port, base::TimeDelta http_request_timeout) argument
/external/libchrome/base/memory/
H A Dref_counted_delete_on_message_loop.h41 // MessageLoop::current()->task_runner().
43 const scoped_refptr<SingleThreadTaskRunner>& task_runner)
44 : task_runner_(task_runner) {
42 RefCountedDeleteOnMessageLoop( const scoped_refptr<SingleThreadTaskRunner>& task_runner) argument
/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();
H A Dtest_io_thread.cc54 task_runner()->PostTask(from_here, task);
60 task_runner()->PostTask(from_here,
/external/libchrome/base/
H A Dthread_task_runner_handle.h29 // Binds |task_runner| to the current thread. |task_runner| must belong
32 const scoped_refptr<SingleThreadTaskRunner>& task_runner);
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 Dtask_runner_util.h12 #include "base/task_runner.h"
50 // target_thread_.task_runner(),
56 TaskRunner* task_runner,
61 return task_runner->PostTaskAndReply(
55 PostTaskAndReplyWithResult( TaskRunner* task_runner, const tracked_objects::Location& from_here, const Callback<TaskReturnType(void)>& task, const Callback<void(ReplyArgType)>& reply) argument
H A Dthread_task_runner_handle.cc33 const scoped_refptr<SingleThreadTaskRunner>& task_runner)
34 : task_runner_(task_runner) {
32 ThreadTaskRunnerHandle( const scoped_refptr<SingleThreadTaskRunner>& task_runner) argument
H A Dtask_runner_util_unittest.cc74 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,
/external/libchrome/base/message_loop/
H A Dmessage_loop_task_runner_unittest.cc112 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(), ThreadTaskRunnerHandl
333 scoped_refptr<SingleThreadTaskRunner> task_runner = local
343 scoped_refptr<SingleThreadTaskRunner> task_runner; local
[all...]
/external/libweave/src/test/
H A Dfake_stream.cc9 #include <weave/provider/task_runner.h>
14 FakeStream::FakeStream(provider::TaskRunner* task_runner) argument
15 : task_runner_{task_runner} {}
16 FakeStream::FakeStream(provider::TaskRunner* task_runner, argument
18 : task_runner_{task_runner}, read_data_{read_data} {}
/external/libweave/examples/provider/
H A Dssl_stream.cc11 #include <weave/provider/task_runner.h>
29 void RetryAsyncTask(provider::TaskRunner* task_runner, argument
32 task_runner->PostDelayedTask(FROM_HERE, task,
50 SSLStream::SSLStream(provider::TaskRunner* task_runner, argument
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
143 Connect( provider::TaskRunner* task_runner, const std::string& host, uint16_t port, const provider::Network::OpenSslSocketCallback& callback) argument
186 auto task_runner = stream->task_runner_; local
[all...]
H A Dfile_config_store.h13 #include <weave/provider/task_runner.h>
21 provider::TaskRunner* task_runner);
H A Dssl_stream.h36 static void Connect(provider::TaskRunner* task_runner,
48 SSLStream(provider::TaskRunner* task_runner,
/external/libweave/include/weave/test/
H A Dfake_stream.h25 explicit FakeStream(provider::TaskRunner* task_runner);
26 FakeStream(provider::TaskRunner* task_runner, const std::string& read_data);
/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/libweave/src/notification/
H A Dpull_channel.cc9 #include <weave/provider/task_runner.h>
18 provider::TaskRunner* task_runner)
19 : pull_interval_{pull_interval}, task_runner_{task_runner} {}
17 PullChannel(base::TimeDelta pull_interval, provider::TaskRunner* task_runner) argument
/external/libchrome/base/trace_event/
H A Dmemory_dump_manager.cc191 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 local
188 RegisterDumpProvider( MemoryDumpProvider* mdp, const char* name, const scoped_refptr<SingleThreadTaskRunner>& task_runner, const MemoryDumpProvider::Options& options) argument
212 RegisterDumpProvider( MemoryDumpProvider* mdp, const char* name, const scoped_refptr<SingleThreadTaskRunner>& task_runner) argument
611 MemoryDumpProviderInfo( MemoryDumpProvider* dump_provider, const char* name, const scoped_refptr<SingleThreadTaskRunner>& task_runner, const MemoryDumpProvider::Options& options) argument
[all...]
H A Dtrace_event_system_stats_monitor.h32 // |task_runner| must be the primary thread for the client
35 scoped_refptr<SingleThreadTaskRunner> task_runner);
/external/libchrome/base/files/
H A Dimportant_file_writer.h62 // |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,
H A Dimportant_file_writer.cc25 #include "base/task_runner.h"
129 const scoped_refptr<SequencedTaskRunner>& task_runner)
132 task_runner,
138 const scoped_refptr<SequencedTaskRunner>& task_runner,
141 task_runner_(task_runner),
127 ImportantFileWriter( const FilePath& path, const scoped_refptr<SequencedTaskRunner>& task_runner) argument
136 ImportantFileWriter( const FilePath& path, const scoped_refptr<SequencedTaskRunner>& task_runner, TimeDelta interval) argument

Completed in 783 milliseconds

1234