Searched refs:eoe_op (Results 1 – 3 of 3) sorted by relevance
97 for (auto &eoe_op : eoe_ops_) { in EoeReceived() local98 MS_LOG(DEBUG) << "Repeat operator sending reset to operator: " << eoe_op->id(); in EoeReceived()99 RETURN_IF_NOT_OK(eoe_op->Reset()); in EoeReceived()135 for (auto &eoe_op : eoe_ops_) { in Reset() local136 MS_LOG(DEBUG) << "Nested repeat operator bouncing a reset to operator: " << eoe_op->id(); in Reset()137 RETURN_IF_NOT_OK(eoe_op->Reset()); in Reset()
71 for (auto &eoe_op : eoe_ops_) { in EoeReceived() local72 MS_LOG(DEBUG) << "Epoch Control driving reset to op: " << eoe_op->id(); in EoeReceived()73 RETURN_IF_NOT_OK(eoe_op->Reset()); in EoeReceived()
104 void AddToEoeList(std::shared_ptr<DatasetOp> eoe_op) { eoe_ops_.push_back(std::move(eoe_op)); } in AddToEoeList() argument