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