From 8b608cd3b71d892bea310603b8e1b6e6c211d60d Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Mon, 8 Nov 2021 10:32:36 +0800 Subject: [PATCH] refact --- include/server/vnode/impl/vnodeImpl.h | 1 + include/server/vnode/vnode.h | 4 ++++ source/dnode/vnode/impl/src/vnodeWrite.c | 13 +++++++++++-- 3 files changed, 16 insertions(+), 2 deletions(-) diff --git a/include/server/vnode/impl/vnodeImpl.h b/include/server/vnode/impl/vnodeImpl.h index 580b770246..0e8a47742c 100644 --- a/include/server/vnode/impl/vnodeImpl.h +++ b/include/server/vnode/impl/vnodeImpl.h @@ -17,6 +17,7 @@ #define _TD_VNODE_IMPL_H_ #include "os.h" +#include "trequest.h" #include "meta.h" #include "tq.h" diff --git a/include/server/vnode/vnode.h b/include/server/vnode/vnode.h index 66e17bdf48..227bfe6594 100644 --- a/include/server/vnode/vnode.h +++ b/include/server/vnode/vnode.h @@ -30,6 +30,10 @@ typedef struct SVnodeOptions SVnodeOptions; SVnode *vnodeOpen(const char *path, const SVnodeOptions *pVnodeOptions); void vnodeClose(SVnode *pVnode); void vnodeDestroy(const char *path); +int vnodeProcessWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch); +int vnodeApplyWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch); +int vnodeProcessReadReq(SVnode *pVnode, SRequest *pReq); +int vnodeProcessSyncReq(SVnode *pVnode, SRequest *pReq); /* ------------------------ SVnodeOptions ------------------------ */ void vnodeOptionsInit(SVnodeOptions *); diff --git a/source/dnode/vnode/impl/src/vnodeWrite.c b/source/dnode/vnode/impl/src/vnodeWrite.c index dc12ffb241..d4acadd695 100644 --- a/source/dnode/vnode/impl/src/vnodeWrite.c +++ b/source/dnode/vnode/impl/src/vnodeWrite.c @@ -13,5 +13,14 @@ * along with this program. If not, see . */ -#define _DEFAULT_SOURCE -#include "vnodeWrite.h" +#include "vnodeDef.h" + +int vnodeProcessWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch) { + /* TODO */ + return 0; +} + +int vnodeApplyWriteReqs(SVnode *pVnode, SReqBatch *pReqBatch) { + /* TODO */ + return 0; +} \ No newline at end of file -- GitLab