提交 82ea4c2f 编写于 作者: B Bomin Zhang

fix coverity 291725

上级 0c5054a3
...@@ -385,8 +385,8 @@ static void taosTimerLoopFunc(int signo) { ...@@ -385,8 +385,8 @@ static void taosTimerLoopFunc(int signo) {
timer = next; timer = next;
} }
pthread_mutex_unlock(&wheel->mutex);
wheel->nextScanAt += wheel->resolution; wheel->nextScanAt += wheel->resolution;
pthread_mutex_unlock(&wheel->mutex);
} }
addToExpired(expired); addToExpired(expired);
...@@ -514,17 +514,14 @@ static void taosTmrModuleInit(void) { ...@@ -514,17 +514,14 @@ static void taosTmrModuleInit(void) {
tmrError("failed to create the mutex for wheel, reason:%s", strerror(errno)); tmrError("failed to create the mutex for wheel, reason:%s", strerror(errno));
return; return;
} }
pthread_mutex_lock(&wheel->mutex);
wheel->nextScanAt = now + wheel->resolution; wheel->nextScanAt = now + wheel->resolution;
wheel->index = 0; wheel->index = 0;
wheel->slots = (tmr_obj_t**)calloc(wheel->size, sizeof(tmr_obj_t*)); wheel->slots = (tmr_obj_t**)calloc(wheel->size, sizeof(tmr_obj_t*));
if (wheel->slots == NULL) { if (wheel->slots == NULL) {
tmrError("failed to allocate wheel slots"); tmrError("failed to allocate wheel slots");
pthread_mutex_unlock(&wheel->mutex);
return; return;
} }
timerMap.size += wheel->size; timerMap.size += wheel->size;
pthread_mutex_unlock(&wheel->mutex);
} }
timerMap.count = 0; timerMap.count = 0;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册