/external/chromium-trace/catapult/dashboard/dashboard/ |
H A D | 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/libweave/src/ |
H A D | 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());
|
H A D | streams.cc | 9 #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 D | device_delegate.cc | 8 #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 D | ref_counted_delete_on_message_loop.h | 41 // 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 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();
|
H A D | test_io_thread.cc | 54 task_runner()->PostTask(from_here, task); 60 task_runner()->PostTask(from_here,
|
/external/libchrome/base/ |
H A D | thread_task_runner_handle.h | 29 // Binds |task_runner| to the current thread. |task_runner| must belong 32 const scoped_refptr<SingleThreadTaskRunner>& task_runner);
|
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 | task_runner_util.h | 12 #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 D | thread_task_runner_handle.cc | 33 const scoped_refptr<SingleThreadTaskRunner>& task_runner) 34 : task_runner_(task_runner) { 32 ThreadTaskRunnerHandle( const scoped_refptr<SingleThreadTaskRunner>& task_runner) argument
|
H A D | 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,
|
/external/libchrome/base/message_loop/ |
H A D | 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(), ThreadTaskRunnerHandl 333 scoped_refptr<SingleThreadTaskRunner> task_runner = local 343 scoped_refptr<SingleThreadTaskRunner> task_runner; local [all...] |
/external/libweave/src/test/ |
H A D | fake_stream.cc | 9 #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 D | ssl_stream.cc | 11 #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 D | file_config_store.h | 13 #include <weave/provider/task_runner.h> 21 provider::TaskRunner* task_runner);
|
H A D | ssl_stream.h | 36 static void Connect(provider::TaskRunner* task_runner, 48 SSLStream(provider::TaskRunner* task_runner,
|
/external/libweave/include/weave/test/ |
H A D | fake_stream.h | 25 explicit FakeStream(provider::TaskRunner* task_runner); 26 FakeStream(provider::TaskRunner* task_runner, const std::string& read_data);
|
/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/libweave/src/notification/ |
H A D | pull_channel.cc | 9 #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 D | 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 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 D | trace_event_system_stats_monitor.h | 32 // |task_runner| must be the primary thread for the client 35 scoped_refptr<SingleThreadTaskRunner> task_runner);
|
/external/libchrome/base/files/ |
H A D | 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,
|
H A D | important_file_writer.cc | 25 #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
|