Home
last modified time | relevance | path

Searched refs:callback_event_count (Results 1 – 3 of 3) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0083-cb_event.c94 int callback_event_count; in main_0083_cb_event() local
137 callback_event_count = wait_event_cb(1 * wait_multiplier); in main_0083_cb_event()
138 … TEST_ASSERT(callback_event_count <= 1, "Event cb called %d times", callback_event_count); in main_0083_cb_event()
140 if (callback_event_count == 1) { in main_0083_cb_event()
141 TEST_SAY("Events received: %d\n", callback_event_count); in main_0083_cb_event()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0083-cb_event.c94 int callback_event_count; in main_0083_cb_event() local
137 callback_event_count = wait_event_cb(1 * wait_multiplier); in main_0083_cb_event()
138 … TEST_ASSERT(callback_event_count <= 1, "Event cb called %d times", callback_event_count); in main_0083_cb_event()
140 if (callback_event_count == 1) { in main_0083_cb_event()
141 TEST_SAY("Events received: %d\n", callback_event_count); in main_0083_cb_event()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0083-cb_event.c94 int callback_event_count; in main_0083_cb_event() local
137 callback_event_count = wait_event_cb(1 * wait_multiplier); in main_0083_cb_event()
138 … TEST_ASSERT(callback_event_count <= 1, "Event cb called %d times", callback_event_count); in main_0083_cb_event()
140 if (callback_event_count == 1) { in main_0083_cb_event()
141 TEST_SAY("Events received: %d\n", callback_event_count); in main_0083_cb_event()