Improved derefcnting

confluentinc · Mar 8, 2013 · 2326c71 · 2326c71
1 parent f808f27
commit 2326c71
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/rdkafka.c b/rdkafka.c
@@ -244,10 +244,9 @@ static void rd_kafka_destroy0 (rd_kafka_t *rk) {
 
 
 void rd_kafka_destroy (rd_kafka_t *rk) {
-	(void)rd_atomic_sub(&rk->rk_refcnt, 1);
 	rk->rk_terminate = 1;
 
-	if (rk->rk_refcnt == 0)
+	if (rd_atomic_sub(&rk->rk_refcnt, 1) == 0)
 		rd_kafka_destroy0(rk);
 }