more

source/dnode/vnode/impl/inc/vnodeDef.h

@@ -17,11 +17,12 @@
 #define _TD_VNODE_DEF_H_
 
 #include "mallocator.h"
+#include "sync.h"
 #include "vnode.h"
 #include "vnodeAllocatorPool.h"
+#include "vnodeCommit.h"
 #include "vnodeOptions.h"
 #include "vnodeStateMgr.h"
-#include "vnodeCommit.h"
 
 #ifdef __cplusplus
 extern "C" {

source/dnode/vnode/impl/inc/vnodeSync.h

@@ -0,0 +1,27 @@
+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef _TD_VNODE_SYNC_H_
+#define _TD_VNODE_SYNC_H_
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /*_TD_VNODE_SYNC_H_*/

source/dnode/vnode/impl/src/vnodeSync.c

@@ -0,0 +1,14 @@
+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */

source/dnode/vnode/impl/src/vnodeWrite.c

@@ -31,6 +31,8 @@ int vnodeApplyWriteRequest(SVnode *pVnode, const SRequest *pRequest) {
     // TODO: handle error
   }
 
+  memcpy(pReq, pRequest, reqSize);
+
   // Push the request to TQ so consumers can consume
   tqPushMsg(pVnode->pTq, pReq, 0);