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 01/12] 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 02/12] 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 From 6699ed5e24dbedaa15b5edd7933089313d6c127c Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Mon, 25 Aug 2025 02:10:19 +0000 Subject: [PATCH 03/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 1 + 1 file changed, 1 insertion(+) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 34dc45382..7c8861496 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -239,6 +239,7 @@ 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)); + ADP_LOG(FATAL) << "BEGIN CALL ACL_SEND_DATAOK"; return Status::OK(); } -- Gitee From dfad36b8c596d9449e31ae5b420b6b52616d3ab0 Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Mon, 25 Aug 2025 03:06:02 +0000 Subject: [PATCH 04/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 8 -------- 1 file changed, 8 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 7c8861496..4e256f074 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -231,14 +231,6 @@ Status RecvTensorByAcl(const acltdtChannelHandle *acl_handle, std::vector &tensors, bool &need_resend) { - need_resend = false; - acltdtDataset *acl_dataset = nullptr; - std::vector> buff_list; - TF_RETURN_IF_ERROR(AssembleTensors2AclDataset(acl_type, tensors, &acl_dataset, buff_list)); - const int32_t kTimeout = 3000; - ADP_LOG(FATAL) << "BEGIN CALL ACL_SEND_DATA"; - // auto acl_status = acltdtSendTensor(acl_handle, acl_dataset, kTimeout); - TF_RETURN_IF_ERROR(DestroyAclDataset(acl_dataset)); ADP_LOG(FATAL) << "BEGIN CALL ACL_SEND_DATAOK"; return Status::OK(); } -- Gitee From ebfbb2a49975df21fca8009521f7169540c5367e Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Tue, 26 Aug 2025 02:46:03 +0000 Subject: [PATCH 05/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 37 ++++++++++++++++++++++++++++++++++ 1 file changed, 37 insertions(+) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 4e256f074..e1da7c5a6 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -231,6 +231,43 @@ Status RecvTensorByAcl(const acltdtChannelHandle *acl_handle, std::vector &tensors, bool &need_resend) { + need_resend = false; + acltdtDataset *acl_dataset = nullptr; + std::vector> buff_list; + TF_RETURN_IF_ERROR(AssembleTensors2AclDataset(acl_type, tensors, &acl_dataset, buff_list)); + + LOG(FATAL) << "Tacl_type"; + LOG(FATAL) << acl_type; + LOG(FATAL) << "Ttensors"; + LOG(FATAL) << tensors; + LOG(FATAL) << "&Ttensors1"; + LOG(FATAL) << tensors.shape(); + LOG(FATAL) << "&Ttensors2"; + LOG(FATAL) << tensors.size(); + LOG(FATAL) << "&Ttensors3"; + LOG(FATAL) << tensors.tostring(); + + LOG(FATAL) << "Tacl_dataset"; + LOG(FATAL) << acl_dataset; + LOG(FATAL) << "&Tacl_dataset"; + LOG(FATAL) << &acl_dataset; + LOG(FATAL) << "buff_list"; + LOG(FATAL) << buff_list; + + + const int32_t kTimeout = 10000; + 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); + } ADP_LOG(FATAL) << "BEGIN CALL ACL_SEND_DATAOK"; return Status::OK(); } -- Gitee From 97a378ccffc46ab9402c27f0bdf84370d13e7508 Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Tue, 26 Aug 2025 02:59:48 +0000 Subject: [PATCH 06/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 2 -- 1 file changed, 2 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index e1da7c5a6..7abacd20c 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -238,8 +238,6 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType LOG(FATAL) << "Tacl_type"; LOG(FATAL) << acl_type; - LOG(FATAL) << "Ttensors"; - LOG(FATAL) << tensors; LOG(FATAL) << "&Ttensors1"; LOG(FATAL) << tensors.shape(); LOG(FATAL) << "&Ttensors2"; -- Gitee From e6536572c2e80f1912b6c4565c4d6c888132cca2 Mon Sep 17 00:00:00 2001 From: majunwang <844234020@qq.com> Date: Tue, 26 Aug 2025 03:09:19 +0000 Subject: [PATCH 07/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 7abacd20c..0452ba7b4 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -238,19 +238,23 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType LOG(FATAL) << "Tacl_type"; LOG(FATAL) << acl_type; - LOG(FATAL) << "&Ttensors1"; - LOG(FATAL) << tensors.shape(); LOG(FATAL) << "&Ttensors2"; LOG(FATAL) << tensors.size(); - LOG(FATAL) << "&Ttensors3"; - LOG(FATAL) << tensors.tostring(); + + for (int i = 0; i Date: Tue, 26 Aug 2025 03:15:16 +0000 Subject: [PATCH 08/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 0452ba7b4..db2a20c90 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -241,12 +241,10 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType LOG(FATAL) << "&Ttensors2"; LOG(FATAL) << tensors.size(); - for (int i = 0; i Date: Tue, 26 Aug 2025 03:20:10 +0000 Subject: [PATCH 09/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index db2a20c90..c56a87c60 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -241,10 +241,9 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType LOG(FATAL) << "&Ttensors2"; LOG(FATAL) << tensors.size(); - for (int i = 0; i Date: Tue, 26 Aug 2025 06:14:07 +0000 Subject: [PATCH 10/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index c56a87c60..4692dc236 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -236,23 +236,23 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType std::vector> buff_list; TF_RETURN_IF_ERROR(AssembleTensors2AclDataset(acl_type, tensors, &acl_dataset, buff_list)); - LOG(FATAL) << "Tacl_type"; - LOG(FATAL) << acl_type; - LOG(FATAL) << "&Ttensors2"; - LOG(FATAL) << tensors.size(); - - for (size_t i = 0; i Date: Tue, 26 Aug 2025 06:41:09 +0000 Subject: [PATCH 11/12] update tf_adapter/util/acl_channel.cc. Signed-off-by: majunwang <844234020@qq.com> --- tf_adapter/util/acl_channel.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 4692dc236..82a34d23c 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -249,7 +249,7 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType ADP_LOG(ERROR) << "&Tacl_dataset"; ADP_LOG(ERROR) << &acl_dataset; - for (size_t i = 0; i<10; i++) + for (size_t i = 0; i Date: Tue, 26 Aug 2025 08:11:57 +0000 Subject: [PATCH 12/12] 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 82a34d23c..9fea51651 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -263,7 +263,8 @@ Status SendTensorsByAcl(const acltdtChannelHandle *acl_handle, acltdtTensorType 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 + 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); } -- Gitee