diff --git a/source/dnode/vnode/impl/inc/vnodeRequest.h b/source/dnode/vnode/impl/inc/vnodeRequest.h
index 788918f105..f2b4ecee91 100644
--- a/source/dnode/vnode/impl/inc/vnodeRequest.h
+++ b/source/dnode/vnode/impl/inc/vnodeRequest.h
@@ -23,15 +23,15 @@ extern "C" {
 typedef struct SVnodeReq SVnodeReq;
 typedef struct SVnodeRsp SVnodeRsp;
 
-typedef enum {
-} EVReqT;
+typedef enum {} EVReqT;
+typedef enum {} EVRspT;
 
 struct SVnodeReq {
-  /* TODO */
+  EVReqT type;
 };
 
 struct SVnodeRsp {
-  /* TODO */
+  EVRspT type;
 };
 
 #ifdef __cplusplus
diff --git a/source/dnode/vnode/impl/src/vnodeWrite.c b/source/dnode/vnode/impl/src/vnodeWrite.c
index f858309c66..69a7cf3478 100644
--- a/source/dnode/vnode/impl/src/vnodeWrite.c
+++ b/source/dnode/vnode/impl/src/vnodeWrite.c
@@ -16,7 +16,15 @@
 #include "vnodeDef.h"
 
 int vnodeProcessWMsgs(SVnode *pVnode, SArray *pMsgs) {
-  /* TODO */
+  SRpcMsg *pReq;
+  SRpcMsg *pRsp;
+
+  for (size_t i = 0; i < taosArrayGetSize(pMsgs); i++) {
+    pReq = taosArrayGet(pMsgs, i);
+
+    vnodeApplyWMsg(pVnode, pReq, pRsp);
+  }
+
   return 0;
 }