| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/ |
| D | zip_op.cc | 33 bool retry_if_eoe) { in getNextZippedRow() argument
38 RETURN_IF_NOT_OK(child_[i]->GetNextRow(&new_row, worker_id, retry_if_eoe)); in getNextZippedRow()
52 Status ZipOp::drainPipeline(int32_t skip_child, int32_t worker_id, bool retry_if_eoe) { in drainPipeline() argument
58 RETURN_IF_NOT_OK(child_[con]->GetNextRow(&row, worker_id, retry_if_eoe)); in drainPipeline()
122 Status ZipOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
124 RETURN_IF_NOT_OK(getNextZippedRow(row, &skip_child, worker_id, retry_if_eoe)); in GetNextRow()
128 RETURN_IF_NOT_OK(drainPipeline(skip_child, worker_id, retry_if_eoe)); in GetNextRow()
|
| D | zip_op.h | 67 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
76 Status drainPipeline(int32_t skip_child, int32_t worker_id, bool retry_if_eoe);
89 …ZippedRow(TensorRow *const new_zip_row, int32_t *skip_child, int32_t worker_id, bool retry_if_eoe);
|
| D | skip_op.cc | 49 Status SkipOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
52 RETURN_IF_NOT_OK(child_[0]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
60 RETURN_IF_NOT_OK(child_[0]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
|
| D | concat_op.cc | 150 Status ConcatOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
157 RETURN_IF_NOT_OK(child_[cur_child_]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
163 RETURN_IF_NOT_OK(GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
182 RETURN_IF_NOT_OK(GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
188 RETURN_IF_NOT_OK(child_[i]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
|
| D | take_op.cc | 44 Status TakeOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
47 RETURN_IF_NOT_OK(child_[0]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
58 RETURN_IF_NOT_OK(child_[0]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
|
| D | project_op.cc | 51 Status ProjectOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
52 RETURN_IF_NOT_OK(child_[0]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
|
| D | rename_op.cc | 36 Status RenameOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
37 RETURN_IF_NOT_OK(child_[0]->GetNextRow(row, worker_id, retry_if_eoe)); in GetNextRow()
|
| D | epoch_ctrl_op.h | 46 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | skip_op.h | 51 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | take_op.h | 61 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | rename_op.h | 65 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | epoch_ctrl_op.cc | 43 Status EpochCtrlOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
|
| D | project_op.h | 62 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | repeat_op.h | 70 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | concat_op.h | 75 Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) override;
|
| D | repeat_op.cc | 60 Status RepeatOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
|
| D | dataset_op.cc | 262 Status DatasetOp::GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe) { in GetNextRow() argument
264 RETURN_IF_NOT_OK(out_connector_->PopWithRetry(static_cast<int>(worker_id), row, retry_if_eoe)); in GetNextRow()
|
| D | dataset_op.h | 163 virtual Status GetNextRow(TensorRow *row, int32_t worker_id, bool retry_if_eoe);
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/ |
| D | db_connector.h | 69 Status PopWithRetry(int32_t worker_id, TensorRow *result, bool retry_if_eoe = false) noexcept {
88 if (!(result->eoe() && retry_if_eoe)) {
|