Skip to content

Commit

Permalink
Address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
emasab committed Apr 8, 2024
1 parent 0872740 commit 20bcfd1
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/rdkafka_partition.c
Original file line number Diff line number Diff line change
Expand Up @@ -2305,11 +2305,11 @@ rd_kafka_resp_err_t rd_kafka_toppar_op_pause_resume(rd_kafka_toppar_t *rktp,
/* If partitions isn't paused, avoid bumping its version,
* as it'll result in resuming fetches from a stale
* next_fetch_start */
rd_bool_t paused = rd_false;
rd_bool_t is_paused = rd_false;
rd_kafka_toppar_lock(rktp);
paused = RD_KAFKA_TOPPAR_IS_PAUSED(rktp);
is_paused = RD_KAFKA_TOPPAR_IS_PAUSED(rktp);
rd_kafka_toppar_unlock(rktp);
if (!paused) {
if (!is_paused) {
rko->rko_replyq = replyq;
rd_kafka_op_reply(rko, RD_KAFKA_RESP_ERR_NO_ERROR);
return RD_KAFKA_RESP_ERR_NO_ERROR;
Expand Down

0 comments on commit 20bcfd1

Please sign in to comment.