提交 45796e5d 编写于 作者: A Alex Duan

[TS-238]<feature>(tsdb): sem_t modify to tsem_t again

...@@ -105,7 +105,7 @@ void vnodeFreeFromRQueue(void *pVnode, SVReadMsg *pRead); ...@@ -105,7 +105,7 @@ void vnodeFreeFromRQueue(void *pVnode, SVReadMsg *pRead);
int32_t vnodeProcessRead(void *pVnode, SVReadMsg *pRead); int32_t vnodeProcessRead(void *pVnode, SVReadMsg *pRead);
// wait thread // wait thread
void vnodeAddWait(void* pVnode, pthread_t* pthread, sem_t* psem, void* param); void vnodeAddWait(void* pVnode, pthread_t* pthread, tsem_t* psem, void* param);
void vnodeRemoveWait(void* pVnode, void* param); void vnodeRemoveWait(void* pVnode, void* param);
#ifdef __cplusplus #ifdef __cplusplus
......
...@@ -612,7 +612,7 @@ static int32_t vnodeProcessTsdbStatus(void *arg, int32_t status, int32_t eno) { ...@@ -612,7 +612,7 @@ static int32_t vnodeProcessTsdbStatus(void *arg, int32_t status, int32_t eno) {
} }
// wait thread // wait thread
void vnodeAddWait(void* vparam, pthread_t* pthread, sem_t* psem, void* param) { void vnodeAddWait(void* vparam, pthread_t* pthread, tsem_t* psem, void* param) {
SVnodeObj* pVnode = (SVnodeObj* )vparam; SVnodeObj* pVnode = (SVnodeObj* )vparam;
if(pVnode->tqueue == NULL) { if(pVnode->tqueue == NULL) {
pVnode->tqueue = taosOpenQueue(); pVnode->tqueue = taosOpenQueue();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册