1 /*
2 * Copyright (c) 2024 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 #ifndef LOG_TAG
16 #define LOG_TAG "OfflineStreamInServer"
17 #endif
18
19 #include "offline_stream_in_server.h"
20 #include "audio_service_log.h"
21 #include "audio_errors.h"
22
23 namespace OHOS {
24 namespace AudioStandard {
25 namespace {
26 static const std::string OFFLINE_SERVER_BUFFER_IN = "offline_server_buffer_in";
27 static const std::string OFFLINE_SERVER_BUFFER_OUT = "offline_server_buffer_out";
28 static constexpr int32_t MAXIMUM_BUFFER_SIZE = 1000000; // 1,000,000
29 }
30 // static method
GetOfflineStream(int32_t & errCode)31 sptr<OfflineStreamInServer> OfflineStreamInServer::GetOfflineStream(int32_t &errCode)
32 {
33 sptr<OfflineStreamInServer> streamInServer = sptr<OfflineStreamInServer>::MakeSptr();
34 CHECK_AND_RETURN_RET_LOG(streamInServer, nullptr, "Create OfflineStream failed, errCode: %{public}d", errCode);
35 return streamInServer;
36 }
37
38 // static method
39 #ifdef FEATURE_OFFLINE_EFFECT
GetOfflineAudioEffectChains(std::vector<std::string> & effectChains)40 int32_t OfflineStreamInServer::GetOfflineAudioEffectChains(std::vector<std::string> &effectChains)
41 {
42 return OfflineAudioEffectServerChain::GetOfflineAudioEffectChains(effectChains);
43 }
44
CreateOfflineEffectChain(const std::string & chainName)45 int32_t OfflineStreamInServer::CreateOfflineEffectChain(const std::string &chainName)
46 {
47 effectChain_ = std::make_shared<OfflineAudioEffectServerChain>(chainName);
48 return effectChain_->Create();
49 }
50
ConfigureOfflineEffectChain(const AudioStreamInfo & inInfo,const AudioStreamInfo & outInfo)51 int32_t OfflineStreamInServer::ConfigureOfflineEffectChain(const AudioStreamInfo &inInfo,
52 const AudioStreamInfo &outInfo)
53 {
54 CHECK_AND_RETURN_RET_LOG(effectChain_, ERR_ILLEGAL_STATE, "effectChain not init");
55 return effectChain_->SetParam(inInfo, outInfo);
56 }
57
PrepareOfflineEffectChain(std::shared_ptr<AudioSharedMemory> & inBuffer,std::shared_ptr<AudioSharedMemory> & outBuffer)58 int32_t OfflineStreamInServer::PrepareOfflineEffectChain(std::shared_ptr<AudioSharedMemory> &inBuffer,
59 std::shared_ptr<AudioSharedMemory> &outBuffer)
60 {
61 if (serverBufferIn_ == nullptr || serverBufferOut_ == nullptr) {
62 uint32_t inSize = 0;
63 uint32_t outSize = 0;
64 effectChain_->GetEffectBufferSize(inSize, outSize);
65 CHECK_AND_RETURN_RET_LOG(AllocSharedMemory(inSize, outSize) == SUCCESS, ERR_OPERATION_FAILED,
66 "AllocSharedMemory failed");
67 }
68 inBuffer = serverBufferIn_;
69 outBuffer = serverBufferOut_;
70 return effectChain_->Prepare(serverBufferIn_, serverBufferOut_);
71 }
72
ProcessOfflineEffectChain(uint32_t inSize,uint32_t outSize)73 int32_t OfflineStreamInServer::ProcessOfflineEffectChain(uint32_t inSize, uint32_t outSize)
74 {
75 CHECK_AND_RETURN_RET_LOG(effectChain_, ERR_ILLEGAL_STATE, "effectChain not init");
76 return effectChain_->Process(inSize, outSize);
77 }
78
ReleaseOfflineEffectChain()79 void OfflineStreamInServer::ReleaseOfflineEffectChain()
80 {
81 CHECK_AND_RETURN_LOG(effectChain_, "effectChain not init");
82 effectChain_->Release();
83 }
84 #endif
85
AllocSharedMemory(uint32_t inSize,uint32_t outSize)86 int32_t OfflineStreamInServer::AllocSharedMemory(uint32_t inSize, uint32_t outSize)
87 {
88 CHECK_AND_RETURN_RET_LOG(inSize < MAXIMUM_BUFFER_SIZE && outSize < MAXIMUM_BUFFER_SIZE,
89 ERR_INVALID_PARAM, "alloc %{public}u inBuf or %{public}u outBuf out of range", inSize, outSize);
90 serverBufferIn_ = AudioSharedMemory::CreateFormLocal(inSize, OFFLINE_SERVER_BUFFER_IN);
91 CHECK_AND_RETURN_RET_LOG(serverBufferIn_ != nullptr, ERR_OPERATION_FAILED, "serverBufferIn_ mmap failed.");
92 serverBufferOut_ = AudioSharedMemory::CreateFormLocal(outSize, OFFLINE_SERVER_BUFFER_OUT);
93 CHECK_AND_RETURN_RET_LOG(serverBufferOut_ != nullptr, ERR_OPERATION_FAILED, "serverBufferOut_ mmap failed.");
94 return SUCCESS;
95 }
96 } // namespace AudioStandard
97 } // namespace OHOS
98