Home
last modified time | relevance | path

Searched refs:Worker (Results 1 – 7 of 7) sorted by relevance

/aosp14/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/
H A Dsnapuserd_dm_user.cpp26 Worker::Worker(const std::string& cow_device, const std::string& backing_device, in Worker() function in android::snapshot::Worker
37 bool Worker::InitializeFds() { in InitializeFds()
66 bool Worker::InitReader() { in InitReader()
137 bool Worker::ProcessZeroOp() { in ProcessZeroOp()
230 void Worker::InitializeBufsink() { in InitializeBufsink()
239 bool Worker::Init() { in Init()
254 bool Worker::RunThread() { in RunThread()
276 bool Worker::ReadDmUserHeader() { in ReadDmUserHeader()
403 int Worker::ReadUnalignedSector( in ReadUnalignedSector()
605 bool Worker::DmuserReadRequest() { in DmuserReadRequest()
[all …]
H A Dsnapuserd_merge.cpp26 int Worker::PrepareMerge(uint64_t* source_offset, int* pending_ops, in PrepareMerge()
73 bool Worker::MergeReplaceZeroOps() { in MergeReplaceZeroOps()
176 bool Worker::MergeOrderedOpsAsync() { in MergeOrderedOpsAsync()
357 bool Worker::MergeOrderedOps() { in MergeOrderedOps()
442 bool Worker::AsyncMerge() { in AsyncMerge()
458 bool Worker::SyncMerge() { in SyncMerge()
468 bool Worker::Merge() { in Merge()
514 bool Worker::InitializeIouring() { in InitializeIouring()
533 void Worker::FinalizeIouring() { in FinalizeIouring()
539 bool Worker::RunMergeThread() { in RunMergeThread()
H A Dsnapuserd_core.cpp49 std::unique_ptr<Worker> wt = in InitializeWorkers()
50 std::make_unique<Worker>(cow_device_, backing_store_device_, control_device_, in InitializeWorkers()
60 merge_thread_ = std::make_unique<Worker>(cow_device_, backing_store_device_, control_device_, in InitializeWorkers()
322 std::async(std::launch::async, &Worker::RunThread, worker_threads_[i].get())); in Start()
326 std::async(std::launch::async, &Worker::RunMergeThread, merge_thread_.get()); in Start()
H A Dsnapuserd_core.h205 class Worker {
207 Worker(const std::string& cow_device, const std::string& backing_device,
422 std::vector<std::unique_ptr<Worker>> worker_threads_;
437 std::unique_ptr<Worker> merge_thread_;
/aosp14/frameworks/base/tests/CoreTests/android/core/
H A DTestWebServer.java263 Worker w = null; in run()
266 Worker ws = new Worker(); in run()
271 w = (Worker) threads.elementAt(0); in run()
300 Worker w = (Worker)e.nextElement(); in close()
326 class Worker implements HttpConstants, Runnable { class in TestWebServer
355 Worker() { in Worker() method in TestWebServer.Worker
/aosp14/frameworks/base/config/
H A Dboot-image-profile.txt29804 HSPLjava/util/concurrent/ThreadPoolExecutor$Worker;-><init>(Ljava/util/concurrent/ThreadPoolExecuto…
29805 HSPLjava/util/concurrent/ThreadPoolExecutor$Worker;->interruptIfStarted()V
29806 HSPLjava/util/concurrent/ThreadPoolExecutor$Worker;->isHeldExclusively()Z
29807 HSPLjava/util/concurrent/ThreadPoolExecutor$Worker;->isLocked()Z
29808 …/ThreadPoolExecutor$Worker;->lock()V+]Ljava/util/concurrent/ThreadPoolExecutor$Worker;Ljava/util/c…
29809 HSPLjava/util/concurrent/ThreadPoolExecutor$Worker;->run()V
29810 …eadPoolExecutor$Worker;->tryAcquire(I)Z+]Ljava/util/concurrent/ThreadPoolExecutor$Worker;Ljava/uti…
29811 HSPLjava/util/concurrent/ThreadPoolExecutor$Worker;->tryLock()Z
29812 …eadPoolExecutor$Worker;->tryRelease(I)Z+]Ljava/util/concurrent/ThreadPoolExecutor$Worker;Ljava/uti…
29813 …ThreadPoolExecutor$Worker;->unlock()V+]Ljava/util/concurrent/ThreadPoolExecutor$Worker;Ljava/util/…
[all …]
H A Dpreloaded-classes15490 java.util.concurrent.ThreadPoolExecutor$Worker