| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0014-reconsume-191.c | 181 int expected_cnt) { in verify_consumed_msg_check0() argument
187 desc, cons_msgs_cnt, expected_cnt, cons_msgs_size); in verify_consumed_msg_check0()
188 if (expected_cnt > cons_msgs_size) in verify_consumed_msg_check0()
190 expected_cnt, cons_msgs_size); in verify_consumed_msg_check0()
192 if (cons_msgs_cnt < expected_cnt) { in verify_consumed_msg_check0()
194 desc,expected_cnt - cons_msgs_cnt); in verify_consumed_msg_check0()
200 for (i = 0 ; i < expected_cnt ; i++) { in verify_consumed_msg_check0()
205 desc, i, expected_cnt); in verify_consumed_msg_check0()
222 "succeeded\n", desc, cons_msgs_cnt, expected_cnt); in verify_consumed_msg_check0()
227 #define verify_consumed_msg_check(desc,expected_cnt) \ argument
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0014-reconsume-191.c | 181 int expected_cnt) { in verify_consumed_msg_check0() argument
187 desc, cons_msgs_cnt, expected_cnt, cons_msgs_size); in verify_consumed_msg_check0()
188 if (expected_cnt > cons_msgs_size) in verify_consumed_msg_check0()
190 expected_cnt, cons_msgs_size); in verify_consumed_msg_check0()
192 if (cons_msgs_cnt < expected_cnt) { in verify_consumed_msg_check0()
194 desc,expected_cnt - cons_msgs_cnt); in verify_consumed_msg_check0()
200 for (i = 0 ; i < expected_cnt ; i++) { in verify_consumed_msg_check0()
205 desc, i, expected_cnt); in verify_consumed_msg_check0()
222 "succeeded\n", desc, cons_msgs_cnt, expected_cnt); in verify_consumed_msg_check0()
227 #define verify_consumed_msg_check(desc,expected_cnt) \ argument
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0014-reconsume-191.c | 181 int expected_cnt) {
187 desc, cons_msgs_cnt, expected_cnt, cons_msgs_size);
188 if (expected_cnt > cons_msgs_size)
190 expected_cnt, cons_msgs_size);
192 if (cons_msgs_cnt < expected_cnt) {
194 desc,expected_cnt - cons_msgs_cnt);
200 for (i = 0 ; i < expected_cnt ; i++) {
205 desc, i, expected_cnt);
222 "succeeded\n", desc, cons_msgs_cnt, expected_cnt);
227 #define verify_consumed_msg_check(desc,expected_cnt) \
[all …]
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdmap.c | 170 struct rd_map_buckets rd_map_alloc_buckets (size_t expected_cnt) { in rd_map_alloc_buckets() argument
194 if (!expected_cnt) { in rd_map_alloc_buckets()
204 (int)expected_cnt / max_depth > bucket_sizes[i]; in rd_map_alloc_buckets()
217 void rd_map_init (rd_map_t *rmap, size_t expected_cnt, in rd_map_init() argument
224 rmap->rmap_buckets = rd_map_alloc_buckets(expected_cnt); in rd_map_init()
|
| H A D | rdmap.h | 211 void rd_map_init (rd_map_t *rmap, size_t expected_cnt,
221 struct rd_map_buckets rd_map_alloc_buckets (size_t expected_cnt);
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdmap.c | 170 struct rd_map_buckets rd_map_alloc_buckets (size_t expected_cnt) { in rd_map_alloc_buckets() argument
194 if (!expected_cnt) { in rd_map_alloc_buckets()
204 (int)expected_cnt / max_depth > bucket_sizes[i]; in rd_map_alloc_buckets()
217 void rd_map_init (rd_map_t *rmap, size_t expected_cnt, in rd_map_init() argument
224 rmap->rmap_buckets = rd_map_alloc_buckets(expected_cnt); in rd_map_init()
|
| H A D | rdmap.h | 211 void rd_map_init (rd_map_t *rmap, size_t expected_cnt,
221 struct rd_map_buckets rd_map_alloc_buckets (size_t expected_cnt);
|
| /dports/emulators/qemu-devel/qemu-de8ed1055c2ce18c95f597eb10df360dcb534f99/tests/qtest/ |
| H A D | npcm7xx_pwm-test.c | 503 int32_t expected_cnt = mft_compute_cnt(rpm, clk); in mft_verify_rpm() local
508 index, clk, duty, rpm, expected_cnt); in mft_verify_rpm()
522 if (expected_cnt == -1) { in mft_verify_rpm()
531 g_assert_cmphex(cnt + MAX_ERROR, >=, expected_cnt); in mft_verify_rpm()
532 g_assert_cmphex(cnt, <=, expected_cnt + MAX_ERROR); in mft_verify_rpm()
|
| /dports/emulators/qemu/qemu-6.2.0/tests/qtest/ |
| H A D | npcm7xx_pwm-test.c | 503 int32_t expected_cnt = mft_compute_cnt(rpm, clk); in mft_verify_rpm() local
508 index, clk, duty, rpm, expected_cnt); in mft_verify_rpm()
522 if (expected_cnt == -1) { in mft_verify_rpm()
531 g_assert_cmphex(cnt + MAX_ERROR, >=, expected_cnt); in mft_verify_rpm()
532 g_assert_cmphex(cnt, <=, expected_cnt + MAX_ERROR); in mft_verify_rpm()
|
| /dports/emulators/qemu60/qemu-6.0.0/tests/qtest/ |
| H A D | npcm7xx_pwm-test.c | 503 int32_t expected_cnt = mft_compute_cnt(rpm, clk); in mft_verify_rpm() local
508 index, clk, duty, rpm, expected_cnt); in mft_verify_rpm()
522 if (expected_cnt == -1) { in mft_verify_rpm()
531 g_assert_cmphex(cnt + MAX_ERROR, >=, expected_cnt); in mft_verify_rpm()
532 g_assert_cmphex(cnt, <=, expected_cnt + MAX_ERROR); in mft_verify_rpm()
|
| /dports/mail/cone/cone-1.1/libmail/ |
| H A D | pop3.C | 1520 size_t expected_cnt; variable
1594 expected_cnt=0; in loggedIn()
1606 expected_cnt=p->second; in loggedIn()
1666 received_cnt=expected_cnt; in serverResponse()
1668 c->reportProgress(expected_cnt, expected_cnt, 1, 1); in serverResponse()
1695 msgCallback->reportProgress(received_cnt, expected_cnt, 0, 1); in serverResponse()
|
| /dports/science/py-pymol/pymol-open-source-2.4.0/layer0/ |
| H A D | Tracker.cpp | 1322 const int expected_cnt = 5341; /* THIS TEST IS FRAGILE -- result depends on in TrackerUnitTest() local
1350 if(cnt != expected_cnt) { in TrackerUnitTest()
1352 __LINE__, expected_cnt, cnt); in TrackerUnitTest()
|