Searched refs:MY_DEL_TOPICS_CNT (Results 1 – 6 of 6) sorted by relevance
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0081-admin.c | 293 #define MY_DEL_TOPICS_CNT 9 in do_test_DeleteTopics() macro 294 char *topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 295 rd_kafka_DeleteTopic_t *del_topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 297 rd_kafka_resp_err_t exp_topicerr[MY_DEL_TOPICS_CNT] = {0}; in do_test_DeleteTopics() 300 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 322 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) { in do_test_DeleteTopics() 324 int notexist_topic = i >= MY_DEL_TOPICS_CNT - skip_topic_cnt; in do_test_DeleteTopics() 355 MY_DEL_TOPICS_CNT-skip_topic_cnt, in do_test_DeleteTopics() 367 rd_kafka_DeleteTopics(rk, del_topics, MY_DEL_TOPICS_CNT, in do_test_DeleteTopics() 455 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) { in do_test_DeleteTopics() [all …]
|
H A D | 0080-admin_ut.c | 287 #define MY_DEL_TOPICS_CNT 4 in do_test_DeleteTopics() macro 288 rd_kafka_DeleteTopic_t *del_topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 305 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) in do_test_DeleteTopics() 325 rd_kafka_DeleteTopics(rk, del_topics, MY_DEL_TOPICS_CNT, in do_test_DeleteTopics() 363 rd_kafka_DeleteTopic_destroy_array(del_topics, MY_DEL_TOPICS_CNT); in do_test_DeleteTopics()
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0081-admin.c | 301 #define MY_DEL_TOPICS_CNT 9 in do_test_DeleteTopics() macro 302 char *topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 303 rd_kafka_DeleteTopic_t *del_topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 305 rd_kafka_resp_err_t exp_topicerr[MY_DEL_TOPICS_CNT] = {0}; in do_test_DeleteTopics() 308 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 332 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) { in do_test_DeleteTopics() 334 int notexist_topic = i >= MY_DEL_TOPICS_CNT - skip_topic_cnt; in do_test_DeleteTopics() 365 MY_DEL_TOPICS_CNT-skip_topic_cnt, in do_test_DeleteTopics() 377 rd_kafka_DeleteTopics(rk, del_topics, MY_DEL_TOPICS_CNT, in do_test_DeleteTopics() 465 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) { in do_test_DeleteTopics() [all …]
|
H A D | 0080-admin_ut.c | 291 #define MY_DEL_TOPICS_CNT 4 in do_test_DeleteTopics() macro 292 rd_kafka_DeleteTopic_t *del_topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 311 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) in do_test_DeleteTopics() 331 rd_kafka_DeleteTopics(rk, del_topics, MY_DEL_TOPICS_CNT, in do_test_DeleteTopics() 369 rd_kafka_DeleteTopic_destroy_array(del_topics, MY_DEL_TOPICS_CNT); in do_test_DeleteTopics() 376 #undef MY_DEL_TOPICS_CNT in do_test_DeleteTopics()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0081-admin.c | 301 #define MY_DEL_TOPICS_CNT 9 in do_test_DeleteTopics() macro 302 char *topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 303 rd_kafka_DeleteTopic_t *del_topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 305 rd_kafka_resp_err_t exp_topicerr[MY_DEL_TOPICS_CNT] = {0}; in do_test_DeleteTopics() 308 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 332 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) { in do_test_DeleteTopics() 334 int notexist_topic = i >= MY_DEL_TOPICS_CNT - skip_topic_cnt; in do_test_DeleteTopics() 365 MY_DEL_TOPICS_CNT-skip_topic_cnt, in do_test_DeleteTopics() 377 rd_kafka_DeleteTopics(rk, del_topics, MY_DEL_TOPICS_CNT, in do_test_DeleteTopics() 465 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) { in do_test_DeleteTopics() [all …]
|
H A D | 0080-admin_ut.c | 291 #define MY_DEL_TOPICS_CNT 4 in do_test_DeleteTopics() macro 292 rd_kafka_DeleteTopic_t *del_topics[MY_DEL_TOPICS_CNT]; in do_test_DeleteTopics() 311 for (i = 0 ; i < MY_DEL_TOPICS_CNT ; i++) in do_test_DeleteTopics() 331 rd_kafka_DeleteTopics(rk, del_topics, MY_DEL_TOPICS_CNT, in do_test_DeleteTopics() 369 rd_kafka_DeleteTopic_destroy_array(del_topics, MY_DEL_TOPICS_CNT); in do_test_DeleteTopics() 376 #undef MY_DEL_TOPICS_CNT in do_test_DeleteTopics()
|