Home
last modified time | relevance | path

Searched refs:OpState (Results 1 – 13 of 13) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Drepeat_op.cc69 if (state_ == OpState::kDeOpIdle) { in GetNextRow()
90 state_ = OpState::kDeOpIdle; in EoeReceived()
93 state_ = OpState::kDeOpRunning; in EoeReceived()
139 state_ = OpState::kDeOpRunning; in Reset()
Depoch_ctrl_op.cc68 state_ = OpState::kDeOpIdle; in EoeReceived()
Ddataset_op.h77 enum OpState { kDeOpRunning = 0, kDeOpIdle = 1, kDeOpTerminated }; enum
379 …OpState state_; // The state of the operator, Runni…
Dbarrier_op.cc156 state_ = OpState::kDeOpIdle; in EoeReceived()
Dproject_op.cc101 state_ = OpState::kDeOpIdle; in EoeReceived()
Ddataset_op.cc45 state_(OpState::kDeOpIdle), in DatasetOp()
333 state_ = OpState::kDeOpRunning; in Reset()
Dzip_op.cc89 state_ = OpState::kDeOpIdle; in EoeReceived()
Dshuffle_op.cc252 state_ = OpState::kDeOpIdle; in EoeReceived()
Dbucket_batch_by_length_op.cc53 state_ = OpState::kDeOpIdle; in EoeReceived()
Dcache_op.cc181 state_ = OpState::kDeOpIdle; in EoeReceived()
Ddevice_queue_op.cc88 state_ = OpState::kDeOpIdle; in EoeReceived()
Dbatch_op.cc276 state_ = OpState::kDeOpIdle; in EoeReceived()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/
Dexecution_tree.cc209 itr->state_ = DatasetOp::OpState::kDeOpRunning; in Launch()