| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_mock.c | 616 if (mcluster->fd_cnt + 1 >= mcluster->fd_size) { in rd_kafka_mock_cluster_io_add()
619 mcluster->fds = rd_realloc(mcluster->fds, in rd_kafka_mock_cluster_io_add()
627 memset(&mcluster->fds[mcluster->fd_cnt], 0, in rd_kafka_mock_cluster_io_add()
628 sizeof(mcluster->fds[mcluster->fd_cnt])); in rd_kafka_mock_cluster_io_add()
629 mcluster->fds[mcluster->fd_cnt].fd = fd; in rd_kafka_mock_cluster_io_add()
630 mcluster->fds[mcluster->fd_cnt].events = events; in rd_kafka_mock_cluster_io_add()
631 mcluster->fds[mcluster->fd_cnt].revents = 0; in rd_kafka_mock_cluster_io_add()
1126 mcluster->handlers[i].cb(mcluster, mcluster->fds[i].fd, in rd_kafka_mock_cluster_io_poll()
1960 mcluster = rd_calloc(1, sizeof(*mcluster)); in rd_kafka_mock_cluster_new()
1969 rd_snprintf(mcluster->id, sizeof(mcluster->id), in rd_kafka_mock_cluster_new()
[all …]
|
| H A D | rdkafka_mock.h | 96 void rd_kafka_mock_cluster_destroy (rd_kafka_mock_cluster_t *mcluster);
105 rd_kafka_mock_cluster_handle (const rd_kafka_mock_cluster_t *mcluster);
145 void rd_kafka_mock_topic_set_error (rd_kafka_mock_cluster_t *mcluster,
160 rd_kafka_mock_topic_create (rd_kafka_mock_cluster_t *mcluster,
173 rd_kafka_mock_partition_set_leader (rd_kafka_mock_cluster_t *mcluster,
185 rd_kafka_mock_partition_set_follower (rd_kafka_mock_cluster_t *mcluster,
210 rd_kafka_mock_broker_set_down (rd_kafka_mock_cluster_t *mcluster,
218 rd_kafka_mock_broker_set_up (rd_kafka_mock_cluster_t *mcluster,
227 rd_kafka_mock_broker_set_rack (rd_kafka_mock_cluster_t *mcluster,
241 rd_kafka_mock_coordinator_set (rd_kafka_mock_cluster_t *mcluster,
[all …]
|
| H A D | rdkafka_mock_handlers.c | 70 all_err = rd_kafka_mock_next_request_error(mcluster, in rd_kafka_mock_handle_Produce()
897 TAILQ_FOREACH(mrkb, &mcluster->brokers, link) { in rd_kafka_mock_handle_Metadata()
1048 err = rd_kafka_mock_next_request_error(mcluster, in rd_kafka_mock_handle_FindCoordinator()
1123 rd_kafka_dbg(mcluster->rk, MOCK, "MOCK", in rd_kafka_mock_handle_JoinGroup()
1517 rd_kafka_mock_cluster_get_coord(mcluster, in rd_kafka_mock_handle_InitProducerId()
1580 rd_kafka_mock_cluster_get_coord(mcluster, in rd_kafka_mock_handle_AddPartitionsToTxn()
1662 rd_kafka_mock_cluster_get_coord(mcluster, in rd_kafka_mock_handle_AddOffsetsToTxn()
1716 rd_kafka_mock_cluster_get_coord(mcluster, in rd_kafka_mock_handle_TxnOffsetCommit()
1809 rd_kafka_mock_cluster_get_coord(mcluster, in rd_kafka_mock_handle_EndTxn()
1874 mcluster, in rd_kafka_mock_handle_ApiVersion()
[all …]
|
| H A D | rdkafka_mock_int.h | 233 *mcluster,
337 rd_kafka_mock_topic_auto_create (rd_kafka_mock_cluster_t *mcluster,
341 rd_kafka_mock_topic_find (const rd_kafka_mock_cluster_t *mcluster,
344 rd_kafka_mock_topic_find_by_kstr (const rd_kafka_mock_cluster_t *mcluster,
347 rd_kafka_mock_cluster_get_coord (rd_kafka_mock_cluster_t *mcluster,
364 rd_kafka_mock_next_request_error (rd_kafka_mock_cluster_t *mcluster,
380 return (ApiVersion >= mcluster->api_handlers[ApiKey].MinVersion && in rd_kafka_mock_cluster_ApiVersion_check()
381 ApiVersion <= mcluster->api_handlers[ApiKey].MaxVersion); in rd_kafka_mock_cluster_ApiVersion_check()
423 rd_kafka_mock_cgrp_find (rd_kafka_mock_cluster_t *mcluster,
426 rd_kafka_mock_cgrp_get (rd_kafka_mock_cluster_t *mcluster,
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_mock.c | 619 if (mcluster->fd_cnt + 1 >= mcluster->fd_size) { in rd_kafka_mock_cluster_io_add()
622 mcluster->fds = rd_realloc(mcluster->fds, in rd_kafka_mock_cluster_io_add()
630 memset(&mcluster->fds[mcluster->fd_cnt], 0, in rd_kafka_mock_cluster_io_add()
631 sizeof(mcluster->fds[mcluster->fd_cnt])); in rd_kafka_mock_cluster_io_add()
632 mcluster->fds[mcluster->fd_cnt].fd = fd; in rd_kafka_mock_cluster_io_add()
633 mcluster->fds[mcluster->fd_cnt].events = events; in rd_kafka_mock_cluster_io_add()
634 mcluster->fds[mcluster->fd_cnt].revents = 0; in rd_kafka_mock_cluster_io_add()
1172 mcluster->handlers[i].cb(mcluster, mcluster->fds[i].fd, in rd_kafka_mock_cluster_io_poll()
2126 mcluster = rd_calloc(1, sizeof(*mcluster)); in rd_kafka_mock_cluster_new()
2133 rd_snprintf(mcluster->id, sizeof(mcluster->id), in rd_kafka_mock_cluster_new()
[all …]
|
| H A D | rdkafka_mock.h | 103 void rd_kafka_mock_cluster_destroy (rd_kafka_mock_cluster_t *mcluster);
112 rd_kafka_mock_cluster_handle (const rd_kafka_mock_cluster_t *mcluster);
194 void rd_kafka_mock_topic_set_error (rd_kafka_mock_cluster_t *mcluster,
209 rd_kafka_mock_topic_create (rd_kafka_mock_cluster_t *mcluster,
223 rd_kafka_mock_partition_set_leader (rd_kafka_mock_cluster_t *mcluster,
260 rd_kafka_mock_broker_set_down (rd_kafka_mock_cluster_t *mcluster,
268 rd_kafka_mock_broker_set_up (rd_kafka_mock_cluster_t *mcluster,
276 rd_kafka_mock_broker_set_rtt (rd_kafka_mock_cluster_t *mcluster,
283 rd_kafka_mock_broker_set_rack (rd_kafka_mock_cluster_t *mcluster,
297 rd_kafka_mock_coordinator_set (rd_kafka_mock_cluster_t *mcluster,
[all …]
|
| H A D | rdkafka_mock_handlers.c | 1474 mtx_lock(&mcluster->lock); in rd_kafka_mock_pid_new()
1475 rd_list_add(&mcluster->pids, pid); in rd_kafka_mock_pid_new()
1477 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_new()
1492 mtx_lock(&mcluster->lock); in rd_kafka_mock_pid_check()
1499 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_check()
1514 mtx_lock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1517 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1522 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1528 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1530 rd_kafka_dbg(mcluster->rk, MOCK, "MOCK", in rd_kafka_mock_pid_bump()
[all …]
|
| H A D | rdkafka_mock_int.h | 246 *mcluster,
354 rd_kafka_mock_topic_auto_create (rd_kafka_mock_cluster_t *mcluster,
358 rd_kafka_mock_topic_find (const rd_kafka_mock_cluster_t *mcluster,
361 rd_kafka_mock_topic_find_by_kstr (const rd_kafka_mock_cluster_t *mcluster,
364 rd_kafka_mock_cluster_get_coord (rd_kafka_mock_cluster_t *mcluster,
394 rd_kafka_mock_cluster_ApiVersion_check (const rd_kafka_mock_cluster_t *mcluster,
397 return (ApiVersion >= mcluster->api_handlers[ApiKey].MinVersion &&
398 ApiVersion <= mcluster->api_handlers[ApiKey].MaxVersion);
441 rd_kafka_mock_cgrp_find (rd_kafka_mock_cluster_t *mcluster,
444 rd_kafka_mock_cgrp_get (rd_kafka_mock_cluster_t *mcluster,
[all …]
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_mock.c | 619 if (mcluster->fd_cnt + 1 >= mcluster->fd_size) { in rd_kafka_mock_cluster_io_add()
622 mcluster->fds = rd_realloc(mcluster->fds, in rd_kafka_mock_cluster_io_add()
630 memset(&mcluster->fds[mcluster->fd_cnt], 0, in rd_kafka_mock_cluster_io_add()
631 sizeof(mcluster->fds[mcluster->fd_cnt])); in rd_kafka_mock_cluster_io_add()
632 mcluster->fds[mcluster->fd_cnt].fd = fd; in rd_kafka_mock_cluster_io_add()
633 mcluster->fds[mcluster->fd_cnt].events = events; in rd_kafka_mock_cluster_io_add()
634 mcluster->fds[mcluster->fd_cnt].revents = 0; in rd_kafka_mock_cluster_io_add()
1172 mcluster->handlers[i].cb(mcluster, mcluster->fds[i].fd, in rd_kafka_mock_cluster_io_poll()
2147 mcluster = rd_calloc(1, sizeof(*mcluster)); in rd_kafka_mock_cluster_new()
2154 rd_snprintf(mcluster->id, sizeof(mcluster->id), in rd_kafka_mock_cluster_new()
[all …]
|
| H A D | rdkafka_mock.h | 103 void rd_kafka_mock_cluster_destroy (rd_kafka_mock_cluster_t *mcluster);
112 rd_kafka_mock_cluster_handle (const rd_kafka_mock_cluster_t *mcluster);
198 void rd_kafka_mock_topic_set_error (rd_kafka_mock_cluster_t *mcluster,
213 rd_kafka_mock_topic_create (rd_kafka_mock_cluster_t *mcluster,
227 rd_kafka_mock_partition_set_leader (rd_kafka_mock_cluster_t *mcluster,
264 rd_kafka_mock_broker_set_down (rd_kafka_mock_cluster_t *mcluster,
272 rd_kafka_mock_broker_set_up (rd_kafka_mock_cluster_t *mcluster,
280 rd_kafka_mock_broker_set_rtt (rd_kafka_mock_cluster_t *mcluster,
287 rd_kafka_mock_broker_set_rack (rd_kafka_mock_cluster_t *mcluster,
301 rd_kafka_mock_coordinator_set (rd_kafka_mock_cluster_t *mcluster,
[all …]
|
| H A D | rdkafka_mock_handlers.c | 1473 mtx_lock(&mcluster->lock); in rd_kafka_mock_pid_new()
1474 rd_list_add(&mcluster->pids, pid); in rd_kafka_mock_pid_new()
1476 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_new()
1491 mtx_lock(&mcluster->lock); in rd_kafka_mock_pid_check()
1498 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_check()
1513 mtx_lock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1516 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1521 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1527 mtx_unlock(&mcluster->lock); in rd_kafka_mock_pid_bump()
1529 rd_kafka_dbg(mcluster->rk, MOCK, "MOCK", in rd_kafka_mock_pid_bump()
[all …]
|
| H A D | rdkafka_mock_int.h | 246 *mcluster,
354 rd_kafka_mock_topic_auto_create (rd_kafka_mock_cluster_t *mcluster,
358 rd_kafka_mock_topic_find (const rd_kafka_mock_cluster_t *mcluster,
361 rd_kafka_mock_topic_find_by_kstr (const rd_kafka_mock_cluster_t *mcluster,
364 rd_kafka_mock_cluster_get_coord (rd_kafka_mock_cluster_t *mcluster,
394 rd_kafka_mock_cluster_ApiVersion_check (const rd_kafka_mock_cluster_t *mcluster, in rd_kafka_mock_cluster_ApiVersion_check() argument
397 return (ApiVersion >= mcluster->api_handlers[ApiKey].MinVersion && in rd_kafka_mock_cluster_ApiVersion_check()
398 ApiVersion <= mcluster->api_handlers[ApiKey].MaxVersion); in rd_kafka_mock_cluster_ApiVersion_check()
441 rd_kafka_mock_cgrp_find (rd_kafka_mock_cluster_t *mcluster,
444 rd_kafka_mock_cgrp_get (rd_kafka_mock_cluster_t *mcluster,
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0105-transactions_mock.c | 210 mcluster, in do_test_txn_recoverable_errors()
240 mcluster, in do_test_txn_recoverable_errors()
267 mcluster, in do_test_txn_recoverable_errors()
273 mcluster, in do_test_txn_recoverable_errors()
292 mcluster, in do_test_txn_recoverable_errors()
346 mcluster, in do_test_txn_fatal_idempo_errors()
446 mcluster, in do_test_txn_slow_reinit()
454 mcluster, in do_test_txn_slow_reinit()
574 mcluster, in do_test_txn_fenced_reinit()
582 mcluster, in do_test_txn_fenced_reinit()
[all …]
|
| H A D | 0104-fetch_from_follower_mock.c | 46 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_reset() local
56 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_offset_reset()
82 mcluster, in do_test_offset_reset()
102 test_mock_cluster_destroy(mcluster); in do_test_offset_reset()
116 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_reset_lag() local
172 test_mock_cluster_destroy(mcluster); in do_test_offset_reset_lag()
186 rd_kafka_mock_cluster_t *mcluster; in do_test_unknown_follower() local
239 test_mock_cluster_destroy(mcluster); in do_test_unknown_follower()
252 rd_kafka_mock_cluster_t *mcluster; in do_test_replica_not_available() local
281 mcluster, in do_test_replica_not_available()
[all …]
|
| H A D | 0117-mock_errors.c | 50 rd_kafka_mock_cluster_t *mcluster; in push_assignment()
74 mcluster = rd_kafka_handle_mock_cluster(rk); in push_assignment()
75 TEST_ASSERT(mcluster, "missing mock cluster"); in push_assignment()
78 mcluster, in push_assignment()
113 rd_kafka_mock_cluster_t *mcluster;
123 mcluster = test_mock_cluster_new(3, &bootstraps);
125 rd_kafka_mock_topic_create(mcluster, topic, 4, 3);
160 mcluster,
183 test_mock_cluster_destroy(mcluster);
|
| H A D | 0106-cgrp_sess_timeout.c | 142 rd_kafka_mock_cluster_t *mcluster; in do_test_session_timeout() local
154 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_session_timeout()
156 rd_kafka_mock_coordinator_set(mcluster, "group", groupid, 1); in do_test_session_timeout()
180 mcluster, RD_KAFKAP_Heartbeat, in do_test_session_timeout()
217 test_mock_cluster_destroy(mcluster); in do_test_session_timeout()
228 rd_kafka_mock_cluster_t *mcluster; in do_test_commit_on_lost() local
239 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_commit_on_lost()
241 rd_kafka_mock_coordinator_set(mcluster, "group", groupid, 1); in do_test_commit_on_lost()
267 rd_kafka_mock_broker_set_down(mcluster, 1); in do_test_commit_on_lost()
284 test_mock_cluster_destroy(mcluster); in do_test_commit_on_lost()
|
| H A D | 0120-asymmetric_subscription.c | 162 rd_kafka_mock_cluster_t *mcluster; in main_0120_asymmetric_subscription() local
169 mcluster = test_mock_cluster_new(3, &bootstraps); in main_0120_asymmetric_subscription()
173 rd_kafka_mock_topic_create(mcluster, "t1", _PART_CNT, 1); in main_0120_asymmetric_subscription()
174 rd_kafka_mock_topic_create(mcluster, "t2", _PART_CNT, 1); in main_0120_asymmetric_subscription()
175 rd_kafka_mock_topic_create(mcluster, "t3", _PART_CNT, 1); in main_0120_asymmetric_subscription()
176 rd_kafka_mock_topic_create(mcluster, "t4", _PART_CNT, 1); in main_0120_asymmetric_subscription()
183 test_mock_cluster_destroy(mcluster); in main_0120_asymmetric_subscription()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0105-transactions_mock.c | 210 mcluster, in do_test_txn_recoverable_errors()
240 mcluster, in do_test_txn_recoverable_errors()
267 mcluster, in do_test_txn_recoverable_errors()
273 mcluster, in do_test_txn_recoverable_errors()
292 mcluster, in do_test_txn_recoverable_errors()
346 mcluster, in do_test_txn_fatal_idempo_errors()
446 mcluster, in do_test_txn_slow_reinit()
454 mcluster, in do_test_txn_slow_reinit()
574 mcluster, in do_test_txn_fenced_reinit()
582 mcluster, in do_test_txn_fenced_reinit()
[all …]
|
| H A D | 0104-fetch_from_follower_mock.c | 46 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_reset() local
56 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_offset_reset()
82 mcluster, in do_test_offset_reset()
102 test_mock_cluster_destroy(mcluster); in do_test_offset_reset()
116 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_reset_lag() local
172 test_mock_cluster_destroy(mcluster); in do_test_offset_reset_lag()
186 rd_kafka_mock_cluster_t *mcluster; in do_test_unknown_follower() local
239 test_mock_cluster_destroy(mcluster); in do_test_unknown_follower()
252 rd_kafka_mock_cluster_t *mcluster; in do_test_replica_not_available() local
281 mcluster, in do_test_replica_not_available()
[all …]
|
| H A D | 0117-mock_errors.c | 50 rd_kafka_mock_cluster_t *mcluster; in do_test_producer_storage_error() local
74 mcluster = rd_kafka_handle_mock_cluster(rk); in do_test_producer_storage_error()
75 TEST_ASSERT(mcluster, "missing mock cluster"); in do_test_producer_storage_error()
78 mcluster, in do_test_producer_storage_error()
108 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_commit_error_during_rebalance() local
118 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_offset_commit_error_during_rebalance()
154 mcluster, in do_test_offset_commit_error_during_rebalance()
177 test_mock_cluster_destroy(mcluster); in do_test_offset_commit_error_during_rebalance()
192 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_commit_request_timed_out() local
231 mcluster, in do_test_offset_commit_request_timed_out()
[all …]
|
| H A D | 0106-cgrp_sess_timeout.c | 142 rd_kafka_mock_cluster_t *mcluster; in do_test_session_timeout() local
154 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_session_timeout()
156 rd_kafka_mock_coordinator_set(mcluster, "group", groupid, 1); in do_test_session_timeout()
180 mcluster, RD_KAFKAP_Heartbeat, in do_test_session_timeout()
217 test_mock_cluster_destroy(mcluster); in do_test_session_timeout()
228 rd_kafka_mock_cluster_t *mcluster; in do_test_commit_on_lost() local
239 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_commit_on_lost()
241 rd_kafka_mock_coordinator_set(mcluster, "group", groupid, 1); in do_test_commit_on_lost()
267 rd_kafka_mock_broker_set_down(mcluster, 1); in do_test_commit_on_lost()
284 test_mock_cluster_destroy(mcluster); in do_test_commit_on_lost()
|
| H A D | 0120-asymmetric_subscription.c | 162 rd_kafka_mock_cluster_t *mcluster; in main_0120_asymmetric_subscription() local
169 mcluster = test_mock_cluster_new(3, &bootstraps); in main_0120_asymmetric_subscription()
173 rd_kafka_mock_topic_create(mcluster, "t1", _PART_CNT, 1); in main_0120_asymmetric_subscription()
174 rd_kafka_mock_topic_create(mcluster, "t2", _PART_CNT, 1); in main_0120_asymmetric_subscription()
175 rd_kafka_mock_topic_create(mcluster, "t3", _PART_CNT, 1); in main_0120_asymmetric_subscription()
176 rd_kafka_mock_topic_create(mcluster, "t4", _PART_CNT, 1); in main_0120_asymmetric_subscription()
183 test_mock_cluster_destroy(mcluster); in main_0120_asymmetric_subscription()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0105-transactions_mock.c | 96 rd_kafka_mock_cluster_t *mcluster; in do_test_txn_recoverable_errors() local
117 mcluster, in do_test_txn_recoverable_errors()
140 mcluster, in do_test_txn_recoverable_errors()
168 mcluster, in do_test_txn_recoverable_errors()
174 mcluster, in do_test_txn_recoverable_errors()
193 mcluster, in do_test_txn_recoverable_errors()
216 rd_kafka_mock_cluster_t *mcluster; in do_test_txn_requires_abort_errors() local
238 mcluster, in do_test_txn_requires_abort_errors()
282 mcluster, in do_test_txn_requires_abort_errors()
316 mcluster, in do_test_txn_requires_abort_errors()
[all …]
|
| H A D | 0104-fetch_from_follower_mock.c | 46 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_reset() local
56 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_offset_reset()
65 rd_kafka_mock_partition_set_leader(mcluster, topic, 0, 1); in do_test_offset_reset()
82 mcluster, in do_test_offset_reset()
102 test_mock_cluster_destroy(mcluster); in do_test_offset_reset()
116 rd_kafka_mock_cluster_t *mcluster; in do_test_offset_reset_lag() local
126 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_offset_reset_lag()
172 test_mock_cluster_destroy(mcluster); in do_test_offset_reset_lag()
186 rd_kafka_mock_cluster_t *mcluster; in do_test_unknown_follower() local
195 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_unknown_follower()
[all …]
|
| H A D | 0106-cgrp_sess_timeout.c | 137 rd_kafka_mock_cluster_t *mcluster; in do_test_session_timeout() local
149 mcluster = test_mock_cluster_new(3, &bootstraps); in do_test_session_timeout()
151 rd_kafka_mock_coordinator_set(mcluster, "group", groupid, 1); in do_test_session_timeout()
175 mcluster, RD_KAFKAP_Heartbeat, in do_test_session_timeout()
212 test_mock_cluster_destroy(mcluster); in do_test_session_timeout()
|