openharmony/communication_ipc
1
0
Fork 0
mirror of https://gitee.com/openharmony/communication_ipc synced 2024-11-26 17:41:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

napi相关代码建设意见修改，异常分支增加delete和return操作

Browse Source 
Signed-off-by: Lixiaoying25 <lixiaoying25@huawei.com>
This commit is contained in:
Lixiaoying25 2024-11-12 11:28:30 +08:00
parent 84998280ca
commit f76688950f
9 changed files with 71 additions and 102 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
interfaces/innerkits/ipc_core/include/ipc_types.h
View File

@ -100,6 +100,9 @@ enum {
ERR_UNKNOWN_REASON,
ERR_INVALID_REPLY,
ERR_INVALID_STATE,
ERR_ALLOC_MEMORY = 11,
ERR_START_UV_WORK = 12,
ERR_INVALID_PARAM = 13,
IPC_SKELETON_ERR = 100,
IPC_SKELETON_NULL_OBJECT_ERR,
IPC_PROXY_ERR = 200,

8
ipc/native/src/napi/src/napi_message_option.cpp
View File

@ -198,10 +198,7 @@ static napi_value NAPIMessageOption_JS_Constructor(napi_env env, napi_callback_i
}
auto messageOption = new (std::nothrow) MessageOption(flags, waitTime);
if (messageOption == nullptr) {
ZLOGE(LOG_LABEL, "new MessageOption failed");
return nullptr;
}
NAPI_ASSERT(env, messageOption != nullptr, "new MessageOption failed");
// connect native message option to js thisVar
napi_status status = napi_wrap(
env, thisVar, messageOption,
@ -211,9 +208,8 @@ static napi_value NAPIMessageOption_JS_Constructor(napi_env env, napi_callback_i
},
nullptr, nullptr);
if (status != napi_ok) {
ZLOGE(LOG_LABEL, "wrap js MessageOption and native option failed. status is %{public}d", status);
delete messageOption;
return nullptr;
NAPI_ASSERT(env, false, "wrap js MessageOption and native option failed");
}
return thisVar;
}

34
ipc/native/src/napi/src/napi_remote_proxy.cpp
View File

