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 #ifndef HISTREAMER_FOUNDATION_AVBUFFER_QUEUE_PRODUCER_H 17 #define HISTREAMER_FOUNDATION_AVBUFFER_QUEUE_PRODUCER_H 18 19 #include "buffer/avbuffer_queue_define.h" 20 #include "iremote_stub.h" 21 #include "surface.h" 22 #include <functional> 23 24 namespace OHOS { 25 namespace Media { 26 27 class AVBufferQueueProducer : public virtual IRemoteBroker { 28 public: 29 virtual uint32_t GetQueueSize() = 0; 30 virtual Status SetQueueSize(uint32_t size) = 0; 31 32 virtual Status RequestBuffer(std::shared_ptr<AVBuffer>& outBuffer, 33 const AVBufferConfig& config, int32_t timeoutMs) = 0; RequestBufferWaitUs(std::shared_ptr<AVBuffer> & outBuffer,const AVBufferConfig & config,int64_t timeoutUs)34 virtual Status RequestBufferWaitUs( 35 std::shared_ptr<AVBuffer> &outBuffer, const AVBufferConfig &config, int64_t timeoutUs) 36 { 37 (void)outBuffer; 38 (void)config; 39 (void)timeoutUs; 40 return Status::ERROR_UNKNOWN; 41 } 42 virtual Status PushBuffer(const std::shared_ptr<AVBuffer>& inBuffer, bool available) = 0; 43 virtual Status ReturnBuffer(const std::shared_ptr<AVBuffer>& inBuffer, bool available) = 0; 44 45 virtual Status AttachBuffer(std::shared_ptr<AVBuffer>& inBuffer, bool isFilled) = 0; 46 virtual Status DetachBuffer(const std::shared_ptr<AVBuffer>& outBuffer) = 0; 47 48 virtual Status SetBufferFilledListener(sptr<IBrokerListener>& listener) = 0; 49 virtual Status RemoveBufferFilledListener(sptr<IBrokerListener>& listener) = 0; 50 virtual Status SetBufferAvailableListener(sptr<IProducerListener>& listener) = 0; 51 virtual Status Clear() = 0; 52 virtual Status ClearBufferIf(std::function<bool(const std::shared_ptr<AVBuffer>&)> pred) = 0; 53 DECLARE_INTERFACE_DESCRIPTOR(u"Media.AVBufferQueueProducer"); 54 55 protected: 56 enum: uint32_t { 57 PRODUCER_GET_QUEUE_SIZE = 0, 58 PRODUCER_SET_QUEUE_SIZE = 1, 59 PRODUCER_REQUEST_BUFFER = 2, 60 PRODUCER_PUSH_BUFFER = 3, 61 PRODUCER_RETURN_BUFFER = 4, 62 PRODUCER_ATTACH_BUFFER = 5, 63 PRODUCER_DETACH_BUFFER = 6, 64 PRODUCER_SET_FILLED_LISTENER = 7, 65 PRODUCER_REMOVE_FILLED_LISTENER = 8, 66 PRODUCER_SET_AVAILABLE_LISTENER = 9 67 }; 68 }; 69 70 } // namespace Media 71 } // namespace OHOS 72 73 #endif // HISTREAMER_FOUNDATION_AVBUFFER_QUEUE_PRODUCER_H 74