Home
last modified time | relevance | path

Searched refs:pool_ (Results 1 - 25 of 31) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dpool_test.cpp43 static Pool<PoolTest::Node> pool_; member in OHOS::Test::PoolTest
45 Pool<PoolTest::Node> PoolTest::pool_ = Pool<PoolTest::Node>(CAPABILITY_TEST, MIN_TEST); member in OHOS::Test::PoolTest
59 pool_.Idle(data); in TearDown()
60 pool_.Release(data); in TearDown()
62 pool_.Clean(close); in TearDown()
75 auto ret = pool_.Get(); in HWTEST_F()
79 ret = pool_.Get(); in HWTEST_F()
83 ret = pool_.Get(); in HWTEST_F()
87 ret = pool_.Get(); in HWTEST_F()
101 auto ret = pool_ in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dtask_executor.cpp21 pool_ = nullptr; in ~TaskExecutor()
32 if (pool_ == nullptr) { in Execute()
35 if (pool_ == nullptr) { in Execute()
38 return pool_->Execute(std::move(task)); in Execute()
43 if (pool_ == nullptr) { in Schedule()
46 if (pool_ == nullptr) { in Schedule()
49 return pool_->Schedule(task, delay, interval, times); in Schedule()
54 if (pool_ == nullptr) { in Remove()
57 return pool_->Remove(taskId, wait); in Remove()
62 if (pool_ in Reset()
[all...]
/foundation/filemanagement/storage_service/services/storage_daemon/mtpfs/src/
H A Dmtpfs_tmp_files_pool.cpp23 MtpFsTmpFilesPool::MtpFsTmpFilesPool() : tmpDir_(SmtpfsGetTmpDir()), pool_() {} in MtpFsTmpFilesPool()
29 auto it = std::find(pool_.begin(), pool_.end(), path); in RemoveFile()
30 if (it == pool_.end()) { in RemoveFile()
33 pool_.erase(it); in RemoveFile()
38 auto it = std::find(pool_.begin(), pool_.end(), path); in GetFile()
39 if (it == pool_.end()) { in GetFile()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/src/
H A Dtask_executor.cpp19 TaskExecutor::TaskExecutor():pool_(nullptr) in TaskExecutor()
25 pool_ = nullptr; in ~TaskExecutor()
36 return pool_; in GetExecutor()
41 pool_ = executor; in SetExecutor()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Ddelay_notify.cpp20 DelayNotify::DelayNotify() : pauseCount_(0), task_(nullptr), pool_(nullptr) in DelayNotify()
26 if (pool_ == nullptr) { in ~DelayNotify()
30 pool_->Remove(delaySyncTaskId_); in ~DelayNotify()
64 if (pool_ != nullptr) { in SetExecutorPool()
67 pool_ = pool; in SetExecutorPool()
84 if (pool_ == nullptr) { in StartTimer()
89 delaySyncTaskId_ = pool_->Schedule(std::chrono::milliseconds(autoSyncInterval_), in StartTimer()
93 pool_->Reset(delaySyncTaskId_, std::chrono::milliseconds(autoSyncInterval_)); in StartTimer()
124 if (pool_ != nullptr) { in StopTimer()
125 pool_ in StopTimer()
[all...]
H A Dtask_executor.cpp21 pool_ = std::make_shared<ExecutorPool>(MAX_THREADS, MIN_THREADS); in TaskExecutor()
26 pool_ = nullptr; in ~TaskExecutor()
38 return pool_; in GetExecutor()
44 pool_ = executor; in SetExecutor()
/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/scrollable/
H A Dscrollable_item_pool.cpp33 auto it = pool_.find(tag); in Allocate()
34 if (it == pool_.end() || it->second.empty()) { in Allocate()
52 auto it = pool_.find(tag); in Deallocate()
53 if (it == pool_.end()) { in Deallocate()
54 pool_[tag] = { obj }; in Deallocate()
H A Dscrollable_item_pool.h38 std::unordered_map<std::string, std::vector<ScrollableItem*>> pool_; member in OHOS::Ace::NG::ScrollableItemPool
/foundation/filemanagement/storage_service/services/storage_daemon/mtpfs/include/
H A Dmtpfs_tmp_files_pool.h33 pool_.insert(tmp); in AddFile()
38 return pool_.size(); in Empty()
49 std::set<MtpFsTypeTmpFile> pool_; member in MtpFsTmpFilesPool
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h44 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
67 pool_.Clean([](std::shared_ptr<Executor> executor) { in ~ExecutorPool()
145 auto executor = pool_.Get(); in Execute()
152 pool_.Idle(exe); in Execute()
156 return pool_.Release(exe, force); in Execute()
174 scheduler_ = pool_.Get(true); in Schedule()
183 pool_.Idle(exe); in Schedule()
187 return pool_.Release(exe, force); in Schedule()
213 Pool<Executor> pool_; member in OHOS::ExecutorPool
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h47 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
70 pool_.Clean([](std::shared_ptr<Executor> executor) { in ~ExecutorPool()
149 auto executor = pool_.Get(); in Execute()
156 pool_.Idle(exe); in Execute()
160 return pool_.Release(exe, force); in Execute()
178 scheduler_ = pool_.Get(true); in Schedule()
187 pool_.Idle(exe); in Schedule()
191 return pool_.Release(exe, force); in Schedule()
217 Pool<Executor> pool_; member in OHOS::NativePreferences::ExecutorPool
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dtask_manager.cpp28 pool_(nullptr), in TaskManager()
41 pool_ = ThreadPool::Create(name_, numThreads_); in Initialize()
42 taskRegistry_ = std::make_unique<TaskRegistry>(name_, pool_.get()); in Initialize()
67 pool_.reset(); in ~TaskManager()
/foundation/arkui/ace_engine/frameworks/core/components/xcomponent/
H A Dxcomponent_component.cpp30 pool_ = AceType::MakeRefPtr<XComponentTaskPool>(); in XComponentComponent()
31 pool_->component_ = AceType::WeakClaim(this); in XComponentComponent()
H A Dxcomponent_component.h180 return pool_; in GetTaskPool()
261 RefPtr<XComponentTaskPool> pool_; member in OHOS::Ace::XComponentComponent
/foundation/arkui/ace_engine/frameworks/core/components/custom_paint/
H A Dcustom_paint_component.h168 pool_ = AceType::MakeRefPtr<CanvasTaskPool>(); in CustomPaintComponent()
199 if (pool_) { in SetOnReadyEvent()
201 pool_->SetOnReadyEvent(onReadyEvent); in SetOnReadyEvent()
207 return pool_; in GetTaskPool()
214 RefPtr<CanvasTaskPool> pool_; member in OHOS::Ace::CustomPaintComponent
H A Drender_custom_paint.cpp49 pool_ = taskPool; in Update()
52 pool_->SetPushToRenderNodeFunc([weak = AceType::WeakClaim(this)](const TaskFunc& taskFunc) { in Update()
/foundation/multimedia/av_codec/services/media_engine/plugins/source/
H A Ddata_stream_source_plugin.cpp66 pool_ = std::make_shared<AVSharedMemoryPool>("pool"); in DataStreamSourcePlugin()
118 pool_->Init(InitOption); in InitPool()
119 pool_->GetName(); in InitPool()
120 pool_->Reset(); in InitPool()
125 return pool_->AcquireMemory(MEM_SIZE); // 10240 in GetMemory()
130 pool_->Reset(); in ResetPool()
H A Ddata_stream_source_plugin.h51 std::shared_ptr<AVSharedMemoryPool> pool_; member in OHOS::Media::Plugin::DataStreamSource::DataStreamSourcePlugin
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/std_stream_source/
H A Dstd_stream_source_plugin.cpp51 pool_ = std::make_shared<AVSharedMemoryPool>("pool"); in StdStreamSourcePlugin()
148 pool_->Init(InitOption); in InitPool()
153 return pool_->AcquireMemory(MEM_SIZE); // 10240 in GetMemory()
158 pool_->Reset(); in ResetPool()
H A Dstd_stream_source_plugin.h54 std::shared_ptr<AVSharedMemoryPool> pool_; member in OHOS::Media::Plugin::StdStreamSource::StdStreamSourcePlugin
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/
H A Ddatashare_connection.cpp85 if (pool_ == nullptr) { in OnAbilityDisconnectDone()
87 if (pool_ == nullptr) { in OnAbilityDisconnectDone()
88 pool_ = std::make_shared<ExecutorPool>(MAX_THREADS, MIN_THREADS); in OnAbilityDisconnectDone()
133 auto taskid = pool_->Schedule(delay, [uri, self]() { in DelayConnectExtAbility()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dtask_executor.h36 std::shared_ptr<ExecutorPool> pool_; member in OHOS::NativeRdb::TaskExecutor
H A Ddelay_notify.h49 std::shared_ptr<ExecutorPool> pool_; member in OHOS::NativeRdb::DelayNotify
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/
H A Dtask_manager.h54 std::unique_ptr<ThreadPool> pool_; member in OHOS::CameraStandard::DeferredProcessing::TaskManager
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dtask_executor.h43 std::shared_ptr<ExecutorPool> pool_ = nullptr; member in OHOS::TaskExecutor

Completed in 10 milliseconds

12