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 "IpcOfflineStreamProxy"
17 #endif
18
19 #include "ipc_offline_stream_proxy.h"
20
21 #include "ipc_offline_stream_stub.h"
22 #include "audio_service_log.h"
23 #include "audio_errors.h"
24
25 namespace OHOS {
26 namespace AudioStandard {
IpcOfflineStreamProxy(const sptr<IRemoteObject> & impl)27 IpcOfflineStreamProxy::IpcOfflineStreamProxy(const sptr<IRemoteObject> &impl) : IRemoteProxy<IpcOfflineStream>(impl) {}
28
29 IpcOfflineStreamProxy::~IpcOfflineStreamProxy() = default;
30
31 #ifdef FEATURE_OFFLINE_EFFECT
CreateOfflineEffectChain(const std::string & chainName)32 int32_t IpcOfflineStreamProxy::CreateOfflineEffectChain(const std::string &chainName)
33 {
34 MessageParcel data;
35 MessageParcel reply;
36 MessageOption option;
37
38 CHECK_AND_RETURN_RET_LOG(data.WriteInterfaceToken(GetDescriptor()), ERROR, "Write descriptor failed!");
39 data.WriteString(chainName);
40 int ret = Remote()->SendRequest(IpcOfflineStreamMsg::CREATE_OFFLINE_EFFECT_CHAIN, data, reply, option);
41 CHECK_AND_RETURN_RET_LOG(ret == AUDIO_OK, ERR_OPERATION_FAILED, "Create failed, error: %{public}d", ret);
42
43 ret = reply.ReadInt32();
44 return ret;
45 }
46
ConfigureOfflineEffectChain(const AudioStreamInfo & inInfo,const AudioStreamInfo & outInfo)47 int32_t IpcOfflineStreamProxy::ConfigureOfflineEffectChain(const AudioStreamInfo &inInfo,
48 const AudioStreamInfo &outInfo)
49 {
50 MessageParcel data;
51 MessageParcel reply;
52 MessageOption option;
53
54 CHECK_AND_RETURN_RET_LOG(data.WriteInterfaceToken(GetDescriptor()), ERROR, "Write descriptor failed!");
55 inInfo.Marshalling(data);
56 outInfo.Marshalling(data);
57 int ret = Remote()->SendRequest(IpcOfflineStreamMsg::CONFIGURE_OFFLINE_EFFECT_CHAIN, data, reply, option);
58 CHECK_AND_RETURN_RET_LOG(ret == AUDIO_OK, ERR_OPERATION_FAILED, "Configure failed, error: %{public}d", ret);
59
60 ret = reply.ReadInt32();
61 return ret;
62 }
63
64
PrepareOfflineEffectChain(std::shared_ptr<AudioSharedMemory> & inBuffer,std::shared_ptr<AudioSharedMemory> & outBuffer)65 int32_t IpcOfflineStreamProxy::PrepareOfflineEffectChain(std::shared_ptr<AudioSharedMemory> &inBuffer,
66 std::shared_ptr<AudioSharedMemory> &outBuffer)
67 {
68 MessageParcel data;
69 MessageParcel reply;
70 MessageOption option;
71
72 CHECK_AND_RETURN_RET_LOG(data.WriteInterfaceToken(GetDescriptor()), ERROR, "Write descriptor failed!");
73 int ret = Remote()->SendRequest(IpcOfflineStreamMsg::PREPARE_OFFLINE_EFFECT_CHAIN, data, reply, option);
74 inBuffer = AudioSharedMemory::ReadFromParcel(reply);
75 outBuffer = AudioSharedMemory::ReadFromParcel(reply);
76 CHECK_AND_RETURN_RET_LOG(ret == AUDIO_OK, ERR_OPERATION_FAILED, "Configure failed, error: %{public}d", ret);
77
78 ret = reply.ReadInt32();
79 return ret;
80 }
81
ProcessOfflineEffectChain(uint32_t inSize,uint32_t outSize)82 int32_t IpcOfflineStreamProxy::ProcessOfflineEffectChain(uint32_t inSize, uint32_t outSize)
83 {
84 MessageParcel data;
85 MessageParcel reply;
86 MessageOption option;
87
88 CHECK_AND_RETURN_RET_LOG(data.WriteInterfaceToken(GetDescriptor()), ERROR, "Write descriptor failed!");
89 data.WriteUint32(inSize);
90 data.WriteUint32(outSize);
91 int ret = Remote()->SendRequest(IpcOfflineStreamMsg::PROCESS_OFFLINE_EFFECT_CHAIN, data, reply, option);
92 CHECK_AND_RETURN_RET_LOG(ret == AUDIO_OK, ERR_OPERATION_FAILED, "Process failed, error: %{public}d", ret);
93
94 ret = reply.ReadInt32();
95 return ret;
96 }
97
ReleaseOfflineEffectChain()98 void IpcOfflineStreamProxy::ReleaseOfflineEffectChain()
99 {
100 MessageParcel data;
101 MessageParcel reply;
102 MessageOption option;
103
104 CHECK_AND_RETURN_LOG(data.WriteInterfaceToken(GetDescriptor()), "Write descriptor failed!");
105 int ret = Remote()->SendRequest(IpcOfflineStreamMsg::RELEASE_OFFLINE_EFFECT_CHAIN, data, reply, option);
106 CHECK_AND_RETURN_LOG(ret == AUDIO_OK, "Relase failed, error: %{public}d", ret);
107 return;
108 }
109 #endif
110 } // namespace AudioStandard
111 } // namespace OHOS
112