vnodePeer.h

src/inc/taosmsg.h

@@ -684,10 +684,15 @@ typedef struct {
 } SSecIe;
 
 typedef struct {
-  uint32_t ip;
-  uint32_t vnode;
+  int32_t dnode;  //the ID of dnode
+  int32_t vnode;  //the index of vnode
 } SVPeerDesc;
 
+typedef struct {
+  int32_t numOfVPeers;
+  SVPeerDesc vpeerDesc[];
+} SVpeerDescArray;
+
 typedef struct {
   int32_t    vnode;
   SVnodeCfg  cfg;

src/mnode/inc/mgmtStable.h

@@ -25,7 +25,7 @@ extern "C" {
 #include <stdint.h>
 #include "mnode.h"
 
-
+int32_t      mgmtInitSTable();
 
 
 #ifdef __cplusplus

src/mnode/src/mgmtStable.c

@@ -34,3 +34,4 @@
 #include "tsqlfunction.h"
 #include "ttime.h"
 #include "tstatus.h"
+

src/mnode/src/mgmtTable.c

@@ -97,7 +97,7 @@ int32_t mgmtMeterDropColumnByName(STabObj *pTable, const char *name);
 static int dropMeterImp(SDbObj *pDb, STabObj * pTable, SAcctObj *pAcct);
 static void dropAllMetersOfMetric(SDbObj *pDb, STabObj * pMetric, SAcctObj *pAcct);
 
-void mgmtMeterActionInit() {
+static void mgmtMeterActionInit() {
   mgmtMeterActionFp[SDB_TYPE_INSERT] = mgmtMeterActionInsert;
   mgmtMeterActionFp[SDB_TYPE_DELETE] = mgmtMeterActionDelete;
   mgmtMeterActionFp[SDB_TYPE_UPDATE] = mgmtMeterActionUpdate;

src/vnode/detail/inc/vnodePeer.h → src/vnode/common/inc/vnodePeer.h

@@ -13,93 +13,41 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef TDENGINE_VNODEPEER_H
+#ifndef TDENGINE_VNODE_PEER_H
 #define TDENGINE_VNODEPEER_H
 
-#include "os.h"
-
 #ifdef __cplusplus
 extern "C" {
 #endif
 
-#define TSDB_VMSG_SYNC_DATA 1
-#define TSDB_VMSG_FORWARD 2
-#define TSDB_VMSG_SYNC_REQ 3
-#define TSDB_VMSG_SYNC_RSP 4
-#define TSDB_VMSG_SYNC_MUST 5
-#define TSDB_VMSG_STATUS 6
-
-#pragma pack(push, 1)
-
-typedef struct {
-  char  type;
-  char  version;
-  short sourceVid;
-  short destVid;
-} SFirstPkt;
-
-typedef struct {
-  uint64_t lastCreate;
-  uint64_t lastRemove;
-  uint32_t fileId;
-  uint64_t fmagic[];
-} SSyncMsg;
+#include <stdint.h>
+#include <stdbool.h>
+#include "tsdb.h"
 
-typedef struct {
-  char     status;
-  uint64_t version;
-} SPeerState;
-
-typedef struct {
-  char       status : 6;
-  char       ack : 2;
-  char       commitInProcess;
-  int32_t    fileId;  // ID for corrupted file, 0 means no corrupted file
-  uint64_t   version;
-  SPeerState peerStates[];
-} SPeerStatus;
-
-#pragma pack(pop)
+/*
+ * Initialize the resources
+ */
+int32_t vnodeInitPeer(int numOfThreads);
 
-typedef struct _thread_obj {
-  pthread_t thread;
-  int       threadId;
-  int       pollFd;
-  int       numOfFds;
-} SThreadObj;
+/*
+ * Free the resources
+ */
+void vnodeCleanUpPeers();
 
-typedef struct {
-  int          numOfThreads;
-  SThreadObj **pThread;
-  pthread_t    thread;
-  int          threadId;
-} SThreadPool;
+/*
+ * Start a vnode synchronization process
+ */
+int32_t vnodeOpenPeer(int32_t vnode);
 
-typedef struct _vnodePeer {
-  void *      signature;
-  int         ownId;  // own vnode ID
-  uint32_t    ip;
-  char        ipstr[20];  // ip string
-  int         vid;
-  int         status;
-  int         syncStatus;
-  int32_t     fileId;  // 0 means no corrupted file
-  uint64_t    version;
-  int         commitInProcess;
-  int         syncFd;
-  int         peerFd;  // forward FD
-  void *      hbTimer;
-  void *      syncTimer;
-  SThreadObj *pThread;
-} SVnodePeer;
+/*
+ * Update the peerinfo of vnode
+ */
+int32_t vnodeConfigPeer(SVpeerDescArray msg);
 
-typedef struct {
-  SVnodePeer *pVPeer;
-  uint64_t    lastCreate;
-  uint64_t    lastRemove;
-  uint32_t    fileId;
-  uint64_t    fmagic[];
-} SSyncCmd;
+/*
+ * Close a vnode synchronization process
+ */
+void vnodeCleanUpPeer(int32_t vnode);
 
 #ifdef __cplusplus
 }