Searched refs:pre_count (Results 1 – 9 of 9) sorted by relevance
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/ |
| D | nonmappable_leaf_op.cc | 215 int64_t *end_offset, const int64_t &pre_count) { in NeedPushFileToBlockQueue() argument
226 if (pre_count <= start_index && pre_count + filename_numrows_[file_name] > start_index) { in NeedPushFileToBlockQueue()
227 *start_offset = start_index - pre_count; in NeedPushFileToBlockQueue()
229 if (pre_count < end_index && pre_count + filename_numrows_[file_name] >= end_index) { in NeedPushFileToBlockQueue()
230 *end_offset = end_index - pre_count; in NeedPushFileToBlockQueue()
236 if (pre_count >= start_index && pre_count < end_index) { in NeedPushFileToBlockQueue()
239 if (pre_count + filename_numrows_[file_name] >= end_index) { in NeedPushFileToBlockQueue()
240 *end_offset = end_index - pre_count; in NeedPushFileToBlockQueue()
|
| D | text_file_op.cc | 124 int64_t pre_count = 0; in FillIOBlockQueue() local
150 if (NeedPushFileToBlockQueue(file_info.first, &start_offset, &end_offset, pre_count)) { in FillIOBlockQueue()
157 pre_count += filename_numrows_[file_info.first]; in FillIOBlockQueue()
160 if (pre_count < (static_cast<int64_t>(device_id_) + 1) * num_rows_per_shard_) { in FillIOBlockQueue()
|
| D | clue_op.cc | 163 int64_t pre_count = 0; in FillIOBlockQueue() local
189 if (NeedPushFileToBlockQueue(file_info.first, &start_offset, &end_offset, pre_count)) { in FillIOBlockQueue()
196 pre_count += filename_numrows_[file_info.first]; in FillIOBlockQueue()
199 if (pre_count < (static_cast<int64_t>(device_id_) + 1) * num_rows_per_shard_) { in FillIOBlockQueue()
|
| D | tf_reader_op.cc | 180 int64_t pre_count = 0; in FillIOBlockShuffle() local
203 if (NeedPushFileToBlockQueue(file_name, &start_offset, &end_offset, pre_count)) { in FillIOBlockShuffle()
210 pre_count += filename_numrows_[file_name]; in FillIOBlockShuffle()
213 …if (equal_rows_per_shard_ && pre_count < (static_cast<int64_t>(device_id_) + 1) * num_rows_per_sha… in FillIOBlockShuffle()
227 int64_t pre_count = 0; in FillIOBlockNoShuffle() local
251 if (NeedPushFileToBlockQueue(file_name, &start_offset, &end_offset, pre_count)) { in FillIOBlockNoShuffle()
257 pre_count += filename_numrows_[file_name]; in FillIOBlockNoShuffle()
260 …if (equal_rows_per_shard_ && pre_count < (static_cast<int64_t>(device_id_) + 1) * num_rows_per_sha… in FillIOBlockNoShuffle()
|
| D | usps_op.cc | 292 int64_t pre_count = 0; in FillIOBlockQueue() local
318 if (NeedPushFileToBlockQueue(file_info.first, &start_offset, &end_offset, pre_count)) { in FillIOBlockQueue()
325 pre_count += filename_numrows_[file_info.first]; in FillIOBlockQueue()
328 if (pre_count < (static_cast<int64_t>(device_id_) + 1) * num_rows_per_shard_) { in FillIOBlockQueue()
|
| D | nonmappable_leaf_op.h | 133 const int64_t &pre_count);
|
| D | csv_op.cc | 518 int64_t pre_count = 0; in FillIOBlockQueue() local
544 if (NeedPushFileToBlockQueue(file_info.first, &start_offset, &end_offset, pre_count)) { in FillIOBlockQueue()
551 pre_count += filename_numrows_[file_info.first]; in FillIOBlockQueue()
554 if (pre_count < (static_cast<int64_t>(device_id_) + 1) * num_rows_per_shard_) { in FillIOBlockQueue()
|
| /third_party/gstreamer/gstreamer/docs/random/wtay/ |
| D | rwlocks | 4 int pre_count;
17 if (atomic_get (lock->pre_count) != post) {
28 atomic_inc (lock->pre_count);
|
| /third_party/gstreamer/gstreamer/gst/ |
| D | gstclock.c | 218 gint pre_count; member
238 if (G_LIKELY (seq == g_atomic_int_get (&clock->priv->pre_count))) in read_seqretry()
250 g_atomic_int_inc (&clock->priv->pre_count); \
|