| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_broker.c | 1479 rd_kafka_broker_t *rkb; in rd_kafka_broker_any() local
1511 rd_kafka_broker_t *rkb; in rd_kafka_broker_any_up() local
1633 rd_kafka_broker_t *rkb; in rd_kafka_broker_controller_nowait() local
2383 rd_kafka_broker_t *rkb, in rd_kafka_broker_handle_ApiVersion()
4746 rd_kafka_broker_t *rkb, in rd_kafka_broker_fetch_reply()
5245 rd_kafka_broker_t *rkb = arg; in rd_kafka_broker_thread_main() local
5522 rd_kafka_broker_t *rkb; in rd_kafka_broker_internal() local
5547 rd_kafka_broker_t *rkb; in rd_kafka_broker_add() local
5906 rd_kafka_broker_t *rkb; in rd_kafka_broker_find() local
6050 rd_kafka_broker_t *rkb; in rd_kafka_brokers_add0() local
[all …]
|
| H A D | rdkafka_request.c | 87 int rd_kafka_err_action (rd_kafka_broker_t *rkb, in rd_kafka_err_action()
721 rd_kafka_broker_t *rkb, in rd_kafka_handle_OffsetFetch()
916 rd_kafka_broker_t *rkb, in rd_kafka_op_handle_OffsetFetch()
1135 rd_kafka_broker_t *rkb, in rd_kafka_handle_OffsetCommit()
1400 rd_kafka_OffsetDeleteRequest (rd_kafka_broker_t *rkb, in rd_kafka_OffsetDeleteRequest()
1703 rd_kafka_broker_t *rkb, in rd_kafka_handle_LeaveGroup()
1957 rd_kafka_MetadataRequest (rd_kafka_broker_t *rkb, in rd_kafka_MetadataRequest()
2111 rd_kafka_broker_t *rkb, in rd_kafka_handle_ApiVersion()
3306 rd_kafka_broker_t *rkb, in rd_kafka_msgbatch_handle_Produce_result()
4464 rd_kafka_EndTxnRequest (rd_kafka_broker_t *rkb, in rd_kafka_EndTxnRequest()
[all …]
|
| H A D | rdkafka_buf.c | 126 rd_kafka_buf_t *rd_kafka_buf_new_request0 (rd_kafka_broker_t *rkb, in rd_kafka_buf_new_request0()
248 void rd_kafka_bufq_purge (rd_kafka_broker_t *rkb, in rd_kafka_bufq_purge()
274 void rd_kafka_bufq_connection_reset (rd_kafka_broker_t *rkb, in rd_kafka_bufq_connection_reset()
307 void rd_kafka_bufq_dump (rd_kafka_broker_t *rkb, const char *fac, in rd_kafka_bufq_dump()
370 int rd_kafka_buf_retry (rd_kafka_broker_t *rkb, rd_kafka_buf_t *rkbuf) { in rd_kafka_buf_retry()
454 rd_kafka_broker_t *rkb, rd_kafka_resp_err_t err, in rd_kafka_buf_callback()
|
| H A D | rdkafka_lz4.c | 50 rd_kafka_lz4_decompress_fixup_bad_framing (rd_kafka_broker_t *rkb, in rd_kafka_lz4_decompress_fixup_bad_framing()
109 rd_kafka_lz4_compress_break_framing (rd_kafka_broker_t *rkb, in rd_kafka_lz4_compress_break_framing()
168 rd_kafka_lz4_decompress (rd_kafka_broker_t *rkb, int proper_hc, int64_t Offset, in rd_kafka_lz4_decompress()
330 rd_kafka_lz4_compress (rd_kafka_broker_t *rkb, int proper_hc, int comp_level, in rd_kafka_lz4_compress()
|
| H A D | rdkafka_transport.c | 368 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_connect_done() local
421 void rd_kafka_transport_request_sent (rd_kafka_broker_t *rkb, in rd_kafka_transport_request_sent()
538 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_post_connect_setup() local
615 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_connected() local
684 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_io_event() local
813 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_io_serve() local
844 rd_kafka_transport_t *rd_kafka_transport_new (rd_kafka_broker_t *rkb, in rd_kafka_transport_new()
893 rd_kafka_transport_t *rd_kafka_transport_connect (rd_kafka_broker_t *rkb, in rd_kafka_transport_connect()
|
| H A D | rdkafka_metadata.c | 48 rd_kafka_broker_t *rkb; in rd_kafka_metadata() local
230 rd_kafka_parse_Metadata (rd_kafka_broker_t *rkb, in rd_kafka_parse_Metadata()
877 rd_kafka_metadata_refresh_topics (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_topics()
973 rd_kafka_metadata_refresh_known_topics (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_known_topics()
1022 rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_consumer_topics()
1091 rd_kafka_metadata_refresh_brokers (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_brokers()
1110 rd_kafka_metadata_refresh_all (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_all()
1153 rd_kafka_metadata_request (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_request()
|
| H A D | rdkafka_coord.c | 117 rd_kafka_broker_t *rkb) { in rd_kafka_coord_cache_add()
156 rd_kafka_broker_t *rkb) { in rd_kafka_coord_cache_evict()
309 rd_kafka_broker_t *rkb, in rd_kafka_coord_req_handle_FindCoordinator()
438 rd_kafka_broker_t *rkb; in rd_kafka_coord_req_fsm() local
526 void rd_kafka_coord_rkb_monitor_cb (rd_kafka_broker_t *rkb) { in rd_kafka_coord_rkb_monitor_cb()
|
| H A D | rdkafka_zstd.c | 41 rd_kafka_zstd_decompress (rd_kafka_broker_t *rkb, in rd_kafka_zstd_decompress()
119 rd_kafka_zstd_compress (rd_kafka_broker_t *rkb, int comp_level, in rd_kafka_zstd_compress()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_broker.c | 1228 rd_kafka_broker_t *rkb; in rd_kafka_broker_any() local
1262 rd_kafka_broker_t *rkb; in rd_kafka_broker_any_up() local
1294 rd_kafka_broker_t *rkb; in rd_kafka_broker_any_usable() local
1416 rd_kafka_broker_t *rkb; in rd_kafka_broker_controller_nowait() local
2142 rd_kafka_broker_t *rkb, in rd_kafka_broker_handle_ApiVersion()
4376 rd_kafka_broker_t *rkb, in rd_kafka_broker_fetch_reply()
5105 rd_kafka_broker_t *rkb; in rd_kafka_broker_internal() local
5130 rd_kafka_broker_t *rkb; in rd_kafka_broker_add() local
5490 rd_kafka_broker_t *rkb; in rd_kafka_broker_find() local
5634 rd_kafka_broker_t *rkb; in rd_kafka_brokers_add0() local
[all …]
|
| H A D | rdkafka_request.c | 87 int rd_kafka_err_action (rd_kafka_broker_t *rkb, in rd_kafka_err_action()
574 rd_kafka_broker_t *rkb, in rd_kafka_handle_OffsetFetch()
726 rd_kafka_broker_t *rkb, in rd_kafka_op_handle_OffsetFetch()
889 rd_kafka_broker_t *rkb, in rd_kafka_handle_OffsetCommit()
1290 rd_kafka_broker_t *rkb, in rd_kafka_handle_SyncGroup()
1514 rd_kafka_broker_t *rkb, in rd_kafka_handle_LeaveGroup()
1764 rd_kafka_MetadataRequest (rd_kafka_broker_t *rkb, in rd_kafka_MetadataRequest()
1895 rd_kafka_broker_t *rkb, in rd_kafka_handle_ApiVersion()
3092 rd_kafka_broker_t *rkb, in rd_kafka_msgbatch_handle_Produce_result()
4084 rd_kafka_EndTxnRequest (rd_kafka_broker_t *rkb, in rd_kafka_EndTxnRequest()
[all …]
|
| H A D | rdkafka_buf.c | 122 rd_kafka_buf_t *rd_kafka_buf_new_request (rd_kafka_broker_t *rkb, int16_t ApiKey, in rd_kafka_buf_new_request()
229 void rd_kafka_bufq_purge (rd_kafka_broker_t *rkb, in rd_kafka_bufq_purge()
255 void rd_kafka_bufq_connection_reset (rd_kafka_broker_t *rkb, in rd_kafka_bufq_connection_reset()
288 void rd_kafka_bufq_dump (rd_kafka_broker_t *rkb, const char *fac, in rd_kafka_bufq_dump()
351 int rd_kafka_buf_retry (rd_kafka_broker_t *rkb, rd_kafka_buf_t *rkbuf) { in rd_kafka_buf_retry()
431 rd_kafka_broker_t *rkb, rd_kafka_resp_err_t err, in rd_kafka_buf_callback()
|
| H A D | rdkafka_metadata.c | 48 rd_kafka_broker_t *rkb; in rd_kafka_metadata() local
213 rd_kafka_parse_Metadata (rd_kafka_broker_t *rkb, in rd_kafka_parse_Metadata()
778 rd_kafka_metadata_refresh_topics (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_topics()
859 rd_kafka_metadata_refresh_known_topics (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_known_topics()
897 rd_kafka_metadata_refresh_brokers (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_brokers()
914 rd_kafka_metadata_refresh_all (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_refresh_all()
949 rd_kafka_metadata_request (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_metadata_request()
|
| H A D | rdkafka_lz4.c | 50 rd_kafka_lz4_decompress_fixup_bad_framing (rd_kafka_broker_t *rkb, in rd_kafka_lz4_decompress_fixup_bad_framing()
109 rd_kafka_lz4_compress_break_framing (rd_kafka_broker_t *rkb, in rd_kafka_lz4_compress_break_framing()
168 rd_kafka_lz4_decompress (rd_kafka_broker_t *rkb, int proper_hc, int64_t Offset, in rd_kafka_lz4_decompress()
330 rd_kafka_lz4_compress (rd_kafka_broker_t *rkb, int proper_hc, int comp_level, in rd_kafka_lz4_compress()
|
| H A D | rdkafka_transport.c | 366 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_connect_done() local
419 void rd_kafka_transport_request_sent (rd_kafka_broker_t *rkb, in rd_kafka_transport_request_sent()
536 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_post_connect_setup() local
613 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_connected() local
677 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_io_event() local
797 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_io_serve() local
828 rd_kafka_transport_t *rd_kafka_transport_new (rd_kafka_broker_t *rkb, in rd_kafka_transport_new()
877 rd_kafka_transport_t *rd_kafka_transport_connect (rd_kafka_broker_t *rkb, in rd_kafka_transport_connect()
|
| H A D | rdkafka_coord.c | 117 rd_kafka_broker_t *rkb) { in rd_kafka_coord_cache_add()
156 rd_kafka_broker_t *rkb) { in rd_kafka_coord_cache_evict()
275 rd_kafka_broker_t *rkb, in rd_kafka_coord_req_handle_FindCoordinator()
385 rd_kafka_broker_t *rkb; in rd_kafka_coord_req_fsm() local
460 void rd_kafka_coord_rkb_monitor_cb (rd_kafka_broker_t *rkb) { in rd_kafka_coord_rkb_monitor_cb()
|
| H A D | rdkafka_broker.h | 319 #define rd_kafka_broker_keep(rkb) rd_refcnt_add(&(rkb)->rkb_refcnt) argument
322 #define rd_kafka_broker_lock(rkb) mtx_lock(&(rkb)->rkb_lock) argument
323 #define rd_kafka_broker_unlock(rkb) mtx_unlock(&(rkb)->rkb_lock) argument
333 rd_kafka_broker_state_t rd_kafka_broker_get_state (rd_kafka_broker_t *rkb) { in rd_kafka_broker_get_state()
358 rd_kafka_broker_is_up (rd_kafka_broker_t *rkb) { in rd_kafka_broker_is_up()
378 int rd_kafka_broker_supports (rd_kafka_broker_t *rkb, int features) { in rd_kafka_broker_supports()
414 rd_kafka_broker_filter_non_blocking (rd_kafka_broker_t *rkb, void *opaque) { in rd_kafka_broker_filter_non_blocking()
423 rd_kafka_broker_filter_non_idempotent (rd_kafka_broker_t *rkb, void *opaque) { in rd_kafka_broker_filter_non_idempotent()
433 rd_kafka_broker_filter_can_coord_query (rd_kafka_broker_t *rkb, void *opaque) { in rd_kafka_broker_filter_can_coord_query()
477 #define rd_kafka_broker_destroy(rkb) \ argument
[all …]
|
| H A D | rdkafka_idempotence.c | 110 rd_kafka_broker_t *rkb; in rd_kafka_idemp_broker_any() local
193 rd_kafka_broker_t *rkb; in rd_kafka_idemp_pid_fsm() local
358 void rd_kafka_idemp_request_pid_failed (rd_kafka_broker_t *rkb, in rd_kafka_idemp_request_pid_failed()
408 void rd_kafka_idemp_pid_update (rd_kafka_broker_t *rkb, in rd_kafka_idemp_pid_update()
|
| H A D | rdkafka_zstd.c | 41 rd_kafka_zstd_decompress (rd_kafka_broker_t *rkb, in rd_kafka_zstd_decompress()
119 rd_kafka_zstd_compress (rd_kafka_broker_t *rkb, int comp_level, in rd_kafka_zstd_compress()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_broker.c | 1466 rd_kafka_broker_t *rkb; in rd_kafka_broker_any() local
1498 rd_kafka_broker_t *rkb; in rd_kafka_broker_any_up() local
1620 rd_kafka_broker_t *rkb; in rd_kafka_broker_controller_nowait() local
2370 rd_kafka_broker_t *rkb, in rd_kafka_broker_handle_ApiVersion()
4691 rd_kafka_broker_t *rkb, in rd_kafka_broker_fetch_reply()
5190 rd_kafka_broker_t *rkb = arg; in rd_kafka_broker_thread_main() local
5467 rd_kafka_broker_t *rkb; in rd_kafka_broker_internal() local
5492 rd_kafka_broker_t *rkb; in rd_kafka_broker_add() local
5851 rd_kafka_broker_t *rkb; in rd_kafka_broker_find() local
5995 rd_kafka_broker_t *rkb; in rd_kafka_brokers_add0() local
[all …]
|
| H A D | rdkafka_request.c | 87 int rd_kafka_err_action (rd_kafka_broker_t *rkb, in rd_kafka_err_action()
552 void rd_kafka_OffsetRequest (rd_kafka_broker_t *rkb, in rd_kafka_OffsetRequest()
646 rd_kafka_broker_t *rkb, in rd_kafka_handle_OffsetFetch()
841 rd_kafka_broker_t *rkb, in rd_kafka_op_handle_OffsetFetch()
1474 rd_kafka_broker_t *rkb, in rd_kafka_handle_SyncGroup()
1698 rd_kafka_broker_t *rkb, in rd_kafka_handle_LeaveGroup()
1952 rd_kafka_MetadataRequest (rd_kafka_broker_t *rkb, in rd_kafka_MetadataRequest()
2106 rd_kafka_broker_t *rkb, in rd_kafka_handle_ApiVersion()
3301 rd_kafka_broker_t *rkb, in rd_kafka_msgbatch_handle_Produce_result()
4459 rd_kafka_EndTxnRequest (rd_kafka_broker_t *rkb, in rd_kafka_EndTxnRequest()
[all …]
|
| H A D | rdkafka_buf.c | 123 rd_kafka_buf_t *rd_kafka_buf_new_request0 (rd_kafka_broker_t *rkb, in rd_kafka_buf_new_request0()
245 void rd_kafka_bufq_purge (rd_kafka_broker_t *rkb, in rd_kafka_bufq_purge()
271 void rd_kafka_bufq_connection_reset (rd_kafka_broker_t *rkb, in rd_kafka_bufq_connection_reset()
304 void rd_kafka_bufq_dump (rd_kafka_broker_t *rkb, const char *fac, in rd_kafka_bufq_dump()
367 int rd_kafka_buf_retry (rd_kafka_broker_t *rkb, rd_kafka_buf_t *rkbuf) { in rd_kafka_buf_retry()
451 rd_kafka_broker_t *rkb, rd_kafka_resp_err_t err, in rd_kafka_buf_callback()
|
| H A D | rdkafka_transport.c | 352 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_connect_done() local
405 void rd_kafka_transport_request_sent (rd_kafka_broker_t *rkb, in rd_kafka_transport_request_sent()
522 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_post_connect_setup() local
599 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_connected() local
668 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_io_event() local
797 rd_kafka_broker_t *rkb = rktrans->rktrans_rkb; in rd_kafka_transport_io_serve() local
828 rd_kafka_transport_t *rd_kafka_transport_new (rd_kafka_broker_t *rkb, in rd_kafka_transport_new()
877 rd_kafka_transport_t *rd_kafka_transport_connect (rd_kafka_broker_t *rkb, in rd_kafka_transport_connect()
|
| H A D | rdkafka_coord.c | 117 rd_kafka_broker_t *rkb) { in rd_kafka_coord_cache_add()
156 rd_kafka_broker_t *rkb) { in rd_kafka_coord_cache_evict()
309 rd_kafka_broker_t *rkb, in rd_kafka_coord_req_handle_FindCoordinator()
438 rd_kafka_broker_t *rkb; in rd_kafka_coord_req_fsm() local
526 void rd_kafka_coord_rkb_monitor_cb (rd_kafka_broker_t *rkb) { in rd_kafka_coord_rkb_monitor_cb()
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/include/storage/ |
| H A D | predicate_internals.h | 50 * cleaned up earlier.) A transaction which is rolled back is cleaned up in rd_kafka_lz4_decompress_fixup_bad_framing()
109 TransactionId xmin; /* the transaction's snapshot xmin */ in rd_kafka_lz4_decompress_fixup_bad_framing()
168 int SxactGlobalXminCount; /* how many active serializable in rd_kafka_lz4_decompress()
331 PREDICATELOCKTAG tag; /* unique identifier of lock */ in rd_kafka_lz4_compress()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0006-symbols.c | 41 int main_0006_symbols (int argc, char **argv) { in rd_kafka_zstd_decompress()
119 rd_kafka_metadata_destroy(NULL); in rd_kafka_zstd_decompress()
|