Home
last modified time | relevance | path

Searched refs:records_count (Results 1 – 25 of 27) sorted by relevance

12

/dports/devel/pecl-swoole/swoole-4.8.5/tests/swoole_websocket_server/
H A Dmemory.phpt63 if (($records_count = count($mem_records)) === MAX_REQUESTS_MID) {
72 for ($i = $records_count / 2; $i < $records_count; $i++) {
73 approximate($master_virtual[$i], $master_virtual[$records_count / 2]);
74 approximate($worker_virtual[$i], $worker_virtual[$records_count / 2]);
75 approximate($worker_real[$i], $worker_real[$records_count / 2]);
87 …phpt_echo("#{$records_count}: push " . (FRAME_DATA_SIZE / 1024) . "k data to {$fd} client success …
/dports/mail/dovecot/dovecot-2.3.17/src/lib-index/
H A Dmail-index-map-read.c86 rec_map->records_count = hdr->messages_count; in mail_index_mmap()
88 rec_map->records_count = in mail_index_mmap()
92 rec_map->records_count * hdr->record_size; in mail_index_mmap()
96 rec_map->records_count); in mail_index_mmap()
143 unsigned int records_count = 0, extra; in mail_index_try_read_map() local
187 records_count = hdr->messages_count; in mail_index_try_read_map()
192 records_count = (file_size - hdr->header_size) / in mail_index_try_read_map()
194 records_size = (size_t)records_count * hdr->record_size; in mail_index_try_read_map()
198 records_count); in mail_index_try_read_map()
243 map->rec_map->records_count = records_count; in mail_index_try_read_map()
H A Dmail-index-map.c329 size = src->records_count * record_size; in mail_index_map_copy_records()
336 dest->records_count = src->records_count; in mail_index_map_copy_records()
444 if (new_map->records_count != map->hdr.messages_count) { in mail_index_record_map_move_to_private()
448 i_assert(new_map->records_count > map->hdr.messages_count); in mail_index_record_map_move_to_private()
449 new_map->records_count = map->hdr.messages_count; in mail_index_record_map_move_to_private()
450 if (new_map->records_count == 0) in mail_index_record_map_move_to_private()
453 rec = MAIL_INDEX_REC_AT_SEQ(map, new_map->records_count); in mail_index_record_map_move_to_private()
456 buffer_set_used_size(new_map->buffer, new_map->records_count * in mail_index_record_map_move_to_private()
516 i_assert(map->hdr.messages_count <= map->rec_map->records_count); in mail_index_bsearch_uid()
H A Dmail-cache.c225 unsigned int records_count, cont_percentage, delete_percentage; in mail_cache_update_need_purge() local
234 msg_count = cache->index->map->rec_map->records_count; in mail_cache_update_need_purge()
236 records_count = 1; in mail_cache_update_need_purge()
243 records_count = I_MAX(msg_count, 1); in mail_cache_update_need_purge()
245 records_count = hdr->record_count; in mail_cache_update_need_purge()
248 cont_percentage = hdr->continued_record_count * 100 / records_count; in mail_cache_update_need_purge()
253 hdr->continued_record_count, records_count); in mail_cache_update_need_purge()
257 (records_count + hdr->deleted_record_count); in mail_cache_update_need_purge()
262 hdr->deleted_record_count, records_count); in mail_cache_update_need_purge()
H A Dmail-index-sync-update.c266 orig_rec_count = map->rec_map->records_count; in sync_expunge_range()
291 map->rec_map->records_count -= seq_count; in sync_expunge_range()
310 append_pos = map->rec_map->records_count * map->hdr.record_size; in sync_append_record()
400 i_assert(map->hdr.messages_count < map->rec_map->records_count); in sync_append()
414 map->rec_map->records_count++; in sync_append()
419 map->rec_map->records_count); in sync_append()
861 for (seq = 1; seq <= map->rec_map->records_count; seq++) { in mail_index_sync_update_hdr_dirty_flag()
877 i_assert(hdr->messages_count <= map->rec_map->records_count); in mail_index_map_check()
921 map->rec_map->records_count * in mail_index_sync_map_want_index_reopen()
H A Dmail-index-fsck.c107 for (r = 0; r < map->rec_map->records_count; r++) { in mail_index_fsck_find_keyword_count()
343 for (i = 0; i < map->rec_map->records_count; ) { in mail_index_fsck_records()
364 (map->rec_map->records_count - i - 1)); in mail_index_fsck_records()
365 map->rec_map->records_count--; in mail_index_fsck_records()
H A Dtest-mail-index-map.c21 rec_map.records_count = map.hdr.messages_count; in test_mail_index_map_lookup_seq_range_count()
H A Dmail-index-map-hdr.c278 if (hdr->messages_count > map->rec_map->records_count) { in mail_index_map_check_header()
281 hdr->messages_count, map->rec_map->records_count); in mail_index_map_check_header()
H A Dtest-mail-index-write.c89 .records_count = 0, in test_mail_index_write()
H A Dmail-index-write.c86 map->rec_map->records_count * map->hdr.record_size); in mail_index_recreate()
H A Dmail-index-sync-ext.c197 new_buffer_size = map->rec_map->records_count * new_record_size; in sync_ext_reorder()
201 for (rec_idx = 0; rec_idx < map->rec_map->records_count; rec_idx++) { in sync_ext_reorder()
565 for (seq = 1; seq <= view->map->rec_map->records_count; seq++) { in mail_index_sync_ext_clear()
H A Dmail-index-private.h124 unsigned int records_count; member
/dports/net-im/uTox/uTox/src/
H A Dchatlog.c58 size_t records_count = 0; in utox_count_chatlog() local
62 records_count++; in utox_count_chatlog()
77 return records_count; in utox_count_chatlog()
91 size_t records_count = utox_count_chatlog(hex); in utox_load_chatlog() local
92 if (skip >= records_count) { in utox_load_chatlog()
107 if (count > (records_count - skip)) { in utox_load_chatlog()
108 count = records_count - skip; in utox_load_chatlog()
120 size_t start_at = records_count - count - skip; in utox_load_chatlog()
/dports/security/clamav/clamav-0.104.2/libclamav/
H A Dunzip.c979 size_t records_count = 0; in index_the_central_directory() local
1018 records_count++; in index_the_central_directory()
1075 …set(&(zip_catalogue[records_count]), 0, sizeof(struct zip_record) * (ZIP_RECORDS_CHECK_BLOCKSIZE *… in index_the_central_directory()
1088 if (records_count > 1) { in index_the_central_directory()
1097 for (index = 1; index < records_count; index++) { in index_the_central_directory()
1143 *num_records = records_count; in index_the_central_directory()
1151 for (i = 0; i < records_count; i++) { in index_the_central_directory()
1183 size_t records_count = 0; in cli_unzip() local
1222 &records_count); in cli_unzip()
1234 for (i = 0; i < records_count; i++) { in cli_unzip()
[all …]
/dports/security/clamav-lts/clamav-0.103.5/libclamav/
H A Dunzip.c979 size_t records_count = 0; in index_the_central_directory() local
1018 records_count++; in index_the_central_directory()
1075 …set(&(zip_catalogue[records_count]), 0, sizeof(struct zip_record) * (ZIP_RECORDS_CHECK_BLOCKSIZE *… in index_the_central_directory()
1088 if (records_count > 1) { in index_the_central_directory()
1097 for (index = 1; index < records_count; index++) { in index_the_central_directory()
1143 *num_records = records_count; in index_the_central_directory()
1151 for (i = 0; i < records_count; i++) { in index_the_central_directory()
1183 size_t records_count = 0; in cli_unzip() local
1222 &records_count); in cli_unzip()
1234 for (i = 0; i < records_count; i++) { in cli_unzip()
[all …]
/dports/www/libdatachannel/libdatachannel-0.16.1/deps/libjuice/src/
H A Dagent.c228 if (records_count < 0) { in agent_gather_candidates()
230 records_count = 0; in agent_gather_candidates()
231 } else if (records_count == 0) { in agent_gather_candidates()
234 records_count = ICE_MAX_CANDIDATES_COUNT - 1; in agent_gather_candidates()
237 for (int i = 0; i < records_count; ++i) { in agent_gather_candidates()
529 int records_count = in agent_run() local
531 if (records_count > 0) { in agent_run()
533 records_count = DEFAULT_MAX_RECORDS_COUNT; in agent_run()
538 for (int j = 0; j < records_count; ++j) { in agent_run()
593 if (records_count > 0) { in agent_run()
[all …]
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/ece/src/
H A Dcommon.rs186 let records_count = chunks.len(); in common_decrypt() localVariable
197 let last_record = count == records_count - 1; in common_decrypt()
/dports/multimedia/mencoder/mplayer-export-2021-12-29/libmpdemux/
H A Dasfheader.c261 uint16_t records_count; in get_meta() local
270 records_count = AV_RL16(buf); in get_meta()
273 while (records_count--) { in get_meta()
/dports/multimedia/mplayer/mplayer-export-2021-12-29/libmpdemux/
H A Dasfheader.c261 uint16_t records_count; in get_meta() local
270 records_count = AV_RL16(buf); in get_meta()
273 while (records_count--) { in get_meta()
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/consumer/
H A Dfetcher.py766 records_count = 0
804 records_count = len(unpacked)
819 self._sensors.record_topic_fetch_metrics(tp.topic, num_bytes, records_count)
845 completed_fetch.metric_aggregator.record(tp, num_bytes, records_count)
/dports/devel/liblas/libLAS-1.8.1/python/liblas/
H A Dheader.py412 records_count = property(get_recordscount, None, None, doc) variable in Header
413 num_vlrs = records_count
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/arrow/src/csv/
H A Dreader.rs136 let mut records_count = 0; in infer_file_schema() localVariable
141 while records_count < max_records { in infer_file_schema()
145 records_count += 1; in infer_file_schema()
190 Ok((Schema::new(fields), records_count)) in infer_file_schema()
/dports/multimedia/libxine/xine-lib-1.2.11/src/demuxers/
H A Dasfheader.c542 uint16_t i, records_count = 0; in asf_header_parse_metadata() local
552 records_count = _X_LE_16 (p); in asf_header_parse_metadata()
554 for (i = 0; i < records_count; i++) in asf_header_parse_metadata()
/dports/devel/liblas12/libLAS-1.2.1/python/liblas/
H A Dheader.py202 records_count = property(get_recordscount) variable in Header
/dports/net-mgmt/collectd5/collectd-5.12.0/src/
H A Dnetapp.c1975 uint32_t records_count; in cna_handle_snapvault_iter() local
1977 records_count = na_child_get_uint32(data, "records", UINT32_MAX); in cna_handle_snapvault_iter()
1978 if (records_count == UINT32_MAX) in cna_handle_snapvault_iter()
1985 DEBUG("netapp plugin: Iterating %u SV records (tag = %s)", records_count, in cna_handle_snapvault_iter()
1988 for (uint32_t i = 0; i < records_count; ++i) { in cna_handle_snapvault_iter()

12