1 /*
2 * Copyright (c) 2021 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 "test.h"
17
18 #include "native_engine/impl/ark/ark_native_engine.h"
19 #include "utils/log.h"
20
21 using panda::RuntimeOption;
22
23 struct ThreadArgs {
24 NativeEngine* engine = nullptr;
25 bool initialState = false;
26 bool suspendState = false;
27 bool resumeState = false;
28 };
29
30 static NativeEngine* g_nativeEngine = nullptr;
31
NativeEngineTest()32 NativeEngineTest::NativeEngineTest()
33 {
34 engine_ = g_nativeEngine;
35 }
36
~NativeEngineTest()37 NativeEngineTest::~NativeEngineTest()
38 {}
39
Run(void * args)40 void *NativeEngineTest::Run(void *args)
41 {
42 ThreadArgs* threadArgs = reinterpret_cast<ThreadArgs*>(args);
43 NativeEngine* engine = threadArgs->engine;
44 threadArgs->initialState = engine->IsSuspended();
45 engine->SuspendVM();
46 threadArgs->suspendState = engine->IsSuspended();
47 engine->ResumeVM();
48 sleep(1);
49 threadArgs->resumeState = engine->IsSuspended();
50 return nullptr;
51 }
52
main(int argc,char ** argv)53 int main(int argc, char** argv)
54 {
55 testing::GTEST_FLAG(output) = "xml:./";
56 testing::InitGoogleTest(&argc, argv);
57
58 // Setup
59 RuntimeOption option;
60 option.SetGcType(RuntimeOption::GC_TYPE::GEN_GC);
61 const int64_t poolSize = 0x1000000; // 16M
62 option.SetGcPoolSize(poolSize);
63 option.SetLogLevel(RuntimeOption::LOG_LEVEL::ERROR);
64 option.SetDebuggerLibraryPath("");
65 EcmaVM* vm = panda::JSNApi::CreateJSVM(option);
66 if (vm == nullptr) {
67 return 0;
68 }
69
70 g_nativeEngine = new ArkNativeEngine(vm, nullptr);
71
72 int ret = testing::UnitTest::GetInstance()->Run();
73
74 g_nativeEngine->Loop(LOOP_NOWAIT);
75
76 delete g_nativeEngine;
77 g_nativeEngine = nullptr;
78 panda::JSNApi::DestroyJSVM(vm);
79 vm = nullptr;
80
81 return ret;
82 }
83
84 HWTEST_F(NativeEngineTest, SuspendVM001, testing::ext::TestSize.Level0)
85 {
86 pthread_t tids;
87 struct ThreadArgs *args = new ThreadArgs;
88 args->engine = engine_;
89 int res = pthread_create(&tids, NULL, Run, (void*)args);
90 if (res != 0) {
91 std::cout << "thread create failed";
92 return;
93 }
94 for (int i = 0; i < 3; ++i) { // 3:Loop 3 times
95 std::this_thread::sleep_for(std::chrono::milliseconds(100));
96 engine_->CheckSafepoint();
97 }
98 ASSERT_TRUE(!args->initialState);
99 ASSERT_TRUE(args->suspendState);
100 ASSERT_TRUE(!args->resumeState);
101 delete args;
102 args = nullptr;
103 }
104
105 HWTEST_F(NativeEngineTest, CreateRuntimeFunc001, testing::ext::TestSize.Level0)
106 {
107 auto result = engine_->CreateRuntime(true);
108 ASSERT_TRUE(result);
109 }
110
111 HWTEST_F(NativeEngineTest, ExecuteTranslateBySourceMapFunc001, testing::ext::TestSize.Level0)
112 {
113 std::string stack = engine_->ExecuteTranslateBySourceMap("test1/test2/test3/test.ts");
114 ASSERT_EQ(stack, "test1/test2/test3/test.ts");
115 }
116
117 HWTEST_F(NativeEngineTest, NapiErrorManagerTest001, testing::ext::TestSize.Level0)
118 {
119 auto onWorkerErrorCallback =
__anon2301ee620102(napi_env env, napi_value exception, std::string vm_name, uint32_t type) 120 [] (napi_env env, napi_value exception, std::string vm_name, uint32_t type) -> bool {
121 EXPECT_EQ(type, 2);
122 EXPECT_EQ(vm_name, "test");
123 return true;
124 };
125 auto onMainThreadErrorCallback =
126 [] (napi_env env, std::string summary, std::string name,
__anon2301ee620202(napi_env env, std::string summary, std::string name, std::string message, std::string stack) 127 std::string message, std::string stack) -> bool {
128 EXPECT_EQ(name, "name");
129 EXPECT_EQ(message, "message");
130 return true;
131 };
__anon2301ee620302() 132 auto hasOnErrorCb = [] () -> bool {
133 return true;
134 };
135 NapiErrorManager::GetInstance()->RegisterHasOnErrorCallback(hasOnErrorCb);
136 NapiErrorManager::GetInstance()->RegisterOnErrorCallback(onWorkerErrorCallback, onMainThreadErrorCallback);
137 ASSERT_NE(NapiErrorManager::GetInstance()->GetOnWorkerErrorCallback(), nullptr);
138 ASSERT_NE(NapiErrorManager::GetInstance()->GetOnMainThreadErrorCallback(), nullptr);
139 napi_value exception = nullptr;
140 NapiErrorManager::GetInstance()->NotifyUncaughtException(reinterpret_cast<napi_env>(engine_),
141 exception, "test", 2);
142 ASSERT_EQ(NapiErrorManager::GetInstance()->NotifyUncaughtException(reinterpret_cast<napi_env>(engine_),
143 "", "name", "message", ""), true);
144 }
145
146 HWTEST_F(NativeEngineTest, NapiErrorManagerTest002, testing::ext::TestSize.Level0)
147 {
148 auto allUnhandledRejectionCallbackTest =
__anon2301ee620402(napi_env env, napi_value* exception, std::string vm_name, uint32_t type) 149 [] (napi_env env, napi_value* exception, std::string vm_name, uint32_t type) -> bool {
150 EXPECT_EQ(type, 0);
151 EXPECT_EQ(vm_name, "test");
152 return true;
153 };
__anon2301ee620502() 154 auto hasAllUnhandledRejectionCb = [] () -> bool {
155 return false;
156 };
157
158 NapiErrorManager::GetInstance()->RegisterHasAllUnhandledRejectionCallback(hasAllUnhandledRejectionCb);
159 napi_value* exception = nullptr;
160 NapiErrorManager::GetInstance()->RegisterAllUnhandledRejectionCallback(allUnhandledRejectionCallbackTest);
161 ASSERT_NE(NapiErrorManager::GetInstance()->GetAllUnhandledRejectionCallback(), nullptr);
162 NapiErrorManager::GetInstance()->NotifyUnhandledRejection(reinterpret_cast<napi_env>(engine_),
163 exception, "test", 0);
164 }
165
166 HWTEST_F(NativeEngineTest, NapiErrorManagerTest003, testing::ext::TestSize.Level0)
167 {
__anon2301ee620602() 168 auto hasOnErrorCb = [] () -> bool {
169 return true;
170 };
171
172 NapiErrorManager::GetInstance()->RegisterHasOnErrorCallback(hasOnErrorCb);
173 auto callback = NapiErrorManager::GetInstance()->GetHasErrorCallback();
174 ASSERT_NE(callback, nullptr);
175 ASSERT_EQ(callback(), true);
176 }
177
178 HWTEST_F(NativeEngineTest, NapiErrorManagerTest004, testing::ext::TestSize.Level0)
179 {
__anon2301ee620702() 180 auto hasAllUnhandledRejectionCb = [] () -> bool {
181 return false;
182 };
183
184 NapiErrorManager::GetInstance()->RegisterHasAllUnhandledRejectionCallback(hasAllUnhandledRejectionCb);
185 auto callback = NapiErrorManager::GetInstance()->GetHasAllUnhandledRejectionCallback();
186 ASSERT_NE(callback, nullptr);
187 ASSERT_EQ(callback(), false);
188 }
189
190 HWTEST_F(NativeEngineTest, FinalizersCallbackTest001, testing::ext::TestSize.Level0)
191 {
192 ASSERT_NE(engine_, nullptr);
193 napi_env env = (napi_env)engine_;
194 const EcmaVM *vm = reinterpret_cast<ArkNativeEngine*>(engine_)->GetEcmaVm();
195
196 const char *str = "FinalizersCallbackTest001";
197 size_t size = 2 * ArkNativeEngine::FINALIZERS_PACK_PENDING_NATIVE_BINDING_SIZE_THRESHOLD;
198 static bool finalizersCallbackDone[2] = {false, false};
199
200 for (int i = 0; i < 2; ++i) {
201 {
202 panda::LocalScope scope(vm);
203 napi_value object = nullptr;
204 napi_create_object(env, &object);
__anon2301ee620802(napi_env env, void *data, void *hint) 205 napi_wrap_with_size(env, object, (void*)str, [](napi_env env, void *data, void *hint) {
206 bool *result = reinterpret_cast<bool*>(hint);
207 ASSERT_FALSE(*result);
208 *result = true;
209 }, reinterpret_cast<void*>(&finalizersCallbackDone[i]), nullptr, size);
210 }
211 panda::JSNApi::TriggerGC(vm, panda::ecmascript::GCReason::OTHER, panda::JSNApi::TRIGGER_GC_TYPE::FULL_GC);
212 }
213
214 ASSERT_FALSE(finalizersCallbackDone[0]);
215 ASSERT_TRUE(finalizersCallbackDone[1]);
216 }
217
218 /**
219 * @tc.name: SetMainThreadEcmaVMTest
220 * @tc.desc: Test interface of ArkIdleMonitor
221 * @tc.type: FUNC
222 */
223 HWTEST_F(NativeEngineTest, SetMainThreadEcmaVMTest001, testing::ext::TestSize.Level0)
224 {
225 ASSERT_NE(engine_, nullptr);
226 EcmaVM *vm = const_cast<EcmaVM*>(reinterpret_cast<ArkNativeEngine*>(engine_)->GetEcmaVm());
227
228 auto arkIdleMonitor = ArkIdleMonitor::GetInstance();
229 arkIdleMonitor->SetMainThreadEcmaVM(vm);
230
231 int64_t oldIdleDuration = arkIdleMonitor->GetTotalIdleDuration();
232 for (int i = 0; i < 10; i++) {
233 arkIdleMonitor->NotifyLooperIdleStart(i * 500, 20);
234 ASSERT_EQ(arkIdleMonitor->IsIdleState(), true);
235 arkIdleMonitor->NotifyLooperIdleEnd(i * 500 + 250);
236 ASSERT_EQ(arkIdleMonitor->IsIdleState(), false);
237 }
238
239 arkIdleMonitor->SetMainThreadEcmaVM(nullptr);
240
241 for (int i = 10; i < 20; i++) {
242 arkIdleMonitor->NotifyLooperIdleStart(i * 500, 20);
243 ASSERT_EQ(arkIdleMonitor->IsIdleState(), true);
244 arkIdleMonitor->NotifyLooperIdleEnd(i * 500 + 250);
245 ASSERT_EQ(arkIdleMonitor->IsIdleState(), false);
246 }
247
248 int64_t newIdleDuration = arkIdleMonitor->GetTotalIdleDuration();
249 ASSERT_TRUE(newIdleDuration > oldIdleDuration);
250 ASSERT_TRUE(arkIdleMonitor->GetIdleNotifyCount() > 0);
251 }
252
253 /**
254 * @tc.name: NotifyChangeBackgroundStateTest
255 * @tc.desc: Test interface of ArkIdleMonitor
256 * @tc.type: FUNC
257 */
258 HWTEST_F(NativeEngineTest, NotifyChangeBackgroundStateTest001, testing::ext::TestSize.Level0)
259 {
260 ASSERT_NE(engine_, nullptr);
261 EcmaVM *vm = const_cast<EcmaVM*>(reinterpret_cast<ArkNativeEngine*>(engine_)->GetEcmaVm());
262
263 auto arkIdleMonitor = ArkIdleMonitor::GetInstance();
264 arkIdleMonitor->SetMainThreadEcmaVM(vm);
265 arkIdleMonitor->SetStartTimerCallback();
266 arkIdleMonitor->NotifyChangeBackgroundState(true);
267 ASSERT_TRUE(arkIdleMonitor->IsInBackground() == true);
268 arkIdleMonitor->NotifyChangeBackgroundState(false);
269 ASSERT_TRUE(arkIdleMonitor->IsInBackground() == false);
270 }
271
272 /**
273 * @tc.name: RegisterWorkerEnvTest
274 * @tc.desc: Test interface of ArkIdleMonitor
275 * @tc.type: FUNC
276 */
277 HWTEST_F(NativeEngineTest, RegisterWorkerEnvTest001, testing::ext::TestSize.Level0)
278 {
279 ASSERT_NE(engine_, nullptr);
280 EcmaVM *vm = const_cast<EcmaVM*>(reinterpret_cast<ArkNativeEngine*>(engine_)->GetEcmaVm());
281
282 auto arkIdleMonitor = ArkIdleMonitor::GetInstance();
283 arkIdleMonitor->SetMainThreadEcmaVM(vm);
284
285 RuntimeOption option;
286 option.SetGcType(RuntimeOption::GC_TYPE::GEN_GC);
287 const int64_t poolSize = 0x1000000; // 16M
288 option.SetGcPoolSize(poolSize);
289 option.SetLogLevel(RuntimeOption::LOG_LEVEL::ERROR);
290 option.SetDebuggerLibraryPath("");
291 auto workerVM1 = panda::JSNApi::CreateJSVM(option);
292 auto workerVM2 = panda::JSNApi::CreateJSVM(option);
293 ArkNativeEngine *workerEngine1 = new ArkNativeEngine(workerVM1, nullptr);
294 ArkNativeEngine *workerEngine2 = new ArkNativeEngine(workerVM2, nullptr);
295 napi_env wokerEnv1 = reinterpret_cast<napi_env>(workerEngine1);
296 napi_env wokerEnv2 = reinterpret_cast<napi_env>(workerEngine2);
297
298 arkIdleMonitor->UnregisterWorkerEnv(wokerEnv1);
299 arkIdleMonitor->UnregisterWorkerEnv(wokerEnv2);
300
301 arkIdleMonitor->RegisterWorkerEnv(wokerEnv1);
302 arkIdleMonitor->RegisterWorkerEnv(wokerEnv2);
303
304 arkIdleMonitor->UnregisterWorkerEnv(wokerEnv1);
305 arkIdleMonitor->UnregisterWorkerEnv(wokerEnv2);
306
307 delete workerEngine1;
308 delete workerEngine2;
309 }