more
This commit is contained in:
parent
8eae8112c7
commit
b97e880808
|
@ -109,7 +109,7 @@ static int vnodeOpenImpl(SVnode *pVnode) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: Open TQ
|
// TODO: Open TQ
|
||||||
sprintf(dir, "%s/wal", pVnode->path);
|
sprintf(dir, "%s/tq", pVnode->path);
|
||||||
pVnode->pTq = tqOpen(dir, &(pVnode->config.tqCfg), NULL, NULL);
|
pVnode->pTq = tqOpen(dir, &(pVnode->config.tqCfg), NULL, NULL);
|
||||||
if (pVnode->pTq == NULL) {
|
if (pVnode->pTq == NULL) {
|
||||||
// TODO: handle error
|
// TODO: handle error
|
||||||
|
|
Loading…
Reference in New Issue