Home
last modified time | relevance | path

Searched refs:records_read (Results 1 – 25 of 135) sorted by relevance

123456

/dports/devel/avro-c/avro-c-1.11.0/tests/
H A Dtest_avro_1906.c35 int records_read = 0; in read_data() local
61 records_read++; in read_data()
70 fprintf(stderr, "read %d records.\n", records_read); in read_data()
77 return records_read; in read_data()
82 int records_read = 0; in read_data_datum() local
107 records_read++; in read_data_datum()
114 fprintf(stderr, "read %d records using 'datum'.\n", records_read); in read_data_datum()
121 return records_read; in read_data_datum()
H A Dtest_avro_1904.c36 int records_read = 0; in read_data() local
57 records_read++; in read_data()
66 fprintf(stderr, "read %d records.\n", records_read); in read_data()
68 if (rval != EOF || records_read != NUM_RECORDS) { in read_data()
H A Dtest_avro_1572.c45 int records_read = 0; in read_data() local
60 records_read++; in read_data()
69 …fprintf(stderr, "wanted %d records, read %d records.\n", NUM_RECORDS1 + NUM_RECORDS2, records_read… in read_data()
71 if (rval != EOF || records_read != (NUM_RECORDS1 + NUM_RECORDS2)) { in read_data()
H A Dtest_avro_1405.c48 int records_read = 0; in read_data() local
69 records_read++; in read_data()
80 if (rval != EOF || records_read != NUM_RECORDS) { in read_data()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/lib/avro/tests/
H A Dtest_avro_1906.c35 int records_read = 0; in read_data() local
61 records_read++; in read_data()
70 fprintf(stderr, "read %d records.\n", records_read); in read_data()
77 return records_read; in read_data()
82 int records_read = 0; in read_data_datum() local
107 records_read++; in read_data_datum()
114 fprintf(stderr, "read %d records using 'datum'.\n", records_read); in read_data_datum()
121 return records_read; in read_data_datum()
H A Dtest_avro_1904.c36 int records_read = 0;
57 records_read++;
66 fprintf(stderr, "read %d records.\n", records_read);
68 if (rval != EOF || records_read != NUM_RECORDS) {
H A Dtest_avro_1572.c45 int records_read = 0; in read_data() local
60 records_read++; in read_data()
69 …fprintf(stderr, "wanted %d records, read %d records.\n", NUM_RECORDS1 + NUM_RECORDS2, records_read… in read_data()
71 if (rval != EOF || records_read != (NUM_RECORDS1 + NUM_RECORDS2)) { in read_data()
H A Dtest_avro_1405.c48 int records_read = 0; in read_data() local
69 records_read++; in read_data()
80 if (rval != EOF || records_read != NUM_RECORDS) { in read_data()
/dports/biology/biolibc-tools/biolibc-tools-0.1.1/
H A Dfastx-derep.c43 size_t records_read, in main() local
80 records_read = records_written = hash_time = in main()
85 ++records_read; in main()
123 records_read, records_written, records_read - records_written); in main()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/parquet/src/arrow/
H A Drecord_reader.rs101 let mut records_read = 0; in read_records() localVariable
110 records_read += self.split_records(num_records - records_read)?; in read_records()
121 records_read += 1; in read_records()
137 Ok(records_read) in read_records()
383 let mut records_read = 0; in split_records() localVariable
390 records_read += 1; in split_records()
399 Ok(records_read) in split_records()
402 let records_read = in split_records() localVariable
404 self.num_records += records_read; in split_records()
405 self.num_values += records_read; in split_records()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/parquet/src/arrow/
H A Drecord_reader.rs163 let mut records_read = 0; in read_records() localVariable
172 records_read += self.split_records(num_records - records_read)?; in read_records()
183 records_read += 1; in read_records()
199 Ok(records_read) in read_records()
456 let mut records_read = 0; in split_records() localVariable
463 records_read += 1; in split_records()
472 Ok(records_read) in split_records()
475 let records_read = in split_records() localVariable
477 self.num_records += records_read; in split_records()
478 self.num_values += records_read; in split_records()
[all …]
/dports/net/py-ldap0/python-ldap0-68c70989a8992cf656764e0b8acad9797895055f/ldap0/
H A Dldif.py204 records_read: int
241 self.records_read = 0
370 (max_entries is None or self.records_read < max_entries):
409 self.records_read = self.records_read + 1
438 (max_entries is None or self.records_read < max_entries):
528 self.records_read = self.records_read + 1
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/parquet/
H A Dcolumn_reader.cc1037 int64_t records_read = 0; in ReadRecords() local
1055 ++records_read; in ReadRecords()
1093 records_read += ReadRecordData(num_records - records_read); in ReadRecords()
1101 return records_read; in ReadRecords()
1137 int64_t records_read = 0; in DelimitRecords() local
1153 ++records_read; in DelimitRecords()
1154 if (records_read == num_records) { in DelimitRecords()
1173 return records_read; in DelimitRecords()
1309 int64_t records_read = 0; in ReadRecordData() local
1318 levels_position_ += records_read; in ReadRecordData()
[all …]
/dports/net/py-ldap/python-ldap-3.4.0/Lib/
H A Dldif.py284 self.records_read = 0
420 (not self._max_entries or self.records_read<self._max_entries):
450 self.records_read = self.records_read + 1
481 (not self._max_entries or self.records_read<self._max_entries):
571 self.records_read = self.records_read + 1
/dports/games/crispy-doom/crispy-doom-crispy-doom-5.10.3/src/
H A Dmidifile.c416 size_t records_read; in ReadTrackHeader() local
419 records_read = fread(&chunk_header, sizeof(chunk_header_t), 1, stream); in ReadTrackHeader()
421 if (records_read < 1) in ReadTrackHeader()
532 size_t records_read; in ReadFileHeader() local
535 records_read = fread(&file->header, sizeof(midi_header_t), 1, stream); in ReadFileHeader()
537 if (records_read < 1) in ReadFileHeader()
/dports/games/chocolate-doom/chocolate-doom-3.0.1/src/
H A Dmidifile.c416 size_t records_read; in ReadTrackHeader() local
419 records_read = fread(&chunk_header, sizeof(chunk_header_t), 1, stream); in ReadTrackHeader()
421 if (records_read < 1) in ReadTrackHeader()
532 size_t records_read; in ReadFileHeader() local
535 records_read = fread(&file->header, sizeof(midi_header_t), 1, stream); in ReadFileHeader()
537 if (records_read < 1) in ReadFileHeader()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/parquet/
H A Dcolumn_reader.cc1128 int64_t records_read = 0; in ReadRecords() local
1146 ++records_read; in ReadRecords()
1184 records_read += ReadRecordData(num_records - records_read); in ReadRecords()
1192 return records_read; in ReadRecords()
1229 int64_t records_read = 0; in DelimitRecords() local
1246 ++records_read; in DelimitRecords()
1247 if (records_read == num_records) { in DelimitRecords()
1266 return records_read; in DelimitRecords()
1402 int64_t records_read = 0; in ReadRecordData() local
1411 levels_position_ += records_read; in ReadRecordData()
[all …]
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/parquet/
H A Dcolumn_reader.cc1210 int64_t records_read = 0; in ReadRecords() local
1228 ++records_read; in ReadRecords()
1266 records_read += ReadRecordData(num_records - records_read); in ReadRecords()
1274 return records_read; in ReadRecords()
1311 int64_t records_read = 0; in DelimitRecords() local
1328 ++records_read; in DelimitRecords()
1329 if (records_read == num_records) { in DelimitRecords()
1348 return records_read; in DelimitRecords()
1484 int64_t records_read = 0; in ReadRecordData() local
1493 levels_position_ += records_read; in ReadRecordData()
[all …]
/dports/archivers/gtar/tar-1.34/src/
H A Ddelete.c37 extern off_t records_read;
106 move_archive ((records_written + records_skipped) - records_read); in write_record()
117 move_archive (records_read - (records_written + records_skipped)); in write_record()
247 records_skipped = records_read - 1; in delete_archive_members()
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dsql_planner.cc1073 pos->records_read= records; in best_access_path()
1292 record_count*= position->records_read; in optimize_straight_join()
1608 if (join->best_positions[i].records_read) in get_partial_join_cost()
2230 position->records_read == (position-1)->records_read; in eq_ref_extension_by_limited_search()
2408 if (pos->records_read > DBL_EPSILON) in prev_record_reads()
2409 found*= pos->records_read; in prev_record_reads()
2877 inner_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2879 outer_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2969 outer_fanout*= dst_pos->records_read; in semijoin_mat_scan_access_paths()
3092 inner_fanout*= p->records_read; in semijoin_dupsweedout_access_paths()
[all …]
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dsql_planner.cc1073 pos->records_read= records; in best_access_path()
1292 record_count*= position->records_read; in optimize_straight_join()
1608 if (join->best_positions[i].records_read) in get_partial_join_cost()
2230 position->records_read == (position-1)->records_read; in eq_ref_extension_by_limited_search()
2408 if (pos->records_read > DBL_EPSILON) in prev_record_reads()
2409 found*= pos->records_read; in prev_record_reads()
2877 inner_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2879 outer_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2969 outer_fanout*= dst_pos->records_read; in semijoin_mat_scan_access_paths()
3092 inner_fanout*= p->records_read; in semijoin_dupsweedout_access_paths()
[all …]
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Dsql_planner.cc1073 pos->records_read= records; in best_access_path()
1292 record_count*= position->records_read; in optimize_straight_join()
1608 if (join->best_positions[i].records_read) in get_partial_join_cost()
2230 position->records_read == (position-1)->records_read; in eq_ref_extension_by_limited_search()
2408 if (pos->records_read > DBL_EPSILON) in prev_record_reads()
2409 found*= pos->records_read; in prev_record_reads()
2877 inner_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2879 outer_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2969 outer_fanout*= dst_pos->records_read; in semijoin_mat_scan_access_paths()
3092 inner_fanout*= p->records_read; in semijoin_dupsweedout_access_paths()
[all …]
H A Dabstract_query_plan.cc171 DBUG_ASSERT(get_join_tab()->position->records_read>0.0); in get_fanout()
172 return get_join_tab()->position->records_read; in get_fanout()
178 DBUG_ASSERT(get_join_tab()->position->records_read>0.0); in get_fanout()
179 return get_join_tab()->position->records_read; in get_fanout()
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Dsql_planner.cc1065 pos->records_read= records; in best_access_path()
1284 record_count*= position->records_read; in optimize_straight_join()
1599 if (join->best_positions[i].records_read) in get_partial_join_cost()
2221 position->records_read == (position-1)->records_read; in eq_ref_extension_by_limited_search()
2399 if (pos->records_read > DBL_EPSILON) in prev_record_reads()
2400 found*= pos->records_read; in prev_record_reads()
2867 inner_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2869 outer_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2959 outer_fanout*= dst_pos->records_read; in semijoin_mat_scan_access_paths()
3082 inner_fanout*= p->records_read; in semijoin_dupsweedout_access_paths()
[all …]
/dports/databases/mysql56-client/mysql-5.6.51/sql/
H A Dsql_planner.cc1065 pos->records_read= records; in best_access_path()
1284 record_count*= position->records_read; in optimize_straight_join()
1599 if (join->best_positions[i].records_read) in get_partial_join_cost()
2221 position->records_read == (position-1)->records_read; in eq_ref_extension_by_limited_search()
2399 if (pos->records_read > DBL_EPSILON) in prev_record_reads()
2400 found*= pos->records_read; in prev_record_reads()
2867 inner_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2869 outer_fanout*= pos->records_read; in semijoin_firstmatch_loosescan_access_paths()
2959 outer_fanout*= dst_pos->records_read; in semijoin_mat_scan_access_paths()
3082 inner_fanout*= p->records_read; in semijoin_dupsweedout_access_paths()
[all …]

123456