@ -99,7 +99,6 @@ napi_value SendRequestAsync(napi_env env, sptr<IRemoteObject> target, uint32_t c
MessageOption &option, napi_value *argv)
{
napi_value result = nullptr;
napi_get_undefined(env, &result);
SendRequestParam *sendRequestParam = new (std::nothrow) SendRequestParam {
.target = target,
.code = code,
@ -117,11 +116,7 @@ napi_value SendRequestAsync(napi_env env, sptr<IRemoteObject> target, uint32_t c
.env = env,
.traceId = 0,
};
if (sendRequestParam == nullptr) {
ZLOGE(LOG_LABEL, "new sendRequestParam failed");
return result;
}
NAPI_ASSERT(env, sendRequestParam != nullptr, "new sendRequestParam failed");
std::string remoteDescriptor = Str16ToStr8(target->GetInterfaceDescriptor());
if (!remoteDescriptor.empty()) {
sendRequestParam->traceValue = remoteDescriptor + std::to_string(code);
@ -139,7 +134,7 @@ napi_value SendRequestAsync(napi_env env, sptr<IRemoteObject> target, uint32_t c
NAPI_CALL(env, napi_create_async_work(env, nullptr, resourceName, ExecuteSendRequest,
SendRequestCbComplete, reinterpret_cast<void *>(sendRequestParam), &sendRequestParam->asyncWork));
NAPI_CALL(env, napi_queue_async_work(env, sendRequestParam->asyncWork));
napi_get_undefined(env, &result);
return result;
}
@ -167,11 +162,7 @@ napi_value SendRequestPromise(napi_env env, sptr<IRemoteObject> target, uint32_t
.env = env,
.traceId = 0,
};
if (sendRequestParam == nullptr) {
ZLOGE(LOG_LABEL, "new sendRequestParam failed");
return nullptr;
}
NAPI_ASSERT(env, sendRequestParam != nullptr, "new sendRequestParam failed");
std::string remoteDescriptor = Str16ToStr8(target->GetInterfaceDescriptor());
if (!remoteDescriptor.empty()) {
sendRequestParam->traceValue = remoteDescriptor + std::to_string(code);
@ -388,11 +379,7 @@ napi_value NAPI_RemoteProxy_addDeathRecipient(napi_env env, napi_callback_info i
}
sptr<NAPIDeathRecipient> nativeRecipient = new (std::nothrow) NAPIDeathRecipient(env, argv[ARGV_INDEX_0]);
if (nativeRecipient == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIDeathRecipient failed");
napi_get_boolean(env, false, &result);
return result;
}
NAPI_ASSERT(env, nativeRecipient != nullptr, "new NAPIDeathRecipient failed");
if (target->AddDeathRecipient(nativeRecipient)) {
NAPIDeathRecipientList *list = proxyHolder->list_;
if (list->Add(nativeRecipient)) {
@ -466,10 +453,7 @@ napi_value NAPI_RemoteProxy_registerDeathRecipient(napi_env env, napi_callback_i
napi_value result = nullptr;
napi_get_undefined(env, &result);
sptr<NAPIDeathRecipient> nativeRecipient = new (std::nothrow) NAPIDeathRecipient(env, argv[ARGV_INDEX_0]);
if (nativeRecipient == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIDeathRecipient failed");
return result;
}
NAPI_ASSERT(env, nativeRecipient != nullptr, "new NAPIDeathRecipient failed");
bool ret = target->AddDeathRecipient(nativeRecipient);
if (ret) {
NAPIDeathRecipientList *list = proxyHolder->list_;
@ -713,10 +697,7 @@ napi_value RemoteProxy_JS_Constructor(napi_env env, napi_callback_info info)
napi_get_cb_info(env, info, nullptr, nullptr, &thisVar, nullptr);
// new napi proxy holder instance
auto proxyHolder = new (std::nothrow) NAPIRemoteProxyHolder();
if (proxyHolder == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIRemoteProxyHolder failed");
return nullptr;
}
NAPI_ASSERT(env, proxyHolder != nullptr, "new NAPIRemoteProxyHolder failed");
// connect native object to js thisVar
napi_status status = napi_wrap(
env, thisVar, proxyHolder,
@ -726,9 +707,8 @@ napi_value RemoteProxy_JS_Constructor(napi_env env, napi_callback_info info)
},
nullptr, nullptr);
if (status != napi_ok) {
ZLOGE(LOG_LABEL, "wrap js RemoteProxy and native holder failed. status is %{public}d", status);
delete proxyHolder;
return nullptr;
NAPI_ASSERT(env, false, "wrap js RemoteProxy and native holder failed");
}
return thisVar;
}

8
ipc/native/src/napi_common/source/napi_ashmem.cpp
View File

@ -952,10 +952,7 @@ napi_value NAPIAshmem::Ashmem_JS_Constructor(napi_env env, napi_callback_info in
NAPI_ASSERT(env, nativeAshmem != nullptr, "invalid parameters");
napiAshmem = new (std::nothrow) NAPIAshmem(nativeAshmem);
}
if (napiAshmem == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIAshmem failed");
return nullptr;
}
NAPI_ASSERT(env, napiAshmem != nullptr, "new NAPIAshmem failed");
// connect native object to js thisVar
napi_status status = napi_wrap(
env, thisVar, napiAshmem,
@ -965,9 +962,8 @@ napi_value NAPIAshmem::Ashmem_JS_Constructor(napi_env env, napi_callback_info in
},
nullptr, nullptr);
if (status != napi_ok) {
ZLOGE(LOG_LABEL, "wrap js Ashmem and native holder failed. status is %{public}d", status);
delete napiAshmem;
return nullptr;
NAPI_ASSERT(env, false, "wrap js Ashmem and native holder failed");
}
return thisVar;
}

8
ipc/native/src/napi_common/source/napi_message_parcel_write.cpp
View File

@ -1451,10 +1451,7 @@ napi_value NAPI_MessageParcel::JS_constructor(napi_env env, napi_callback_info i
}
// new native parcel object
auto messageParcel = new (std::nothrow) NAPI_MessageParcel(env, thisVar, parcel);
if (messageParcel == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIAshmem failed");
return nullptr;
}
NAPI_ASSERT(env, messageParcel != nullptr, "new messageParcel failed");
// connect native object to js thisVar
status = napi_wrap(
env, thisVar, messageParcel,
@ -1466,9 +1463,8 @@ napi_value NAPI_MessageParcel::JS_constructor(napi_env env, napi_callback_info i
},
nullptr, nullptr);
if (status != napi_ok) {
ZLOGE(LOG_LABEL, "napi wrap message parcel failed. status is %{public}d", status);
delete messageParcel;
return nullptr;
NAPI_ASSERT(env, false, "napi wrap message parcel failed");
}
return thisVar;
}

8
ipc/native/src/napi_common/source/napi_message_sequence_write.cpp
View File

@ -2099,10 +2099,7 @@ napi_value NAPI_MessageSequence::JS_constructor(napi_env env, napi_callback_info
}
// new native parcel object
auto messageSequence = new (std::nothrow) NAPI_MessageSequence(env, thisVar, parcel);
if (messageSequence == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIAshmem failed");
return nullptr;
}
NAPI_ASSERT(env, messageSequence != nullptr, "new messageSequence failed");
// connect native object to js thisVar
status = napi_wrap(
env, thisVar, messageSequence,
@ -2114,9 +2111,8 @@ napi_value NAPI_MessageSequence::JS_constructor(napi_env env, napi_callback_info
},
nullptr, nullptr);
if (status != napi_ok) {
ZLOGE(LOG_LABEL, "napi wrap message parcel failed. status is %{public}d", status);
delete messageSequence;
return nullptr;
NAPI_ASSERT(env, false, "napi wrap message parcel failed");
}
return thisVar;
}

92
ipc/native/src/napi_common/source/napi_remote_object.cpp
View File

@ -59,7 +59,7 @@ static bool IsValidParamWithNotify(napi_value value, CallbackParam *param, napi_
{
if (value == nullptr) {
ZLOGE(LOG_LABEL, "%{public}s", errDesc);
param->result = -1;
param->result = ERR_INVALID_PARAM;
std::unique_lock<std::mutex> lock(param->lockInfo->mutex);
napi_close_handle_scope(param->env, scope);
param->lockInfo->ready = true;
@ -174,7 +174,7 @@ static bool GetPromiseThen(CallbackParam *param, const napi_value returnVal, nap
napi_get_named_property(param->env, returnVal, "then", &promiseThen);
if (promiseThen == nullptr) {
ZLOGE(LOG_LABEL, "get promiseThen failed");
param->result = -1;
param->result = ERR_INVALID_PARAM;
return false;
}
return true;
@ -446,32 +446,29 @@ static void IncreaseJsObjectRef(napi_env env, napi_ref ref)
static void RemoteObjectHolderRefCb(napi_env env, void *data, void *hint)
{
NAPIRemoteObjectHolder *holder = reinterpret_cast<NAPIRemoteObjectHolder *>(data);
if (holder == nullptr) {
ZLOGW(LOG_LABEL, "RemoteObjectHolderRefCb holder is nullptr");
return;
}
NAPI_ASSERT_RETURN_VOID(env, holder != nullptr, "holder is nullptr");
holder->Lock();
int32_t curAttachCount = holder->DecAttachCount();
holder->Unlock();
ZLOGD(LOG_LABEL, "RemoteObjectHolderRefCb, curAttachCount:%{public}d", curAttachCount);
napi_ref ref = holder->GetJsObjectRef();
NAPI_ASSERT_RETURN_VOID(env, ref != nullptr, "ref is nullptr");
napi_env workerEnv = holder->GetJsObjectEnv();
if (ref == nullptr || workerEnv == nullptr) {
ZLOGE(LOG_LABEL, "ref or env is null");
return;
}
NAPI_ASSERT_RETURN_VOID(env, workerEnv != nullptr, "workerEnv is nullptr");
uv_loop_s *loop = nullptr;
napi_get_uv_event_loop(workerEnv, &loop);
uv_work_t *work = new(std::nothrow) uv_work_t;
uv_work_t *work = new (std::nothrow) uv_work_t;
NAPI_ASSERT_RETURN_VOID(workerEnv, work != nullptr, "cb failed to new work");
OperateJsRefParam *param = new (std::nothrow) OperateJsRefParam {
.env = workerEnv,
.thisVarRef = ref
};
if (param == nullptr) {
ZLOGE(LOG_LABEL, "new OperateJsRefParam failed");
return;
delete work;
NAPI_ASSERT_RETURN_VOID(workerEnv, false, "new OperateJsRefParam failed");
}
work->data = reinterpret_cast<void *>(param);
int uvRet = uv_queue_work(loop, work, [](uv_work_t *work) {
@ -488,6 +485,8 @@ static void RemoteObjectHolderRefCb(napi_env env, void *data, void *hint)
});
if (uvRet != 0) {
ZLOGE(LOG_LABEL, "uv_queue_work failed, ret %{public}d", uvRet);
delete param;
delete work;
}
}
@ -571,17 +570,18 @@ napi_value RemoteObject_JS_Constructor(napi_env env, napi_callback_info info)
NAPI_ASSERT(env, jsStringLength == bufferSize, "string length wrong");
std::string descriptor = stringValue;
auto holder = new (std::nothrow) NAPIRemoteObjectHolder(env, Str8ToStr16(descriptor), thisVar);
if (holder == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIRemoteObjectHolder failed");
return nullptr;
}
napi_coerce_to_native_binding_object(env, thisVar, RemoteObjectDetachCb, RemoteObjectAttachCb, holder, nullptr);
// connect native object to js thisVar
napi_status status = napi_wrap(env, thisVar, holder, RemoteObjectHolderFinalizeCb, nullptr, nullptr);
NAPI_ASSERT(env, holder != nullptr, "new NAPIRemoteObjectHolder failed");
napi_status status = napi_coerce_to_native_binding_object(env, thisVar, RemoteObjectDetachCb, RemoteObjectAttachCb,
holder, nullptr);
if (status != napi_ok) {
ZLOGE(LOG_LABEL, "wrap js RemoteObject and native holder failed. status is %{public}d", status);
delete holder;
return nullptr;
NAPI_ASSERT(env, false, "bind native RemoteObject failed");
}
// connect native object to js thisVar
status = napi_wrap(env, thisVar, holder, RemoteObjectHolderFinalizeCb, nullptr, nullptr);
if (status != napi_ok) {
delete holder;
NAPI_ASSERT(env, false, "wrap js RemoteObject and native holder failed");
}
return thisVar;
}
@ -600,7 +600,7 @@ NAPIRemoteObject::NAPIRemoteObject(std::thread::id jsThreadId, napi_env env, nap
} else {
uv_loop_s *loop = nullptr;
napi_get_uv_event_loop(env_, &loop);
uv_work_t *work = new(std::nothrow) uv_work_t;
uv_work_t *work = new (std::nothrow) uv_work_t;
NAPI_ASSERT_RETURN_VOID(env_, work != nullptr, "create NAPIRemoteObject, new work failed");
std::shared_ptr<struct ThreadLockInfo> lockInfo = std::make_shared<struct ThreadLockInfo>();
OperateJsRefParam *param = new (std::nothrow) OperateJsRefParam {
@ -609,8 +609,9 @@ NAPIRemoteObject::NAPIRemoteObject(std::thread::id jsThreadId, napi_env env, nap
.lockInfo = lockInfo.get()
};
if (param == nullptr) {
ZLOGE(LOG_LABEL, "new OperateJsRefParam failed");
}
delete work;
NAPI_ASSERT_RETURN_VOID(env_, false, "new OperateJsRefParam failed");
}
work->data = reinterpret_cast<void *>(param);
int uvRet = uv_queue_work(loop, work, [](uv_work_t *work) {
@ -645,14 +646,16 @@ NAPIRemoteObject::~NAPIRemoteObject()
} else {
uv_loop_s *loop = nullptr;
napi_get_uv_event_loop(env_, &loop);
uv_work_t *work = new(std::nothrow) uv_work_t;
uv_work_t *work = new (std::nothrow) uv_work_t;
NAPI_ASSERT_RETURN_VOID(env_, work != nullptr, "release NAPIRemoteObject, new work failed");
OperateJsRefParam *param = new (std::nothrow) OperateJsRefParam {
.env = env_,
.thisVarRef = thisVarRef_
};
if (param == nullptr) {
ZLOGE(LOG_LABEL, "new OperateJsRefParam failed");
thisVarRef_ = nullptr;
delete work;
NAPI_ASSERT_RETURN_VOID(env_, false, "new OperateJsRefParam failed");
}
work->data = reinterpret_cast<void *>(param);
int uvRet = uv_queue_work(loop, work, [](uv_work_t *work) {
@ -668,6 +671,8 @@ NAPIRemoteObject::~NAPIRemoteObject()
});
if (uvRet != 0) {
ZLOGE(LOG_LABEL, "uv_queue_work failed, ret %{public}d", uvRet);
delete param;
delete work;
}
}
thisVarRef_ = nullptr;
@ -725,7 +730,7 @@ int NAPIRemoteObject::OnRemoteRequest(uint32_t code, MessageParcel &data, Messag
};
if (param == nullptr) {
ZLOGE(LOG_LABEL, "new CallbackParam failed");
return -1;
return ERR_ALLOC_MEMORY;
}
NAPI_RemoteObject_getCallingInfo(param->callingInfo);
@ -741,6 +746,7 @@ int NAPIRemoteObject::OnRemoteRequest(uint32_t code, MessageParcel &data, Messag
std::chrono::steady_clock::now().time_since_epoch()).count());
ZLOGE(LOG_LABEL, "OnJsRemoteRequest failed, ret:%{public}d time:%{public}" PRIu64, ret, curTime);
}
delete param;
return ret;
}
@ -811,11 +817,10 @@ int NAPIRemoteObject::OnJsRemoteRequest(CallbackParam *jsParam)
uv_loop_s *loop = nullptr;
napi_get_uv_event_loop(env_, &loop);
uv_work_t *work = new(std::nothrow) uv_work_t;
uv_work_t *work = new (std::nothrow) uv_work_t;
if (work == nullptr) {
ZLOGE(LOG_LABEL, "failed to new uv_work_t");
delete jsParam;
return -1;
return ERR_ALLOC_MEMORY;
}
work->data = reinterpret_cast<void *>(jsParam);
@ -831,14 +836,13 @@ int NAPIRemoteObject::OnJsRemoteRequest(CallbackParam *jsParam)
}, OnJsRemoteRequestCallBack, uv_qos_user_initiated);
int ret = 0;
if (uvRet != 0) {
ZLOGE(LOG_LABEL, "uv_queue_work_with_qos failed, ret:%{public}d", uvRet);
ret = -1;
ZLOGE(LOG_LABEL, "uv_queue_work_with_qos failed, ret:%{public}d", uvRet);
ret = ERR_START_UV_WORK;
} else {
std::unique_lock<std::mutex> lock(jsParam->lockInfo->mutex);
jsParam->lockInfo->condition.wait(lock, [&jsParam] { return jsParam->lockInfo->ready; });
ret = jsParam->result;
}
delete jsParam;
delete work;
return ret;
}
@ -901,10 +905,7 @@ napi_value NAPI_ohos_rpc_CreateJsRemoteObject(napi_env env, const sptr<IRemoteOb
}
proxyHolder->object_ = target;
proxyHolder->list_ = new (std::nothrow) NAPIDeathRecipientList();
if (proxyHolder->list_ == nullptr) {
ZLOGE(LOG_LABEL, "new NAPIDeathRecipientList failed");
return nullptr;
}
NAPI_ASSERT(env, proxyHolder->list_ != nullptr, "new NAPIDeathRecipientList failed");
return jsRemoteProxy;
}
@ -1153,6 +1154,8 @@ void StubExecuteSendRequest(napi_env env, SendRequestParam *param)
}, afterWorkCb);
if (uvRet != 0) {
ZLOGE(LOG_LABEL, "uv_queue_work failed, ret %{public}d", uvRet);
delete param;
delete work;
}
}
@ -1161,7 +1164,6 @@ napi_value StubSendRequestAsync(napi_env env, sptr<IRemoteObject> target, uint32
MessageOption &option, napi_value *argv)
{
napi_value result = nullptr;
napi_get_undefined(env, &result);
SendRequestParam *sendRequestParam = new (std::nothrow) SendRequestParam {
.target = target,
.code = code,
@ -1179,10 +1181,7 @@ napi_value StubSendRequestAsync(napi_env env, sptr<IRemoteObject> target, uint32
.env = env,
.traceId = 0,
};
if (sendRequestParam == nullptr) {
ZLOGE(LOG_LABEL, "new SendRequestParam failed");
return result;
}
NAPI_ASSERT(env, sendRequestParam != nullptr, "new SendRequestParam failed");
if (target != nullptr) {
std::string remoteDescriptor = Str16ToStr8(target->GetObjectDescriptor());
if (!remoteDescriptor.empty()) {
@ -1198,7 +1197,7 @@ napi_value StubSendRequestAsync(napi_env env, sptr<IRemoteObject> target, uint32
napi_create_reference(env, argv[ARGV_INDEX_4], 1, &sendRequestParam->callback);
std::thread t(StubExecuteSendRequest, env, sendRequestParam);
t.detach();
napi_get_undefined(env, &result);
return result;
}
@ -1226,10 +1225,7 @@ napi_value StubSendRequestPromise(napi_env env, sptr<IRemoteObject> target, uint
.env = env,
.traceId = 0,
};
if (sendRequestParam == nullptr) {
ZLOGE(LOG_LABEL, "new SendRequestParam failed");
return nullptr;
}
NAPI_ASSERT(env, sendRequestParam != nullptr, "new SendRequestParam failed");
if (target != nullptr) {
std::string remoteDescriptor = Str16ToStr8(target->GetObjectDescriptor());
if (!remoteDescriptor.empty()) {

5
ipc/native/src/napi_common/source/napi_remote_object_holder.cpp
View File

@ -54,7 +54,7 @@ void NAPIRemoteObjectHolder::DeleteJsObjectRefInUvWork()
{
uv_loop_s *loop = nullptr;
napi_get_uv_event_loop(env_, &loop);
uv_work_t *work = new(std::nothrow) uv_work_t;
uv_work_t *work = new (std::nothrow) uv_work_t;
if (work == nullptr) {
ZLOGE(LOG_LABEL, "failed to new work");
return;
@ -65,6 +65,7 @@ void NAPIRemoteObjectHolder::DeleteJsObjectRefInUvWork()
};
if (param == nullptr) {
ZLOGE(LOG_LABEL, "new OperateJsRefParam failed");
delete work;
return;
}
work->data = reinterpret_cast<void *>(param);
@ -83,6 +84,8 @@ void NAPIRemoteObjectHolder::DeleteJsObjectRefInUvWork()
delete work;
});
if (uvRet != 0) {
delete param;
delete work;
ZLOGE(LOG_LABEL, "uv_queue_work failed, ret %{public}d", uvRet);
}
}

7
ipc/native/src/napi_common/source/napi_remote_proxy_holder.cpp
View File

@ -28,7 +28,7 @@ NAPIDeathRecipient::NAPIDeathRecipient(napi_env env, napi_value jsDeathRecipient
{
env_ = env;
napi_status status = napi_create_reference(env_, jsDeathRecipient, 1, &deathRecipientRef_);
NAPI_ASSERT_RETURN_VOID(env, status == napi_ok, "failed to create ref to js death recipient");
NAPI_ASSERT_RETURN_VOID(env_, status == napi_ok, "failed to create ref to js death recipient");
}
void NAPIDeathRecipient::AfterWorkCallback(uv_work_t *work, int status)
@ -98,7 +98,7 @@ void NAPIDeathRecipient::OnRemoteDied(const wptr<IRemoteObject> &object)
return;
}
uv_work_t *work = new(std::nothrow) uv_work_t;
uv_work_t *work = new (std::nothrow) uv_work_t;
if (work == nullptr) {
ZLOGE(LOG_LABEL, "failed to new uv_work_t");
return;
@ -109,6 +109,7 @@ void NAPIDeathRecipient::OnRemoteDied(const wptr<IRemoteObject> &object)
};
if (param == nullptr) {
ZLOGE(LOG_LABEL, "new OnRemoteDiedParam failed");
delete work;
return;
}
work->data = reinterpret_cast<void *>(param);
@ -118,6 +119,8 @@ void NAPIDeathRecipient::OnRemoteDied(const wptr<IRemoteObject> &object)
}, AfterWorkCallback);
if (uvRet != 0) {
ZLOGE(LOG_LABEL, "uv_queue_work failed, ret %{public}d", uvRet);
delete param;
delete work;
}
}