xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix #304 

Signed-off-by: H-ZeX <hzx20112012@gmail.com>
This commit is contained in:
H-ZeX 2019-08-09 00:49:06 +08:00
parent 34efa468ad
commit 0f3a8a4bc5
No known key found for this signature in database
GPG Key ID: B363CD8898542D21
1 changed files with 22 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/os/linux/src/os.c
View File

@ -223,29 +223,31 @@ 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;
} }