/*
 * Copyright (c) 2021 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "test.h"

#include "ark_native_engine.h"
#include "utils/log.h"

using panda::RuntimeOption;
static NativeEngine* g_nativeEngine = nullptr;

NativeEngineTest::NativeEngineTest()
{
    engine_ = g_nativeEngine;
}

NativeEngineTest::~NativeEngineTest()
{}

void *NativeEngineTest::Run(void *arg)
{
    NativeEngine* engine = reinterpret_cast<NativeEngine*>(arg);
    bool falgThread = engine->IsSuspended();
    engine->SuspendVM();
    bool falgThread2 = engine->IsSuspended();
    engine->ResumeVM();
    sleep(10); // 10:sleep 10 second to wait thread checkpoint again
    bool falgThread3 = engine->IsSuspended();
    if (falgThread == 0 && falgThread2 == 1 && falgThread3 == 0) {
        std::cout << "[OK]" << std::endl;
    }
    return nullptr;
}

int main(int argc, char** argv)
{
    testing::GTEST_FLAG(output) = "xml:./";
    testing::InitGoogleTest(&argc, argv);

    // Setup
    RuntimeOption option;
    option.SetGcType(RuntimeOption::GC_TYPE::GEN_GC);
    const int64_t poolSize = 0x1000000;  // 16M
    option.SetGcPoolSize(poolSize);
    option.SetLogLevel(RuntimeOption::LOG_LEVEL::ERROR);
    option.SetDebuggerLibraryPath("");
    EcmaVM* vm = panda::JSNApi::CreateJSVM(option);
    if (vm == nullptr) {
        return 0;
    }

    g_nativeEngine = new ArkNativeEngine(vm, nullptr);

    int ret = testing::UnitTest::GetInstance()->Run();

    g_nativeEngine->Loop(LOOP_NOWAIT);

    delete g_nativeEngine;
    g_nativeEngine = nullptr;
    panda::JSNApi::DestroyJSVM(vm);
    vm = nullptr;

    return ret;
}

HWTEST_F(NativeEngineTest, suppend002, testing::ext::TestSize.Level0)
{
    std::cout << "NativeEngineTest is start"<<std::endl;
    pthread_t tids;
    int res = pthread_create(&tids, NULL, Run, (void*)engine_);
    if (res != 0) {
        std::cout << "thread create failed";
        return;
    }
    std::cout << "NativeEngineTest is start2"<<std::endl;
    for (int i = 0; i < 10; ++i) { // 10:Loop 10 times
        sleep(10); // 10:sleep 10 second to wait thread checkpoint again
        bool supportFlag = engine_->CheckSafepoint();
        std::cout << "supportFlag " << supportFlag ;
        if (supportFlag) {
            std::cout << "CheckSafepoint is ture";
        }
    }
    pthread_exit(NULL);
}