Home
last modified time | relevance | path

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

123456

/system/extras/simpleperf/
DIOEventLoop_test.cpp32 IOEventLoop loop; in TEST() local
35 ASSERT_NE(nullptr, loop.AddReadEvent(fd[0], [&]() { in TEST()
41 return loop.ExitLoop(); in TEST()
59 ASSERT_TRUE(loop.RunLoop()); in TEST()
71 IOEventLoop loop; in TEST() local
73 ASSERT_NE(nullptr, loop.AddWriteEvent(fd[1], [&]() { in TEST()
80 loop.ExitLoop(); in TEST()
96 ASSERT_TRUE(loop.RunLoop()); in TEST()
105 IOEventLoop loop; in TEST() local
107 ASSERT_TRUE(loop.AddSignalEvent(SIGINT, [&]() { in TEST()
[all …]
Dworkload_test.cpp28 IOEventLoop loop; in TEST() local
29 ASSERT_TRUE(loop.AddSignalEvent(SIGCHLD, [&]() { 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, [&]() { return loop.ExitLoop(); })); in run_signaled_workload()
51 ASSERT_TRUE(loop.RunLoop()); in run_signaled_workload()
64 IOEventLoop loop; in run_exit_nonzero_workload() local
65 ASSERT_TRUE(loop.AddSignalEvent(SIGCHLD, [&]() { return loop.ExitLoop(); })); in run_exit_nonzero_workload()
69 ASSERT_TRUE(loop.RunLoop()); in run_exit_nonzero_workload()
DIOEventLoop.cpp27 IOEventLoop* loop; member
33 IOEvent(IOEventLoop* loop, const std::function<bool()>& callback) in IOEvent()
34 : loop(loop), e(nullptr), timeout({}), callback(callback), enabled(false) {} in IOEvent()
103 e->loop->has_error_ = true; in EventCallbackFn()
104 e->loop->ExitLoop(); in EventCallbackFn()
227 IOEventLoop* loop = ref->loop; in DelEvent() local
228 for (auto it = loop->events_.begin(); it != loop->events_.end(); ++it) { in DelEvent()
230 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()
278 IOEventLoop loop; in TEST_F() local
282 return loop.ExitLoop(); in TEST_F()
284 ASSERT_TRUE(thread.RegisterDataCallback(loop, callback)); in TEST_F()
287 ASSERT_TRUE(loop.RunLoop()); in TEST_F()
297 IOEventLoop loop; in TEST_F() local
311 return loop.ExitLoop(); in TEST_F()
313 ASSERT_TRUE(thread.RegisterDataCallback(loop, callback)); in TEST_F()
320 ASSERT_TRUE(loop.RunLoop()); in TEST_F()
[all …]
DRecordReadThread.cpp256 bool RecordReadThread::RegisterDataCallback(IOEventLoop& loop, in RegisterDataCallback() argument
270 if (!loop.AddReadEvent(read_data_fd_, data_callback)) { in RegisterDataCallback()
341 IOEventLoop loop; in RunReadThread() local
342 CHECK(loop.AddReadEvent(read_cmd_fd_, [&]() { return HandleCmd(loop); })); in RunReadThread()
343 loop.RunLoop(); in RunReadThread()
363 bool RecordReadThread::HandleCmd(IOEventLoop& loop) { in HandleCmd() argument
369 result = HandleAddEventFds(loop, *static_cast<std::vector<EventFd*>*>(cmd_arg_)); in HandleCmd()
378 result = loop.ExitLoop(); in HandleCmd()
392 bool RecordReadThread::HandleAddEventFds(IOEventLoop& loop, in HandleAddEventFds() argument
434 if (!pair.second->StartPolling(loop, [this]() { return ReadRecordsFromKernelBuffer(); })) { in HandleAddEventFds()
Dcmd_monitor.cpp267 IOEventLoop* loop = event_selection_set_.GetIOEventLoop(); in PrepareMonitoring() local
268 auto exit_loop_callback = [loop]() { return loop->ExitLoop(); }; in PrepareMonitoring()
269 if (!loop->AddSignalEvents({SIGCHLD, SIGINT, SIGTERM}, exit_loop_callback, IOEventHighPriority)) { in PrepareMonitoring()
276 if (!loop->AddSignalEvent(SIGHUP, exit_loop_callback, IOEventHighPriority)) { in PrepareMonitoring()
282 if (!loop->AddPeriodicEvent( in PrepareMonitoring()
283 SecondToTimeval(duration_in_sec_), [loop]() { return loop->ExitLoop(); }, in PrepareMonitoring()
/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.cc280 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
283 loop.dev(), kPostinstallDefaultScript, false, false, false); in TEST_F()
293 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
294 RunPostinstallAction(loop.dev(), "bin/postinst_link", false, false, false); in TEST_F()
299 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
301 RunPostinstallAction(loop.dev(), in TEST_F()
314 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
317 RunPostinstallAction(loop.dev(), in TEST_F()
330 ScopedLoopbackDeviceBinder loop(postinstall_image_, false, nullptr); in TEST_F() local
333 RunPostinstallAction(loop.dev(), in TEST_F()
[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.cpp568 LoopDevice loop(tmp, 10s); in TEST_F() local
569 ASSERT_TRUE(loop.valid()); in TEST_F()
572 ASSERT_TRUE(table.Emplace<DmTargetLinear>(0, 1, loop.device(), 0)); in TEST_F()
592 LoopDevice loop(tmp, 10s); in TEST_F() local
593 ASSERT_TRUE(loop.valid()); in TEST_F()
594 ASSERT_TRUE(android::base::StartsWith(loop.device(), "/dev/block")); in TEST_F()
597 ASSERT_TRUE(table.Emplace<DmTargetLinear>(0, 1, loop.device(), 0)); in TEST_F()
605 ASSERT_FALSE(dm.IsDmBlockDevice(loop.device())); in TEST_F()
611 LoopDevice loop(tmp, 10s); in TEST_F() local
612 ASSERT_TRUE(loop.valid()); in TEST_F()
[all …]
/system/libprocinfo/
Dprocess_test.cpp109 …for (int loop = 0; loop < 50 && procinfo.state != android::procinfo::kProcessStateSleeping; loop++… in TEST() local
118 …for (int loop = 0; loop < 50 && procinfo.state != android::procinfo::kProcessStateZombie; loop++) { in TEST() local
/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
/system/core/libappfuse/tests/
DFuseAppLoopTest.cc43 FuseAppLoop* loop; member in android::fuse::__anon0bcc026e0111::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()
/system/sepolicy/microdroid/system/private/
Dapkdmverity.te20 # allow apkdmverity to create loop devices with /dev/loop-control
26 # allow apkdmverity to access loop devices
Dapexd.te5 # allow apexd to create loop devices with /dev/loop-control
7 # allow apexd to access loop devices
63 # Configure read-ahead of dm-verity and loop devices
98 # apexd uses it to decide whether it needs to keep retrying polling for loop device.
/system/sepolicy/prebuilts/api/32.0/private/
Dotapreopt_chroot.te54 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
56 # Allow otapreopt_chroot to access loop devices.
69 # Allow otapreopt_chroot to configure read-ahead of loop devices.
85 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/sepolicy/prebuilts/api/33.0/private/
Dotapreopt_chroot.te54 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
56 # Allow otapreopt_chroot to access loop devices.
69 # Allow otapreopt_chroot to configure read-ahead of loop devices.
85 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/sepolicy/prebuilts/api/31.0/private/
Dotapreopt_chroot.te54 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
56 # Allow otapreopt_chroot to access loop devices.
69 # Allow otapreopt_chroot to configure read-ahead of loop devices.
85 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/sepolicy/private/
Dotapreopt_chroot.te55 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
57 # Allow otapreopt_chroot to access loop devices.
70 # Allow otapreopt_chroot to configure read-ahead of loop devices.
86 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/sepolicy/prebuilts/api/34.0/private/
Dotapreopt_chroot.te55 # Allow otapreopt_chroot to create loop devices with /dev/loop-control.
57 # Allow otapreopt_chroot to access loop devices.
70 # Allow otapreopt_chroot to configure read-ahead of loop devices.
86 # Allow otapreopt_chroot to access /dev/block (needed to detach loop
/system/core/libutils/
DProcessCallStack_fuzz.cpp29 void loop() { in loop() function
45 std::thread th = std::thread(loop); in spawnThreads()
/system/update_engine/aosp/
Dsideload_main.cc128 brillo::BaseMessageLoop loop; in ApplyUpdatePayload() local
129 loop.SetAsCurrent(); in ApplyUpdatePayload()
167 loop.Run(); in ApplyUpdatePayload()

123456