未验证 提交 72552aa0 编写于 作者: S slguan 提交者: GitHub

Merge pull request #1779 from taosdata/hotfix/uninitialized

initialize SCqCfg structure
...@@ -312,8 +312,6 @@ typedef struct SSqlObj { ...@@ -312,8 +312,6 @@ typedef struct SSqlObj {
void (*fp)(); void (*fp)();
void (*fetchFp)(); void (*fetchFp)();
void * param; void * param;
uint32_t ip;
short vnode;
int64_t stime; int64_t stime;
uint32_t queryId; uint32_t queryId;
void * pStream; void * pStream;
......
...@@ -32,6 +32,8 @@ int taosGetFqdn(char *fqdn) { ...@@ -32,6 +32,8 @@ int taosGetFqdn(char *fqdn) {
uError("failed to get host name"); uError("failed to get host name");
return -1; return -1;
} }
free(h);
} }
uint32_t taosGetIpFromFqdn(const char *fqdn) { uint32_t taosGetIpFromFqdn(const char *fqdn) {
......
...@@ -194,9 +194,10 @@ int32_t vnodeOpen(int32_t vnode, char *rootDir) { ...@@ -194,9 +194,10 @@ int32_t vnodeOpen(int32_t vnode, char *rootDir) {
pVnode->wqueue = dnodeAllocateWqueue(pVnode); pVnode->wqueue = dnodeAllocateWqueue(pVnode);
pVnode->rqueue = dnodeAllocateRqueue(pVnode); pVnode->rqueue = dnodeAllocateRqueue(pVnode);
SCqCfg cqCfg; SCqCfg cqCfg = {0};
sprintf(cqCfg.user, "root"); sprintf(cqCfg.user, "root");
strcpy(cqCfg.pass, tsInternalPass); strcpy(cqCfg.pass, tsInternalPass);
cqCfg.vgId = vnode;
cqCfg.cqWrite = vnodeWriteToQueue; cqCfg.cqWrite = vnodeWriteToQueue;
pVnode->cq = cqOpen(pVnode, &cqCfg); pVnode->cq = cqOpen(pVnode, &cqCfg);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册