| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0011-produce_batch.c | 86 rd_kafka_message_t *rkmessages; in test_single_partition() local
108 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_single_partition()
128 if (rkmessages[i].err) { in test_single_partition()
148 free(rkmessages); in test_single_partition()
208 rd_kafka_message_t *rkmessages; in test_partitioner() local
228 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_partitioner()
265 free(rkmessages); in test_partitioner()
349 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_per_message_partition_flag()
389 free(rkmessages); in test_per_message_partition_flag()
479 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_message_partitioner_wo_per_message_flag()
[all …]
|
| H A D | 0012-produce_consume.c | 78 rd_kafka_message_t *rkmessages; in produce_messages() local
101 rkmessages = calloc(sizeof(*rkmessages), msgcnt / partition_cnt); in produce_messages()
109 rkmessages[i].payload = rd_strdup(msg); in produce_messages()
110 rkmessages[i].len = strlen(msg); in produce_messages()
118 rkmessages, batch_cnt); in produce_messages()
127 if (rkmessages[i].err) { in produce_messages()
132 rd_kafka_err2str(rkmessages[i]. in produce_messages()
156 free(rkmessages); in produce_messages()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0011-produce_batch.c | 86 rd_kafka_message_t *rkmessages; in test_single_partition() local
108 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_single_partition()
128 if (rkmessages[i].err) { in test_single_partition()
148 free(rkmessages); in test_single_partition()
208 rd_kafka_message_t *rkmessages; in test_partitioner() local
228 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_partitioner()
265 free(rkmessages); in test_partitioner()
349 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_per_message_partition_flag()
389 free(rkmessages); in test_per_message_partition_flag()
478 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_message_partitioner_wo_per_message_flag()
[all …]
|
| H A D | 0012-produce_consume.c | 78 rd_kafka_message_t *rkmessages; in produce_messages() local
101 rkmessages = calloc(sizeof(*rkmessages), msgcnt / partition_cnt); in produce_messages()
109 rkmessages[i].payload = rd_strdup(msg); in produce_messages()
110 rkmessages[i].len = strlen(msg); in produce_messages()
118 rkmessages, batch_cnt); in produce_messages()
127 if (rkmessages[i].err) { in produce_messages()
132 rd_kafka_err2str(rkmessages[i]. in produce_messages()
156 free(rkmessages); in produce_messages()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0011-produce_batch.c | 86 rd_kafka_message_t *rkmessages; in test_single_partition() local
108 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_single_partition()
128 if (rkmessages[i].err) { in test_single_partition()
148 free(rkmessages); in test_single_partition()
208 rd_kafka_message_t *rkmessages; in test_partitioner() local
228 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_partitioner()
265 free(rkmessages); in test_partitioner()
349 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_per_message_partition_flag()
389 free(rkmessages); in test_per_message_partition_flag()
479 rkmessages = calloc(sizeof(*rkmessages), msgcnt); in test_message_partitioner_wo_per_message_flag()
[all …]
|
| H A D | 0012-produce_consume.c | 78 rd_kafka_message_t *rkmessages; in produce_messages() local
101 rkmessages = calloc(sizeof(*rkmessages), msgcnt / partition_cnt); in produce_messages()
109 rkmessages[i].payload = rd_strdup(msg); in produce_messages()
110 rkmessages[i].len = strlen(msg); in produce_messages()
118 rkmessages, batch_cnt); in produce_messages()
127 if (rkmessages[i].err) { in produce_messages()
132 rd_kafka_err2str(rkmessages[i]. in produce_messages()
156 free(rkmessages); in produce_messages()
|
| /dports/net/pecl-rdkafka/rdkafka-4.0.4/ |
| H A D | topic.c | 388 rd_kafka_message_t **rkmessages; in ZEND_END_ARG_INFO() local
410 rkmessages = malloc(sizeof(*rkmessages) * batch_size); in ZEND_END_ARG_INFO()
412 result = rd_kafka_consume_batch(intern->rkt, partition, timeout_ms, rkmessages, batch_size); in ZEND_END_ARG_INFO()
415 free(rkmessages); in ZEND_END_ARG_INFO()
422 kafka_message_list_to_array(return_value, rkmessages, result TSRMLS_CC); in ZEND_END_ARG_INFO()
424 rd_kafka_message_destroy(rkmessages[i]); in ZEND_END_ARG_INFO()
428 free(rkmessages); in ZEND_END_ARG_INFO()
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | Consumer.c | 916 rd_kafka_message_t **rkmessages; in Consumer_consume() local
940 rkmessages = malloc(num_messages * sizeof(rd_kafka_message_t *)); in Consumer_consume()
944 rkmessages, in Consumer_consume()
949 rd_kafka_message_destroy(rkmessages[i]); in Consumer_consume()
951 free(rkmessages); in Consumer_consume()
956 free(rkmessages); in Consumer_consume()
965 PyObject *msgobj = Message_new0(self, rkmessages[i]); in Consumer_consume()
969 rd_kafka_message_detach_headers(rkmessages[i], &((Message *)msgobj)->c_headers); in Consumer_consume()
972 rd_kafka_message_destroy(rkmessages[i]); in Consumer_consume()
975 free(rkmessages); in Consumer_consume()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_msg.c | 536 rkmessages[i].err = all_err; in rd_kafka_produce_batch()
545 rkmessages[i].payload, in rd_kafka_produce_batch()
546 rkmessages[i].len, in rd_kafka_produce_batch()
547 rkmessages[i].key, in rd_kafka_produce_batch()
548 rkmessages[i].key_len, in rd_kafka_produce_batch()
549 rkmessages[i]._private, in rd_kafka_produce_batch()
553 if (rkmessages[i].err == RD_KAFKA_RESP_ERR__QUEUE_FULL) in rd_kafka_produce_batch()
554 all_err = rkmessages[i].err; in rd_kafka_produce_batch()
567 rkmessages[i].err = in rd_kafka_produce_batch()
597 if (unlikely(rkmessages[i].err)) { in rd_kafka_produce_batch()
[all …]
|
| H A D | rdkafka_event.c | 134 const rd_kafka_message_t **rkmessages, in rd_kafka_event_message_array() argument
140 rkmessages[cnt++] = rkmessage; in rd_kafka_event_message_array()
|
| H A D | rdkafka_queue.c | 532 rd_kafka_message_t **rkmessages, in rd_kafka_q_serve_rkmessages() argument
547 rkmessages, rkmessages_size); in rd_kafka_q_serve_rkmessages()
610 rkmessages[cnt++] = rd_kafka_message_get(rko); in rd_kafka_q_serve_rkmessages()
|
| H A D | rdkafka.h | 3320 rd_kafka_message_t **rkmessages,
3395 rd_kafka_message_t **rkmessages,
4013 rd_kafka_message_t *rkmessages, int message_cnt);
4586 const rd_kafka_message_t **rkmessages,
|
| H A D | rdkafka.c | 2680 rd_kafka_message_t **rkmessages, in rd_kafka_consume_batch0() argument
2684 rkmessages, rkmessages_size); in rd_kafka_consume_batch0()
2690 rd_kafka_message_t **rkmessages, in rd_kafka_consume_batch() argument
2715 rkmessages, rkmessages_size); in rd_kafka_consume_batch()
2726 rd_kafka_message_t **rkmessages, in rd_kafka_consume_batch_queue() argument
2730 rkmessages, rkmessages_size); in rd_kafka_consume_batch_queue()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_queue.c | 537 rd_kafka_message_t **rkmessages, size_t cnt) { in rd_kafka_purge_outdated_messages() argument
543 rko = rkmessages[i]->_private; in rd_kafka_purge_outdated_messages()
548 rkmessages[valid_count++] = rkmessages[i]; in rd_kafka_purge_outdated_messages()
566 rd_kafka_message_t **rkmessages, in rd_kafka_q_serve_rkmessages() argument
581 rkmessages, rkmessages_size); in rd_kafka_q_serve_rkmessages()
624 rkmessages, in rd_kafka_q_serve_rkmessages()
657 rkmessages[cnt++] = rd_kafka_message_get(rko); in rd_kafka_q_serve_rkmessages()
|
| H A D | rdkafka_msg.c | 749 rkmessages[i].err = all_err; in rd_kafka_produce_batch()
758 rkmessages[i].payload, in rd_kafka_produce_batch()
759 rkmessages[i].len, in rd_kafka_produce_batch()
760 rkmessages[i].key, in rd_kafka_produce_batch()
761 rkmessages[i].key_len, in rd_kafka_produce_batch()
762 rkmessages[i]._private, in rd_kafka_produce_batch()
766 if (rkmessages[i].err == RD_KAFKA_RESP_ERR__QUEUE_FULL) in rd_kafka_produce_batch()
767 all_err = rkmessages[i].err; in rd_kafka_produce_batch()
780 rkmessages[i].err = in rd_kafka_produce_batch()
807 if (unlikely(rkmessages[i].err)) { in rd_kafka_produce_batch()
[all …]
|
| H A D | rdkafka_event.c | 140 const rd_kafka_message_t **rkmessages, in rd_kafka_event_message_array() argument
146 rkmessages[cnt++] = rkmessage; in rd_kafka_event_message_array()
|
| H A D | rdkafka.h | 3595 rd_kafka_message_t **rkmessages,
3670 rd_kafka_message_t **rkmessages,
4437 rd_kafka_message_t *rkmessages, int message_cnt);
5024 const rd_kafka_message_t **rkmessages,
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_queue.c | 537 rd_kafka_message_t **rkmessages, size_t cnt) { in rd_kafka_purge_outdated_messages() argument
543 rko = rkmessages[i]->_private; in rd_kafka_purge_outdated_messages()
548 rkmessages[valid_count++] = rkmessages[i]; in rd_kafka_purge_outdated_messages()
566 rd_kafka_message_t **rkmessages, in rd_kafka_q_serve_rkmessages() argument
581 rkmessages, rkmessages_size); in rd_kafka_q_serve_rkmessages()
624 rkmessages, in rd_kafka_q_serve_rkmessages()
657 rkmessages[cnt++] = rd_kafka_message_get(rko); in rd_kafka_q_serve_rkmessages()
|
| H A D | rdkafka_msg.c | 749 rkmessages[i].err = all_err; in rd_kafka_produce_batch()
758 rkmessages[i].payload, in rd_kafka_produce_batch()
759 rkmessages[i].len, in rd_kafka_produce_batch()
760 rkmessages[i].key, in rd_kafka_produce_batch()
761 rkmessages[i].key_len, in rd_kafka_produce_batch()
762 rkmessages[i]._private, in rd_kafka_produce_batch()
766 if (rkmessages[i].err == RD_KAFKA_RESP_ERR__QUEUE_FULL) in rd_kafka_produce_batch()
767 all_err = rkmessages[i].err; in rd_kafka_produce_batch()
780 rkmessages[i].err = in rd_kafka_produce_batch()
807 if (unlikely(rkmessages[i].err)) { in rd_kafka_produce_batch()
[all …]
|
| H A D | rdkafka_event.c | 140 const rd_kafka_message_t **rkmessages, in rd_kafka_event_message_array() argument
146 rkmessages[cnt++] = rkmessage; in rd_kafka_event_message_array()
|
| H A D | rdkafka.h | 3592 rd_kafka_message_t **rkmessages,
3667 rd_kafka_message_t **rkmessages,
4434 rd_kafka_message_t *rkmessages, int message_cnt);
5018 const rd_kafka_message_t **rkmessages,
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_performance.c | 1523 rd_kafka_message_t **rkmessages = NULL; in main() local
1542 rkmessages = malloc(sizeof(*rkmessages) * batch_size); in main()
1574 rkmessages, in main()
1578 msg_consume(rkmessages[i], in main()
1581 rkmessages[i]); in main()
1624 free(rkmessages); in main()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_performance.c | 1495 rd_kafka_message_t **rkmessages = NULL; in main() local
1520 rkmessages = malloc(sizeof(*rkmessages) * batch_size); in main()
1553 rkmessages, in main()
1557 msg_consume(rkmessages[i], in main()
1560 rkmessages[i]); in main()
1603 free(rkmessages); in main()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_performance.c | 1523 rd_kafka_message_t **rkmessages = NULL; in main() local
1542 rkmessages = malloc(sizeof(*rkmessages) * batch_size); in main()
1574 rkmessages, in main()
1578 msg_consume(rkmessages[i], in main()
1581 rkmessages[i]); in main()
1624 free(rkmessages); in main()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 1148 rkmessages: *mut *mut rd_kafka_message_t, in rd_kafka_consume_batch()
1173 rkmessages: *mut *mut rd_kafka_message_t, in rd_kafka_consume_batch_queue()
1326 rkmessages: *mut rd_kafka_message_t, in rd_kafka_produce_batch()
1500 rkmessages: *mut *const rd_kafka_message_t, in rd_kafka_event_message_array()
|