Searched refs:workQueue_ (Results 1 - 5 of 5) sorted by relevance
| /foundation/resourceschedule/work_scheduler/services/test/src/ |
| H A D | work_queue_test.cpp | 34 static std::shared_ptr<WorkQueue> workQueue_; member in OHOS::WorkScheduler::WorkQueueTest
37 std::shared_ptr<WorkQueue> WorkQueueTest::workQueue_ = nullptr; member in OHOS::WorkScheduler::WorkQueueTest
41 workQueue_ = std::make_shared<WorkQueue>(); in SetUpTestCase()
54 std::shared_ptr<Condition> ret = workQueue_->ParseCondition(type, value); in HWTEST_F()
68 std::shared_ptr<Condition> ret = workQueue_->ParseCondition(type, value); in HWTEST_F()
82 std::shared_ptr<Condition> ret = workQueue_->ParseCondition(type, value); in HWTEST_F()
96 std::shared_ptr<Condition> ret = workQueue_->ParseCondition(type, value); in HWTEST_F()
110 std::shared_ptr<Condition> ret = workQueue_->ParseCondition(type, value); in HWTEST_F()
124 std::shared_ptr<Condition> ret = workQueue_->ParseCondition(type, value); in HWTEST_F()
138 std::shared_ptr<Condition> ret = workQueue_ in HWTEST_F()
[all...] |
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/ |
| H A D | i_cast_stream_manager.cpp | 48 while (!workQueue_.empty()) { in ~ICastStreamManager()
49 workQueue_.pop(); in ~ICastStreamManager()
66 if (workQueue_.empty()) { in Handle()
67 condition_.wait(lock, [this] { return (!this->workQueue_.empty() || !this->isRunning_.load()); }); in Handle()
72 work = workQueue_.front(); in Handle()
73 workQueue_.pop(); in Handle()
108 workQueue_.push(std::pair<json, StreamActionProcessor> { data[KEY_DATA], iter->second }); in ProcessActionsEvent()
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/ |
| H A D | i_cast_stream_manager.cpp | 48 while (!workQueue_.empty()) { in ~ICastStreamManager()
49 workQueue_.pop(); in ~ICastStreamManager()
66 if (workQueue_.empty()) { in Handle()
67 condition_.wait(lock, [this] { return (!this->workQueue_.empty() || !this->isRunning_.load()); }); in Handle()
72 work = workQueue_.front(); in Handle()
73 workQueue_.pop(); in Handle()
108 workQueue_.push(std::pair<json, StreamActionProcessor> { data[KEY_DATA], iter->second }); in ProcessActionsEvent()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/include/ |
| H A D | i_cast_stream_manager.h | 136 std::queue<std::pair<json, StreamActionProcessor>> workQueue_; member in OHOS::CastEngine::CastEngineService::ICastStreamManager
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/stream/include/ |
| H A D | i_cast_stream_manager.h | 136 std::queue<std::pair<json, StreamActionProcessor>> workQueue_; member in OHOS::CastEngine::CastEngineService::ICastStreamManager
|
Completed in 5 milliseconds