Insert prioritised wake-ups to head of broker operations queue

See also: confluentinc#1088 confluentinc#3692
cdn77 · Feb 7, 2022 · af44ba8 · af44ba8
1 parent a532f1a
commit af44ba8
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/rdkafka_broker.c b/src/rdkafka_broker.c
@@ -6230,8 +6230,7 @@ const char *rd_kafka_broker_name (rd_kafka_broker_t *rkb) {
  */
 void rd_kafka_broker_wakeup (rd_kafka_broker_t *rkb) {
         rd_kafka_op_t *rko = rd_kafka_op_new(RD_KAFKA_OP_WAKEUP);
-        rd_kafka_op_set_prio(rko, RD_KAFKA_PRIO_FLASH);
-        rd_kafka_q_enq(rkb->rkb_ops, rko);
+        rd_kafka_q_enq1(rkb->rkb_ops, rko, rkb->rkb_ops, 1, 1);
         rd_rkb_dbg(rkb, QUEUE, "WAKEUP", "Wake-up");
 }