提交 9bc81582 编写于 作者: S Shengliang Guan

Modify the incorrect use of tqueue

上级 28cc613e
...@@ -988,7 +988,7 @@ int32_t sdbAllocWriteQueue() { ...@@ -988,7 +988,7 @@ int32_t sdbAllocWriteQueue() {
} }
void sdbFreeWritequeue() { void sdbFreeWritequeue() {
taosCloseQset(tsSdbWriteQueue); taosCloseQueue(tsSdbWriteQueue);
taosFreeQall(tsSdbWriteQall); taosFreeQall(tsSdbWriteQall);
taosCloseQset(tsSdbWriteQset); taosCloseQset(tsSdbWriteQset);
tsSdbWriteQall = NULL; tsSdbWriteQall = NULL;
......
...@@ -241,7 +241,6 @@ void taosCloseQset(taos_qset param) { ...@@ -241,7 +241,6 @@ void taosCloseQset(taos_qset param) {
if (param == NULL) return; if (param == NULL) return;
STaosQset *qset = (STaosQset *)param; STaosQset *qset = (STaosQset *)param;
#if 0
// remove all the queues from qset // remove all the queues from qset
pthread_mutex_lock(&qset->mutex); pthread_mutex_lock(&qset->mutex);
while (qset->head) { while (qset->head) {
...@@ -252,7 +251,6 @@ void taosCloseQset(taos_qset param) { ...@@ -252,7 +251,6 @@ void taosCloseQset(taos_qset param) {
queue->next = NULL; queue->next = NULL;
} }
pthread_mutex_unlock(&qset->mutex); pthread_mutex_unlock(&qset->mutex);
#endif
pthread_mutex_destroy(&qset->mutex); pthread_mutex_destroy(&qset->mutex);
tsem_destroy(&qset->sem); tsem_destroy(&qset->sem);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册