Merge pull request #1657 from taosdata/enhance/vnodeGetTsdb

remove vnodeGetTsdb API

src/inc/vnode.h

@@ -47,7 +47,6 @@ void*   vnodeGetVnode(int32_t vgId);      // keep refcount unchanged
 void*   vnodeGetRqueue(void *);
 void*   vnodeGetWqueue(int32_t vgId);
 void*   vnodeGetWal(void *pVnode);
-void*   vnodeGetTsdb(void *pVnode);
 
 int32_t vnodeProcessWrite(void *pVnode, int qtype, void *pHead, void *item);
 void    vnodeBuildStatusMsg(void * param);

src/vnode/src/vnodeMain.c

@@ -274,10 +274,6 @@ void *vnodeGetWal(void *pVnode) {
   return ((SVnodeObj *)pVnode)->wal; 
 }
 
-void *vnodeGetTsdb(void *pVnode) {
-  return ((SVnodeObj *)pVnode)->tsdb; 
-}
-
 void vnodeBuildStatusMsg(void *param) {
   SDMStatusMsg *pStatus = param;
   taosVisitIntHashWithFp(tsDnodeVnodesHash, vnodeBuildVloadMsg, pStatus);

src/vnode/src/vnodeRead.c

@@ -56,8 +56,7 @@ static int32_t vnodeProcessQueryMsg(SVnodeObj *pVnode, void *pCont, int32_t cont
   
   qinfo_t pQInfo = NULL;
   if (contLen != 0) {
-    void* tsdb = vnodeGetTsdb(pVnode);
-    pRet->code = qCreateQueryInfo(tsdb, pQueryTableMsg, &pQInfo);
+    pRet->code = qCreateQueryInfo(pVnode->tsdb, pQueryTableMsg, &pQInfo);
   
     SQueryTableRsp *pRsp = (SQueryTableRsp *) rpcMallocCont(sizeof(SQueryTableRsp));
     pRsp->qhandle = htobe64((uint64_t) (pQInfo));

src/vnode/src/vnodeWrite.c

@@ -147,8 +147,7 @@ static int32_t vnodeProcessCreateTableMsg(SVnodeObj *pVnode, void *pCont, SRspRe
     tsdbTableSetTagValue(&tCfg, dataRow, false);
   }
 
-  void *pTsdb = vnodeGetTsdb(pVnode);
-  code = tsdbCreateTable(pTsdb, &tCfg);
+  code = tsdbCreateTable(pVnode->tsdb, &tCfg);
 
   tfree(pDestSchema);
 
@@ -211,8 +210,7 @@ static int32_t vnodeProcessAlterTableMsg(SVnodeObj *pVnode, void *pCont, SRspRet
     tsdbTableSetTagValue(&tCfg, dataRow, false);
   }
 
-  void *pTsdb = vnodeGetTsdb(pVnode);
-  code = tsdbAlterTable(pTsdb, &tCfg);
+  code = tsdbAlterTable(pVnode->tsdb, &tCfg);
 
   tfree(pDestSchema);