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

add vnode's dependency on wal

This commit is contained in:
Liu Jicong 2021-10-13 13:41:04 +08:00
parent 2d8aadff21
commit c635e77d4e
4 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/server/vnode/inc/vnodeInt.h
View File

@ -83,7 +83,7 @@ typedef struct {
#if 0 #if 0
SSyncCfg syncCfg; SSyncCfg syncCfg;
#endif #endif
SWalCfg walCfg; //SWalCfg walCfg;
void * qMgmt; void * qMgmt;
char * rootDir; char * rootDir;
tsem_t sem; tsem_t sem;

3
source/server/vnode/inc/vnodeMain.h
View File

@ -16,10 +16,11 @@
#ifndef _TD_VNODE_MAIN_H_ #ifndef _TD_VNODE_MAIN_H_
#define _TD_VNODE_MAIN_H_ #define _TD_VNODE_MAIN_H_
#include "vnodeInt.h"
#ifdef __cplusplus #ifdef __cplusplus
extern "C" { extern "C" {
#endif #endif
#include "vnodeInt.h"
int32_t vnodeInitMain(); int32_t vnodeInitMain();
void vnodeCleanupMain(); void vnodeCleanupMain();

4
source/server/vnode/inc/vnodeWrite.h
View File

@ -27,7 +27,7 @@ taos_queue vnodeAllocWriteQueue(SVnode *pVnode);
void vnodeFreeWriteQueue(taos_queue pQueue); void vnodeFreeWriteQueue(taos_queue pQueue);
void vnodeProcessWriteMsg(SRpcMsg *pRpcMsg); void vnodeProcessWriteMsg(SRpcMsg *pRpcMsg);
int32_t vnodeProcessWalMsg(SVnode *pVnode, SWalHead *pHead); //int32_t vnodeProcessWalMsg(SVnode *pVnode, SWalHead *pHead);
void vnodeStartWrite(SVnode *pVnode); void vnodeStartWrite(SVnode *pVnode);
void vnodeStopWrite(SVnode *pVnode); void vnodeStopWrite(SVnode *pVnode);
@ -37,4 +37,4 @@ void vnodeWaitWriteCompleted(SVnode *pVnode);
} }
#endif #endif
#endif /*_TD_VNODE_WRITE_H_*/ #endif /*_TD_VNODE_WRITE_H_*/

3
source/server/vnode/tq/CMakeLists.txt
View File

@ -3,10 +3,11 @@ add_library(tq ${TQ_SRC})
target_include_directories( target_include_directories(
tq tq
PUBLIC "${CMAKE_SOURCE_DIR}/include/server/vnode/tq" PUBLIC "${CMAKE_SOURCE_DIR}/include/server/vnode/tq"
PUBLIC "${CMAKE_SOURCE_DIR}/include/libs/wal"
PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/inc" PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/inc"
PRIVATE "${CMAKE_SOURCE_DIR}/include/os" PRIVATE "${CMAKE_SOURCE_DIR}/include/os"
) )
target_link_libraries( target_link_libraries(
os wal
) )