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
GetOfflineAudioEffectChains(std::vector<std::string> & effectChains)39 int32_t OfflineStreamInServer::GetOfflineAudioEffectChains(std::vector<std::string> &effectChains)
40 {
41 return OfflineAudioEffectServerChain::GetOfflineAudioEffectChains(effectChains);
42 }
43
CreateOfflineEffectChain(const std::string & chainName)44 int32_t OfflineStreamInServer::CreateOfflineEffectChain(const std::string &chainName)
45 {
46 effectChain_ = std::make_shared<OfflineAudioEffectServerChain>(chainName);
47 return effectChain_->Create();
48 }
49
ConfigureOfflineEffectChain(const AudioStreamInfo & inInfo,const AudioStreamInfo & outInfo)50 int32_t OfflineStreamInServer::ConfigureOfflineEffectChain(const AudioStreamInfo &inInfo,
51 const AudioStreamInfo &outInfo)
52 {
53 CHECK_AND_RETURN_RET_LOG(effectChain_, ERR_ILLEGAL_STATE, "effectChain not init");
54 return effectChain_->SetParam(inInfo, outInfo);
55 }
56
PrepareOfflineEffectChain(std::shared_ptr<AudioSharedMemory> & inBuffer,std::shared_ptr<AudioSharedMemory> & outBuffer)57 int32_t OfflineStreamInServer::PrepareOfflineEffectChain(std::shared_ptr<AudioSharedMemory> &inBuffer,
58 std::shared_ptr<AudioSharedMemory> &outBuffer)
59 {
60 if (serverBufferIn_ == nullptr || serverBufferOut_ == nullptr) {
61 uint32_t inSize = 0;
62 uint32_t outSize = 0;
63 effectChain_->GetEffectBufferSize(inSize, outSize);
64 CHECK_AND_RETURN_RET_LOG(AllocSharedMemory(inSize, outSize) == SUCCESS, ERR_OPERATION_FAILED,
65 "AllocSharedMemory failed");
66 }
67 inBuffer = serverBufferIn_;
68 outBuffer = serverBufferOut_;
69 return effectChain_->Prepare(serverBufferIn_, serverBufferOut_);
70 }
71
ProcessOfflineEffectChain(uint32_t inSize,uint32_t outSize)72 int32_t OfflineStreamInServer::ProcessOfflineEffectChain(uint32_t inSize, uint32_t outSize)
73 {
74 CHECK_AND_RETURN_RET_LOG(effectChain_, ERR_ILLEGAL_STATE, "effectChain not init");
75 return effectChain_->Process(inSize, outSize);
76 }
77
ReleaseOfflineEffectChain()78 void OfflineStreamInServer::ReleaseOfflineEffectChain()
79 {
80 CHECK_AND_RETURN_LOG(effectChain_, "effectChain not init");
81 effectChain_->Release();
82 }
83
AllocSharedMemory(uint32_t inSize,uint32_t outSize)84 int32_t OfflineStreamInServer::AllocSharedMemory(uint32_t inSize, uint32_t outSize)
85 {
86 CHECK_AND_RETURN_RET_LOG(inSize < MAXIMUM_BUFFER_SIZE && outSize < MAXIMUM_BUFFER_SIZE,
87 ERR_INVALID_PARAM, "alloc %{public}u inBuf or %{public}u outBuf out of range", inSize, outSize);
88 serverBufferIn_ = AudioSharedMemory::CreateFormLocal(inSize, OFFLINE_SERVER_BUFFER_IN);
89 CHECK_AND_RETURN_RET_LOG(serverBufferIn_ != nullptr, ERR_OPERATION_FAILED, "serverBufferIn_ mmap failed.");
90 serverBufferOut_ = AudioSharedMemory::CreateFormLocal(outSize, OFFLINE_SERVER_BUFFER_OUT);
91 CHECK_AND_RETURN_RET_LOG(serverBufferOut_ != nullptr, ERR_OPERATION_FAILED, "serverBufferOut_ mmap failed.");
92 return SUCCESS;
93 }
94 } // namespace AudioStandard
95 } // namespace OHOS
96