From b081b4241dec381f32d272511dc40c14c225db74 Mon Sep 17 00:00:00 2001
From: heguokai <275503077@qq.com>
Date: Thu, 28 Aug 2025 20:45:36 +0800
Subject: [PATCH] =?UTF-8?q?OnOperationCallback=E6=8E=A5=E5=8F=A3=E8=A7=84?=
 =?UTF-8?q?=E8=8C=83=E6=80=A7=E6=95=B4=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: heguokai <275503077@qq.com>
---
 frameworks/ets/ani/src/sts_subscribe.cpp | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/frameworks/ets/ani/src/sts_subscribe.cpp b/frameworks/ets/ani/src/sts_subscribe.cpp
index b22f35ed3..029757b91 100644
--- a/frameworks/ets/ani/src/sts_subscribe.cpp
+++ b/frameworks/ets/ani/src/sts_subscribe.cpp
@@ -35,9 +35,12 @@ StsDistributedOperationCallback::StsDistributedOperationCallback(ani_object prom
 ErrCode StsDistributedOperationCallback::OnOperationCallback(const int32_t operationResult)
 {
     std::lock_guard<std::mutex> l(lock_);
-    if (isCall_) return ANI_OK;
+    if (isCall_) {
+        ANS_LOGD("OnOperationCallback isCall_ is true");
+        return ANI_OK;
+    }
     if (etsVm_ == nullptr) {
-        ANS_LOGD("etsVm_ is null");
+        ANS_LOGE("etsVm_ is null");
         return ANI_OK;
     }
     ani_env* etsEnv;
@@ -45,13 +48,13 @@ ErrCode StsDistributedOperationCallback::OnOperationCallback(const int32_t opera
     ani_options aniArgs { 0, nullptr };
     aniResult = etsVm_->AttachCurrentThread(&aniArgs, ANI_VERSION_1, &etsEnv);
     if (aniResult != ANI_OK) {
-        ANS_LOGD("StsDistributedOperationCallback AttachCurrentThread error. result: %{public}d.", aniResult);
+        ANS_LOGE("StsDistributedOperationCallback AttachCurrentThread error. result: %{public}d.", aniResult);
         return aniResult;
     }
     OnStsOperationCallback(etsEnv, operationResult);
     aniResult = etsVm_->DetachCurrentThread();
     if (aniResult != ANI_OK) {
-        ANS_LOGD("StsDistributedOperationCallback DetachCurrentThread error. result: %{public}d.", aniResult);
+        ANS_LOGE("StsDistributedOperationCallback DetachCurrentThread error. result: %{public}d.", aniResult);
         return aniResult;
     }
     isCall_ = true;
@@ -60,7 +63,7 @@ ErrCode StsDistributedOperationCallback::OnOperationCallback(const int32_t opera
 
 void StsDistributedOperationCallback::OnStsOperationCallback(ani_env *env, const int32_t operationResult)
 {
-    ANS_LOGD("ENTER");
+    ANS_LOGD("OnStsOperationCallback enter");
     if (env == nullptr) {
         ANS_LOGD("env is nullptr");
         return;
@@ -70,10 +73,10 @@ void StsDistributedOperationCallback::OnStsOperationCallback(ani_env *env, const
     ANS_LOGD("operationResult %{public}d, externalCode %{public}d", operationResult, externalErrCode);
 
     if (externalErrCode == ERR_OK) {
-        ANS_LOGD("OnStsOperationCallback Resolve");
+        ANS_LOGD("OnStsOperationCallback resolve");
         ani_object ret = OHOS::AppExecFwk::CreateInt(env, externalErrCode);
         if (ANI_OK != (status = env->PromiseResolver_Resolve(resolver_, static_cast<ani_ref>(ret)))) {
-            ANS_LOGD("PromiseResolver_Resolve faild. status %{public}d", status);
+            ANS_LOGE("PromiseResolver_Resolve faild. status %{public}d", status);
             return;
         }
     } else {
@@ -82,7 +85,7 @@ void StsDistributedOperationCallback::OnStsOperationCallback(ani_env *env, const
         ani_error rejection =
             static_cast<ani_error>(OHOS::NotificationSts::CreateError(env, externalErrCode, errMsg));
         if (ANI_OK != (status = env->PromiseResolver_Reject(resolver_, rejection))) {
-            ANS_LOGD("PromiseResolver_Resolve faild. status %{public}d", status);
+            ANS_LOGE("PromiseResolver_Resolve faild. status %{public}d", status);
         }
     }
 }
-- 
Gitee