mirror of
https://github.com/openharmony/ark_js_runtime.git
synced 2026-07-19 11:34:49 -04:00
dingwen
87e9f4ff3c
Description:Divide RegionFactory into HeapRegionAllocator and NativeAreaAllocator,use ChunkVector replace some unreasonable CVector. issue:https://gitee.com/openharmony/ark_js_runtime/issues/I4TRB8 Signed-off-by: dingwen <dingwen6@huawei.com>
291 lines
9.4 KiB
C++
291 lines
9.4 KiB
C++
/*
|
||
* 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 "ecmascript/js_thread.h"
|
||
#include "ecmascript/compiler/llvm/llvm_stackmap_parser.h"
|
||
#include "ecmascript/global_env_constants-inl.h"
|
||
#include "ecmascript/ic/properties_cache-inl.h"
|
||
#include "ecmascript/internal_call_params.h"
|
||
#include "ecmascript/interpreter/interpreter-inl.h"
|
||
#include "ecmascript/mem/machine_code.h"
|
||
#include "ecmascript/stub_module.h"
|
||
#include "include/panda_vm.h"
|
||
|
||
namespace panda::ecmascript {
|
||
// static
|
||
JSThread *JSThread::Create(Runtime *runtime, PandaVM *vm)
|
||
{
|
||
auto jsThread = new JSThread(runtime, vm);
|
||
jsThread->nativeAreaAllocator_ = EcmaVM::Cast(vm)->GetNativeAreaAllocator();
|
||
jsThread->heapRegionAllocator_ = EcmaVM::Cast(vm)->GetHeapRegionAllocator();
|
||
// algin with 16
|
||
jsThread->frameBase_ = static_cast<JSTaggedType *>(
|
||
EcmaVM::Cast(vm)->GetNativeAreaAllocator()->Allocate(sizeof(JSTaggedType) * MAX_STACK_SIZE));
|
||
jsThread->currentFrame_ = jsThread->frameBase_ + MAX_STACK_SIZE;
|
||
JSThread::SetCurrent(jsThread);
|
||
EcmaInterpreter::InitStackFrame(jsThread);
|
||
return jsThread;
|
||
}
|
||
|
||
JSThread::JSThread(Runtime *runtime, PandaVM *vm)
|
||
: ManagedThread(GetCurrentThreadId(), runtime->GetInternalAllocator(), vm,
|
||
Thread::ThreadType::THREAD_TYPE_MANAGED)
|
||
{
|
||
SetLanguageContext(runtime->GetLanguageContext(panda_file::SourceLang::ECMASCRIPT));
|
||
auto chunk = EcmaVM::Cast(vm)->GetChunk();
|
||
globalStorage_ = chunk->New<EcmaGlobalStorage>(chunk);
|
||
internalCallParams_ = new InternalCallParams();
|
||
propertiesCache_ = new PropertiesCache();
|
||
}
|
||
|
||
JSThread::~JSThread()
|
||
{
|
||
for (auto n : handleStorageNodes_) {
|
||
delete n;
|
||
}
|
||
handleStorageNodes_.clear();
|
||
currentHandleStorageIndex_ = -1;
|
||
handleScopeCount_ = 0;
|
||
handleScopeStorageNext_ = handleScopeStorageEnd_ = nullptr;
|
||
EcmaVM::Cast(GetVM())->GetChunk()->Delete(globalStorage_);
|
||
|
||
GetNativeAreaAllocator()->Free(frameBase_, sizeof(JSTaggedType) * MAX_STACK_SIZE);
|
||
frameBase_ = nullptr;
|
||
nativeAreaAllocator_ = nullptr;
|
||
heapRegionAllocator_ = nullptr;
|
||
if (internalCallParams_ != nullptr) {
|
||
delete internalCallParams_;
|
||
internalCallParams_ = nullptr;
|
||
}
|
||
if (propertiesCache_ != nullptr) {
|
||
delete propertiesCache_;
|
||
propertiesCache_ = nullptr;
|
||
}
|
||
}
|
||
|
||
EcmaVM *JSThread::GetEcmaVM() const
|
||
{
|
||
return EcmaVM::Cast(GetVM());
|
||
}
|
||
|
||
void JSThread::SetException(JSTaggedValue exception)
|
||
{
|
||
exception_ = exception;
|
||
}
|
||
|
||
void JSThread::ClearException()
|
||
{
|
||
exception_ = JSTaggedValue::Hole();
|
||
}
|
||
|
||
JSTaggedValue JSThread::GetCurrentLexenv() const
|
||
{
|
||
return InterpretedFrameHandler(currentFrame_).GetEnv();
|
||
}
|
||
|
||
void JSThread::Iterate(const RootVisitor &v0, const RootRangeVisitor &v1)
|
||
{
|
||
if (propertiesCache_ != nullptr) {
|
||
propertiesCache_->Clear();
|
||
}
|
||
|
||
if (!exception_.IsHole()) {
|
||
v0(Root::ROOT_VM, ObjectSlot(ToUintPtr(&exception_)));
|
||
}
|
||
if (!stubCode_.IsHole()) {
|
||
v0(Root::ROOT_VM, ObjectSlot(ToUintPtr(&stubCode_)));
|
||
}
|
||
// visit global Constant
|
||
globalConst_.VisitRangeSlot(v1);
|
||
// visit stack roots
|
||
FrameIterator iterator(currentFrame_, this);
|
||
iterator.Iterate(v0, v1);
|
||
// visit internal call params；
|
||
internalCallParams_->Iterate(v1);
|
||
// visit tagged handle storage roots
|
||
if (currentHandleStorageIndex_ != -1) {
|
||
int32_t nid = currentHandleStorageIndex_;
|
||
for (int32_t i = 0; i <= nid; ++i) {
|
||
auto node = handleStorageNodes_.at(i);
|
||
auto start = node->data();
|
||
auto end = (i != nid) ? &(node->data()[NODE_BLOCK_SIZE]) : handleScopeStorageNext_;
|
||
v1(ecmascript::Root::ROOT_HANDLE, ObjectSlot(ToUintPtr(start)), ObjectSlot(ToUintPtr(end)));
|
||
}
|
||
}
|
||
globalStorage_->IterateUsageGlobal([v0](EcmaGlobalStorage::Node *node) {
|
||
JSTaggedValue value(node->GetObject());
|
||
if (value.IsHeapObject()) {
|
||
v0(ecmascript::Root::ROOT_HANDLE, ecmascript::ObjectSlot(node->GetObjectAddress()));
|
||
}
|
||
});
|
||
}
|
||
|
||
void JSThread::IterateWeakEcmaGlobalStorage(const WeakRootVisitor &visitor)
|
||
{
|
||
globalStorage_->IterateWeakUsageGlobal([visitor](EcmaGlobalStorage::Node *node) {
|
||
JSTaggedValue value(node->GetObject());
|
||
if (value.IsHeapObject()) {
|
||
auto object = value.GetTaggedObject();
|
||
auto fwd = visitor(object);
|
||
if (fwd == nullptr) {
|
||
// undefind
|
||
node->SetObject(JSTaggedValue::Undefined().GetRawData());
|
||
} else if (fwd != object) {
|
||
// update
|
||
node->SetObject(JSTaggedValue(fwd).GetRawData());
|
||
}
|
||
}
|
||
});
|
||
}
|
||
|
||
bool JSThread::DoStackOverflowCheck(const JSTaggedType *sp)
|
||
{
|
||
// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
|
||
if (UNLIKELY(sp <= frameBase_ + RESERVE_STACK_SIZE)) {
|
||
ObjectFactory *factory = GetEcmaVM()->GetFactory();
|
||
JSHandle<JSObject> error = factory->GetJSError(base::ErrorType::RANGE_ERROR, "Stack overflow!");
|
||
if (LIKELY(!HasPendingException())) {
|
||
SetException(error.GetTaggedValue());
|
||
}
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
uintptr_t *JSThread::ExpandHandleStorage()
|
||
{
|
||
uintptr_t *result = nullptr;
|
||
int32_t lastIndex = handleStorageNodes_.size() - 1;
|
||
if (currentHandleStorageIndex_ == lastIndex) {
|
||
auto n = new std::array<JSTaggedType, NODE_BLOCK_SIZE>();
|
||
handleStorageNodes_.push_back(n);
|
||
currentHandleStorageIndex_++;
|
||
result = reinterpret_cast<uintptr_t *>(&n->data()[0]);
|
||
handleScopeStorageEnd_ = &n->data()[NODE_BLOCK_SIZE];
|
||
} else {
|
||
currentHandleStorageIndex_++;
|
||
auto lastNode = handleStorageNodes_[currentHandleStorageIndex_];
|
||
result = reinterpret_cast<uintptr_t *>(&lastNode->data()[0]);
|
||
handleScopeStorageEnd_ = &lastNode->data()[NODE_BLOCK_SIZE];
|
||
}
|
||
|
||
return result;
|
||
}
|
||
|
||
void JSThread::ShrinkHandleStorage(int prevIndex)
|
||
{
|
||
currentHandleStorageIndex_ = prevIndex;
|
||
int32_t lastIndex = handleStorageNodes_.size() - 1;
|
||
#if ECMASCRIPT_ENABLE_ZAP_MEM
|
||
uintptr_t size = ToUintPtr(handleScopeStorageEnd_) - ToUintPtr(handleScopeStorageNext_);
|
||
memset_s(handleScopeStorageNext_, size, 0, size);
|
||
for (int32_t i = currentHandleStorageIndex_ + 1; i < lastIndex; i++) {
|
||
memset_s(handleStorageNodes_[i], NODE_BLOCK_SIZE * sizeof(JSTaggedType), 0,
|
||
NODE_BLOCK_SIZE * sizeof(JSTaggedType));
|
||
}
|
||
#endif
|
||
|
||
if (lastIndex > MIN_HANDLE_STORAGE_SIZE && currentHandleStorageIndex_ < MIN_HANDLE_STORAGE_SIZE) {
|
||
for (int i = MIN_HANDLE_STORAGE_SIZE; i < lastIndex; i++) {
|
||
auto node = handleStorageNodes_.back();
|
||
delete node;
|
||
handleStorageNodes_.pop_back();
|
||
}
|
||
}
|
||
}
|
||
|
||
void JSThread::NotifyStableArrayElementsGuardians(JSHandle<JSObject> receiver)
|
||
{
|
||
if (!receiver->GetJSHClass()->IsPrototype()) {
|
||
return;
|
||
}
|
||
if (!stableArrayElementsGuardians_) {
|
||
return;
|
||
}
|
||
auto env = GetEcmaVM()->GetGlobalEnv();
|
||
if (receiver.GetTaggedValue() == env->GetObjectFunctionPrototype().GetTaggedValue() ||
|
||
receiver.GetTaggedValue() == env->GetArrayPrototype().GetTaggedValue()) {
|
||
stableArrayElementsGuardians_ = false;
|
||
}
|
||
}
|
||
|
||
void JSThread::ResetGuardians()
|
||
{
|
||
stableArrayElementsGuardians_ = true;
|
||
}
|
||
|
||
void JSThread::LoadFastStubModule(const char *moduleFile)
|
||
{
|
||
StubModule stubModule;
|
||
std::string fileName(moduleFile);
|
||
stubModule.Load(this, fileName);
|
||
for (int i = 0; i < kungfu::FAST_STUB_MAXCOUNT; i++) {
|
||
fastStubEntries_[i] = stubModule.GetStubEntry(i);
|
||
}
|
||
#ifdef NDEBUG
|
||
kungfu::LLVMStackMapParser::GetInstance().Print();
|
||
#endif
|
||
stubCode_ = stubModule.GetCode();
|
||
}
|
||
|
||
bool JSThread::CheckSafepoint()
|
||
{
|
||
if (VMNeedSuspension()) {
|
||
SuspendVM();
|
||
}
|
||
#ifndef NDEBUG
|
||
EcmaVM::Cast(GetVM())->CollectGarbage(TriggerGCType::FULL_GC);
|
||
return true;
|
||
#endif
|
||
if (IsMarkFinished()) {
|
||
auto heap = EcmaVM::Cast(GetVM())->GetHeap();
|
||
heap->GetConcurrentMarker()->HandleMarkFinished();
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
bool JSThread::NotifyVMThreadSuspension() // block caller thread
|
||
{
|
||
if (VMNeedSuspension()) { // only enable one thread to post suspension
|
||
return false;
|
||
}
|
||
SetVMNeedSuspension(true);
|
||
os::memory::LockHolder lock(vmThreadSuspensionMutex_);
|
||
while (!IsSuspended()) {
|
||
vmThreadNeedSuspensionCV_.Wait(&vmThreadSuspensionMutex_);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
void JSThread::SuspendVM() // block vm thread
|
||
{
|
||
os::memory::LockHolder lock(vmThreadSuspensionMutex_);
|
||
SetVMSuspened(true);
|
||
vmThreadNeedSuspensionCV_.Signal(); // wake up the thread who needs suspend vmthread
|
||
while (VMNeedSuspension()) {
|
||
vmThreadHasSuspendedCV_.Wait(&vmThreadSuspensionMutex_);
|
||
}
|
||
SetVMSuspened(false);
|
||
}
|
||
|
||
void JSThread::ResumeVM()
|
||
{
|
||
os::memory::LockHolder lock(vmThreadSuspensionMutex_);
|
||
SetVMNeedSuspension(false);
|
||
vmThreadHasSuspendedCV_.Signal();
|
||
}
|
||
} // namespace panda::ecmascript
|