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 
16 #include "rs_surface_buffer_callback_stub.h"
17 #include "platform/common/rs_log.h"
18 
19 namespace OHOS {
20 namespace Rosen {
OnRemoteRequest(uint32_t code,MessageParcel & data,MessageParcel & reply,MessageOption & option)21 int RSSurfaceBufferCallbackStub::OnRemoteRequest(
22     uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option)
23 {
24     auto token = data.ReadInterfaceToken();
25     if (token != RSISurfaceBufferCallback::GetDescriptor()) {
26         ROSEN_LOGE("RSSurfaceBufferCallbackStub: token ERR_INVALID_STATE");
27         return ERR_INVALID_STATE;
28     }
29     int ret = ERR_NONE;
30     switch (code) {
31         case static_cast<uint32_t>(RSISurfaceBufferCallbackInterfaceCode::ON_FINISH): {
32             FinishCallbackRet ret;
33             auto readRet = data.ReadUint64(ret.uid);
34             readRet = readRet && data.ReadUInt32Vector(&ret.surfaceBufferIds);
35             readRet = readRet && data.ReadUInt8Vector(&ret.isRenderedFlags);
36             readRet = readRet && data.ReadBool(ret.isUniRender);
37 #ifdef ROSEN_OHOS
38             uint64_t releaseFenceVecSize = {};
39             constexpr uint64_t MAX_RELEASE_FENCE_VEC_SIZE = 32;
40             readRet = readRet && data.ReadUint64(releaseFenceVecSize);
41             if (releaseFenceVecSize > MAX_RELEASE_FENCE_VEC_SIZE) {
42                 ROSEN_LOGE("RSSurfaceBufferCallbackStub releaseFenceVecSize exceeds limits");
43                 return ERR_INVALID_DATA;
44             }
45             ret.releaseFences.reserve(releaseFenceVecSize);
46             for (uint64_t idx = 0; idx < releaseFenceVecSize; ++idx) {
47                 auto fence = SyncFence::ReadFromMessageParcel(data);
48                 ret.releaseFences.emplace_back(fence);
49                 readRet = readRet && (!!fence);
50             }
51 #endif
52             if (!readRet) {
53                 ROSEN_LOGE("RSSurfaceBufferCallbackStub Read Remote Data ERROR");
54             }
55             OnFinish(ret);
56             break;
57         }
58         case static_cast<uint32_t>(RSISurfaceBufferCallbackInterfaceCode::ON_AFTER_ACQUIRE_BUFFER) : {
59             AfterAcquireBufferRet ret;
60             auto readRet = data.ReadUint64(ret.uid);
61             readRet = readRet && data.ReadBool(ret.isUniRender);
62             if (!readRet) {
63                 ROSEN_LOGE("RSSurfaceBufferCallbackStub Read Remote Data ERROR");
64             }
65             OnAfterAcquireBuffer(ret);
66             break;
67         }
68         default: {
69             ROSEN_LOGE("RSSurfaceBufferCallbackStub: Unhandled enumeration value");
70             ret = IPCObjectStub::OnRemoteRequest(code, data, reply, option);
71             break;
72         }
73     }
74 
75     return ret;
76 }
77 } // namespace Rosen
78 } // namespace OHOS
79