Searched refs:RD_KAFKA_OP_REPLY (Results 1 – 19 of 19) sorted by relevance
101 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()
150 #define RD_KAFKA_OP_REPLY (int)(1 << 30) /* Reply op. */ macro151 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
1703 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()
3720 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()
406 rko = rd_kafka_op_new(RD_KAFKA_OP_TXN|RD_KAFKA_OP_REPLY); in rd_kafka_txn_curr_api_reply_error()
956 rko_reply = rd_kafka_op_new(RD_KAFKA_OP_OFFSET_FETCH|RD_KAFKA_OP_REPLY); in rd_kafka_op_handle_OffsetFetch()
145 #define RD_KAFKA_OP_REPLY (int)(1 << 30) /* Reply op. */146 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
1688 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()
3719 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY:3728 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY:
406 rko = rd_kafka_op_new(RD_KAFKA_OP_TXN|RD_KAFKA_OP_REPLY);
881 rko_reply = rd_kafka_op_new(RD_KAFKA_OP_OFFSET_FETCH|RD_KAFKA_OP_REPLY); in rd_kafka_op_handle_OffsetFetch()
90 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()
132 #define RD_KAFKA_OP_REPLY (int)(1 << 30) /* Reply op. */ macro133 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
1670 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()
364 rko = rd_kafka_op_new(RD_KAFKA_OP_TXN|RD_KAFKA_OP_REPLY); in rd_kafka_txn_curr_api_reply_error()
3108 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY: in rd_kafka_cgrp_op_serve()
759 rko_reply = rd_kafka_op_new(RD_KAFKA_OP_OFFSET_FETCH|RD_KAFKA_OP_REPLY); in rd_kafka_op_handle_OffsetFetch()
3506 case RD_KAFKA_OP_OFFSET_COMMIT | RD_KAFKA_OP_REPLY: in rd_kafka_poll_cb()