Home
last modified time | relevance | path

Searched refs:num_workers_paused_ (Results 1 – 6 of 6) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Dparallel_op.cc33 num_workers_paused_(0), in ParallelOp()
86 num_workers_paused_ = 0; in WaitForWorkers()
Dparallel_op.h110 std::atomic_int num_workers_paused_; variable
Dcache_base_op.cc172 if (++num_workers_paused_ == num_workers_) { in FetchFromCache()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/
Dmappable_leaf_op.cc99 if (++num_workers_paused_ == num_workers_) { in WorkerEntry()
Dmindrecord_op.cc154 if (++num_workers_paused_ == num_workers_) { in WorkerEntry()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/map_op/
Dmap_op.cc218 if (++num_workers_paused_ == num_workers_) { in WorkerEntry()
414 num_workers_paused_ = 0; in WaitForWorkers()