more

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

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;
 }