1 /*
2 * Copyright (c) 2021-2025 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "avbuffer_queue_producer_impl.h"
17
18
19 namespace OHOS {
20 namespace Media {
21
AVBufferQueueProducerImpl(std::shared_ptr<AVBufferQueueImpl> & bufferQueue)22 AVBufferQueueProducerImpl::AVBufferQueueProducerImpl(std::shared_ptr<AVBufferQueueImpl>& bufferQueue)
23 : AVBufferQueueProducerStub(), bufferQueue_(bufferQueue) {
24 }
25
GetQueueSize()26 uint32_t AVBufferQueueProducerImpl::GetQueueSize()
27 {
28 return bufferQueue_->GetQueueSize();
29 }
30
SetQueueSize(uint32_t size)31 Status AVBufferQueueProducerImpl::SetQueueSize(uint32_t size)
32 {
33 return bufferQueue_->SetQueueSize(size);
34 }
35
RequestBuffer(std::shared_ptr<AVBuffer> & buffer,const AVBufferConfig & config,int32_t timeoutMs)36 Status AVBufferQueueProducerImpl::RequestBuffer(std::shared_ptr<AVBuffer>& buffer,
37 const AVBufferConfig& config, int32_t timeoutMs)
38 {
39 return bufferQueue_->RequestBuffer(buffer, config, timeoutMs);
40 }
41
RequestBufferWaitUs(std::shared_ptr<AVBuffer> & buffer,const AVBufferConfig & config,int64_t timeoutUs)42 Status AVBufferQueueProducerImpl::RequestBufferWaitUs(
43 std::shared_ptr<AVBuffer> &buffer, const AVBufferConfig &config, int64_t timeoutUs)
44 {
45 return bufferQueue_->RequestBufferWaitUs(buffer, config, timeoutUs);
46 }
47
PushBuffer(uint64_t uniqueId,bool available)48 Status AVBufferQueueProducerImpl::PushBuffer(uint64_t uniqueId, bool available)
49 {
50 return bufferQueue_->PushBuffer(uniqueId, available);
51 }
52
PushBuffer(const std::shared_ptr<AVBuffer> & buffer,bool available)53 Status AVBufferQueueProducerImpl::PushBuffer(const std::shared_ptr<AVBuffer>& buffer, bool available)
54 {
55 return bufferQueue_->PushBuffer(buffer, available);
56 }
57
ReturnBuffer(uint64_t uniqueId,bool available)58 Status AVBufferQueueProducerImpl::ReturnBuffer(uint64_t uniqueId, bool available)
59 {
60 return bufferQueue_->ReturnBuffer(uniqueId, available);
61 }
62
ReturnBuffer(const std::shared_ptr<AVBuffer> & buffer,bool available)63 Status AVBufferQueueProducerImpl::ReturnBuffer(const std::shared_ptr<AVBuffer>& buffer, bool available)
64 {
65 return bufferQueue_->ReturnBuffer(buffer, available);
66 }
67
AttachBuffer(std::shared_ptr<AVBuffer> & buffer,bool isFilled)68 Status AVBufferQueueProducerImpl::AttachBuffer(std::shared_ptr<AVBuffer>& buffer, bool isFilled)
69 {
70 return bufferQueue_->AttachBuffer(buffer, isFilled);
71 }
72
DetachBuffer(uint64_t uniqueId)73 Status AVBufferQueueProducerImpl::DetachBuffer(uint64_t uniqueId)
74 {
75 return bufferQueue_->DetachBuffer(uniqueId);
76 }
77
DetachBuffer(const std::shared_ptr<AVBuffer> & buffer)78 Status AVBufferQueueProducerImpl::DetachBuffer(const std::shared_ptr<AVBuffer>& buffer)
79 {
80 return bufferQueue_->DetachBuffer(buffer);
81 }
82
SetBufferFilledListener(sptr<IBrokerListener> & listener)83 Status AVBufferQueueProducerImpl::SetBufferFilledListener(sptr<IBrokerListener>& listener)
84 {
85 return bufferQueue_->SetBrokerListener(listener);
86 }
87
RemoveBufferFilledListener(sptr<IBrokerListener> & listener)88 Status AVBufferQueueProducerImpl::RemoveBufferFilledListener(sptr<IBrokerListener>& listener)
89 {
90 return bufferQueue_->RemoveBrokerListener(listener);
91 }
92
Clear()93 Status AVBufferQueueProducerImpl::Clear()
94 {
95 return bufferQueue_->Clear();
96 }
97
ClearBufferIf(std::function<bool (const std::shared_ptr<AVBuffer> &)> pred)98 Status AVBufferQueueProducerImpl::ClearBufferIf(std::function<bool(const std::shared_ptr<AVBuffer>&)> pred)
99 {
100 return bufferQueue_->ClearBufferIf(pred);
101 }
102
SetBufferAvailableListener(sptr<IProducerListener> & listener)103 Status AVBufferQueueProducerImpl::SetBufferAvailableListener(sptr<IProducerListener>& listener)
104 {
105 return bufferQueue_->SetProducerListener(listener);
106 }
107
108 } // namespace Media
109 } // namespace OHOS