xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

restore vnode.h and remove vnodeGetqMgmt() to tsdbHealth.c

This commit is contained in:
AlexDuan 2021-08-19 11:28:37 +08:00
parent 3d22388b2b
commit f0ce38e77c
4 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/inc/vnode.h
View File

@ -88,9 +88,6 @@ int32_t vnodeWriteToRQueue(void *pVnode, void *pCont, int32_t contLen, int8_t qt
void vnodeFreeFromRQueue(void *pVnode, SVReadMsg *pRead);
int32_t vnodeProcessRead(void *pVnode, SVReadMsg *pRead);
// util
void* vnodeGetqMgmt(void* pVnode);
#ifdef __cplusplus
}
#endif

8
src/tsdb/src/tsdbHealth.c
View File

@ -22,10 +22,14 @@
#include "tsdbBuffer.h"
#include "tsdbLog.h"
#include "tsdbHealth.h"
#include "tsdbint.h"
#include "ttimer.h"
#include "vnode.h"
#include "../../vnode/inc/vnodeInt.h"
// get qmgmt
void* vnodeGetqMgmt(void* pVnode){
if(pVnode == NULL) return NULL;
return ((SVnodeObj*)pVnode)->qMgmt;
}
// return malloc new block count
int32_t tsdbInsertNewBlock(STsdbRepo * pRepo) {

6
src/vnode/src/vnodeMain.c
View File

@ -562,9 +562,3 @@ static int32_t vnodeProcessTsdbStatus(void *arg, int32_t status, int32_t eno) {
return 0;
}
// get qmgmt
void* vnodeGetqMgmt(void* pVnode){
if(pVnode == NULL) return NULL;
return ((SVnodeObj*)pVnode)->qMgmt;
}

1
src/vnode/src/vnodeSync.c
View File

@ -178,3 +178,4 @@ void vnodeConfirmForward(void *vparam, uint64_t version, int32_t code, bool forc
SVnodeObj *pVnode = vparam;
syncConfirmForward(pVnode->sync, version, code, force);
}