Home
last modified time | relevance | path

Searched refs:acl_handle_ (Results 1 – 7 of 7) sorted by relevance

/third_party/mindspore/mindspore/core/utils/
Dms_context.cc129 acl_handle_ = acltdtCreateChannel(device_id, (kReceivePrefix + channel_name).c_str()); in CreateTensorPrintThread()
130 if (acl_handle_ == nullptr) { in CreateTensorPrintThread()
135 acl_tdt_print_ = ctr(print_file_path, acl_handle_); in CreateTensorPrintThread()
136 TdtHandle::AddHandle(&acl_handle_, &acl_tdt_print_); in CreateTensorPrintThread()
153 if (acl_handle_ == nullptr) { in DestroyTensorPrintThread()
158 aclError stopStatus = acltdtStopChannel(acl_handle_); in DestroyTensorPrintThread()
165 aclError destroydStatus = acltdtDestroyChannel(acl_handle_); in DestroyTensorPrintThread()
170 TdtHandle::DelHandle(&acl_handle_); in DestroyTensorPrintThread()
Dms_context.h195 acltdtChannelHandle *acl_handle_ = nullptr; variable
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/tdt/
Dtdt_plugin.cc36 acl_handle_ = acltdtCreateChannel(device_id, channel_name.c_str()); in TdtPlugin()
37 if (acl_handle_ == nullptr) { in TdtPlugin()
42 TdtHandle::AddHandle(&acl_handle_, nullptr); in TdtPlugin()
46 if (acl_handle_ != nullptr) { in ~TdtPlugin()
47 if (acltdtDestroyChannel(acl_handle_) != ACL_SUCCESS) { in ~TdtPlugin()
51 TdtHandle::DelHandle(&acl_handle_); in ~TdtPlugin()
52 acl_handle_ = nullptr; in ~TdtPlugin()
90 auto status = acltdtSendTensor(acl_handle_, acl_dataset, -1); in hostPush()
Dtdt_plugin.h49 acltdtChannelHandle *acl_handle_; variable
/third_party/mindspore/mindspore/ccsrc/utils/
Dtensorprint_utils.h34 : print_file_path_(path), acl_handle_(acl_handle) {} in TensorPrint()
40 const acltdtChannelHandle *acl_handle_; variable
Dtensorprint_utils.cc284 if (acltdtReceiveTensor(acl_handle_, acl_dataset, -1 /* no timeout */) != ACL_SUCCESS) { in operator ()()
301 if (acltdtReceiveTensor(acl_handle_, acl_dataset, -1 /* no timeout */) != ACL_SUCCESS) { in operator ()()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Ddevice_queue_op.cc154 if (tdtInstancePtr->acl_handle_ == nullptr) { in operator ()()