| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/ |
| D | cache_base_op.cc | 106 for (auto row_id : prefetch_keys) { in FetchSamplesToWorkers() local
107 keys.push_back(row_id); in FetchSamplesToWorkers()
119 for (auto row_id : prefetch_keys) { in FetchSamplesToWorkers() local
120 keys.push_back(row_id); in FetchSamplesToWorkers()
186 for (auto row_id : keys) { in FetchFromCache() local
189 RETURN_IF_NOT_OK(GetPrefetchRow(row_id, &row)); in FetchFromCache()
194 std::string errMsg = "Row id " + std::to_string(row_id) + " not found."; in FetchFromCache()
228 Status CacheBase::GetPrefetchRow(row_id_type row_id, TensorRow *out) { in GetPrefetchRow() argument
230 …CHECK_FAIL_RETURN_UNEXPECTED(row_id >= 0, "Expect positive row id, but got:" + std::to_string(row_… in GetPrefetchRow()
231 RETURN_IF_NOT_OK(prefetch_.PopFront(row_id, out)); in GetPrefetchRow()
[all …]
|
| D | cache_merge_op.cc | 83 auto row_id = new_row.getId(); in WorkerEntry() local
85 RETURN_IF_NOT_OK(cache_miss_.PopFront(row_id, &new_row)); in WorkerEntry()
124 row_id_type row_id = new_row.getId(); in CacheMissWorkerEntry() local
125 if (row_id < 0) { in CacheMissWorkerEntry()
126 std::string errMsg = "Expect positive row id, but got: " + std::to_string(row_id); in CacheMissWorkerEntry()
133 RETURN_IF_NOT_OK(GetRq(row_id, &rq)); in CacheMissWorkerEntry()
139 RETURN_IF_NOT_OK(io_que_->EmplaceBack(row_id)); in CacheMissWorkerEntry()
146 RETURN_IF_NOT_OK(cache_miss_.Add(row_id, std::move(new_row))); in CacheMissWorkerEntry()
156 row_id_type row_id; in Cleaner() local
157 RETURN_IF_NOT_OK(io_que_->PopFront(&row_id)); in Cleaner()
[all …]
|
| /third_party/boost/libs/regex/performance/ |
| D | table_helper.cpp | 235 unsigned row_id = 1001; in add_cell() local
240 row_id = i; in add_cell()
244 if(row_id > 1000) in add_cell()
253 row_id = table_data.size() - 1; in add_cell()
260 for(unsigned i = 1; i < table_data[row_id].size(); ++i) in add_cell()
270 std::cout << "Existing cell value was " << table_data[row_id][i] << std::endl; in add_cell()
271 boost::uintmax_t cell_val = get_value_from_cell(table_data[row_id][i]); in add_cell()
281 for(unsigned i = 1; i < table_data[row_id].size(); ++i) in add_cell()
283 std::string& s = table_data[row_id][i]; in add_cell()
|
| /third_party/boost/libs/math/reporting/performance/ |
| D | table_helper.cpp | 245 unsigned row_id = 1001; in add_cell() local
250 row_id = i; in add_cell()
254 if(row_id > 1000) in add_cell()
263 row_id = table_data.size() - 1; in add_cell()
270 for(unsigned i = 1; i < table_data[row_id].size(); ++i) in add_cell()
280 std::cout << "Existing cell value was " << table_data[row_id][i] << std::endl; in add_cell()
281 boost::uintmax_t cell_val = get_value_from_cell(table_data[row_id][i]); in add_cell()
291 for(unsigned i = 1; i < table_data[row_id].size(); ++i) in add_cell()
293 std::string& s = table_data[row_id][i]; in add_cell()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_service.cc | 98 if (msg->row_id() < 0) { in CacheRow()
99 std::string errMsg = "Expect positive row id: " + std::to_string(msg->row_id()); in CacheRow()
102 *row_id_generated = msg->row_id(); in CacheRow()
169 if (msg->row_id() < 0) { in FastCacheRow()
170 std::string errMsg = "Expect positive row id: " + std::to_string(msg->row_id()); in FastCacheRow()
173 *row_id_generated = msg->row_id(); in FastCacheRow()
245 for (auto row_id : v) { in PreBatchFetch() local
247 RETURN_IF_NOT_OK(cp_->GetDataLocator(row_id, fbb, &offset)); in PreBatchFetch()
|
| D | de_tensor.fbs | 44 /// \param row_id is the row id of the TensorRow.
49 row_id:int64;
59 row_id:[int64] (required);
|
| D | cache_client.cc | 128 Status CacheClient::GetRows(const std::vector<row_id_type> &row_id, TensorTable *out) const { in GetRows() argument
130 auto rq = std::make_shared<BatchFetchRequest>(this, row_id); in GetRows()
318 auto sz = p->row_id()->size(); in ServerRunningOutOfResources()
321 row_ids.push_back(p->row_id()->Get(i)); in ServerRunningOutOfResources()
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/gpu/cuda_impl/ |
| D | transpose_impl_opt.cu | 127 for (int row_id = shm_row_id; row_id < (TileHeight); in Swap3DTensorLast2DimKernel_shared() local
128 row_id += NumRowsPerLoadLoop) { // move to the next pass, loop in Swap3DTensorLast2DimKernel_shared()
130 shm_tile[row_id * (TileWidth + 1) + shm_col_id] = in Swap3DTensorLast2DimKernel_shared()
136 for (int row_id = shm_row_id; row_id < (tile_height); row_id += NumRowsPerLoadLoop) { in Swap3DTensorLast2DimKernel_shared() local
138 shm_tile[row_id * (TileWidth + 1) + shm_col_id] = input[input_idx]; in Swap3DTensorLast2DimKernel_shared()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/ |
| D | mindrecord_op.cc | 183 const uint64_t row_id = keys[0]; in WorkerEntry() local
187 if (row_id % LOG_INTERVAL == 0) { in WorkerEntry()
188 …MS_LOG(DEBUG) << "MindRecord operator consumed row " << row_id << " by worker " << worker_id << ".… in WorkerEntry()
190 RETURN_IF_NOT_OK(GetRowFromReader(&fetched_row, row_id, worker_id)); in WorkerEntry()
197 Status MindRecordOp::GetRowFromReader(TensorRow *fetched_row, uint64_t row_id, int32_t worker_id) { in GetRowFromReader() argument
199 auto rc = shard_reader_->GetNextById(row_id, worker_id); in GetRowFromReader()
206 fetched_row->setId(row_id); in GetRowFromReader()
218 fetched_row->setId(row_id); in GetRowFromReader()
|
| D | coco_op.cc | 79 Status CocoOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
80 std::string image_id = image_ids_[row_id]; in LoadTensorRow()
115 RETURN_IF_NOT_OK(LoadDetectionTensorRow(row_id, image_id, image, coordinate, trow)); in LoadTensorRow()
117 RETURN_IF_NOT_OK(LoadSimpleTensorRow(row_id, image_id, image, coordinate, trow)); in LoadTensorRow()
119 RETURN_IF_NOT_OK(LoadMixTensorRow(row_id, image_id, image, coordinate, trow)); in LoadTensorRow()
127 Status CocoOp::LoadDetectionTensorRow(row_id_type row_id, const std::string &image_id, std::shared_… in LoadDetectionTensorRow() argument
152 …(*trow) = TensorRow(row_id, {std::move(image), std::move(coordinate), std::move(category_id), std:… in LoadDetectionTensorRow()
171 Status CocoOp::LoadSimpleTensorRow(row_id_type row_id, const std::string &image_id, std::shared_ptr… in LoadSimpleTensorRow() argument
185 (*trow) = TensorRow(row_id, {std::move(image), std::move(coordinate), std::move(item)}); in LoadSimpleTensorRow()
204 Status CocoOp::LoadMixTensorRow(row_id_type row_id, const std::string &image_id, std::shared_ptr<Te… in LoadMixTensorRow() argument
[all …]
|
| D | coco_op.h | 188 Status LoadTensorRow(row_id_type row_id, TensorRow *row) override;
197 …Status LoadDetectionTensorRow(row_id_type row_id, const std::string &image_id, std::shared_ptr<Ten…
207 …Status LoadSimpleTensorRow(row_id_type row_id, const std::string &image_id, std::shared_ptr<Tensor…
217 …Status LoadMixTensorRow(row_id_type row_id, const std::string &image_id, std::shared_ptr<Tensor> i…
|
| D | mnist_op.cc | 45 Status MnistOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
46 MnistLabelPair mnist_pair = image_label_pairs_[row_id]; in LoadTensorRow()
52 (*trow) = TensorRow(row_id, {std::move(image), std::move(label)}); in LoadTensorRow()
53 trow->setPath({image_path_[row_id], label_path_[row_id]}); in LoadTensorRow()
|
| D | mindrecord_op.h | 121 Status GetRowFromReader(TensorRow *fetched_row, uint64_t row_id, int32_t worker_id);
130 Status LoadTensorRow(row_id_type row_id, TensorRow *row) override { in LoadTensorRow() argument
|
| D | flickr_op.cc | 61 Status FlickrOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
62 …std::string, std::vector<std::string>> data = image_annotation_pairs_[static_cast<size_t>(row_id)]; in LoadTensorRow()
76 (*trow) = TensorRow(row_id, {std::move(image), std::move(annotations)}); in LoadTensorRow()
|
| D | sbu_op.cc | 62 Status SBUOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
65 SBUImageCaptionPair image_caption_pair = image_caption_pairs_[row_id]; in LoadTensorRow()
72 (*trow) = TensorRow(row_id, {std::move(image), std::move(caption)}); in LoadTensorRow()
|
| D | voc_op.cc | 77 Status VOCOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
78 std::string image_id = image_ids_[row_id]; in LoadTensorRow()
88 (*trow) = TensorRow(row_id, {std::move(image), std::move(target)}); in LoadTensorRow()
97 trow->setId(row_id); in LoadTensorRow()
|
| D | celeba_op.cc | 246 Status CelebAOp::LoadTensorRow(row_id_type row_id, TensorRow *row) { in LoadTensorRow() argument
247 std::pair<std::string, std::vector<int32_t>> &image_label = image_labels_vec_[row_id]; in LoadTensorRow()
275 (*row) = TensorRow(row_id, {std::move(image), std::move(label)}); in LoadTensorRow()
|
| D | cityscapes_op.cc | 67 Status CityscapesOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
69 std::pair<std::string, std::string> data = image_task_pairs_[static_cast<size_t>(row_id)]; in LoadTensorRow()
105 (*trow) = TensorRow(row_id, {std::move(image), std::move(task)}); in LoadTensorRow()
|
| D | manifest_op.cc | 64 Status ManifestOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
65 …::pair<std::string, std::vector<std::string>> data = image_labelname_[static_cast<size_t>(row_id)]; in LoadTensorRow()
86 (*trow) = TensorRow(row_id, {std::move(image), std::move(label)}); in LoadTensorRow()
|
| D | div2k_op.cc | 88 Status DIV2KOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
90 std::pair<std::string, std::string> data = image_hr_lr_pairs_[static_cast<size_t>(row_id)]; in LoadTensorRow()
109 (*trow) = TensorRow(row_id, {std::move(hr_image), std::move(lr_image)}); in LoadTensorRow()
|
| D | mappable_leaf_op.h | 89 virtual Status LoadTensorRow(row_id_type row_id, TensorRow *row) = 0;
|
| D | image_folder_op.cc | 85 Status ImageFolderOp::LoadTensorRow(row_id_type row_id, TensorRow *trow) { in LoadTensorRow() argument
86 ImageLabelPair pair_ptr = image_label_pairs_[row_id]; in LoadTensorRow()
98 (*trow) = TensorRow(row_id, {std::move(image), std::move(label)}); in LoadTensorRow()
|
| D | celeba_op.h | 93 Status LoadTensorRow(row_id_type row_id, TensorRow *row) override;
|
| D | sbu_op.h | 76 Status LoadTensorRow(row_id_type row_id, TensorRow *row) override;
|
| /third_party/boost/libs/math/reporting/accuracy/ |
| D | handle_test_result.hpp | 207 unsigned row_id = 1001; in add_cell() local
212 row_id = i; in add_cell()
216 if(row_id > 1000) in add_cell()
225 row_id = table_data.size() - 1; in add_cell()
230 std::string& s = table_data[row_id][column_id]; in add_cell()
|