diff --git a/tf_adapter/util/acl_channel.cc b/tf_adapter/util/acl_channel.cc index 17c7961411fe1a6bf3130103be35c54930d39fee..34dc45382f32eb7833f132611a68cd643ee4c6d1 100644 --- a/tf_adapter/util/acl_channel.cc +++ b/tf_adapter/util/acl_channel.cc @@ -236,19 +236,9 @@ 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; - 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(); }