未验证 提交 cfa7527c 编写于 作者: S slguan 提交者: GitHub

Merge pull request #305 from H-ZeX/fix-mem-leak

fix memory leak in os/linux/src/os.c::taosInitTimer #304 
...@@ -223,28 +223,30 @@ int taosOpenUDServerSocket(char *ip, short port) { ...@@ -223,28 +223,30 @@ int taosOpenUDServerSocket(char *ip, short port) {
return sockFd; return sockFd;
} }
// The callback functions MUST free the param pass to it after finishing use it.
int taosInitTimer(void *(*callback)(void *), int ms) { int taosInitTimer(void *(*callback)(void *), int ms) {
/******************************************************** /********************************************************
* Create SIGALRM loop thread * Create SIGALRM loop thread
********************************************************/ ********************************************************/
pthread_t thread; pthread_t thread;
pthread_attr_t tattr; pthread_attr_t tattr;
if (pthread_attr_init(&tattr)) { if (pthread_attr_init(&tattr)) {
return -1; return -1;
} }
if (pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED)) { if (pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED)) {
return -1; return -1;
} }
int *tms = (int *)malloc(sizeof(int)); int *tms = (int *) malloc(sizeof(int));
*tms = ms; *tms = ms;
if (pthread_create(&thread, &tattr, callback, (void *)tms)) { if (pthread_create(&thread, &tattr, callback, (void *) tms)) {
return -1; free(tms);
return -1;
} }
if (pthread_attr_destroy(&tattr)) { if (pthread_attr_destroy(&tattr)) {
return -1; return -1;
} }
return 0; return 0;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册