Home
last modified time | relevance | path

Searched refs:msgs_wait (Results 1 – 12 of 12) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0007-autotopic.c44 static int msgs_wait = 0; /* bitmask */ variable
56 if (!(msgs_wait & (1 << msgid))) in dr_cb()
58 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
63 msgs_wait &= ~(1 << msgid); in dr_cb()
111 msgs_wait |= (1 << i); in main_0007_autotopic()
118 if (msgs_wait != 0) in main_0007_autotopic()
119 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main_0007_autotopic()
H A D1000-unktopic.c48 static int msgs_wait = 0; /* bitmask */ variable
60 if (!(msgs_wait & (1 << msgid))) in dr_cb()
62 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
67 msgs_wait &= ~(1 << msgid); in dr_cb()
127 msgs_wait |= (1 << i); in main()
142 if (msgs_wait != 0) in main()
143 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main()
H A D0003-msgmaxsize.c41 static int msgs_wait = 0; /* bitmask */ variable
57 if (!(msgs_wait & (1 << msgid))) in dr_cb()
59 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
64 msgs_wait &= ~(1 << msgid); in dr_cb()
150 msgs_wait |= (1 << i); in main_0003_msgmaxsize()
165 if (msgs_wait != 0) in main_0003_msgmaxsize()
166 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main_0003_msgmaxsize()
H A D0002-unkpart.c41 static int msgs_wait = 0; /* bitmask */ variable
53 if (!(msgs_wait & (1 << msgid))) in dr_cb()
55 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
60 msgs_wait &= ~(1 << msgid); in dr_cb()
129 msgs_wait |= (1 << i); in do_test_unkpart()
146 if (msgs_wait != 0) in do_test_unkpart()
147 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in do_test_unkpart()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0007-autotopic.c44 static int msgs_wait = 0; /* bitmask */ variable
56 if (!(msgs_wait & (1 << msgid))) in dr_cb()
58 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
63 msgs_wait &= ~(1 << msgid); in dr_cb()
111 msgs_wait |= (1 << i); in main_0007_autotopic()
118 if (msgs_wait != 0) in main_0007_autotopic()
119 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main_0007_autotopic()
H A D1000-unktopic.c48 static int msgs_wait = 0; /* bitmask */ variable
60 if (!(msgs_wait & (1 << msgid))) in dr_cb()
62 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
67 msgs_wait &= ~(1 << msgid); in dr_cb()
127 msgs_wait |= (1 << i); in main()
142 if (msgs_wait != 0) in main()
143 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main()
H A D0003-msgmaxsize.c41 static int msgs_wait = 0; /* bitmask */ variable
57 if (!(msgs_wait & (1 << msgid))) in dr_cb()
59 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
64 msgs_wait &= ~(1 << msgid); in dr_cb()
150 msgs_wait |= (1 << i); in main_0003_msgmaxsize()
160 if (msgs_wait != 0) in main_0003_msgmaxsize()
161 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main_0003_msgmaxsize()
H A D0002-unkpart.c41 static int msgs_wait = 0; /* bitmask */ variable
53 if (!(msgs_wait & (1 << msgid))) in dr_cb()
55 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
60 msgs_wait &= ~(1 << msgid); in dr_cb()
129 msgs_wait |= (1 << i); in do_test_unkpart()
146 if (msgs_wait != 0) in do_test_unkpart()
147 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in do_test_unkpart()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0007-autotopic.c44 static int msgs_wait = 0; /* bitmask */ variable
56 if (!(msgs_wait & (1 << msgid))) in dr_cb()
58 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
63 msgs_wait &= ~(1 << msgid); in dr_cb()
111 msgs_wait |= (1 << i); in main_0007_autotopic()
118 if (msgs_wait != 0) in main_0007_autotopic()
119 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main_0007_autotopic()
H A D1000-unktopic.c48 static int msgs_wait = 0; /* bitmask */ variable
60 if (!(msgs_wait & (1 << msgid))) in dr_cb()
62 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
67 msgs_wait &= ~(1 << msgid); in dr_cb()
127 msgs_wait |= (1 << i); in main()
142 if (msgs_wait != 0) in main()
143 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in main()
H A D0003-msgmaxsize.c41 static int msgs_wait = 0; /* bitmask */
57 if (!(msgs_wait & (1 << msgid)))
59 "(waiting for 0x%x)\n", msgid, msgs_wait);
64 msgs_wait &= ~(1 << msgid);
150 msgs_wait |= (1 << i);
165 if (msgs_wait != 0)
166 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait);
H A D0002-unkpart.c41 static int msgs_wait = 0; /* bitmask */ variable
53 if (!(msgs_wait & (1 << msgid))) in dr_cb()
55 "(waiting for 0x%x)\n", msgid, msgs_wait); in dr_cb()
60 msgs_wait &= ~(1 << msgid); in dr_cb()
129 msgs_wait |= (1 << i); in do_test_unkpart()
146 if (msgs_wait != 0) in do_test_unkpart()
147 TEST_FAIL("Still waiting for messages: 0x%x\n", msgs_wait); in do_test_unkpart()