Home
last modified time | relevance | path

Searched refs:rk_ops (Results 1 – 25 of 32) sorted by relevance

12

/dports/multimedia/v4l_compat/linux-5.13-rc2/sound/soc/rockchip/
H A Drk3288_hdmi_analog.c138 static const struct snd_soc_ops rk_ops = { variable
152 .ops = &rk_ops,
/dports/multimedia/libv4l/linux-5.13-rc2/sound/soc/rockchip/
H A Drk3288_hdmi_analog.c138 static const struct snd_soc_ops rk_ops = { variable
152 .ops = &rk_ops,
/dports/multimedia/v4l-utils/linux-5.13-rc2/sound/soc/rockchip/
H A Drk3288_hdmi_analog.c138 static const struct snd_soc_ops rk_ops = { variable
152 .ops = &rk_ops,
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_admin.c1790 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_CreateTopics()
2012 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_DeleteTopics()
2308 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_CreatePartitions()
2897 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_AlterConfigs()
3203 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_DescribeConfigs()
3453 rk->rk_ops); in rd_kafka_DeleteRecords_leaders_queried_cb()
3466 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_DeleteRecords_leaders_queried_cb()
3544 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_DeleteRecords()
3824 rk->rk_ops); in rd_kafka_DeleteGroups()
3844 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_DeleteGroups()
[all …]
H A Drdkafka_txnmgr.c939 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_register_partitions()
1264 reply = rd_kafka_op_req0(rk->rk_ops, tmpq, rko, RD_POLL_INFINITE); in rd_kafka_txn_curr_api_req()
1484 rk->rk_ops, in rd_kafka_begin_transaction()
1651 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_handle_TxnOffsetCommit()
1953 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_handle_AddOffsetsToTxn()
2022 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_op_send_offsets_to_transaction()
2393 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_op_commit_transaction()
2750 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_op_abort_transaction()
3103 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_coord_query()
3288 rk->rk_ops, in rd_kafka_txns_init()
H A Drdkafka_idempotence.c308 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_idemp_pid_fsm()
323 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_idemp_pid_fsm()
H A Drdkafka.c902 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_set_fatal_error0()
960 rd_kafka_q_destroy_owner(rk->rk_ops); in rd_kafka_destroy_final()
2043 rd_kafka_q_fwd_set(rk->rk_cgrp->rkcg_ops, rk->rk_ops); in rd_kafka_thread_main()
2054 rd_kafka_q_len(rk->rk_ops) || in rd_kafka_thread_main()
2058 rd_kafka_q_serve(rk->rk_ops, (int)(sleeptime / 1000), 0, in rd_kafka_thread_main()
2071 rd_kafka_q_disable(rk->rk_ops); in rd_kafka_thread_main()
2072 rd_kafka_q_purge(rk->rk_ops); in rd_kafka_thread_main()
2190 rk->rk_ops = rd_kafka_q_new(rk); in rd_kafka_new()
2191 rk->rk_ops->rkq_serve = rd_kafka_poll_cb; in rd_kafka_new()
2192 rk->rk_ops->rkq_opaque = rk; in rd_kafka_new()
[all …]
H A Drdkafka_assignment.c341 rktp, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_assignment_serve_removals()
555 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_assignment_serve_pending()
H A Drdkafka_coord.c504 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_coord_req_fsm()
H A Drdkafka_int.h225 rd_kafka_q_t *rk_ops; /* any -> rdkafka main thread ops */ member
H A Drdkafka_partition.c288 rd_kafka_q_fwd_set(rktp->rktp_ops, rkt->rkt_rk->rk_ops); in rd_kafka_toppar_new0()
3583 rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_topic_partition_list_query_leaders_async_worker()
3753 rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_topic_partition_list_query_leaders_async()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_admin.c1781 rd_kafka_q_enq(rk->rk_ops, rko);
2003 rd_kafka_q_enq(rk->rk_ops, rko);
2299 rd_kafka_q_enq(rk->rk_ops, rko);
2888 rd_kafka_q_enq(rk->rk_ops, rko);
3194 rd_kafka_q_enq(rk->rk_ops, rko);
3417 rk->rk_ops);
3430 rd_kafka_q_enq(rk->rk_ops, rko);
3508 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
3788 rk->rk_ops);
3808 rd_kafka_q_enq(rk->rk_ops, rko);
[all …]
H A Drdkafka_txnmgr.c939 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
1264 reply = rd_kafka_op_req0(rk->rk_ops, tmpq, rko, RD_POLL_INFINITE);
1484 rk->rk_ops,
1651 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
1946 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
2015 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
2386 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
2743 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
3094 RD_KAFKA_REPLYQ(rk->rk_ops, 0),
3279 rk->rk_ops,
H A Drdkafka_idempotence.c308 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_buf_write_ensure()
323 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_buf_write_ensure()
H A Drdkafka.c902 rd_kafka_q_enq(rk->rk_ops, rko);
960 rd_kafka_q_destroy_owner(rk->rk_ops);
2043 rd_kafka_q_fwd_set(rk->rk_cgrp->rkcg_ops, rk->rk_ops);
2054 rd_kafka_q_len(rk->rk_ops) ||
2058 rd_kafka_q_serve(rk->rk_ops, (int)(sleeptime / 1000), 0,
2071 rd_kafka_q_disable(rk->rk_ops);
2072 rd_kafka_q_purge(rk->rk_ops);
2189 rk->rk_ops = rd_kafka_q_new(rk);
2190 rk->rk_ops->rkq_serve = rd_kafka_poll_cb;
2191 rk->rk_ops->rkq_opaque = rk;
[all …]
H A Drdkafka_assignment.c341 rktp, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_assignment_serve_removals()
555 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_assignment_serve_pending()
H A Drdkafka_coord.c504 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_coord_req_fsm()
H A Drdkafka_int.h225 rd_kafka_q_t *rk_ops; /* any -> rdkafka main thread ops */ member
H A Drdkafka_partition.c288 rd_kafka_q_fwd_set(rktp->rktp_ops, rkt->rkt_rk->rk_ops); in rd_kafka_toppar_new0()
3568 rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_topic_partition_list_query_leaders_async_worker()
3738 rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_topic_partition_list_query_leaders_async()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_txnmgr.c790 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_register_partitions()
1108 reply = rd_kafka_op_req0(rk->rk_ops, tmpq, rko, RD_POLL_INFINITE); in rd_kafka_txn_curr_api_req()
1328 rk->rk_ops, in rd_kafka_begin_transaction()
1481 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_handle_TxnOffsetCommit()
1718 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_handle_AddOffsetsToTxn()
1787 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_op_send_offsets_to_transaction()
2028 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_op_commit_transaction()
2247 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_op_abort_transaction()
2539 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_txn_coord_query()
2724 rk->rk_ops, in rd_kafka_txns_init()
H A Drdkafka_admin.c425 rd_kafka_enq_once_new(rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_admin_request_op_new()
509 rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_admin_common_get_broker()
556 rko, RD_KAFKA_REPLYQ(rk->rk_ops, 0)); in rd_kafka_admin_common_get_controller()
785 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_admin_worker()
1320 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_CreateTopics()
1541 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_DeleteTopics()
1834 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_CreatePartitions()
2417 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_AlterConfigs()
2720 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_DescribeConfigs()
H A Drdkafka.c868 rd_kafka_q_enq(rk->rk_ops, rko); in rd_kafka_set_fatal_error0()
922 rd_kafka_q_destroy_owner(rk->rk_ops); in rd_kafka_destroy_final()
1040 rd_kafka_q_enq(rk->rk_ops, rd_kafka_op_new(RD_KAFKA_OP_TERMINATE)); in rd_kafka_destroy_app()
1926 rd_kafka_q_fwd_set(rk->rk_cgrp->rkcg_ops, rk->rk_ops); in rd_kafka_thread_main()
1937 rd_kafka_q_len(rk->rk_ops))) { in rd_kafka_thread_main()
1940 rd_kafka_q_serve(rk->rk_ops, (int)(sleeptime / 1000), 0, in rd_kafka_thread_main()
1953 rd_kafka_q_disable(rk->rk_ops); in rd_kafka_thread_main()
1954 rd_kafka_q_purge(rk->rk_ops); in rd_kafka_thread_main()
2070 rk->rk_ops = rd_kafka_q_new(rk); in rd_kafka_new()
2071 rk->rk_ops->rkq_serve = rd_kafka_poll_cb; in rd_kafka_new()
[all …]
H A Drdkafka_coord.c441 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_coord_req_fsm()
H A Drdkafka_idempotence.c273 RD_KAFKA_REPLYQ(rk->rk_ops, 0), in rd_kafka_idemp_pid_fsm()
H A Drdkafka_int.h221 rd_kafka_q_t *rk_ops; /* any -> rdkafka main thread ops */ member

12