Утечка памяти в MySQL C ++ Connector
Я использую MySQL C ++ разъем. Valgrind показывает, что на каждое соединение уходит 192 байта.
Это утечка памяти только в многопоточной среде без многопоточности, это не утечка памяти. Что я делаю не так? Нужно ли вызывать некоторые другие функции для очистки?
Образец кода:
#include <pthread.h>
#include <iostream>
#include <cppconn/driver.h>
#include <cppconn/exception.h>
#include <cppconn/resultset.h>
#include <cppconn/statement.h>
#include <cppconn/prepared_statement.h>
using namespace std;
void* test(void* arg) {
try {
sql::Driver *driver;
sql::Connection *con;
/* Create a connection */
driver = get_driver_instance();
con = driver->connect("tcp://127.0.0.1:3306", "root", "root");
/* Connect to the MySQL test database */
con->setSchema("test");
delete con;
} catch (sql::SQLException &e) {
cout << "# ERR: SQLException in " << __FILE__;
cout << "(" << __FUNCTION__ << ") on line " << __LINE__ << endl;
cout << "# ERR: " << e.what();
cout << " (MySQL error code: " << e.getErrorCode();
cout << ", SQLState: " << e.getSQLState() << " )" << endl;
}
return NULL;
}
int main() {
pthread_t thread1, thread2, thread3, thread4;
pthread_create(&thread1, NULL, test, NULL);
pthread_create(&thread2, NULL, test, NULL);
pthread_join(thread1, NULL);
pthread_join(thread2, NULL);
return 0;
}
Выход Valgrind:
==10252== Memcheck, a memory error detector
==10252== Copyright (C) 2002-2011, and GNU GPL'd, by Julian Seward et al.
==10252== Using Valgrind-3.7.0 and LibVEX; rerun with -h for copyright info
==10252== Command: ./app/bin/app-test
==10252== Parent PID: 6312
==10252==
==10252==
==10252== HEAP SUMMARY:
==10252== in use at exit: 384 bytes in 2 blocks
==10252== total heap usage: 212 allocs, 210 frees, 208,400 bytes allocated
==10252==
==10252== 192 bytes in 1 blocks are definitely lost in loss record 1 of 2
==10252== at 0x4C29DB4: calloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==10252== by 0x5E1CB3E: my_thread_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x5E1CE3C: my_thread_global_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x5E1AA54: my_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x5DF86CA: mysql_server_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x4EA3C08: sql::mysql::NativeAPI::getCApiHandle(sql::SQLString const&) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x4EA40EA: sql::mysql::NativeAPI::MySQL_NativeDriverWrapper::MySQL_NativeDriverWrapper(sql::SQLString const&) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x4EA4138: sql::mysql::NativeAPI::createNativeDriverWrapper(sql::SQLString const&) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x4E6F2F3: sql::mysql::MySQL_Driver::MySQL_Driver(sql::SQLString const&) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x4E6F50B: sql::mysql::get_driver_instance_by_name(char const*) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x40AB8C: test(void*) (main.cc:17)
==10252== by 0x50D9E99: start_thread (pthread_create.c:308)
==10252==
==10252== 192 bytes in 1 blocks are definitely lost in loss record 2 of 2
==10252== at 0x4C29DB4: calloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==10252== by 0x5E1CB3E: my_thread_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x5DF86DC: mysql_server_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x5DFE85E: mysql_init (in /usr/lib/x86_64-linux-gnu/libmysqlclient.so.18.0.0)
==10252== by 0x4EA4A82: sql::mysql::NativeAPI::MySQL_NativeConnectionWrapper::MySQL_NativeConnectionWrapper(boost::shared_ptr<sql::mysql::NativeAPI::IMySQLCAPI>) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x4EA4014: sql::mysql::NativeAPI::MySQL_NativeDriverWrapper::conn_init() (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x4E6F0DC: sql::mysql::MySQL_Driver::connect(sql::SQLString const&, sql::SQLString const&, sql::SQLString const&) (in /usr/lib/libmysqlcppconn.so.5.1.1.0)
==10252== by 0x40ABE8: test(void*) (main.cc:18)
==10252== by 0x50D9E99: start_thread (pthread_create.c:308)
==10252== by 0x5AFCCBC: clone (clone.S:112)
==10252==
==10252== LEAK SUMMARY:
==10252== definitely lost: 384 bytes in 2 blocks
==10252== indirectly lost: 0 bytes in 0 blocks
==10252== possibly lost: 0 bytes in 0 blocks
==10252== still reachable: 0 bytes in 0 blocks
==10252== suppressed: 0 bytes in 0 blocks
==10252==
==10252== For counts of detected and suppressed errors, rerun with: -v
==10252== ERROR SUMMARY: 2 errors from 2 contexts (suppressed: 2 from 2)
Решение
как предложил WhozCraig, вы можете добавить delete Driver; к вашей тестовой функции, но я бы предложил использовать auto_ptr или C ++ 11 unique_ptr или же shared_ptr для всего MYSQL и вам никогда не придется беспокоиться об утечках памяти
возьми это к примеру
с C ++ 11
std::unique_ptr< sql::Connection > con( driver->connect("tcp://127.0.0.1:3306", "root", "root"));
или C ++
std::auto_ptr< sql::Connection > con( driver->connect("tcp://127.0.0.1:3306", "root", "root"));
РЕДАКТИРОВАТЬ
ты не можешь просто delete Driver , я буду смотреть на это больше, когда у меня будет время
ОБНОВИТЬ
Я посмотрел через driver.h исходный код, это действительно protected: так что вы не можете просто использовать удаление, как никогда в
virtual ~Driver() {}public: есть два
virtual void threadInit() = 0;
virtual void threadEnd() = 0;
что может быть то, что вам нужно
есть и это пример что может быть очень полезным и делает это немного иначе, чем вы
Другие решения
Первая проблема в том, что ваш код неверен. В случае любого исключения в try блок, программа никогда не достигнет delete con; заявление, и вы останетесь с открытым подключением к серверу MySQL и утечки памяти. Вы должны объявить и удалить con вне try заблокировать или использовать интеллектуальный указатель C ++ 11:
Неправильно:
try {
sql::Connection *con = driver->connect("URL", "user", "password");
// code
delete con;
}
catch (const sql::SQLException &e) {
// code
}
Правильно, до C ++ 11:
sql::Connection *con = NULL;
try {
con = driver->connect("URL", "user", "password");
// code
}
catch (const sql::SQLException &e) {
// code
}
delete con; // delete on NULL is harmless.
con = NULL;
Правильно, C ++ 11, рекомендуемый способ:
try {
// unique_ptr will automatically call delete when it goes out of scope.
// That will also happen in case of exception.
std::unique_ptr<sql::Connection> con (driver->connect("URL", "user", "password"));
// code
}
catch (const sql::SQLException &e) {
// code
}
Также, driver = get_driver_instance(); должен вызываться только один раз в вашей программе, а не в каждом потоке. Так что вы должны сделать sql::Driver *driver; глобальная переменная и вызов driver = get_driver_instance(); в main() прежде чем создавать какие-либо темы.