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