2015-07-31 1 views
2

Я делаю C++ Kafka Client https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_example.cpp.Недопустимое чтение размером 8, но отсутствие утечек памяти

В моем классе KafkaProducer есть несколько указателей.

RdKafka::Conf* m_conf; 
RdKafka::Conf* m_tconf; 
RdKafka::Producer* m_producer; 
RdKafka::Topic* m_topic; 

m_conf = RdKafka::Conf::create(RdKafka::Conf::CONF_GLOBAL); 
m_producer = RdKafka::Producer::create(m_conf, m_errstr); 
m_tconf = RdKafka::Conf::create(RdKafka::Conf::CONF_TOPIC); 
m_topic = RdKafka::Topic::create(m_producer, m_topic_str, m_tconf, m_errstr); 

В деструкторе, я сделал следующее:

if(m_producer) 
    delete m_producer; 

if(m_topic) 
    delete m_topic; 

if(m_tconf) 
    delete m_tconf; 

if(m_conf) 
    delete m_conf; 

Я использовал Valgrind, чтобы проверить мою программу, нет никаких утечек. Но есть некоторые проблемы «Недопустимое чтение». Некоторая память освобождается дважды. Но я знаю, какую память. Ниже приведены части выходных данных valgrind.

==4627== 2 errors in context 10 of 12: 
==4627== Invalid read of size 8 
==4627== at 0x52887A7: RdKafka::log_cb_trampoline(rd_kafka_s const*, int, char const*, char const*) (in /usr/lib/x86_64-linux-gnu/librdkafka++.so.1) 
==4627== by 0x5493C8F: ??? (in /usr/lib/x86_64-linux-gnu/librdkafka.so.1) 
==4627== by 0x549A531: ??? (in /usr/lib/x86_64-linux-gnu/librdkafka.so.1) 
==4627== by 0x54A0219: ??? (in /usr/lib/x86_64-linux-gnu/librdkafka.so.1) 
==4627== by 0x54A1A13: ??? (in /usr/lib/x86_64-linux-gnu/librdkafka.so.1) 
==4627== by 0x506C181: start_thread (pthread_create.c:312) 
==4627== by 0x5EE747C: clone (clone.S:111) 
==4627== Address 0x68df7f8 is 24 bytes inside a block of size 64 free'd 
==4627== at 0x4C2C2BC: operator delete(void*) (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so) 
==4627== by 0x407E90: KafkaProducer::disconnect() (kafkaproducer.cpp:57) 
==4627== by 0x407D29: KafkaProducer::~KafkaProducer() (kafkaproducer.cpp:32) 
==4627== by 0x407DF1: KafkaProducer::~KafkaProducer() (kafkaproducer.cpp:38) 
==4627== by 0x409DC0: KafkaProducerFactory::~KafkaProducerFactory() (kafkaproducerfactory.cpp:22) 
==4627== by 0x4045A8: main (test_kafkaproducerfactory.cpp:14) 

kafkaproducer.cpp линии 56-67 (двойной интервал Сохранившиеся):

if(m_producer)   // line 56 
    delete m_producer; 

if(m_topic) 
    delete m_topic; 


if(m_tconf) 
    delete m_tconf; 

if(m_conf) 
    delete m_conf;  // line 67 

Любая помощь приветствуется.

UPDATE

Я уже нашел следующие коды причиной этой проблемы. Если я прокомментировал следующую часть (если я не установил функцию обратного вызова события), проблема исчезнет. Но я не знаю, почему это вызвало проблему. Я использовал тот же способ, чтобы установить функцию обратного вызова, что не вызвало никаких проблем. Это проводной.

//defination 
    class MyEventCb : public RdKafka::EventCb 
    { 
    public: 
     void event_cb (RdKafka::Event &event) 
     { 
     } 
    private: 

    }; 

//set the callback function 
    if(m_conf->set("event_cb", &m_event_cb, m_errstr) != RdKafka::Conf::CONF_OK) 
    { 
     DBG_PRINT(1, "Kafka::Failed to set event callback : %s\n", m_errstr.c_str()); 
     return false; 
    } 
    // Class member 
MyEventCb m_event_cb; // event callback 
+1

Вы не должны явно проверить указатель на 'nullptr' удаления будет обрабатывать, что правильно – Slava

+0

ли следовать за вами правило 3? http://en.cppreference.com/w/cpp/language/rule_of_three – Slava

+0

Значит, ваш код читает 8-байтовое значение размера (указатель?) внутри чего-то, что было освобождено ... –

ответ

1

Поскольку m_topic использует m_producer я не думаю, что вы должны удалить m_producer перед тем m_topic ...

Смежные вопросы