Home
last modified time | relevance | path

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

1234

/external/libchrome/base/message_loop/
Dmessage_loop_task_runner_unittest.cc112 ASSERT_TRUE(task_thread_.task_runner()->PostTaskAndReply( in TEST_F()
146 scoped_refptr<SingleThreadTaskRunner> task_runner = in TEST_F() local
147 task_thread_.task_runner(); in TEST_F()
152 task_runner->PostTaskAndReply(FROM_HERE, Bind(&RecordLoop, task_recoder), in TEST_F()
180 ASSERT_TRUE(current_loop_->task_runner()->PostTaskAndReply( in TEST_F()
213 task_thread_.task_runner()->PostTaskAndReply( in TEST_F()
260 ASSERT_TRUE(io_thread_->task_runner()->BelongsToCurrentThread()); in AssertOnIOThread()
261 ASSERT_EQ(io_thread_->task_runner(), ThreadTaskRunnerHandle::Get()); in AssertOnIOThread()
265 ASSERT_TRUE(file_thread_->task_runner()->BelongsToCurrentThread()); in AssertOnFileThread()
266 ASSERT_EQ(file_thread_->task_runner(), ThreadTaskRunnerHandle::Get()); in AssertOnFileThread()
[all …]
/external/libweave/examples/provider/
Dssl_stream.cc29 void RetryAsyncTask(provider::TaskRunner* task_runner, in RetryAsyncTask() argument
32 task_runner->PostDelayedTask(FROM_HERE, task, in RetryAsyncTask()
50 SSLStream::SSLStream(provider::TaskRunner* task_runner, in SSLStream() argument
52 : task_runner_{task_runner} { in SSLStream()
144 provider::TaskRunner* task_runner, in Connect() argument
158 new SSLStream{task_runner, std::move(stream_bio)}}; in Connect()
169 auto task_runner = stream->task_runner_; in ConnectBio() local
172 task_runner, FROM_HERE, in ConnectBio()
178 task_runner->PostDelayedTask( in ConnectBio()
186 auto task_runner = stream->task_runner_; in DoHandshake() local
[all …]
/external/libchrome/base/trace_event/
Dmemory_dump_manager.cc191 const scoped_refptr<SingleThreadTaskRunner>& task_runner, in RegisterDumpProvider() argument
197 new MemoryDumpProviderInfo(mdp, name, task_runner, options); in RegisterDumpProvider()
215 const scoped_refptr<SingleThreadTaskRunner>& task_runner) { in RegisterDumpProvider() argument
216 RegisterDumpProvider(mdp, name, task_runner, MemoryDumpProvider::Options()); in RegisterDumpProvider()
262 DCHECK((*mdp_iter)->task_runner && in UnregisterDumpProviderInternal()
263 (*mdp_iter)->task_runner->BelongsToCurrentThread()) in UnregisterDumpProviderInternal()
331 callback, dump_thread_->task_runner())); in CreateProcessDump()
389 SingleThreadTaskRunner* task_runner = mdpinfo->task_runner.get(); in ContinueAsyncProcessDump() local
390 if (!task_runner) in ContinueAsyncProcessDump()
391 task_runner = pmd_async_state->dump_thread_task_runner.get(); in ContinueAsyncProcessDump()
[all …]
Dmemory_dump_manager.h79 const scoped_refptr<SingleThreadTaskRunner>& task_runner);
83 const scoped_refptr<SingleThreadTaskRunner>& task_runner,
174 const scoped_refptr<SingleThreadTaskRunner>& task_runner,
188 const scoped_refptr<SingleThreadTaskRunner> task_runner;
Dmemory_dump_manager_unittest.cc52 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, in RegisterDumpProvider() argument
56 mdm->RegisterDumpProvider(mdp, "TestDumpProvider", task_runner, options); in RegisterDumpProvider()
133 void DumpCallbackAdapter(scoped_refptr<SingleThreadTaskRunner> task_runner, in DumpCallbackAdapter() argument
138 task_runner->PostTask(FROM_HERE, closure); in DumpCallbackAdapter()
152 MessageLoop::current()->task_runner(), run_loop.QuitClosure()); in RequestGlobalDumpAndWait()
400 scoped_refptr<SingleThreadTaskRunner> task_runner = thread->task_runner(); in TEST_F() local
403 RegisterDumpProvider(mdp, task_runner, kDefaultOptions); in TEST_F()
407 [task_runner](const MemoryDumpArgs&, ProcessMemoryDump*) -> bool { in TEST_F()
408 EXPECT_TRUE(task_runner->RunsTasksOnCurrentThread()); in TEST_F()
429 threads.back()->task_runner()->PostTaskAndReply(FROM_HERE, unregistration, in TEST_F()
[all …]
/external/chromium-trace/catapult/dashboard/dashboard/
Dtask_runner_test.py7 from dashboard import task_runner
34 @mock.patch.object(task_runner, '_AddReportToLog')
40 task_runner.Run(SampleTask)
42 self.ExecuteDeferredTasks(task_runner._TASK_QUEUE_NAME)
/external/libweave/src/
Dstreams_unittest.cc18 provider::test::FakeTaskRunner task_runner; in TEST() local
22 MemoryStream source{test_data, &task_runner}; in TEST()
23 MemoryStream destination{{}, &task_runner}; in TEST()
36 task_runner.Run(test_data.size()); in TEST()
Ddevice_manager.cc26 provider::TaskRunner* task_runner, in DeviceManager() argument
34 component_manager_{new ComponentManagerImpl{task_runner}} {
41 config_.get(), component_manager_.get(), task_runner, http_client,
52 StartPrivet(task_runner, network, dns_sd, http_server, wifi, bluetooth);
73 void DeviceManager::StartPrivet(provider::TaskRunner* task_runner, in StartPrivet() argument
79 privet_.reset(new privet::Manager{task_runner}); in StartPrivet()
278 provider::TaskRunner* task_runner, in Create() argument
286 new DeviceManager{config_store, task_runner, http_client, network, dns_sd, in Create()
/external/libchrome/base/task/
Dcancelable_task_tracker.cc51 void RunOrPostToTaskRunner(TaskRunner* task_runner, const Closure& closure) { in RunOrPostToTaskRunner() argument
52 if (task_runner->RunsTasksOnCurrentThread()) in RunOrPostToTaskRunner()
55 task_runner->PostTask(FROM_HERE, closure); in RunOrPostToTaskRunner()
75 TaskRunner* task_runner, in PostTask() argument
80 return PostTaskAndReply(task_runner, from_here, task, Bind(&base::DoNothing)); in PostTask()
84 TaskRunner* task_runner, in PostTaskAndReply() argument
102 task_runner->PostTaskAndReply(from_here, in PostTaskAndReply()
Dcancelable_task_tracker.h71 TaskId PostTask(base::TaskRunner* task_runner,
75 TaskId PostTaskAndReply(base::TaskRunner* task_runner,
82 base::TaskRunner* task_runner, in PostTaskAndReplyWithResult() argument
88 task_runner, in PostTaskAndReplyWithResult()
Dcancelable_task_tracker_unittest.cc87 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
92 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
168 worker_thread.task_runner().get(), FROM_HERE, Bind(&DoNothing), in TEST_F()
195 other_thread.task_runner()->PostTask( in TEST_F()
202 other_thread.task_runner()->PostTask( in TEST_F()
377 bad_thread.task_runner()->PostTask( in TEST_F()
398 bad_thread.task_runner()->PostTask( in TEST_F()
416 bad_thread.task_runner()->PostTask( in TEST_F()
/external/libweave/src/privet/
Ddevice_delegate.cc19 DeviceDelegateImpl(provider::TaskRunner* task_runner, in DeviceDelegateImpl() argument
23 : task_runner_{task_runner}, in DeviceDelegateImpl()
60 provider::TaskRunner* task_runner, in CreateDefault() argument
65 task_runner, http_port, https_port, http_request_timeout)); in CreateDefault()
/external/libweave/src/test/
Dfake_stream.cc14 FakeStream::FakeStream(provider::TaskRunner* task_runner) in FakeStream() argument
15 : task_runner_{task_runner} {} in FakeStream()
16 FakeStream::FakeStream(provider::TaskRunner* task_runner, in FakeStream() argument
18 : task_runner_{task_runner}, read_data_{read_data} {} in FakeStream()
/external/libchrome/base/
Dtask_runner_util_unittest.cc74 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST()
87 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST()
101 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST()
115 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST()
Dthread_task_runner_handle.cc33 const scoped_refptr<SingleThreadTaskRunner>& task_runner) in ThreadTaskRunnerHandle() argument
34 : task_runner_(task_runner) { in ThreadTaskRunnerHandle()
Dtask_runner.cc64 void TaskRunnerTraits::Destruct(const TaskRunner* task_runner) { in Destruct() argument
65 task_runner->OnDestruct(); in Destruct()
/external/webrtc/webrtc/base/
Dtask_unittest.cc499 DeleteTestTaskRunner task_runner; in TEST() local
500 HappyTask* happy_task = new HappyTask(&task_runner); in TEST()
508 task_runner.RunTasks(); in TEST()
515 DeleteTestTaskRunner task_runner; in TEST() local
516 HappyTask* happy_task = new HappyTask(&task_runner); in TEST()
529 DeleteTestTaskRunner task_runner; in TEST() local
530 HappyTask* happy_task = new HappyTask(&task_runner); in TEST()
539 task_runner.RunTasks(); in TEST()
/external/libchrome/base/threading/
Dthread_unittest.cc156 a.task_runner()->PostTask(FROM_HERE, base::Bind(&ToggleValue, &was_invoked)); in TEST_F()
177 a.task_runner()->PostTask( in TEST_F()
181 a.task_runner()->PostTask(FROM_HERE, in TEST_F()
214 a.task_runner()->PostTask( in TEST_F()
273 t.task_runner()->PostTask( in TEST_F()
289 EXPECT_EQ(nullptr, a.task_runner()); in TEST_F()
/external/libchrome/base/files/
Dimportant_file_writer.cc129 const scoped_refptr<SequencedTaskRunner>& task_runner) in ImportantFileWriter() argument
132 task_runner, in ImportantFileWriter()
138 const scoped_refptr<SequencedTaskRunner>& task_runner, in ImportantFileWriter() argument
141 task_runner_(task_runner), in ImportantFileWriter()
Dfile_path_watcher_fsevents.cc170 task_runner()->PostTask( in OnFilePathsChanged()
178 DCHECK(task_runner()->RunsTasksOnCurrentThread()); in DispatchEvents()
244 task_runner()->PostTask( in UpdateEventStream()
255 task_runner()->PostTask( in ResolveTargetPath()
262 DCHECK(task_runner()->RunsTasksOnCurrentThread()); in ReportError()
/external/libchrome/base/test/
Dtest_io_thread.h46 scoped_refptr<SingleThreadTaskRunner> task_runner() { in task_runner() function
47 return message_loop()->task_runner(); in task_runner()
/external/libchrome/base/memory/
Dref_counted_delete_on_message_loop.h43 const scoped_refptr<SingleThreadTaskRunner>& task_runner) in RefCountedDeleteOnMessageLoop() argument
44 : task_runner_(task_runner) { in RefCountedDeleteOnMessageLoop()
Dweak_ptr_unittest.cc28 creator_thread.task_runner()->PostTask( in NewObject()
68 task_runner()->PostTask( in CreateArrowFromTarget()
76 task_runner()->PostTask( in CreateArrowFromArrow()
84 task_runner()->PostTask( in DeleteTarget()
92 task_runner()->PostTask( in CopyAndAssignArrow()
100 task_runner()->PostTask( in CopyAndAssignArrowBase()
108 task_runner()->PostTask( in DeleteArrow()
117 task_runner()->PostTask(FROM_HERE, base::Bind(&BackgroundThread::DoDeRef, in DeRef()
/external/libweave/include/weave/test/
Dfake_stream.h25 explicit FakeStream(provider::TaskRunner* task_runner);
26 FakeStream(provider::TaskRunner* task_runner, const std::string& read_data);
/external/libweave/src/notification/
Dpull_channel.cc18 provider::TaskRunner* task_runner) in PullChannel() argument
19 : pull_interval_{pull_interval}, task_runner_{task_runner} {} in PullChannel()

1234