1 /*
2 * Copyright (c) 2023 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 "js_transaction_manager.h"
17
18 #include <transaction/rs_sync_transaction_controller.h>
19 #include <transaction/rs_transaction.h>
20
21 #include "js_runtime_utils.h"
22 #include "rs_adapter.h"
23 #include "scene_session_manager.h"
24 #include "screen_session_manager_client.h"
25 #include "window_manager_hilog.h"
26
27 namespace OHOS::Rosen {
28 using namespace AbilityRuntime;
29 namespace {
30 constexpr HiviewDFX::HiLogLabel LABEL = { LOG_CORE, HILOG_DOMAIN_WINDOW, "JsTransactionManager" };
31 } // namespace
32
NapiGetUndefined(napi_env env)33 napi_value NapiGetUndefined(napi_env env)
34 {
35 napi_value result = nullptr;
36 napi_get_undefined(env, &result);
37 return result;
38 }
39
NapiThrowError(napi_env env,WSErrorCode err,const std::string & msg)40 napi_value NapiThrowError(napi_env env, WSErrorCode err, const std::string& msg)
41 {
42 napi_throw(env, CreateJsError(env, static_cast<int32_t>(err), msg));
43 return NapiGetUndefined(env);
44 }
45
Init(napi_env env,napi_value exportObj)46 napi_value JsTransactionManager::Init(napi_env env, napi_value exportObj)
47 {
48 TLOGD(WmsLogTag::DEFAULT, "JsTransactionManager Init");
49 if (env == nullptr || exportObj == nullptr) {
50 WLOGFE("env or exportObj is null!");
51 return nullptr;
52 }
53
54 std::unique_ptr<JsTransactionManager> jsTransactionManager = std::make_unique<JsTransactionManager>(env);
55 napi_wrap(env, exportObj, jsTransactionManager.release(), JsTransactionManager::Finalizer, nullptr, nullptr);
56
57 const char* moduleName = "JsTransactionManager";
58 BindNativeFunction(env, exportObj, "openSyncTransaction", moduleName,
59 JsTransactionManager::OpenSyncTransaction);
60 BindNativeFunction(env, exportObj, "closeSyncTransaction", moduleName,
61 JsTransactionManager::CloseSyncTransaction);
62 BindNativeFunction(env, exportObj, "closeSyncTransactionWithVsync", moduleName,
63 JsTransactionManager::CloseSyncTransactionWithVsync);
64 return NapiGetUndefined(env);
65 }
66
JsTransactionManager(napi_env env)67 JsTransactionManager::JsTransactionManager(napi_env env)
68 {}
69
Finalizer(napi_env env,void * data,void * hint)70 void JsTransactionManager::Finalizer(napi_env env, void* data, void* hint)
71 {
72 TLOGD(WmsLogTag::DEFAULT, "Enter");
73 std::unique_ptr<JsTransactionManager>(static_cast<JsTransactionManager*>(data));
74 }
75
OpenSyncTransaction(napi_env env,napi_callback_info info)76 napi_value JsTransactionManager::OpenSyncTransaction(napi_env env, napi_callback_info info)
77 {
78 TLOGD(WmsLogTag::DEFAULT, "Enter");
79 JsTransactionManager* me = CheckParamsAndGetThis<JsTransactionManager>(env, info);
80 return (me != nullptr) ? me->OnOpenSyncTransaction(env, info) : nullptr;
81 }
82
CloseSyncTransaction(napi_env env,napi_callback_info info)83 napi_value JsTransactionManager::CloseSyncTransaction(napi_env env, napi_callback_info info)
84 {
85 TLOGD(WmsLogTag::DEFAULT, "Enter");
86 JsTransactionManager* me = CheckParamsAndGetThis<JsTransactionManager>(env, info);
87 return (me != nullptr) ? me->OnCloseSyncTransaction(env, info) : nullptr;
88 }
89
CloseSyncTransactionWithVsync(napi_env env,napi_callback_info info)90 napi_value JsTransactionManager::CloseSyncTransactionWithVsync(napi_env env, napi_callback_info info)
91 {
92 TLOGD(WmsLogTag::DEFAULT, "Enter");
93 JsTransactionManager* me = CheckParamsAndGetThis<JsTransactionManager>(env, info);
94 return (me != nullptr) ? me->OnCloseSyncTransactionWithVsync(env, info) : nullptr;
95 }
96
ParseScreenIdFromArgs(napi_env env,napi_callback_info info)97 ScreenId ParseScreenIdFromArgs(napi_env env, napi_callback_info info)
98 {
99 RETURN_IF_RS_CLIENT_MULTI_INSTANCE_DISABLED(SCREEN_ID_INVALID);
100 size_t argc = 1;
101 napi_value argv[1] = { nullptr };
102 napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr);
103
104 if (argc != 1) {
105 TLOGW(WmsLogTag::DEFAULT, "Argc is invalid: %{public}zu", argc);
106 return SCREEN_ID_INVALID;
107 }
108
109 int64_t screenIdValue = static_cast<int64_t>(SCREEN_ID_INVALID);
110 if (!ConvertFromJsValue(env, argv[0], screenIdValue)) {
111 TLOGW(WmsLogTag::DEFAULT, "Failed to convert parameter to screenId");
112 return SCREEN_ID_INVALID;
113 }
114
115 if (screenIdValue == static_cast<int64_t>(SCREEN_ID_INVALID)) {
116 TLOGW(WmsLogTag::DEFAULT, "Invalid screenId");
117 return SCREEN_ID_INVALID;
118 }
119
120 return static_cast<ScreenId>(screenIdValue);
121 }
122
OnOpenSyncTransaction(napi_env env,napi_callback_info info)123 napi_value JsTransactionManager::OnOpenSyncTransaction(napi_env env, napi_callback_info info)
124 {
125 ScreenId screenId = ParseScreenIdFromArgs(env, info);
126 auto task = [screenId] {
127 auto rsUIContext = ScreenSessionManagerClient::GetInstance().GetRSUIContext(screenId);
128 RSTransactionAdapter::FlushImplicitTransaction(rsUIContext);
129 RSSyncTransactionAdapter::OpenSyncTransaction(rsUIContext);
130 };
131 auto handler = SceneSessionManager::GetInstance().GetTaskScheduler();
132 if (handler) {
133 // must sync to include change
134 handler->PostVoidSyncTask(task);
135 } else {
136 task();
137 }
138 return NapiGetUndefined(env);
139 }
140
OnCloseSyncTransaction(napi_env env,napi_callback_info info)141 napi_value JsTransactionManager::OnCloseSyncTransaction(napi_env env, napi_callback_info info)
142 {
143 ScreenId screenId = ParseScreenIdFromArgs(env, info);
144 auto task = [screenId] {
145 auto rsUIContext = ScreenSessionManagerClient::GetInstance().GetRSUIContext(screenId);
146 RSSyncTransactionAdapter::CloseSyncTransaction(rsUIContext);
147 };
148 if (auto handler = SceneSessionManager::GetInstance().GetTaskScheduler()) {
149 handler->PostAsyncTask(task, __func__);
150 } else {
151 task();
152 }
153 return NapiGetUndefined(env);
154 }
155
OnCloseSyncTransactionWithVsync(napi_env env,napi_callback_info info)156 napi_value JsTransactionManager::OnCloseSyncTransactionWithVsync(napi_env env, napi_callback_info info)
157 {
158 ScreenId screenId = ParseScreenIdFromArgs(env, info);
159 auto task = [screenId] {
160 auto rsUIContext = ScreenSessionManagerClient::GetInstance().GetRSUIContext(screenId);
161 RSSyncTransactionAdapter::CloseSyncTransaction(rsUIContext);
162 };
163 SceneSessionManager::GetInstance().CloseSyncTransaction(task);
164 return NapiGetUndefined(env);
165 }
166 } // namespace OHOS::Rosen
167