| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0056-balanced_group_mt.c | 53 rd_kafka_queue_t * rkqu; member
67 rd_kafka_queue_t *rkqu = info->rkqu; in partition_consume() local
79 rkmsg = rd_kafka_consume_queue(rkqu, 500); in partition_consume()
113 rd_kafka_queue_destroy(rkqu); in partition_consume()
118 static thrd_t spawn_thread (rd_kafka_queue_t *rkqu, int partition) { in spawn_thread() argument
122 info->rkqu = rkqu; in spawn_thread()
158 rd_kafka_queue_t *rkqu; in rebalance_cb() local
160 rkqu = rd_kafka_queue_get_partition(rk, part.topic, in rebalance_cb()
163 rd_kafka_queue_forward(rkqu, NULL); in rebalance_cb()
164 tids[part.partition] = spawn_thread(rkqu, in rebalance_cb()
|
| H A D | 0080-admin_ut.c | 717 static void do_test_mix (rd_kafka_t *rk, rd_kafka_queue_t *rkqu) { in do_test_mix() argument
746 test_CreateTopics_simple(rk, rkqu, topics, 2, 1, &id1); in do_test_mix()
747 test_DeleteTopics_simple(rk, rkqu, &topics[1], 1, &id2); in do_test_mix()
748 test_CreateTopics_simple(rk, rkqu, &topics[2], 1, 1, &id3); in do_test_mix()
749 test_DeleteGroups_simple(rk, rkqu, topics, 3, &id4); in do_test_mix()
750 test_DeleteRecords_simple(rk, rkqu, offsets, &id5); in do_test_mix()
756 test_CreateTopics_simple(rk, rkqu, topics, 2, -1, &id9); in do_test_mix()
764 rkev = rd_kafka_queue_poll(rkqu, -1); in do_test_mix()
846 options, rkqu); in do_test_configs()
867 options, rkqu); in do_test_configs()
[all …]
|
| H A D | 0013-null-msgs.c | 334 rd_kafka_queue_t *rkqu; in consume_messages_with_queues() local
345 rkqu = rd_kafka_queue_new(rk); in consume_messages_with_queues()
363 rkqu) == -1) in consume_messages_with_queues()
374 rkmessage = rd_kafka_consume_queue(rkqu, tmout_multip(5000)); in consume_messages_with_queues()
397 rd_kafka_queue_destroy(rkqu); in consume_messages_with_queues()
|
| H A D | 0012-produce_consume.c | 377 rd_kafka_queue_t *rkqu; in consume_messages_with_queues() local
390 rkqu = rd_kafka_queue_new(rk); in consume_messages_with_queues()
408 rkqu) == -1) in consume_messages_with_queues()
419 rkmessage = rd_kafka_consume_queue(rkqu, tmout_multip(5000)); in consume_messages_with_queues()
454 rd_kafka_queue_destroy(rkqu); in consume_messages_with_queues()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0056-balanced_group_mt.c | 53 rd_kafka_queue_t * rkqu; member
67 rd_kafka_queue_t *rkqu = info->rkqu; in partition_consume() local
79 rkmsg = rd_kafka_consume_queue(rkqu, 500); in partition_consume()
113 rd_kafka_queue_destroy(rkqu); in partition_consume()
118 static thrd_t spawn_thread (rd_kafka_queue_t *rkqu, int partition) { in spawn_thread() argument
122 info->rkqu = rkqu; in spawn_thread()
158 rd_kafka_queue_t *rkqu; in rebalance_cb() local
160 rkqu = rd_kafka_queue_get_partition(rk, part.topic, in rebalance_cb()
163 rd_kafka_queue_forward(rkqu, NULL); in rebalance_cb()
164 tids[part.partition] = spawn_thread(rkqu, in rebalance_cb()
|
| H A D | 0080-admin_ut.c | 381 static void do_test_mix (rd_kafka_t *rk, rd_kafka_queue_t *rkqu) { in do_test_mix() argument
395 test_CreateTopics_simple(rk, rkqu, topics, 2, 1, &id1); in do_test_mix()
396 test_DeleteTopics_simple(rk, rkqu, &topics[1], 1, &id2); in do_test_mix()
397 test_CreateTopics_simple(rk, rkqu, &topics[2], 1, 1, &id3); in do_test_mix()
398 test_CreatePartitions_simple(rk, rkqu, "topicD", 15, &id4); in do_test_mix()
404 rkev = rd_kafka_queue_poll(rkqu, -1); in do_test_mix()
432 static void do_test_configs (rd_kafka_t *rk, rd_kafka_queue_t *rkqu) { in do_test_configs() argument
482 options, rkqu); in do_test_configs()
484 rkev = test_wait_admin_result(rkqu, RD_KAFKA_EVENT_ALTERCONFIGS_RESULT, in do_test_configs()
503 options, rkqu); in do_test_configs()
[all …]
|
| H A D | 0013-null-msgs.c | 334 rd_kafka_queue_t *rkqu; in consume_messages_with_queues() local
345 rkqu = rd_kafka_queue_new(rk); in consume_messages_with_queues()
363 rkqu) == -1) in consume_messages_with_queues()
374 rkmessage = rd_kafka_consume_queue(rkqu, tmout_multip(5000)); in consume_messages_with_queues()
397 rd_kafka_queue_destroy(rkqu); in consume_messages_with_queues()
|
| H A D | 0012-produce_consume.c | 377 rd_kafka_queue_t *rkqu; in consume_messages_with_queues() local
390 rkqu = rd_kafka_queue_new(rk); in consume_messages_with_queues()
408 rkqu) == -1) in consume_messages_with_queues()
419 rkmessage = rd_kafka_consume_queue(rkqu, tmout_multip(5000)); in consume_messages_with_queues()
454 rd_kafka_queue_destroy(rkqu); in consume_messages_with_queues()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0056-balanced_group_mt.c | 53 rd_kafka_queue_t * rkqu; member
67 rd_kafka_queue_t *rkqu = info->rkqu; in partition_consume() local
79 rkmsg = rd_kafka_consume_queue(rkqu, 500); in partition_consume()
113 rd_kafka_queue_destroy(rkqu); in partition_consume()
118 static thrd_t spawn_thread (rd_kafka_queue_t *rkqu, int partition) { in spawn_thread() argument
122 info->rkqu = rkqu; in spawn_thread()
158 rd_kafka_queue_t *rkqu; in rebalance_cb() local
160 rkqu = rd_kafka_queue_get_partition(rk, part.topic, in rebalance_cb()
163 rd_kafka_queue_forward(rkqu, NULL); in rebalance_cb()
164 tids[part.partition] = spawn_thread(rkqu, in rebalance_cb()
|
| H A D | 0080-admin_ut.c | 717 static void do_test_mix (rd_kafka_t *rk, rd_kafka_queue_t *rkqu) { in do_test_mix() argument
746 test_CreateTopics_simple(rk, rkqu, topics, 2, 1, &id1); in do_test_mix()
747 test_DeleteTopics_simple(rk, rkqu, &topics[1], 1, &id2); in do_test_mix()
748 test_CreateTopics_simple(rk, rkqu, &topics[2], 1, 1, &id3); in do_test_mix()
749 test_DeleteGroups_simple(rk, rkqu, topics, 3, &id4); in do_test_mix()
750 test_DeleteRecords_simple(rk, rkqu, offsets, &id5); in do_test_mix()
756 test_CreateTopics_simple(rk, rkqu, topics, 2, -1, &id9); in do_test_mix()
764 rkev = rd_kafka_queue_poll(rkqu, -1); in do_test_mix()
846 options, rkqu); in do_test_configs()
867 options, rkqu); in do_test_configs()
[all …]
|
| H A D | 0013-null-msgs.c | 334 rd_kafka_queue_t *rkqu; in consume_messages_with_queues() local
345 rkqu = rd_kafka_queue_new(rk); in consume_messages_with_queues()
363 rkqu) == -1) in consume_messages_with_queues()
374 rkmessage = rd_kafka_consume_queue(rkqu, tmout_multip(5000)); in consume_messages_with_queues()
397 rd_kafka_queue_destroy(rkqu); in consume_messages_with_queues()
|
| H A D | 0012-produce_consume.c | 377 rd_kafka_queue_t *rkqu; in consume_messages_with_queues() local
390 rkqu = rd_kafka_queue_new(rk); in consume_messages_with_queues()
408 rkqu) == -1) in consume_messages_with_queues()
419 rkmessage = rd_kafka_consume_queue(rkqu, tmout_multip(5000)); in consume_messages_with_queues()
454 rd_kafka_queue_destroy(rkqu); in consume_messages_with_queues()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_queue.c | 676 if (rkqu->rkqu_is_owner) in rd_kafka_queue_destroy()
680 rd_free(rkqu); in rd_kafka_queue_destroy()
684 rd_kafka_queue_t *rkqu; in rd_kafka_queue_new0() local
686 rkqu = rd_calloc(1, sizeof(*rkqu)); in rd_kafka_queue_new0()
688 rkqu->rkqu_q = rkq; in rd_kafka_queue_new0()
691 rkqu->rkqu_rk = rk; in rd_kafka_queue_new0()
693 return rkqu; in rd_kafka_queue_new0()
699 rd_kafka_queue_t *rkqu; in rd_kafka_queue_new() local
705 rkqu->rkqu_is_owner = 1; in rd_kafka_queue_new()
706 return rkqu; in rd_kafka_queue_new()
[all …]
|
| H A D | rdkafka.h | 3205 void rd_kafka_queue_destroy(rd_kafka_queue_t *rkqu);
3365 void rd_kafka_queue_yield (rd_kafka_queue_t *rkqu);
3451 int64_t offset, rd_kafka_queue_t *rkqu);
4067 rd_kafka_queue_t *rkqu,
6424 rd_kafka_queue_t *rkqu);
6502 rd_kafka_queue_t *rkqu);
6626 rd_kafka_queue_t *rkqu);
6905 rd_kafka_queue_t *rkqu);
7065 rd_kafka_queue_t *rkqu);
7140 rd_kafka_queue_t *rkqu);
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_queue.c | 676 if (rkqu->rkqu_is_owner) in rd_kafka_queue_destroy()
680 rd_free(rkqu); in rd_kafka_queue_destroy()
684 rd_kafka_queue_t *rkqu; in rd_kafka_queue_new0() local
686 rkqu = rd_calloc(1, sizeof(*rkqu)); in rd_kafka_queue_new0()
688 rkqu->rkqu_q = rkq; in rd_kafka_queue_new0()
691 rkqu->rkqu_rk = rk; in rd_kafka_queue_new0()
693 return rkqu; in rd_kafka_queue_new0()
699 rd_kafka_queue_t *rkqu; in rd_kafka_queue_new() local
705 rkqu->rkqu_is_owner = 1; in rd_kafka_queue_new()
706 return rkqu; in rd_kafka_queue_new()
[all …]
|
| H A D | rdkafka.h | 3202 void rd_kafka_queue_destroy(rd_kafka_queue_t *rkqu);
3362 void rd_kafka_queue_yield (rd_kafka_queue_t *rkqu);
3448 int64_t offset, rd_kafka_queue_t *rkqu);
4064 rd_kafka_queue_t *rkqu,
6418 rd_kafka_queue_t *rkqu);
6496 rd_kafka_queue_t *rkqu);
6620 rd_kafka_queue_t *rkqu);
6899 rd_kafka_queue_t *rkqu);
7059 rd_kafka_queue_t *rkqu);
7134 rd_kafka_queue_t *rkqu);
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_queue.c | 629 if (rkqu->rkqu_is_owner) in rd_kafka_queue_destroy()
633 rd_free(rkqu); in rd_kafka_queue_destroy()
637 rd_kafka_queue_t *rkqu; in rd_kafka_queue_new0() local
639 rkqu = rd_calloc(1, sizeof(*rkqu)); in rd_kafka_queue_new0()
641 rkqu->rkqu_q = rkq; in rd_kafka_queue_new0()
644 rkqu->rkqu_rk = rk; in rd_kafka_queue_new0()
646 return rkqu; in rd_kafka_queue_new0()
652 rd_kafka_queue_t *rkqu; in rd_kafka_queue_new() local
658 rkqu->rkqu_is_owner = 1; in rd_kafka_queue_new()
659 return rkqu; in rd_kafka_queue_new()
[all …]
|
| H A D | rdkafka.h | 2988 void rd_kafka_queue_destroy(rd_kafka_queue_t *rkqu);
3093 size_t rd_kafka_queue_length (rd_kafka_queue_t *rkqu);
3133 void rd_kafka_queue_cb_event_enable (rd_kafka_queue_t *rkqu,
3221 int64_t offset, rd_kafka_queue_t *rkqu);
3393 ssize_t rd_kafka_consume_batch_queue(rd_kafka_queue_t *rkqu,
3692 rd_kafka_queue_t *rkqu,
5836 rd_kafka_queue_t *rkqu);
5914 rd_kafka_queue_t *rkqu);
6038 rd_kafka_queue_t *rkqu);
6317 rd_kafka_queue_t *rkqu);
[all …]
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | Admin.c | 337 rd_kafka_queue_t *rkqu; in Admin_create_topics() local
434 rkqu = rd_kafka_queue_get_background(self->rk); in Admin_create_topics()
443 rd_kafka_CreateTopics(self->rk, c_objs, tcnt, c_options, rkqu); in Admin_create_topics()
480 rd_kafka_queue_t *rkqu; in Admin_delete_topics() local
537 rkqu = rd_kafka_queue_get_background(self->rk); in Admin_delete_topics()
584 rd_kafka_queue_t *rkqu; in Admin_create_partitions() local
664 rkqu = rd_kafka_queue_get_background(self->rk); in Admin_create_partitions()
710 rd_kafka_queue_t *rkqu; in Admin_describe_configs() local
792 rkqu = rd_kafka_queue_get_background(self->rk); in Admin_describe_configs()
845 rd_kafka_queue_t *rkqu; in Admin_alter_configs() local
[all …]
|
| H A D | Consumer.c | 44 if (self->u.Consumer.rkqu) { in Consumer_clear0()
45 rd_kafka_queue_destroy(self->u.Consumer.rkqu); in Consumer_clear0()
46 self->u.Consumer.rkqu = NULL; in Consumer_clear0()
383 rd_kafka_queue_t *rkqu = NULL; in Consumer_commit() local
437 rkqu = self->u.Consumer.rkqu; in Consumer_commit()
447 err = rd_kafka_commit_queue(self->rk, c_offsets, rkqu, in Consumer_commit()
918 rd_kafka_queue_t *rkqu = self->u.Consumer.rkqu; in Consumer_consume() local
942 n = (Py_ssize_t)rd_kafka_consume_batch_queue(rkqu, in Consumer_consume()
994 if (self->u.Consumer.rkqu) { in Consumer_close()
996 self->u.Consumer.rkqu = NULL; in Consumer_close()
[all …]
|
| /dports/net/pecl-rdkafka/rdkafka-4.0.4/ |
| H A D | queue.c | 42 if (intern->rkqu) { in kafka_queue_free()
75 if (!orkqu->rkqu) { in get_kafka_queue_object()
106 message = rd_kafka_consume_queue(intern->rkqu, timeout_ms); in ZEND_END_ARG_INFO()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | HandleImpl.cpp | 364 rd_kafka_queue_t *rkqu; in get_partition_queue() local
365 rkqu = rd_kafka_queue_get_partition(rk_, in get_partition_queue()
369 if (rkqu == NULL) in get_partition_queue()
373 queueimpl->queue_ = rkqu; in get_partition_queue()
380 rd_kafka_queue_t *rkqu = NULL; in set_log_queue() local
383 rkqu = queueimpl->queue_; in set_log_queue()
386 rd_kafka_set_log_queue(rk_, rkqu)); in set_log_queue()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
| H A D | HandleImpl.cpp | 362 rd_kafka_queue_t *rkqu; in get_partition_queue() local
363 rkqu = rd_kafka_queue_get_partition(rk_, in get_partition_queue()
367 if (rkqu == NULL) in get_partition_queue()
371 queueimpl->queue_ = rkqu; in get_partition_queue()
378 rd_kafka_queue_t *rkqu = NULL; in set_log_queue() local
381 rkqu = queueimpl->queue_; in set_log_queue()
384 rd_kafka_set_log_queue(rk_, rkqu)); in set_log_queue()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
| H A D | HandleImpl.cpp | 364 rd_kafka_queue_t *rkqu; in get_partition_queue() local
365 rkqu = rd_kafka_queue_get_partition(rk_, in get_partition_queue()
369 if (rkqu == NULL) in get_partition_queue()
373 queueimpl->queue_ = rkqu; in get_partition_queue()
380 rd_kafka_queue_t *rkqu = NULL; in set_log_queue() local
383 rkqu = queueimpl->queue_; in set_log_queue()
386 rd_kafka_set_log_queue(rk_, rkqu)); in set_log_queue()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 1092 rkqu: *mut rd_kafka_queue_t, in rd_kafka_set_log_queue()
1100 rkqu: *mut rd_kafka_queue_t, in rd_kafka_queue_io_event_enable()
1108 rkqu: *mut rd_kafka_queue_t, in rd_kafka_queue_cb_event_enable()
1122 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_start_queue()
1165 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_queue()
1171 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_batch_queue()
1179 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_callback_queue()
1254 rkqu: *mut rd_kafka_queue_t, in rd_kafka_commit_queue()
1575 rkqu: *mut rd_kafka_queue_t, in rd_kafka_queue_poll()
1901 rkqu: *mut rd_kafka_queue_t, in rd_kafka_CreateTopics()
[all …]
|