/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0007-autotopic.c | 44 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 D | 1000-unktopic.c | 48 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 D | 0003-msgmaxsize.c | 41 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 D | 0002-unkpart.c | 41 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 D | 0007-autotopic.c | 44 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 D | 1000-unktopic.c | 48 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 D | 0003-msgmaxsize.c | 41 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 D | 0002-unkpart.c | 41 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 D | 0007-autotopic.c | 44 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 D | 1000-unktopic.c | 48 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 D | 0003-msgmaxsize.c | 41 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 D | 0002-unkpart.c | 41 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()
|