From cfde0d820098eeee06e8e0b6714c3da4b74fe09d Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Mon, 25 Aug 2025 01:18:10 +0000 Subject: [PATCH 1/2] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 17c796141..b0cc9e1a8 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -236,7 +236,8 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType std::vector> buff_list; TF_RETURN_IF_ERROR(AssembleTensors2AclDataset(acl_type, tensors, &acl_dataset, buff_list)); const int32_t kTimeout = 3000; - auto acl_status = acltdtSendTensor(acl_handle, acl_dataset, kTimeout); + ADP_LOG(FATAL) << "BEGIN CALL ACL_SEND_DATA"; + // auto acl_status = acltdtSendTensor(acl_handle, acl_dataset, kTimeout); TF_RETURN_IF_ERROR(DestroyAclDataset(acl_dataset)); if (acl_status == ACL_ERROR_RT_QUEUE_FULL) { need_resend = true; -- Gitee From 90d03debd29297933b37892f3174d88700e89ad8 Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Mon, 25 Aug 2025 02:06:55 +0000 Subject: [PATCH 2/2] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index b0cc9e1a8..34dc45382 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -239,17 +239,6 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType ADP_LOG(FATAL) << "BEGIN CALL ACL_SEND_DATA"; // auto acl_status = acltdtSendTensor(acl_handle, acl_dataset, kTimeout); TF_RETURN_IF_ERROR(DestroyAclDataset(acl_dataset)); - if (acl_status == ACL_ERROR_RT_QUEUE_FULL) { - need_resend = true; - ADP_LOG(INFO) << "Queue is full , try to send data again."; - return Status::OK(); - } - if (acl_status != ACL_ERROR_NONE) { - sleep(kWaitingForLogRecord); - LOG(FATAL) << "Failed to send data by acl, error code : "<< acl_status << std::endl - << "Error Message is " << std::endl << ge::GEGetErrorMsgV2().GetString(); - return errors::Internal("Acl send data failed, acl status:", acl_status); - } return Status::OK(); } -- Gitee