Home
last modified time | relevance | path

Searched refs:loop (Results 1 – 25 of 85) sorted by relevance

1234

/system/extras/simpleperf/
DIOEventLoop_test.cpp30 IOEventLoop loop; in TEST() local
33 ASSERT_NE(nullptr, loop.AddReadEvent(fd[0], [&]() { in TEST()
39 return loop.ExitLoop(); in TEST()
57 ASSERT_TRUE(loop.RunLoop()); in TEST()
69 IOEventLoop loop; in TEST() local
71 ASSERT_NE(nullptr, loop.AddWriteEvent(fd[1], [&]() { in TEST()
78 loop.ExitLoop(); in TEST()
94 ASSERT_TRUE(loop.RunLoop()); in TEST()
103 IOEventLoop loop; in TEST() local
105 ASSERT_TRUE(loop.AddSignalEvent(SIGINT, [&]() { in TEST()
[all …]
Dworkload_test.cpp26 IOEventLoop loop; in TEST() local
27 ASSERT_TRUE(loop.AddSignalEvent(SIGCHLD, [&]() { in TEST()
28 return loop.ExitLoop(); in TEST()
34 ASSERT_TRUE(loop.RunLoop()); in TEST()
45 IOEventLoop loop; in run_signaled_workload() local
46 ASSERT_TRUE(loop.AddSignalEvent(SIGCHLD, [&]() { in run_signaled_workload()
47 return loop.ExitLoop(); in run_signaled_workload()
53 ASSERT_TRUE(loop.RunLoop()); in run_signaled_workload()
66 IOEventLoop loop; in run_exit_nonzero_workload() local
67 ASSERT_TRUE(loop.AddSignalEvent(SIGCHLD, [&]() { in run_exit_nonzero_workload()
[all …]
DIOEventLoop.cpp25 IOEventLoop* loop; member
31 IOEvent(IOEventLoop* loop, const std::function<bool()>& callback) in IOEvent()
32 : loop(loop), e(nullptr), timeout({}), callback(callback), enabled(false) { in IOEvent()
98 e->loop->has_error_ = true; in EventCallbackFn()
99 e->loop->ExitLoop(); in EventCallbackFn()
220 IOEventLoop* loop = ref->loop; in DelEvent() local
221 for (auto it = loop->events_.begin(); it != loop->events_.end(); ++it) { in DelEvent()
223 loop->events_.erase(it); in DelEvent()
DRecordReadThread_test.cpp61 for (size_t loop = 0; loop < 10; ++loop) { in TEST_F() local
63 size_t record_size = sizeof(perf_event_header) + loop; in TEST_F()
255 IOEventLoop loop; in TEST_F() local
259 return loop.ExitLoop(); in TEST_F()
261 ASSERT_TRUE(thread.RegisterDataCallback(loop, callback)); in TEST_F()
264 ASSERT_TRUE(loop.RunLoop()); in TEST_F()
274 IOEventLoop loop; in TEST_F() local
288 return loop.ExitLoop(); in TEST_F()
290 ASSERT_TRUE(thread.RegisterDataCallback(loop, callback)); in TEST_F()
297 ASSERT_TRUE(loop.RunLoop()); in TEST_F()
[all …]
DRecordReadThread.cpp241 bool RecordReadThread::RegisterDataCallback(IOEventLoop& loop, in RegisterDataCallback() argument
255 if (!loop.AddReadEvent(read_data_fd_, data_callback)) { in RegisterDataCallback()
322 IOEventLoop loop; in RunReadThread() local
323 CHECK(loop.AddReadEvent(read_cmd_fd_, [&]() { return HandleCmd(loop); })); in RunReadThread()
324 loop.RunLoop(); in RunReadThread()
344 bool RecordReadThread::HandleCmd(IOEventLoop& loop) { in HandleCmd() argument
350 result = HandleAddEventFds(loop, *static_cast<std::vector<EventFd*>*>(cmd_arg_)); in HandleCmd()
359 result = loop.ExitLoop(); in HandleCmd()
373 bool RecordReadThread::HandleAddEventFds(IOEventLoop& loop, in HandleAddEventFds() argument
415 if (!pair.second->StartPolling(loop, [this]() { return ReadRecordsFromKernelBuffer(); })) { in HandleAddEventFds()
DRecordReadThread.h141 bool RegisterDataCallback(IOEventLoop& loop, const std::function<bool()>& data_callback);
172 bool HandleCmd(IOEventLoop& loop);
173 bool HandleAddEventFds(IOEventLoop& loop, const std::vector<EventFd*>& event_fds);
Dcmd_stat.cpp560 IOEventLoop* loop = event_selection_set_.GetIOEventLoop(); in Run() local
562 if (!loop->UsePreciseTimer()) { in Run()
571 auto exit_loop_callback = [loop]() { in Run()
572 return loop->ExitLoop(); in Run()
574 if (!loop->AddSignalEvents({SIGCHLD, SIGINT, SIGTERM, SIGHUP}, exit_loop_callback)) { in Run()
578 if (!loop->AddReadEvent(stop_signal_fd_, exit_loop_callback)) { in Run()
583 if (!loop->AddPeriodicEvent(SecondToTimeval(duration_in_sec_), exit_loop_callback)) { in Run()
606 if (!loop->AddPeriodicEvent(SecondToTimeval(interval_in_ms_ / 1000.0), in Run()
617 if (!loop->RunLoop()) { in Run()
/system/extras/simpleperf/runtest/
Dfunction_indirect_recursive.cpp3 void FunctionRecursiveTwo(int loop);
5 void FunctionRecursiveOne(int loop) { in FunctionRecursiveOne() argument
8 if (loop >= 0) { in FunctionRecursiveOne()
9 FunctionRecursiveTwo(loop); in FunctionRecursiveOne()
13 void FunctionRecursiveTwo(int loop) { in FunctionRecursiveTwo() argument
16 if (loop > 0) { in FunctionRecursiveTwo()
17 FunctionRecursiveOne(loop - 1); in FunctionRecursiveTwo()
Dfunction_recursive.cpp3 void FunctionRecursive(int loop) { in FunctionRecursive() argument
6 if (loop > 0) { in FunctionRecursive()
7 FunctionRecursive(loop - 1); in FunctionRecursive()
/system/update_engine/payload_consumer/
Dpostinstall_runner_action_unittest.cc267 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
270 loop.dev(), kPostinstallDefaultScript, false, false, false); in TEST_F()
280 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
281 RunPostinstallAction(loop.dev(), "bin/postinst_link", false, false, false); in TEST_F()
286 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
288 RunPostinstallAction(loop.dev(), in TEST_F()
301 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
304 RunPostinstallAction(loop.dev(), in TEST_F()
317 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
320 RunPostinstallAction(loop.dev(), in TEST_F()
[all …]
Ddownload_action_unittest.cc132 brillo::FakeMessageLoop loop(nullptr); in TestWithData() local
133 loop.SetAsCurrent(); in TestWithData()
194 loop.PostTask(FROM_HERE, in TestWithData()
196 loop.Run(); in TestWithData()
197 EXPECT_FALSE(loop.PendingTasks()); in TestWithData()
254 brillo::FakeMessageLoop loop(nullptr); in TEST() local
255 loop.SetAsCurrent(); in TEST()
327 loop.PostTask( in TEST()
332 loop.Run(); in TEST()
333 EXPECT_FALSE(loop.PendingTasks()); in TEST()
[all …]
/system/core/libappfuse/
DFuseAppLoop.cc32 bool HandleLookUp(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleLookUp() argument
37 return loop->ReplySimple(buffer->request.header.unique, -ENOENT); in HandleLookUp()
44 return loop->ReplySimple(buffer->request.header.unique, -ENOENT); in HandleLookUp()
50 return loop->ReplySimple(buffer->request.header.unique, -ENOENT); in HandleLookUp()
57 bool HandleGetAttr(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleGetAttr() argument
59 return loop->ReplyGetAttr(buffer->request.header.unique, buffer->request.header.nodeid, 0, in HandleGetAttr()
67 bool HandleRead(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleRead() argument
69 return loop->ReplySimple(buffer->request.header.unique, -EINVAL); in HandleRead()
77 bool HandleWrite(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleWrite() argument
79 return loop->ReplySimple(buffer->request.header.unique, -EINVAL); in HandleWrite()
[all …]
/system/core/fs_mgr/libdm/
Dloop_control_test.cpp56 LoopDevice loop(fd, 10s); in TEST() local
57 ASSERT_TRUE(loop.valid()); in TEST()
60 unique_fd loop_fd(open(loop.device().c_str(), O_RDWR)); in TEST()
Ddm_test.cpp540 LoopDevice loop(tmp, 10s); in TEST() local
541 ASSERT_TRUE(loop.valid()); in TEST()
544 ASSERT_TRUE(table.Emplace<DmTargetLinear>(0, 1, loop.device(), 0)); in TEST()
564 LoopDevice loop(tmp, 10s); in TEST() local
565 ASSERT_TRUE(loop.valid()); in TEST()
566 ASSERT_TRUE(android::base::StartsWith(loop.device(), "/dev/block")); in TEST()
569 ASSERT_TRUE(table.Emplace<DmTargetLinear>(0, 1, loop.device(), 0)); in TEST()
577 ASSERT_FALSE(dm.IsDmBlockDevice(loop.device())); in TEST()
583 LoopDevice loop(tmp, 10s); in TEST() local
584 ASSERT_TRUE(loop.valid()); in TEST()
[all …]
/system/update_engine/
Domaha_request_action_fuzzer.cc31 brillo::FakeMessageLoop loop(nullptr); in LLVMFuzzerTestOneInput() local
32 loop.SetAsCurrent(); in LLVMFuzzerTestOneInput()
52 loop.Run(); in LLVMFuzzerTestOneInput()
Dsideload_main.cc128 brillo::BaseMessageLoop loop; in ApplyUpdatePayload() local
129 loop.SetAsCurrent(); in ApplyUpdatePayload()
164 loop.Run(); in ApplyUpdatePayload()
/system/core/libpixelflinger/codeflinger/
Ddisassem.c577 int loop; in disasm_print_reglist() local
585 for (loop = 0; loop < 17; ++loop) { in disasm_print_reglist()
587 if (loop == 16 || !(insn & (1 << loop))) { in disasm_print_reglist()
592 if (start == loop - 1) in disasm_print_reglist()
595 di->di_printf("r%d-r%d", start, loop - 1); in disasm_print_reglist()
599 if (insn & (1 << loop)) in disasm_print_reglist()
600 start = loop; in disasm_print_reglist()
/system/sepolicy/prebuilts/api/30.0/private/
Dotapreopt_chroot.te40 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
42 # Allow otapreopt_chroot to access loop devices.
54 # Allow otapreopt_chroot to configure read-ahead of loop devices.
69 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/sepolicy/prebuilts/api/29.0/private/
Dotapreopt_chroot.te40 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
42 # Allow otapreopt_chroot to access loop devices.
54 # Allow otapreopt_chroot to configure read-ahead of loop devices.
69 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
Dapexd.te14 # allow apexd to create loop devices with /dev/loop-control
16 # allow apexd to access loop devices
58 # Configure read-ahead of dm-verity and loop devices
/system/sepolicy/private/
Dotapreopt_chroot.te40 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
42 # Allow otapreopt_chroot to access loop devices.
54 # Allow otapreopt_chroot to configure read-ahead of loop devices.
69 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/core/libappfuse/tests/
DFuseAppLoopTest.cc43 FuseAppLoop* loop; member in android::fuse::__anon7435ee890111::Callback
47 EXPECT_TRUE(loop->ReplyGetAttr(seq, inode, kTestFileSize, S_IFREG | 0777)); in OnGetAttr()
52 EXPECT_TRUE(loop->ReplyLookup(unique, inode, kTestFileSize)); in OnLookup()
57 loop->ReplySimple(seq, 0); in OnFsync()
63 loop->ReplyWrite(seq, 0); in OnWrite()
69 loop->ReplySimple(seq, 0); in OnRead()
74 loop->ReplyOpen(seq, inode); in OnOpen()
79 loop->ReplySimple(seq, 0); in OnRelease()
96 callback_.loop = loop_.get(); in SetUp()
DFuseBridgeLoopTest.cc58 FuseBridgeLoop loop; in SetUp() local
59 loop.AddBridge(1, std::move(dev_sockets_[1]), std::move(proxy_sockets_[0])); in SetUp()
60 loop.Start(&callback_); in SetUp()
/system/core/fs_mgr/libfiemap/
DREADME.md52 encryption, we instead use a loop device with `LOOP_SET_DIRECT_IO` enabled.
59 on an FBE/unencrypted device we will have multiple loop devices. In this case,
60 we create a device-mapper device as well. For each loop device it will have one
73 line in this file denotes a dependency on either a device-mapper node or a loop
/system/core/storaged/
DREADME.properties2 ro.storaged.event.perf_check # check for time spent in event loop, in microseconds

1234