| /dports/math/pspp/pspp-1.4.1/src/language/data-io/ |
| H A D | data-reader.c | 70 unsigned eof_cnt; /* # of attempts to advance past EOF. */ member
152 r->eof_cnt = 0; in dfm_open_reader()
557 if (r->eof_cnt == 0 && read_record (r)) in dfm_eof()
563 r->eof_cnt++; in dfm_eof()
564 if (r->eof_cnt == 2) in dfm_eof()
574 return r->eof_cnt; in dfm_eof()
584 assert (r->eof_cnt == 0); in dfm_get_record()
599 assert (r->eof_cnt == 0); in dfm_expand_tabs()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0026-consume_pause.c | 76 int eof_cnt = -1; in consume_pause() local
92 eof_cnt = partition_cnt; in consume_pause()
98 per_pause_msg_cnt, eof_cnt); in consume_pause()
125 eof_cnt, in consume_pause()
|
| H A D | test.c | 4049 int eof_cnt = 0; in test_consumer_poll_exact() local
4059 ((exp_eof_cnt <= 0 || eof_cnt < exp_eof_cnt) && in test_consumer_poll_exact()
4062 (eof_cnt < exp_eof_cnt || in test_consumer_poll_exact()
4070 eof_cnt, exp_eof_cnt, cnt, exp_cnt); in test_consumer_poll_exact()
4082 eof_cnt++; in test_consumer_poll_exact()
4112 what, cnt, exp_cnt, eof_cnt, exp_eof_cnt); in test_consumer_poll_exact()
4116 (exp_eof_cnt == -1 || exp_eof_cnt == eof_cnt)), in test_consumer_poll_exact()
4119 what, eof_cnt, exp_eof_cnt, cnt, exp_cnt); in test_consumer_poll_exact()
4122 TEST_ASSERT(cnt == 0 && eof_cnt == exp_eof_cnt, in test_consumer_poll_exact()
4125 what, exp_eof_cnt, cnt, eof_cnt); in test_consumer_poll_exact()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0026-consume_pause.c | 76 int eof_cnt = -1; in consume_pause() local
92 eof_cnt = partition_cnt; in consume_pause()
98 per_pause_msg_cnt, eof_cnt); in consume_pause()
125 eof_cnt, in consume_pause()
|
| H A D | test.c | 3669 int eof_cnt = 0; in test_consumer_poll() local
3677 while ((exp_eof_cnt <= 0 || eof_cnt < exp_eof_cnt) && in test_consumer_poll()
3685 eof_cnt, exp_eof_cnt, cnt, exp_cnt); in test_consumer_poll()
3697 eof_cnt++; in test_consumer_poll()
3720 what, cnt, exp_cnt, eof_cnt, exp_eof_cnt); in test_consumer_poll()
3723 TEST_ASSERT(cnt == 0 && eof_cnt == exp_eof_cnt, in test_consumer_poll()
3726 what, exp_eof_cnt, cnt, eof_cnt); in test_consumer_poll()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0026-consume_pause.c | 76 int eof_cnt = -1;
92 eof_cnt = partition_cnt;
98 per_pause_msg_cnt, eof_cnt);
125 eof_cnt,
|
| H A D | test.c | 4007 int eof_cnt = 0; in test_consumer_poll_exact() local
4017 ((exp_eof_cnt <= 0 || eof_cnt < exp_eof_cnt) && in test_consumer_poll_exact()
4020 (eof_cnt < exp_eof_cnt || in test_consumer_poll_exact()
4028 eof_cnt, exp_eof_cnt, cnt, exp_cnt); in test_consumer_poll_exact()
4040 eof_cnt++; in test_consumer_poll_exact()
4070 what, cnt, exp_cnt, eof_cnt, exp_eof_cnt); in test_consumer_poll_exact()
4074 (exp_eof_cnt == -1 || exp_eof_cnt == eof_cnt)), in test_consumer_poll_exact()
4077 what, eof_cnt, exp_eof_cnt, cnt, exp_cnt); in test_consumer_poll_exact()
4080 TEST_ASSERT(cnt == 0 && eof_cnt == exp_eof_cnt, in test_consumer_poll_exact()
4083 what, exp_eof_cnt, cnt, eof_cnt); in test_consumer_poll_exact()
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_complex_consumer_example.cpp | 67 static int eof_cnt = 0; variable
172 eof_cnt = 0; /* FIXME: Won't work with COOPERATIVE */ in rebalance_cb()
218 if (exit_eof && ++eof_cnt == partition_cnt) { in msg_consume()
|
| H A D | rdkafka_performance.c | 75 static int eof_cnt = 0; variable
271 if (exit_eof && ++eof_cnt == partition_cnt) in msg_consume()
368 eof_cnt = 0; in rebalance_cb()
387 eof_cnt = 0; /* FIXME: Not correct for incremental case */ in rebalance_cb()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_complex_consumer_example.cpp | 66 static int eof_cnt = 0; variable
156 eof_cnt = 0; in rebalance_cb()
195 if (exit_eof && ++eof_cnt == partition_cnt) { in msg_consume()
|
| H A D | rdkafka_performance.c | 75 static int eof_cnt = 0; variable
271 if (exit_eof && ++eof_cnt == partition_cnt) in msg_consume()
352 eof_cnt = 0; in rebalance_cb()
361 eof_cnt = 0; in rebalance_cb()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_complex_consumer_example.cpp | 67 static int eof_cnt = 0;
172 eof_cnt = 0; /* FIXME: Won't work with COOPERATIVE */
218 if (exit_eof && ++eof_cnt == partition_cnt) {
|
| H A D | rdkafka_performance.c | 75 static int eof_cnt = 0; variable
271 if (exit_eof && ++eof_cnt == partition_cnt) in msg_consume()
368 eof_cnt = 0; in rebalance_cb()
387 eof_cnt = 0; /* FIXME: Not correct for incremental case */ in rebalance_cb()
|
| /dports/net/kcat/kcat-1.7.0/ |
| H A D | kcat.h | 136 int eof_cnt; /**< Current number of partitions reached EOF */ member
|
| H A D | kcat.c | 547 !conf.assignment || conf.eof_cnt == 0) in partition_not_eof()
560 conf.eof_cnt--; in partition_not_eof()
592 conf.eof_cnt++; in partition_at_eof()
594 if (conf.eof_cnt == conf.assignment->cnt) in partition_at_eof()
|
| /dports/audio/wildmidi/wildmidi-wildmidi-0.4.2/src/ |
| H A D | wildmidi_lib.c | 1858 uint8_t eof_cnt = 1; in WildMidi_SongSeek() local
1861 if (eof_cnt == 0) { in WildMidi_SongSeek()
1864 eof_cnt = 0; in WildMidi_SongSeek()
|