Searched refs:RD_KAFKA_OP_CB (Results 1 – 9 of 9) sorted by relevance
264 if ((rko->rko_type & RD_KAFKA_OP_CB) && rko->rko_op_cb) { in rd_kafka_op_destroy()537 rko = rd_kafka_op_new(type | RD_KAFKA_OP_CB); in rd_kafka_op_new_cb()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()818 rko->rko_type & RD_KAFKA_OP_CB) in rd_kafka_op_handle_std()
149 #define RD_KAFKA_OP_CB (int)(1 << 29) /* Callback op. */ macro151 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
760 RD_KAFKA_OP_CB); in rd_kafka_offset_reset()
144 #define RD_KAFKA_OP_CB (int)(1 << 29) /* Callback op. */146 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
760 RD_KAFKA_OP_CB);
353 if (rko->rko_type & RD_KAFKA_OP_CB && rko->rko_op_cb) { in rd_kafka_op_destroy()442 rko = rd_kafka_op_new(type | RD_KAFKA_OP_CB); in rd_kafka_op_new_cb()462 rko->rko_type |= (rko->rko_op_cb ? RD_KAFKA_OP_CB : RD_KAFKA_OP_REPLY); in rd_kafka_op_reply()673 rko->rko_type & RD_KAFKA_OP_CB) in rd_kafka_op_handle_std()
131 #define RD_KAFKA_OP_CB (int)(1 << 29) /* Callback op. */ macro133 #define RD_KAFKA_OP_FLAGMASK (RD_KAFKA_OP_CB | RD_KAFKA_OP_REPLY)
766 RD_KAFKA_OP_CB); in rd_kafka_offset_reset()