| /foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/ |
| H A D | blocking_queue.h | 40 return que_.size(); in Size()
45 return que_.size() == capacity_; in Full()
54 return que_.empty(); in Empty()
61 que_.push(value); in Push()
71 que_.push(value); in Push()
81 que_.push(std::move(value)); in Push()
92 if (que_.empty()) { in Pop()
93 cvEmpty_.wait(lock, [this] { return !isActive_ || !que_.empty(); }); in Pop()
98 T el = que_.front(); in Pop()
99 que_ in Pop()
220 std::queue<T> que_; global() member in OHOS::CameraStandard::DeferredProcessing::BlockingQueue
[all...] |
| /foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
| H A D | blocking_queue.h | 41 return que_.size(); in Size()
51 return que_.empty(); in Empty()
60 if (que_.size() >= capacity_) { in Push()
62 cvFull_.Wait(lock, [this] { return !isActive || que_.size() < capacity_; }); in Push()
66 "d", name_.c_str(), isActive.load(), que_.size() < capacity_); in Push()
69 que_.push(value); in Push()
81 if (que_.size() >= capacity_) { in Push()
83 cvFull_.WaitFor(lock, timeoutMs, [this] { return !isActive || que_.size() < capacity_; }); in Push()
85 if (!isActive || (que_.size() == capacity_)) { in Push()
87 isActive.load(), que_ in Push()
180 std::queue<T> que_; global() member in OHOS::Media::BlockingQueue
[all...] |
| /foundation/multimedia/media_foundation/engine/include/foundation/utils/ |
| H A D | blocking_queue.h | 42 return que_.size(); in Size()
51 return que_.empty(); in Empty()
60 if (que_.size() >= capacity_) { in Push()
62 cvFull_.Wait(lock, [this] { return !isActive || que_.size() < capacity_; }); in Push()
66 "d", name_.c_str(), isActive.load(), que_.size() < capacity_); in Push()
69 que_.push(value); in Push()
81 if (que_.size() >= capacity_) { in Push()
83 cvFull_.WaitFor(lock, timeoutMs, [this] { return !isActive || que_.size() < capacity_; }); in Push()
85 if (!isActive || (que_.size() == capacity_)) { in Push()
87 isActive.load(), que_ in Push()
169 std::queue<T> que_; global() member in OHOS::Media::BlockingQueue
[all...] |
| /foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/demuxer/ |
| H A D | block_queue.h | 40 return que_.size(); in Size()
51 return que_.empty(); in Empty()
62 if (que_.size() >= capacity_) { in Push()
64 condFull_.wait(lock, [this] { return !isActive_ || que_.size() < capacity_; }); in Push()
68 name_.c_str(), isActive_.load(), que_.size() < capacity_); in Push()
71 que_.push_back(block); in Push()
81 if (que_.empty() && !isActive_) { in Pop()
85 if (que_.empty() && isActive_) { in Pop()
87 condEmpty_.wait(lock, [this] { return !isActive_ || !que_.empty(); }); in Pop()
89 if (que_ in Pop()
183 std::deque<T> que_; global() member in OHOS::Media::BlockQueue
[all...] |
| /foundation/multimedia/av_codec/services/utils/include/ |
| H A D | block_queue.h | 43 return que_.size(); in Size()
54 return que_.empty(); in Empty()
65 if (que_.size() >= capacity_) { in Push()
67 condFull_.wait(lock, [this] { return !isActive_ || que_.size() < capacity_; }); in Push()
71 name_.c_str(), isActive_.load(), que_.size() < capacity_); in Push()
74 que_.push(block); in Push()
84 if (que_.empty() && !isActive_) { in Pop()
87 } else if (que_.empty() && isActive_) { in Pop()
89 condEmpty_.wait(lock, [this] { return !isActive_ || !que_.empty(); }); in Pop()
91 if (que_ in Pop()
160 std::queue<T> que_; global() member in OHOS::MediaAVCodec::BlockQueue
[all...] |
| /foundation/multimedia/media_foundation/engine/pipeline/filters/demux/ |
| H A D | data_packer.cpp | 34 DataPacker::DataPacker() : mutex_(), que_(), size_(0), mediaOffset_(0), pts_(0), dts_(0), in DataPacker()
71 if (que_.size() >= capacity_) { in PushData()
75 [this] { return que_.size() < capacity_ || stopped_.load(); }); in PushData()
80 } while (que_.size() >= capacity_); in PushData()
84 if (que_.empty()) { in PushData()
89 que_.emplace_back(std::move(bufferPtr)); in PushData()
102 if (que_.empty() || offset < curOffsetTemp || offset > curOffsetTemp + size_) { // 原有数据无法命中, 则删除原有数据 in IsDataAvailable()
108 size_t bufCnt = que_.size(); in IsDataAvailable()
110 uint64_t curOffsetEnd = mediaOffset_ + GetBufferSize(que_.front()); in IsDataAvailable()
118 curOffsetEnd = preOffsetEnd + GetBufferSize(que_[ in IsDataAvailable()
[all...] |
| H A D | data_packer.h | 114 std::deque<AVBufferPtr> que_; member in OHOS::Media::DataPacker
|
| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/task_group/ |
| H A D | base_task_group.cpp | 29 que_(name + " queue") in BaseTaskGroup()
37 que_.SetActive(false); in ~BaseTaskGroup()
38 que_.Clear(); in ~BaseTaskGroup()
44 que_.SetActive(true); in Initialize()
61 if (que_.Full()) { in SubmitTask()
65 static_cast<int>(handle_), que_.Size()); in SubmitTask()
67 que_.Push(std::move(param)); in SubmitTask()
76 que_.Clear(); in CancelAllTasks()
84 if (que_.Empty()) { in GetTaskUnlocked()
89 auto task = [param = que_ in GetTaskUnlocked()
[all...] |
| /foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/task_group/ |
| H A D | base_task_group.h | 56 BlockingQueue<std::any> que_; member in OHOS::CameraStandard::DeferredProcessing::BaseTaskGroup
|