Home
last modified time | relevance | path

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 D0081-admin.c293 #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 D0080-admin_ut.c287 #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 D0081-admin.c301 #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 D0080-admin_ut.c291 #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 D0081-admin.c301 #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 D0080-admin_ut.c291 #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()