Home
last modified time | relevance | path

Searched refs:FindMe (Results 1 – 25 of 47) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/
Dtask_manager.h87 static Task *FindMe();
171 Task *my_task = TaskManager::FindMe(); in is_interrupted()
176 Task *my_task = TaskManager::FindMe(); in is_master_thread()
181 Task *my_task = TaskManager::FindMe(); in GetInterruptStatus()
Dtask_manager.cc93 Task *TaskManager::FindMe() { in FindMe() function in mindspore::dataset::TaskManager
186 TaskManager::FindMe()->Post(); in WatchDog()
282 auto pMytask = TaskManager::FindMe(); in CreateAsyncTask()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgraph_data_server.cc65 TaskManager::FindMe()->Post(); in InitGraphDataImpl()
77 TaskManager::FindMe()->Post(); in StartAsyncRpcService()
84 TaskManager::FindMe()->Post(); in JudgeAutoShutdownServer()
/third_party/mindspore/tests/ut/cpp/dataset/
Dinterrupt_test.cc42 TaskManager::FindMe()->Post(); in TEST_F()
60 TaskManager::FindMe()->Post(); in TEST_F()
Dtask_manager_test.cc35 TaskManager::FindMe()->Post(); in TEST_F()
69 TaskManager::FindMe()->Post(); in TEST_F()
Dconnector_test.cc250 TaskManager::FindMe()->Post(); in SerialWorkerPull()
279 TaskManager::FindMe()->Post(); in FirstWorkerPush()
299 TaskManager::FindMe()->Post(); in MidWorkerJob()
Dbtree_test.cc114 TaskManager::FindMe()->Post(); in TEST_F()
125 TaskManager::FindMe()->Post(); in TEST_F()
Dcircular_pool_test.cc49 TaskManager::FindMe()->Post(); in TestMem()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Ddevice_queue_op.cc133 TaskManager::FindMe()->Post(); in operator ()()
289 if (stop_send_ || !TaskManager::FindMe()->Interrupted()) { in SendDataToAscend()
406 TaskManager::FindMe()->Post(); in PushDataToGPU()
484 if (!TaskManager::FindMe()->Interrupted() && !GpuBufferMgr::GetInstance().IsClosed()) { in PushDataToGPU()
498 if (!TaskManager::FindMe()->Interrupted() && !GpuBufferMgr::GetInstance().IsClosed()) { in PushDataToGPU()
511 while (!GpuBufferMgr::GetInstance().IsClosed() && !TaskManager::FindMe()->Interrupted()) { in RetryPushData()
540 TaskManager::FindMe()->Post(); in WorkerEntry()
592 if (!TaskManager::FindMe()->Interrupted() && !GpuBufferMgr::GetInstance().IsClosed()) { in SendDataToGPU()
599 if (!TaskManager::FindMe()->Interrupted() && !GpuBufferMgr::GetInstance().IsClosed()) { in SendDataToGPU()
700 TaskManager::FindMe()->Post(); in DetectFirstBatch()
Dcache_merge_op.cc66 TaskManager::FindMe()->Post(); in operator ()()
73 TaskManager::FindMe()->Post(); in WorkerEntry()
96 TaskManager::FindMe()->Post(); in CacheMissWorkerEntry()
154 TaskManager::FindMe()->Post(); in Cleaner()
Dcache_lookup_op.cc39 TaskManager::FindMe()->Post(); in operator ()()
46 TaskManager::FindMe()->Post(); in WorkerEntry()
Dfilter_op.cc58 TaskManager::FindMe()->Post(); in operator ()()
120 TaskManager::FindMe()->Post(); in WorkerEntry()
173 TaskManager::FindMe()->Post(); in Collector()
Dbuild_vocab_op.cc48 TaskManager::FindMe()->Post(); in WorkerEntry()
91 TaskManager::FindMe()->Post(); in operator ()()
128 TaskManager::FindMe()->Post(); in CollectorThread()
Dcache_op.cc53 TaskManager::FindMe()->Post(); in operator ()()
164 TaskManager::FindMe()->Post(); in WorkerEntry()
Dbuild_sentence_piece_vocab_op.cc49 TaskManager::FindMe()->Post(); in operator ()()
71 TaskManager::FindMe()->Post(); in SentenceThread()
Dbarrier_op.cc39 TaskManager::FindMe()->Post(); in operator ()()
Dshuffle_op.cc113 TaskManager::FindMe()->Post(); in operator ()()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/
Dnonmappable_leaf_op.cc66 TaskManager::FindMe()->Post(); in operator ()()
133 TaskManager::FindMe()->Post(); in WorkerEntry()
256 TaskManager::FindMe()->Post(); in WaitToFillIOBlockQueue()
Dimage_folder_op.cc150 TaskManager::FindMe()->Post(); in PrescanWorkerEntry()
204 TaskManager::FindMe()->Post(); in StartAsyncWalk()
237 TaskManager::FindMe()->Post(); in LaunchThreadsAndInitOp()
Drandom_data_op.cc164 TaskManager::FindMe()->Post(); in operator ()()
233 TaskManager::FindMe()->Post(); in WorkerEntry()
Dceleba_op.cc63 TaskManager::FindMe()->Post(); in LaunchThreadsAndInitOp()
71 TaskManager::FindMe()->Post(); in ParseAttrFile()
Dmappable_leaf_op.cc92 TaskManager::FindMe()->Post(); in WorkerEntry()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/perf/
Dmonitor.cc29 TaskManager::FindMe()->Post(); in operator ()()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/map_op/
Dmap_op.cc126 TaskManager::FindMe()->Post(); in operator ()()
134 TaskManager::FindMe()->Post(); in operator ()()
202 TaskManager::FindMe()->Post(); in WorkerEntry()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/perf/
Dcache_pipeline_run.cc136 TaskManager::FindMe()->Post(); in ListenToParent()
262 TaskManager::FindMe()->Post(); in WriterWorkerEntry()
403 TaskManager::FindMe()->Post(); in ReaderWorkerEntry()

12