From b8f2ba4f0d7743f6d65962c4f30aea5a176244c9 Mon Sep 17 00:00:00 2001
From: winlin <winlin@vip.126.com>
Date: Fri, 23 Oct 2015 14:40:14 +0800
Subject: [PATCH] complete kafka

---
 trunk/src/app/srs_app_kafka.cpp | 7 ++-----
 trunk/src/app/srs_app_kafka.hpp | 2 ++
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/trunk/src/app/srs_app_kafka.cpp b/trunk/src/app/srs_app_kafka.cpp
index ed63d9748..89491f742 100644
--- a/trunk/src/app/srs_app_kafka.cpp
+++ b/trunk/src/app/srs_app_kafka.cpp
@@ -352,7 +352,8 @@ int SrsKafkaProducer::initialize()
 {
     int ret = ERROR_SUCCESS;
     
-    srs_info("initialize kafka producer ok.");
+    enabled = _srs_config->get_kafka_enabled();
+    srs_info("initialize kafka ok, enabled=%d.", enabled);
     
     return ret;
 }
@@ -415,7 +416,6 @@ int SrsKafkaProducer::on_client(int key, SrsListenerType type, string ip)
 {
     int ret = ERROR_SUCCESS;
     
-    bool enabled = _srs_config->get_kafka_enabled();
     if (!enabled) {
         return ret;
     }
@@ -433,7 +433,6 @@ int SrsKafkaProducer::on_close(int key)
 {
     int ret = ERROR_SUCCESS;
     
-    bool enabled = _srs_config->get_kafka_enabled();
     if (!enabled) {
         return ret;
     }
@@ -494,7 +493,6 @@ int SrsKafkaProducer::do_cycle()
     int ret = ERROR_SUCCESS;
     
     // ignore when disabled.
-    bool enabled = _srs_config->get_kafka_enabled();
     if (!enabled) {
         return ret;
     }
@@ -513,7 +511,6 @@ int SrsKafkaProducer::request_metadata()
     int ret = ERROR_SUCCESS;
     
     // ignore when disabled.
-    bool enabled = _srs_config->get_kafka_enabled();
     if (!enabled) {
         return ret;
     }
diff --git a/trunk/src/app/srs_app_kafka.hpp b/trunk/src/app/srs_app_kafka.hpp
index 3b4129262..e7508b249 100644
--- a/trunk/src/app/srs_app_kafka.hpp
+++ b/trunk/src/app/srs_app_kafka.hpp
@@ -155,6 +155,8 @@ public:
 class SrsKafkaProducer : virtual public ISrsReusableThreadHandler, virtual public ISrsKafkaCluster
 {
 private:
+    // TODO: FIXME: support reload.
+    bool enabled;
     st_mutex_t lock;
     SrsReusableThread* pthread;
 private: