minor changes
This commit is contained in:
parent
d76a0c9b6d
commit
457f5450e6
|
@ -68,13 +68,12 @@ int32_t vmProcessCreateVnodeReq(SVnodesMgmt *pMgmt, SNodeMsg *pMsg) {
|
||||||
SWrapperCfg wrapperCfg = {0};
|
SWrapperCfg wrapperCfg = {0};
|
||||||
vmGenerateWrapperCfg(pMgmt, &createReq, &wrapperCfg);
|
vmGenerateWrapperCfg(pMgmt, &createReq, &wrapperCfg);
|
||||||
|
|
||||||
#if 0
|
|
||||||
if (createReq.dnodeId != pMgmt->pDnode->dnodeId) {
|
if (createReq.dnodeId != pMgmt->pDnode->dnodeId) {
|
||||||
terrno = TSDB_CODE_DND_VNODE_INVALID_OPTION;
|
terrno = TSDB_CODE_DND_VNODE_INVALID_OPTION;
|
||||||
dDebug("vgId:%d, failed to create vnode since %s", createReq.vgId, terrstr());
|
dDebug("vgId:%d, failed to create vnode since %s", createReq.vgId, terrstr());
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
SVnodeObj *pVnode = vmAcquireVnode(pMgmt, createReq.vgId);
|
SVnodeObj *pVnode = vmAcquireVnode(pMgmt, createReq.vgId);
|
||||||
if (pVnode != NULL) {
|
if (pVnode != NULL) {
|
||||||
dDebug("vgId:%d, already exist", createReq.vgId);
|
dDebug("vgId:%d, already exist", createReq.vgId);
|
||||||
|
|
Loading…
Reference in New Issue