Fixed a possible memory leak.

modified: src/sfutil/sf_kafka.c
redBorder · Jul 3, 2013 · dd159ed · dd159ed
1 parent 0896ef8
commit dd159ed
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/sfutil/sf_kafka.c b/src/sfutil/sf_kafka.c
@@ -154,7 +154,10 @@ bool KafkaLog_Flush(KafkaLog* this)
     if(this->handler==NULL && BcDaemonMode()){
         this->handler = KafkaLog_Open(this->broker);
     }
-    rd_kafka_produce(this->handler, this->topic, 0, RD_KAFKA_OP_F_FREE, this->buf, this->pos);
+    if(this->handler->rk_state == RD_KAFKA_STATE_DOWN)
+	free(this->buf);
+    else
+        rd_kafka_produce(this->handler, this->topic, 0, RD_KAFKA_OP_F_FREE, this->buf, this->pos);
     this->buf = malloc(sizeof(char)*this->maxBuf);
 
     KafkaLog_Reset(this);