Home
last modified time | relevance | path

Searched refs:RD_KAFKA_OP_REPLY (Results 1 – 19 of 19) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_op.c101 if (type & RD_KAFKA_OP_REPLY) in rd_kafka_op2str()
520 rko = rd_kafka_op_new(rko_orig->rko_type | RD_KAFKA_OP_REPLY); in rd_kafka_op_new_reply()
560 rko->rko_type |= (rko->rko_op_cb ? RD_KAFKA_OP_CB : RD_KAFKA_OP_REPLY); in rd_kafka_op_reply()
586 rko->rko_type |= (rko->rko_op_cb ? RD_KAFKA_OP_CB : RD_KAFKA_OP_REPLY); in rd_kafka_op_error_reply()
823 rko->rko_type & RD_KAFKA_OP_REPLY && in rd_kafka_op_handle_std()
H A Drdkafka_op.h150 #define RD_KAFKA_OP_REPLY (int)(1 << 30) /* Reply op. */ macro
151 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
H A Drdkafka_partition.c1703 rko = rd_kafka_op_new(RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_fetch_stopped()
1817 rko = rd_kafka_op_new(RD_KAFKA_OP_SEEK|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_seek()
2198 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY: in rd_kafka_toppar_op_serve()
2206 case RD_KAFKA_OP_OFFSET_FETCH | RD_KAFKA_OP_REPLY: in rd_kafka_toppar_op_serve()
H A Drdkafka.c3720 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY: in rd_kafka_poll_cb()
3729 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY: in rd_kafka_poll_cb()
H A Drdkafka_txnmgr.c406 rko = rd_kafka_op_new(RD_KAFKA_OP_TXN|RD_KAFKA_OP_REPLY); in rd_kafka_txn_curr_api_reply_error()
H A Drdkafka_request.c956 rko_reply = rd_kafka_op_new(RD_KAFKA_OP_OFFSET_FETCH|RD_KAFKA_OP_REPLY); in rd_kafka_op_handle_OffsetFetch()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_op.c101 if (type & RD_KAFKA_OP_REPLY) in rd_kafka_op2str()
520 rko = rd_kafka_op_new(rko_orig->rko_type | RD_KAFKA_OP_REPLY); in rd_kafka_op_new_reply()
560 rko->rko_type |= (rko->rko_op_cb ? RD_KAFKA_OP_CB : RD_KAFKA_OP_REPLY); in rd_kafka_op_reply()
586 rko->rko_type |= (rko->rko_op_cb ? RD_KAFKA_OP_CB : RD_KAFKA_OP_REPLY); in rd_kafka_op_error_reply()
823 rko->rko_type & RD_KAFKA_OP_REPLY && in rd_kafka_op_handle_std()
H A Drdkafka_op.h145 #define RD_KAFKA_OP_REPLY (int)(1 << 30) /* Reply op. */
146 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
H A Drdkafka_partition.c1688 rko = rd_kafka_op_new(RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_fetch_stopped()
1802 rko = rd_kafka_op_new(RD_KAFKA_OP_SEEK|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_seek()
2183 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY: in rd_kafka_toppar_op_serve()
2191 case RD_KAFKA_OP_OFFSET_FETCH | RD_KAFKA_OP_REPLY: in rd_kafka_toppar_op_serve()
H A Drdkafka.c3719 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY:
3728 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY:
H A Drdkafka_txnmgr.c406 rko = rd_kafka_op_new(RD_KAFKA_OP_TXN|RD_KAFKA_OP_REPLY);
H A Drdkafka_request.c881 rko_reply = rd_kafka_op_new(RD_KAFKA_OP_OFFSET_FETCH|RD_KAFKA_OP_REPLY); in rd_kafka_op_handle_OffsetFetch()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_op.c90 if (type & RD_KAFKA_OP_REPLY) in rd_kafka_op2str()
424 rko = rd_kafka_op_new(rko_orig->rko_type | RD_KAFKA_OP_REPLY); in rd_kafka_op_new_reply()
462 rko->rko_type |= (rko->rko_op_cb ? RD_KAFKA_OP_CB : RD_KAFKA_OP_REPLY); in rd_kafka_op_reply()
678 rko->rko_type & RD_KAFKA_OP_REPLY && in rd_kafka_op_handle_std()
H A Drdkafka_op.h132 #define RD_KAFKA_OP_REPLY (int)(1 << 30) /* Reply op. */ macro
133 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
H A Drdkafka_partition.c1670 rko = rd_kafka_op_new(RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_fetch_stopped()
1784 rko = rd_kafka_op_new(RD_KAFKA_OP_SEEK|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_seek()
2144 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY: in rd_kafka_toppar_op_serve()
2152 case RD_KAFKA_OP_OFFSET_FETCH | RD_KAFKA_OP_REPLY: in rd_kafka_toppar_op_serve()
H A Drdkafka_txnmgr.c364 rko = rd_kafka_op_new(RD_KAFKA_OP_TXN|RD_KAFKA_OP_REPLY); in rd_kafka_txn_curr_api_reply_error()
H A Drdkafka_cgrp.c3108 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY: in rd_kafka_cgrp_op_serve()
H A Drdkafka_request.c759 rko_reply = rd_kafka_op_new(RD_KAFKA_OP_OFFSET_FETCH|RD_KAFKA_OP_REPLY); in rd_kafka_op_handle_OffsetFetch()
H A Drdkafka.c3506 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY: in rd_kafka_poll_cb()