[TD-10431] remove mnode files

src/mnode/CMakeLists.txt

-aux_source_directory(source MNODE_SRC)
-add_library(mnode ${MNODE_SRC})
-target_include_directories(
-    mnode
-    PUBLIC "${CMAKE_SOURCE_DIR}/include/mnode"
-    PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/include"
-)
\ No newline at end of file

src/mnode/CMakeLists.txt.in

-CMAKE_MINIMUM_REQUIRED(VERSION 2.8...3.20)
-PROJECT(TDengine)
-
-INCLUDE_DIRECTORIES(${TD_COMMUNITY_DIR}/src/query/inc)
-INCLUDE_DIRECTORIES(${TD_COMMUNITY_DIR}/src/dnode/inc)
-
-INCLUDE_DIRECTORIES(inc)
-AUX_SOURCE_DIRECTORY(src SRC)
-
-ADD_LIBRARY(mnode ${SRC})

src/mnode/inc/mnodeAcct.h

-/*
- * 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 TDENGINE_MNODE_ACCT_H
-#define TDENGINE_MNODE_ACCT_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-#include "tacct.h"
-
-int32_t mnodeInitAccts();
-void    mnodeCleanupAccts();
-void    mnodeGetStatOfAllAcct(SAcctInfo* pAcctInfo);
-void *  mnodeGetAcct(char *acctName);
-void *  mnodeGetNextAcct(void *pIter, SAcctObj **pAcct);
-void    mnodeCancelGetNextAcct(void *pIter);
-void    mnodeIncAcctRef(SAcctObj *pAcct);
-void    mnodeDecAcctRef(SAcctObj *pAcct);
-void    mnodeAddDbToAcct(SAcctObj *pAcct, SDbObj *pDb);
-void    mnodeDropDbFromAcct(SAcctObj *pAcct, SDbObj *pDb);
-void    mnodeAddUserToAcct(SAcctObj *pAcct, SUserObj *pUser);
-void    mnodeDropUserFromAcct(SAcctObj *pAcct, SUserObj *pUser);
-
-int32_t mnodeCompactAccts();
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeCluster.h

-/*
- * 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 TDENGINE_MNODE_CLUSTER_H
-#define TDENGINE_MNODE_CLUSTER_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-int32_t mnodeInitCluster();
-void    mnodeCleanupCluster();
-void    mnodeUpdateClusterId();
-const char* mnodeGetClusterId();
-
-int32_t mnodeCompactCluster();
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeDb.h

-/*
- * 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 TDENGINE_MNODE_DB_H
-#define TDENGINE_MNODE_DB_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-#include "mnodeDef.h"
-
-enum _TSDB_DB_STATUS {
-  TSDB_DB_STATUS_READY,
-  TSDB_DB_STATUS_DROPPING
-};
-
-// api
-int32_t mnodeInitDbs();
-void    mnodeCleanupDbs();
-int64_t mnodeGetDbNum();
-int32_t mnodeGetDbMaxReplica();
-SDbObj *mnodeGetDb(char *db);
-SDbObj *mnodeGetDbByTableName(char *db);
-void *  mnodeGetNextDb(void *pIter, SDbObj **pDb);
-void    mnodeCancelGetNextDb(void *pIter);
-void    mnodeIncDbRef(SDbObj *pDb);
-void    mnodeDecDbRef(SDbObj *pDb);
-bool    mnodeCheckIsMonitorDB(char *db, char *monitordb);
-void    mnodeDropAllDbs(SAcctObj *pAcct);
-int     mnodeInsertAlterDbRow(SDbObj *pDb, void *pMsg);
-
-int32_t mnodeCompactDbs();
-
-// util func
-void mnodeAddSuperTableIntoDb(SDbObj *pDb);
-void mnodeRemoveSuperTableFromDb(SDbObj *pDb);
-void mnodeAddTableIntoDb(SDbObj *pDb);
-void mnodeRemoveTableFromDb(SDbObj *pDb);
-void mnodeAddVgroupIntoDb(SVgObj *pVgroup);
-void mnodeRemoveVgroupFromDb(SVgObj *pVgroup);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeDef.h

-/*
- * 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 TDENGINE_MNODE_DEF_H
-#define TDENGINE_MNODE_DEF_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-#include "taosdef.h"
-#include "taosmsg.h"
-
-struct SVgObj;
-struct SDbObj;
-struct SAcctObj;
-struct SUserObj;
-struct SMnodeObj;
-
-/*
-struct define notes:
-1. The first field must be the xxxxId field or name field , e.g. 'int32_t dnodeId', 'int32_t mnodeId', 'char name[]', 'char user[]', ...
-2. From the dnodeId field to the updataEnd field, these information will be falled disc;
-3. The fields behind the updataEnd field can be changed;
-*/
-
-typedef struct SClusterObj {
-  char    uid[TSDB_CLUSTER_ID_LEN];
-  int64_t createdTime;
-  int8_t  reserved[12];
-  int8_t  updateEnd[4];
-  int32_t refCount;
-} SClusterObj;
-
-typedef struct SDnodeObj {
-  int32_t    dnodeId;
-  int32_t    openVnodes;
-  int64_t    createdTime;
-  int64_t    lastAccess;
-  int32_t    customScore;      // config by user
-  uint16_t   numOfCores;       // from dnode status msg
-  uint16_t   dnodePort;
-  char       dnodeFqdn[TSDB_FQDN_LEN];
-  char       dnodeEp[TSDB_EP_LEN];
-  int8_t     alternativeRole;  // from dnode status msg, 0-any, 1-mgmt, 2-dnode
-  int8_t     status;           // set in balance function
-  int8_t     isMgmt;
-  int8_t     reserve1[11];  
-  int8_t     updateEnd[4];
-  int32_t    refCount;
-  uint32_t   moduleStatus;
-  uint32_t   lastReboot;       // time stamp for last reboot
-  float      score;            // calc in balance function
-  float      diskAvailable;    // from dnode status msg
-  int16_t    diskAvgUsage;     // calc from sys.disk
-  int16_t    cpuAvgUsage;      // calc from sys.cpu
-  int16_t    memoryAvgUsage;   // calc from sys.mem
-  int16_t    bandwidthUsage;   // calc from sys.band
-  int8_t     offlineReason;
-  int8_t     reserved2[1];
-} SDnodeObj;
-
-typedef struct SMnodeObj {
-  int32_t    mnodeId;
-  int8_t     reserved0[4];
-  int64_t    createdTime;
-  int8_t     reserved1[4];
-  int8_t     updateEnd[4];
-  int32_t    refCount;
-  int8_t     role;
-  int64_t    roleTime;
-  int8_t     reserved2[3];
-} SMnodeObj;
-
-typedef struct STableObj {
-  char  *tableId;
-  int8_t type;
-} STableObj;
-
-typedef struct SSTableObj {
-  STableObj  info; 
-  int8_t     reserved0[9]; // for fill struct STableObj to 4byte align
-  int16_t    nextColId;
-  int32_t    sversion;
-  uint64_t   uid;
-  int64_t    createdTime;
-  int32_t    tversion;
-  int32_t    numOfColumns;
-  int32_t    numOfTags;
-  int8_t     updateEnd[4];
-  int32_t    refCount;
-  int32_t    numOfTables;
-  SSchema *  schema;
-  void *     vgHash;
-} SSTableObj;
-
-typedef struct {
-  STableObj  info;  
-  int8_t     reserved0[9]; // for fill struct STableObj to 4byte align
-  int16_t    nextColId;    //used by normal table
-  int32_t    sversion;     //used by normal table  
-  uint64_t   uid;
-  uint64_t   suid;
-  int64_t    createdTime;
-  int32_t    numOfColumns; //used by normal table
-  int32_t    tid;
-  int32_t    vgId;
-  int32_t    sqlLen;
-  int8_t     updateEnd[4];
-  int32_t    refCount;
-  char*      sql;          //used by normal table
-  SSchema*   schema;       //used by normal table
-  SSTableObj*superTable;
-} SCTableObj;
-
-typedef struct {
-  int32_t    dnodeId;
-  int8_t     role;
-  int8_t     vver[3];  // To ensure compatibility, 3 bits are used to represent the remainder of 64 bit version
-  SDnodeObj *pDnode;
-} SVnodeGid;
-
-typedef struct SVgObj {
-  uint32_t       vgId;
-  int32_t        numOfVnodes;
-  int64_t        createdTime;
-  int32_t        lbDnodeId;
-  int32_t        lbTime;
-  char           dbName[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
-  int8_t         inUse;
-  int8_t         accessState;
-  int8_t         status;
-  int8_t         reserved0[4];
-  SVnodeGid      vnodeGid[TSDB_MAX_REPLICA];
-  int32_t        vgCfgVersion;
-  int8_t         compact;
-  int8_t         reserved1[8];
-  int8_t         updateEnd[4];
-  int32_t        refCount;
-  int32_t        numOfTables;
-  int64_t        totalStorage;
-  int64_t        compStorage;
-  int64_t        pointsWritten;
-  struct SDbObj *pDb;
-  void *         idPool;
-} SVgObj;
-
-typedef struct {
-  int32_t cacheBlockSize;
-  int32_t totalBlocks;
-  int32_t maxTables;
-  int32_t daysPerFile;
-  int32_t daysToKeep0;
-  int32_t daysToKeep1;
-  int32_t daysToKeep2;
-  int32_t minRowsPerFileBlock;
-  int32_t maxRowsPerFileBlock;
-  int32_t commitTime;
-  int32_t fsyncPeriod;
-  int8_t  precision;
-  int8_t  compression;
-  int8_t  walLevel;
-  int8_t  replications;
-  int8_t  quorum;
-  int8_t  update;
-  int8_t  cacheLastRow;
-  int8_t  dbType;
-  int16_t partitions;
-  int8_t  reserved[7];
-} SDbCfg;
-
-typedef struct SDbObj {
-  char    name[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
-  int8_t  reserved0[4];
-  char    acct[TSDB_USER_LEN];
-  int64_t createdTime;
-  int32_t dbCfgVersion;
-  SDbCfg  cfg;
-  int8_t  status;
-  int8_t  reserved1[11];
-  int8_t  updateEnd[4];
-  int32_t refCount;
-  int32_t numOfVgroups;
-  int32_t numOfTables;
-  int32_t numOfSuperTables;
-  int32_t vgListSize; 
-  int32_t vgListIndex;
-  SVgObj **vgList;
-  struct SAcctObj *pAcct;
-  pthread_mutex_t  mutex;
-} SDbObj;
-
-typedef struct SUserObj {
-  char              user[TSDB_USER_LEN];
-  char              pass[TSDB_KEY_LEN];
-  char              acct[TSDB_USER_LEN];
-  int64_t           createdTime;
-  int8_t            superAuth;
-  int8_t            writeAuth;
-  int8_t            reserved[10];
-  int8_t            updateEnd[4];
-  int32_t           refCount;
-  struct SAcctObj * pAcct;
-} SUserObj;
-
-typedef struct SFuncObj {
-  char              name[TSDB_FUNC_NAME_LEN];
-  char              path[128];
-  int32_t           contLen;
-  char              cont[TSDB_FUNC_CODE_LEN];
-  int32_t           funcType;
-  int32_t           bufSize;
-  int64_t           createdTime;
-  uint8_t           resType;
-  int16_t           resBytes;
-  int64_t           sig;         // partial md5 sign
-  int16_t           type;        // [lua script|so|js]
-  int8_t            reserved[64];
-  int8_t            updateEnd[4];
-  int32_t           refCount;
-} SFuncObj;
-
-typedef struct {
-  int64_t totalStorage;  // Total storage wrtten from this account
-  int64_t compStorage;   // Compressed storage on disk
-  int64_t queryTime;
-  int64_t totalPoints;
-  int64_t inblound;
-  int64_t outbound;
-  int64_t sKey;
-  int32_t numOfUsers;
-  int32_t numOfDbs;
-  int32_t numOfTimeSeries;
-  int32_t numOfPointsPerSecond;
-  int32_t numOfConns;
-  int32_t numOfQueries;
-  int32_t numOfStreams;
-  int8_t  accessState;   // Checked by mgmt heartbeat message
-  int8_t  reserved[3];
-} SAcctInfo;
-
-typedef struct SAcctObj {
-  char      user[TSDB_USER_LEN];
-  char      pass[TSDB_KEY_LEN];
-  SAcctCfg  cfg;
-  int64_t   createdTime;
-  int32_t   acctId;
-  int8_t    status;
-  int8_t    reserved0[7];
-  int8_t    updateEnd[4];
-  int32_t   refCount;
-  int8_t    reserved1[4];
-  SAcctInfo acctInfo;
-  pthread_mutex_t  mutex;
-} SAcctObj;
-
-typedef struct {
-  char     db[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
-  int8_t   type;
-  int16_t  numOfColumns;
-  int32_t  index;
-  int32_t  rowSize;
-  int32_t  numOfRows;
-  void *   pIter;
-  void *   pVgIter;
-  void **  ppShow;
-  int16_t  offset[TSDB_MAX_COLUMNS];
-  int32_t  bytes[TSDB_MAX_COLUMNS];
-  int32_t  numOfReads;
-  int8_t   maxReplica;
-  int8_t   reserved0[1];
-  uint16_t payloadLen;
-  char     payload[];
-} SShowObj;
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeDnode.h

-/*
- * 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 TDENGINE_MNODE_DNODE_H
-#define TDENGINE_MNODE_DNODE_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-typedef enum {
-  TAOS_DN_STATUS_OFFLINE,
-  TAOS_DN_STATUS_DROPPING,
-  TAOS_DN_STATUS_BALANCING,
-  TAOS_DN_STATUS_READY
-} EDnodeStatus;
-
-typedef enum {
-  TAOS_DN_ALTERNATIVE_ROLE_ANY,
-  TAOS_DN_ALTERNATIVE_ROLE_MNODE,
-  TAOS_DN_ALTERNATIVE_ROLE_VNODE
-} EDnodeAlternativeRole;
-
-typedef enum EDnodeOfflineReason {
-  TAOS_DN_OFF_ONLINE = 0,
-  TAOS_DN_OFF_STATUS_MSG_TIMEOUT,
-  TAOS_DN_OFF_STATUS_NOT_RECEIVED,
-  TAOS_DN_OFF_RESET_BY_MNODE,
-  TAOS_DN_OFF_VERSION_NOT_MATCH,
-  TAOS_DN_OFF_DNODE_ID_NOT_MATCH,
-  TAOS_DN_OFF_CLUSTER_ID_NOT_MATCH,
-  TAOS_DN_OFF_NUM_OF_MNODES_NOT_MATCH,
-  TAOS_DN_OFF_ENABLE_BALANCE_NOT_MATCH,
-  TAOS_DN_OFF_MN_EQUAL_VN_NOT_MATCH,
-  TAOS_DN_OFF_OFFLINE_THRESHOLD_NOT_MATCH,
-  TAOS_DN_OFF_STATUS_INTERVAL_NOT_MATCH,
-  TAOS_DN_OFF_MAX_TAB_PER_VN_NOT_MATCH,
-  TAOS_DN_OFF_MAX_VG_PER_DB_NOT_MATCH,
-  TAOS_DN_OFF_ARBITRATOR_NOT_MATCH,
-  TAOS_DN_OFF_TIME_ZONE_NOT_MATCH,
-  TAOS_DN_OFF_LOCALE_NOT_MATCH,
-  TAOS_DN_OFF_CHARSET_NOT_MATCH,
-  TAOS_DN_OFF_FLOW_CTRL_NOT_MATCH,
-  TAOS_DN_OFF_SLAVE_QUERY_NOT_MATCH,
-  TAOS_DN_OFF_ADJUST_MASTER_NOT_MATCH,
-  TAOS_DN_OFF_OTHERS
-} EDnodeOfflineReason;
-
-extern char* dnodeStatus[];
-extern char* dnodeRoles[];
-
-int32_t mnodeInitDnodes();
-void    mnodeCleanupDnodes();
-
-int32_t mnodeGetDnodesNum();
-int32_t mnodeGetOnlinDnodesCpuCoreNum();
-int32_t mnodeGetOnlineDnodesNum();
-void    mnodeGetOnlineAndTotalDnodesNum(int32_t *onlineNum, int32_t *totalNum);
-void *  mnodeGetNextDnode(void *pIter, SDnodeObj **pDnode);
-void    mnodeCancelGetNextDnode(void *pIter);
-void    mnodeIncDnodeRef(SDnodeObj *pDnode);
-void    mnodeDecDnodeRef(SDnodeObj *pDnode);
-void *  mnodeGetDnode(int32_t dnodeId);
-void *  mnodeGetDnodeByEp(char *ep);
-void    mnodeUpdateDnode(SDnodeObj *pDnode);
-int32_t mnodeDropDnode(SDnodeObj *pDnode, void *pMsg);
-
-int32_t mnodeCompactDnodes();
-extern int64_t tsAccessSquence;
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeFunc.h

-/*
- * 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 TDENGINE_MNODE_FUNC_H
-#define TDENGINE_MNODE_FUNC_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-int32_t   mnodeInitFuncs();
-void      mnodeCleanupFuncs();
-
-SFuncObj *mnodeGetFunc(char *name);
-void *    mnodeGetNextFunc(void *pIter, SFuncObj **pFunc);
-void      mnodeCancelGetNextFunc(void *pIter);
-
-void      mnodeIncFuncRef(SFuncObj *pFunc);
-void      mnodeDecFuncRef(SFuncObj *pFunc);
-
-int32_t   mnodeCreateFunc(SAcctObj *pAcct, char *name, int32_t codeLen, char *code, char *path, uint8_t outputType, int16_t outputLen, int32_t funcType, int32_t bufSize, SMnodeMsg *pMsg);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeInt.h

-/*
- * 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 TDENGINE_MNODE_LOG_H
-#define TDENGINE_MNODE_LOG_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-#include "tlog.h"
-#include "monitor.h"
-
-extern int32_t mDebugFlag;
-extern int32_t sdbDebugFlag;
-
-// mnode log function
-#define mFatal(...) { if (mDebugFlag & DEBUG_FATAL) { taosPrintLog("MND FATAL ", 255, __VA_ARGS__); }}
-#define mError(...) { if (mDebugFlag & DEBUG_ERROR) { taosPrintLog("MND ERROR ", 255, __VA_ARGS__); }}
-#define mWarn(...)  { if (mDebugFlag & DEBUG_WARN)  { taosPrintLog("MND WARN ", 255, __VA_ARGS__); }}
-#define mInfo(...)  { if (mDebugFlag & DEBUG_INFO)  { taosPrintLog("MND ", 255, __VA_ARGS__); }}
-#define mDebug(...) { if (mDebugFlag & DEBUG_DEBUG) { taosPrintLog("MND ", mDebugFlag, __VA_ARGS__); }}
-#define mTrace(...) { if (mDebugFlag & DEBUG_TRACE) { taosPrintLog("MND ", mDebugFlag, __VA_ARGS__); }}
-
-#define sdbFatal(...) { if (sdbDebugFlag & DEBUG_FATAL) { taosPrintLog("SDB FATAL ", 255, __VA_ARGS__); }}
-#define sdbError(...) { if (sdbDebugFlag & DEBUG_ERROR) { taosPrintLog("SDB ERROR ", 255, __VA_ARGS__); }}
-#define sdbWarn(...)  { if (sdbDebugFlag & DEBUG_WARN)  { taosPrintLog("SDB WARN ", 255, __VA_ARGS__); }}
-#define sdbInfo(...)  { if (sdbDebugFlag & DEBUG_INFO)  { taosPrintLog("SDB ", 255, __VA_ARGS__); }}
-#define sdbDebug(...) { if (sdbDebugFlag & DEBUG_DEBUG) { taosPrintLog("SDB ", sdbDebugFlag, __VA_ARGS__); }}
-#define sdbTrace(...) { if (sdbDebugFlag & DEBUG_TRACE) { taosPrintLog("SDB ", sdbDebugFlag, __VA_ARGS__); }}
-
-#define mLError(...) { monSaveLog(2, __VA_ARGS__); mError(__VA_ARGS__) }
-#define mLWarn(...)  { monSaveLog(1, __VA_ARGS__); mWarn(__VA_ARGS__)  }
-#define mLInfo(...)  { monSaveLog(0, __VA_ARGS__); mInfo(__VA_ARGS__) }
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeMnode.h

-/*
- * 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 TDENGINE_MNODE_MNODE_H
-#define TDENGINE_MNODE_MNODE_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-struct SMnodeObj;
-
-typedef enum {
-  TAOS_MN_STATUS_OFFLINE,
-  TAOS_MN_STATUS_DROPPING,
-  TAOS_MN_STATUS_READY
-} EMnodeStatus;
-
-int32_t mnodeInitMnodes();
-void    mnodeCleanupMnodes();
-
-void    mnodeCreateMnode(int32_t dnodeId, char *dnodeEp, bool needConfirm);
-int32_t mnodeDropMnode(int32_t dnodeId);
-void    mnodeDropMnodeLocal(int32_t dnodeId);
-
-void *  mnodeGetMnode(int32_t mnodeId);
-int32_t mnodeGetMnodesNum();
-void *  mnodeGetNextMnode(void *pIter, struct SMnodeObj **pMnode);
-void    mnodeCancelGetNextMnode(void *pIter);
-void    mnodeIncMnodeRef(struct SMnodeObj *pMnode);
-void    mnodeDecMnodeRef(struct SMnodeObj *pMnode);
-
-char *  mnodeGetMnodeRoleStr();
-void    mnodeGetMnodeEpSetForPeer(SRpcEpSet *epSet, bool redirect);
-void    mnodeGetMnodeEpSetForShell(SRpcEpSet *epSet, bool redirect);
-char*   mnodeGetMnodeMasterEp();
-
-void    mnodeGetMnodeInfos(void *mnodes);
-void    mnodeUpdateMnodeEpSet(SMInfos *pMnodes);
-
-int32_t mnodeCompactMnodes();
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodePeer.h

-/*
- * 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 TDENGINE_MNODE_PEER_H
-#define TDENGINE_MNODE_PEER_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-void    mnodeAddPeerRspHandle(uint8_t msgType, void (*fp)(SRpcMsg *rpcMsg));
-void    mnodeAddPeerMsgHandle(uint8_t msgType, int32_t (*fp)(SMnodeMsg *mnodeMsg));
-int32_t mnodeProcessPeerReq(SMnodeMsg *pMsg);
-void    mnodeProcessPeerRsp(SRpcMsg *pMsg);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeProfile.h

-/*
- * 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 TDENGINE_MNODE_PROFILE_H
-#define TDENGINE_MNODE_PROFILE_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-typedef struct {
-  char     user[TSDB_USER_LEN];
-  char     appName[TSDB_APPNAME_LEN];  // app name that invokes taosc
-  uint32_t pid;                        // pid of app that invokes taosc
-  int8_t   killed;
-  uint16_t port;
-  uint32_t ip;
-  uint32_t connId;
-  uint64_t stime;
-  uint64_t lastAccess;
-  uint32_t queryId;
-  uint32_t streamId;
-  int32_t  numOfQueries;
-  int32_t  numOfStreams;
-  SStreamDesc *pStreams;
-  SQueryDesc * pQueries;
-} SConnObj;
-
-int32_t mnodeInitProfile();
-void    mnodeCleanupProfile();
-
-SConnObj *mnodeCreateConn(char *user, uint32_t ip, uint16_t port, int32_t pid, const char* app);
-SConnObj *mnodeAccquireConn(int32_t connId, char *user, uint32_t ip, uint16_t port);
-void      mnodeReleaseConn(SConnObj *pConn);
-int32_t   mnodeSaveQueryStreamList(SConnObj *pConn, SHeartBeatMsg *pHBMsg);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif
\ No newline at end of file

src/mnode/inc/mnodeRead.h

-/*
- * 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 TDENGINE_MNODE_READ_H
-#define TDENGINE_MNODE_READ_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-void    mnodeAddReadMsgHandle(uint8_t msgType, int32_t (*fp)(SMnodeMsg *mnodeMsg));
-int32_t mnodeProcessRead(SMnodeMsg *pMsg);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeSdb.h

-/*
- * 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 TDENGINE_MNODE_SDB_H
-#define TDENGINE_MNODE_SDB_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-#include "mnode.h"
-#include "twal.h"
-
-typedef enum {
-  SDB_TABLE_CLUSTER = 0,
-  SDB_TABLE_DNODE   = 1,
-  SDB_TABLE_MNODE   = 2,
-  SDB_TABLE_ACCOUNT = 3,
-  SDB_TABLE_USER    = 4,
-  SDB_TABLE_DB      = 5,
-  SDB_TABLE_VGROUP  = 6,
-  SDB_TABLE_STABLE  = 7,
-  SDB_TABLE_CTABLE  = 8,
-  SDB_TABLE_FUNC    = 9,
-  SDB_TABLE_MAX     = 10
-} ESdbTable;
-
-typedef enum {
-  SDB_KEY_STRING     = 0, 
-  SDB_KEY_INT        = 1,
-  SDB_KEY_AUTO       = 2,
-  SDB_KEY_VAR_STRING = 3,
-} ESdbKey;
-
-typedef enum {
-  SDB_OPER_GLOBAL = 0,
-  SDB_OPER_LOCAL  = 1
-} ESdbOper;
-
-typedef struct SSdbRow {
-  ESdbOper   type;
-  int32_t    processedCount;  // for sync fwd callback
-  int32_t    code;            // for callback in sdb queue
-  int32_t    rowSize;
-  void *     rowData;
-  void *     pObj;
-  void *     pTable;
-  SMnodeMsg *pMsg;
-  int32_t  (*fpReq)(SMnodeMsg *pMsg);
-  int32_t  (*fpRsp)(SMnodeMsg *pMsg, int32_t code);
-  char       reserveForSync[24];
-  SWalHead   pHead;
-} SSdbRow;
-
-typedef struct {
-  char *    name;
-  int32_t   hashSessions;
-  int32_t   maxRowSize;
-  int32_t   refCountPos;
-  ESdbTable id;
-  ESdbKey   keyType;
-  int32_t (*fpInsert)(SSdbRow *pRow);
-  int32_t (*fpDelete)(SSdbRow *pRow);
-  int32_t (*fpUpdate)(SSdbRow *pRow);
-  int32_t (*fpEncode)(SSdbRow *pRow);
-  int32_t (*fpDecode)(SSdbRow *pRow);  
-  int32_t (*fpDestroy)(SSdbRow *pRow);
-  int32_t (*fpRestored)();
-} SSdbTableDesc;
-
-int32_t sdbInitRef();
-void    sdbCleanUpRef();
-int32_t sdbInit();
-void    sdbCleanUp();
-int64_t sdbOpenTable(SSdbTableDesc *desc);
-void    sdbCloseTable(int64_t rid);
-void*   sdbGetTableByRid(int64_t rid);
-bool    sdbIsMaster();
-bool    sdbIsServing();
-void    sdbUpdateMnodeRoles();
-int32_t sdbGetReplicaNum();
-
-int32_t sdbInsertRow(SSdbRow *pRow);
-int32_t sdbInsertCompactRow(SSdbRow *pRow);
-int32_t sdbDeleteRow(SSdbRow *pRow);
-int32_t sdbUpdateRow(SSdbRow *pRow);
-int32_t sdbInsertRowToQueue(SSdbRow *pRow);
-
-void *   sdbGetRow(void *pTable, void *key);
-void *   sdbFetchRow(void *pTable, void *pIter, void **ppRow);
-void     sdbFreeIter(void *pTable, void *pIter);
-void     sdbIncRef(void *pTable, void *pRow);
-void     sdbDecRef(void *pTable, void *pRow);
-int64_t  sdbGetNumOfRows(void *pTable);
-int32_t  sdbGetId(void *pTable);
-uint64_t sdbGetVersion();
-bool     sdbCheckRowDeleted(void *pTable, void *pRow);
-
-int32_t mnodeCompactWal();
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeShow.h

-/*
- * 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 TDENGINE_MNODE_SHELL_H
-#define TDENGINE_MNODE_SHELL_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-int32_t mnodeInitShow();
-void    mnodeCleanUpShow();
-
-typedef int32_t (*SShowMetaFp)(STableMetaMsg *pMeta, SShowObj *pShow, void *pConn);
-typedef int32_t (*SShowRetrieveFp)(SShowObj *pShow, char *data, int32_t rows, void *pConn);
-typedef void    (*SShowFreeIterFp)(void *pIter);
-void mnodeAddShowMetaHandle(uint8_t showType, SShowMetaFp fp);
-void mnodeAddShowRetrieveHandle(uint8_t showType, SShowRetrieveFp fp);
-void mnodeAddShowFreeIterHandle(uint8_t msgType, SShowFreeIterFp fp);
-void mnodeVacuumResult(char *data, int32_t numOfCols, int32_t rows, int32_t capacity, SShowObj *pShow);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeTable.h

-/*
- * 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 TBASE_MNODE_TABLE_H
-#define TBASE_MNODE_TABLE_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-#include "mnodeDef.h"
-
-int32_t mnodeInitTables();
-void    mnodeCleanupTables();
-int64_t mnodeGetSuperTableNum();
-int64_t mnodeGetChildTableNum();
-void *  mnodeGetTable(char *tableId);
-void    mnodeIncTableRef(void *pTable);
-void    mnodeDecTableRef(void *pTable);
-void *  mnodeGetNextChildTable(void *pIter, SCTableObj **pTable);
-void *  mnodeGetNextSuperTable(void *pIter, SSTableObj **pTable);
-void    mnodeCancelGetNextChildTable(void *pIter);
-void    mnodeCancelGetNextSuperTable(void *pIter);
-void    mnodeDropAllChildTables(SDbObj *pDropDb);
-void    mnodeDropAllSuperTables(SDbObj *pDropDb);
-void    mnodeDropAllChildTablesInVgroups(SVgObj *pVgroup);
-int32_t mnodeCompactTables();
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeUser.h

-/*
- * 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 TDENGINE_MNODE_USER_H
-#define TDENGINE_MNODE_USER_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-int32_t   mnodeInitUsers();
-void      mnodeCleanupUsers();
-SUserObj *mnodeGetUser(char *name);
-void *    mnodeGetNextUser(void *pIter, SUserObj **pUser);
-void      mnodeCancelGetNextUser(void *pIter);
-void      mnodeIncUserRef(SUserObj *pUser);
-void      mnodeDecUserRef(SUserObj *pUser);
-SUserObj *mnodeGetUserFromConn(void *pConn);
-char *    mnodeGetUserFromMsg(void *pMnodeMsg);
-int32_t   mnodeCreateUser(SAcctObj *pAcct, char *name, char *pass, void *pMsg);
-void      mnodeDropAllUsers(SAcctObj *pAcct);
-
-int32_t   mnodeCompactUsers();
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeVgroup.h

-/*
- * 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 TDENGINE_MNODE_VGROUP_H
-#define TDENGINE_MNODE_VGROUP_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-struct SMnodeMsg;
-
-int32_t mnodeInitVgroups();
-void    mnodeCleanupVgroups();
-int64_t mnodeGetVgroupNum();
-SVgObj *mnodeGetVgroup(int32_t vgId);
-void    mnodeIncVgroupRef(SVgObj *pVgroup);
-void    mnodeDecVgroupRef(SVgObj *pVgroup);
-void    mnodeDropAllDbVgroups(SDbObj *pDropDb);
-void    mnodeSendDropAllDbVgroupsMsg(SDbObj *pDropDb);
-void    mnodeDropAllDnodeVgroups(SDnodeObj *pDropDnode);
-//void  mnodeUpdateAllDbVgroups(SDbObj *pAlterDb);
-int32_t mnodeCompactVgroups();
-
-void *  mnodeGetNextVgroup(void *pIter, SVgObj **pVgroup);
-void    mnodeCancelGetNextVgroup(void *pIter);
-void    mnodeUpdateVgroup(SVgObj *pVgroup);
-void    mnodeUpdateVgroupStatus(SVgObj *pVgroup, SDnodeObj *pDnode, SVnodeLoad *pVload);
-void    mnodeCheckUnCreatedVgroup(SDnodeObj *pDnode, SVnodeLoad *pVloads, int32_t openVnodes);
-
-int32_t mnodeCreateVgroup(struct SMnodeMsg *pMsg);
-void    mnodeDropVgroup(SVgObj *pVgroup, void *ahandle);
-void    mnodeAlterVgroup(SVgObj *pVgroup, void *ahandle);
-int32_t mnodeGetAvailableVgroup(struct SMnodeMsg *pMsg, SVgObj **pVgroup, int32_t *sid);
-
-int32_t mnodeAddTableIntoVgroup(SVgObj *pVgroup, SCTableObj *pTable, bool needCheck);
-void    mnodeRemoveTableFromVgroup(SVgObj *pVgroup, SCTableObj *pTable);
-void    mnodeSendDropVnodeMsg(int32_t vgId, SRpcEpSet *epSet, void *ahandle);
-void    mnodeSendCreateVgroupMsg(SVgObj *pVgroup, void *ahandle);
-void    mnodeSendAlterVgroupMsg(SVgObj *pVgroup,SMnodeMsg *pMsg);
-void    mnodeSendSyncVgroupMsg(SVgObj *pVgroup);
-void    mnodeSendCompactVgroupMsg(SVgObj *pVgroup);
-
-SRpcEpSet mnodeGetEpSetFromVgroup(SVgObj *pVgroup);
-SRpcEpSet mnodeGetEpSetFromIp(char *ep);
-
-int32_t mnodeGetVgidVer(int8_t *vver);
-void    mnodeSetVgidVer(int8_t *cver, uint64_t iver);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/inc/mnodeWrite.h

-/*
- * 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 TDENGINE_MNODE_WRITE_H
-#define TDENGINE_MNODE_WRITE_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-#include "mnodeDef.h"
-
-void    mnodeAddWriteMsgHandle(uint8_t msgType, int32_t (*fp)(SMnodeMsg *mnodeMsg));
-int32_t mnodeProcessRead(SMnodeMsg *pMsg);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif

src/mnode/src/mnodeAcct.c

-/*
- * 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/>.
- */
-
-#define _DEFAULT_SOURCE
-#include "os.h"
-#include "taoserror.h"
-#include "tglobal.h"
-#include "dnode.h"
-#include "mnodeDef.h"
-#include "mnodeInt.h"
-#include "mnodeAcct.h"
-#include "mnodeDb.h"
-#include "mnodeSdb.h"
-#include "mnodeUser.h"
-#include "mnodeVgroup.h"
-
-int64_t tsAcctRid = -1;
-void *  tsAcctSdb = NULL;
-static int32_t tsAcctUpdateSize;
-static int32_t mnodeCreateRootAcct();
-
-static int32_t mnodeAcctActionDestroy(SSdbRow *pRow) {
-  SAcctObj *pAcct = pRow->pObj;
-  pthread_mutex_destroy(&pAcct->mutex);
-  tfree(pRow->pObj);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeAcctActionInsert(SSdbRow *pRow) {
-  SAcctObj *pAcct = pRow->pObj;
-  memset(&pAcct->acctInfo, 0, sizeof(SAcctInfo));
-  pAcct->acctInfo.accessState = TSDB_VN_ALL_ACCCESS;
-  pthread_mutex_init(&pAcct->mutex, NULL);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeAcctActionDelete(SSdbRow *pRow) {
-  SAcctObj *pAcct = pRow->pObj;
-  mnodeDropAllUsers(pAcct);
-  mnodeDropAllDbs(pAcct);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeAcctActionUpdate(SSdbRow *pRow) {
-  SAcctObj *pAcct = pRow->pObj;
-  SAcctObj *pSaved = mnodeGetAcct(pAcct->user);
-  if (pAcct != pSaved) {
-    memcpy(pSaved, pAcct, tsAcctUpdateSize);
-    free(pAcct);
-  }
-  mnodeDecAcctRef(pSaved);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeAcctActionEncode(SSdbRow *pRow) {
-  SAcctObj *pAcct = pRow->pObj;
-  memcpy(pRow->rowData, pAcct, tsAcctUpdateSize);
-  pRow->rowSize = tsAcctUpdateSize;
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeAcctActionDecode(SSdbRow *pRow) {
-  SAcctObj *pAcct = (SAcctObj *) calloc(1, sizeof(SAcctObj));
-  if (pAcct == NULL) return TSDB_CODE_MND_OUT_OF_MEMORY;
-
-  memcpy(pAcct, pRow->rowData, tsAcctUpdateSize);
-  pRow->pObj = pAcct;
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeAcctActionRestored() {
-  int64_t numOfRows = sdbGetNumOfRows(tsAcctSdb);
-  if (numOfRows <= 0 && dnodeIsFirstDeploy()) {
-    mInfo("dnode first deploy, create root acct");
-    int32_t code = mnodeCreateRootAcct();
-    if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) {
-      mError("failed to create root account, reason:%s", tstrerror(code));
-      return code;
-    }
-  }
-
-  acctInit();
-  return TSDB_CODE_SUCCESS;
-}
-
-int32_t mnodeInitAccts() {
-  SAcctObj tObj;
-  tsAcctUpdateSize = (int32_t)((int8_t *)tObj.updateEnd - (int8_t *)&tObj);
-
-  SSdbTableDesc desc = {
-    .id           = SDB_TABLE_ACCOUNT,
-    .name         = "accounts",
-    .hashSessions = TSDB_DEFAULT_ACCOUNTS_HASH_SIZE,
-    .maxRowSize   = tsAcctUpdateSize,
-    .refCountPos  = (int32_t)((int8_t *)(&tObj.refCount) - (int8_t *)&tObj),
-    .keyType      = SDB_KEY_STRING,
-    .fpInsert     = mnodeAcctActionInsert,
-    .fpDelete     = mnodeAcctActionDelete,
-    .fpUpdate     = mnodeAcctActionUpdate,
-    .fpEncode     = mnodeAcctActionEncode,
-    .fpDecode     = mnodeAcctActionDecode,
-    .fpDestroy    = mnodeAcctActionDestroy,
-    .fpRestored   = mnodeAcctActionRestored
-  };
-
-  tsAcctRid = sdbOpenTable(&desc);
-  tsAcctSdb = sdbGetTableByRid(tsAcctRid);
-  if (tsAcctSdb == NULL) {
-    mError("table:%s, failed to create hash", desc.name);
-    return -1;
-  }
-
-  mDebug("table:%s, hash is created", desc.name);
-  return TSDB_CODE_SUCCESS;
-}
-
-void mnodeCleanupAccts() {
-  acctCleanUp();
-  sdbCloseTable(tsAcctRid);
-  tsAcctSdb = NULL;
-}
-
-void mnodeGetStatOfAllAcct(SAcctInfo* pAcctInfo) {
-  memset(pAcctInfo, 0, sizeof(*pAcctInfo));
-
-  void   *pIter = NULL;
-  SAcctObj *pAcct = NULL;
-  while (1) {
-    pIter = mnodeGetNextAcct(pIter, &pAcct);
-    if (pAcct == NULL) {
-      break;
-    }
-    pAcctInfo->numOfDbs += pAcct->acctInfo.numOfDbs;
-    pAcctInfo->numOfTimeSeries += pAcct->acctInfo.numOfTimeSeries;
-    mnodeDecAcctRef(pAcct);
-  }
-
-  SVgObj *pVgroup = NULL;
-  pIter = NULL;
-  while (1) {
-    pIter = mnodeGetNextVgroup(pIter, &pVgroup);
-    if (pVgroup == NULL) {
-       break;
-    }
-    pAcctInfo->totalStorage += pVgroup->totalStorage;
-    pAcctInfo->compStorage += pVgroup->compStorage;
-    pAcctInfo->totalPoints += pVgroup->pointsWritten;
-    mnodeDecVgroupRef(pVgroup);
-  }
-}
-
-void *mnodeGetAcct(char *name) {
-  return sdbGetRow(tsAcctSdb, name);
-}
-
-void *mnodeGetNextAcct(void *pIter, SAcctObj **pAcct) {
-  return sdbFetchRow(tsAcctSdb, pIter, (void **)pAcct); 
-}
-
-void mnodeCancelGetNextAcct(void *pIter) {
-  sdbFreeIter(tsAcctSdb, pIter);
-}
-
-void mnodeIncAcctRef(SAcctObj *pAcct) {
-  sdbIncRef(tsAcctSdb, pAcct);
-}
-
-void mnodeDecAcctRef(SAcctObj *pAcct) {
-  sdbDecRef(tsAcctSdb, pAcct);
-}
-
-void mnodeAddDbToAcct(SAcctObj *pAcct, SDbObj *pDb) {
-  atomic_add_fetch_32(&pAcct->acctInfo.numOfDbs, 1);
-  pDb->pAcct = pAcct;
-  mnodeIncAcctRef(pAcct);
-}
-
-void mnodeDropDbFromAcct(SAcctObj *pAcct, SDbObj *pDb) {
-  atomic_sub_fetch_32(&pAcct->acctInfo.numOfDbs, 1);
-  pDb->pAcct = NULL;
-  mnodeDecAcctRef(pAcct);
-}
-
-void mnodeAddUserToAcct(SAcctObj *pAcct, SUserObj *pUser) {
-  atomic_add_fetch_32(&pAcct->acctInfo.numOfUsers, 1);
-  pUser->pAcct = pAcct;
-  mnodeIncAcctRef(pAcct);
-}
-
-void mnodeDropUserFromAcct(SAcctObj *pAcct, SUserObj *pUser) {
-  atomic_sub_fetch_32(&pAcct->acctInfo.numOfUsers, 1);
-  pUser->pAcct = NULL;
-  mnodeDecAcctRef(pAcct);
-}
-
-static int32_t mnodeCreateRootAcct() {
-  int64_t numOfAccts = sdbGetNumOfRows(tsAcctSdb);
-  if (numOfAccts != 0) return TSDB_CODE_SUCCESS;
-
-  SAcctObj *pAcct = malloc(sizeof(SAcctObj));
-  memset(pAcct, 0, sizeof(SAcctObj));
-  strcpy(pAcct->user, TSDB_DEFAULT_USER);
-  taosEncryptPass((uint8_t *)TSDB_DEFAULT_PASS, strlen(TSDB_DEFAULT_PASS), pAcct->pass);
-  pAcct->cfg = (SAcctCfg){
-    .maxUsers           = 128,
-    .maxDbs             = 128,
-    .maxTimeSeries      = INT32_MAX,
-    .maxConnections     = 1024,
-    .maxStreams         = 1000,
-    .maxPointsPerSecond = 10000000,
-    .maxStorage         = INT64_MAX,
-    .maxQueryTime       = INT64_MAX,
-    .maxInbound         = 0,
-    .maxOutbound        = 0,
-    .accessState        = TSDB_VN_ALL_ACCCESS
-  };
-  pAcct->acctId = sdbGetId(tsAcctSdb);
-  pAcct->createdTime = taosGetTimestampMs();
-
-  SSdbRow row = {
-    .type   = SDB_OPER_GLOBAL,
-    .pTable = tsAcctSdb,
-    .pObj   = pAcct,
-  };
-
-  return sdbInsertRow(&row);
-}
-
-int32_t mnodeCompactAccts() {
-  void *pIter = NULL;
-  SAcctObj *pAcct = NULL;
-
-  mInfo("start to compact accts table...");
-
-  while (1) {
-    pIter = mnodeGetNextAcct(pIter, &pAcct);
-    if (pAcct == NULL) break;
-
-    SSdbRow row = {
-      .type   = SDB_OPER_GLOBAL,
-      .pTable = tsAcctSdb,
-      .pObj   = pAcct,
-    };
-
-    mInfo("compact accts %s", pAcct->user);
-    
-    sdbInsertCompactRow(&row);
-  }
-
-  mInfo("end to compact accts table...");
-
-  return 0;
-}
-
-#ifndef _ACCT
-
-int32_t acctInit() { return TSDB_CODE_SUCCESS; }
-void    acctCleanUp() {}
-int32_t acctCheck(void *pAcct, EAcctGrantType type) { return TSDB_CODE_SUCCESS; }
-
-#endif

src/mnode/src/mnodeCluster.c

-/*
- * 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/>.
- */
-
-#define _DEFAULT_SOURCE
-#include "os.h"
-#include "taoserror.h"
-#include "dnode.h"
-#include "mnodeDef.h"
-#include "mnodeInt.h"
-#include "mnodeCluster.h"
-#include "mnodeSdb.h"
-#include "mnodeShow.h"
-#include "tglobal.h"
-
-int64_t        tsClusterRid = -1;
-static void *  tsClusterSdb = NULL;
-static int32_t tsClusterUpdateSize;
-static char    tsClusterId[TSDB_CLUSTER_ID_LEN];
-static int32_t mnodeCreateCluster();
-
-static int32_t mnodeGetClusterMeta(STableMetaMsg *pMeta, SShowObj *pShow, void *pConn);
-static int32_t mnodeRetrieveClusters(SShowObj *pShow, char *data, int32_t rows, void *pConn);
-static void    mnodeCancelGetNextCluster(void *pIter);
-
-static int32_t mnodeClusterActionDestroy(SSdbRow *pRow) {
-  tfree(pRow->pObj);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeClusterActionInsert(SSdbRow *pRow) {
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeClusterActionDelete(SSdbRow *pRow) {
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeClusterActionUpdate(SSdbRow *pRow) {
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeClusterActionEncode(SSdbRow *pRow) {
-  SClusterObj *pCluster = pRow->pObj;
-  memcpy(pRow->rowData, pCluster, tsClusterUpdateSize);
-  pRow->rowSize = tsClusterUpdateSize;
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeClusterActionDecode(SSdbRow *pRow) {
-  SClusterObj *pCluster = (SClusterObj *) calloc(1, sizeof(SClusterObj));
-  if (pCluster == NULL) return TSDB_CODE_MND_OUT_OF_MEMORY;
-
-  memcpy(pCluster, pRow->rowData, tsClusterUpdateSize);
-  pRow->pObj = pCluster;
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeClusterActionRestored() {
-  int64_t numOfRows = sdbGetNumOfRows(tsClusterSdb);
-  if (numOfRows <= 0 && dnodeIsFirstDeploy()) {
-    mInfo("dnode first deploy, create cluster");
-    int32_t code = mnodeCreateCluster();
-    if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) {
-      mError("failed to create cluster, reason:%s", tstrerror(code));
-      return code;
-    }
-  }
-
-  mnodeUpdateClusterId();
-  return TSDB_CODE_SUCCESS;
-}
-
-int32_t mnodeInitCluster() {
-  SClusterObj tObj;
-  tsClusterUpdateSize = (int32_t)((int8_t *)tObj.updateEnd - (int8_t *)&tObj);
-
-  SSdbTableDesc desc = {
-    .id           = SDB_TABLE_CLUSTER,
-    .name         = "cluster",
-    .hashSessions = TSDB_DEFAULT_CLUSTER_HASH_SIZE,
-    .maxRowSize   = tsClusterUpdateSize,
-    .refCountPos  = (int32_t)((int8_t *)(&tObj.refCount) - (int8_t *)&tObj),
-    .keyType      = SDB_KEY_STRING,
-    .fpInsert     = mnodeClusterActionInsert,
-    .fpDelete     = mnodeClusterActionDelete,
-    .fpUpdate     = mnodeClusterActionUpdate,
-    .fpEncode     = mnodeClusterActionEncode,
-    .fpDecode     = mnodeClusterActionDecode,
-    .fpDestroy    = mnodeClusterActionDestroy,
-    .fpRestored   = mnodeClusterActionRestored
-  };
-
-  tsClusterRid = sdbOpenTable(&desc);
-  tsClusterSdb = sdbGetTableByRid(tsClusterRid);
-  if (tsClusterSdb == NULL) {
-    mError("table:%s, rid:%" PRId64 ", failed to create hash", desc.name, tsClusterRid);
-    return -1;
-  }
-
-  mnodeAddShowMetaHandle(TSDB_MGMT_TABLE_CLUSTER, mnodeGetClusterMeta);
-  mnodeAddShowRetrieveHandle(TSDB_MGMT_TABLE_CLUSTER, mnodeRetrieveClusters);
-  mnodeAddShowFreeIterHandle(TSDB_MGMT_TABLE_CLUSTER, mnodeCancelGetNextCluster);
-
-  mDebug("table:%s, hash is created", desc.name);
-  return TSDB_CODE_SUCCESS;
-}
-
-void mnodeCleanupCluster() {
-  sdbCloseTable(tsClusterRid);
-  tsClusterSdb = NULL;
-}
-
-void *mnodeGetNextCluster(void *pIter, SClusterObj **pCluster) {
-  return sdbFetchRow(tsClusterSdb, pIter, (void **)pCluster); 
-}
-
-void mnodeCancelGetNextCluster(void *pIter) {
-  sdbFreeIter(tsClusterSdb, pIter);
-}
-
-void mnodeIncClusterRef(SClusterObj *pCluster) {
-  sdbIncRef(tsClusterSdb, pCluster);
-}
-
-void mnodeDecClusterRef(SClusterObj *pCluster) {
-  sdbDecRef(tsClusterSdb, pCluster);
-}
-
-static int32_t mnodeCreateCluster() {
-  int64_t numOfClusters = sdbGetNumOfRows(tsClusterSdb);
-  if (numOfClusters != 0) return TSDB_CODE_SUCCESS;
-
-  SClusterObj *pCluster = malloc(sizeof(SClusterObj));
-  memset(pCluster, 0, sizeof(SClusterObj));
-  pCluster->createdTime = taosGetTimestampMs();
-  bool getuid = taosGetSystemUid(pCluster->uid);
-  if (!getuid) {
-    strcpy(pCluster->uid, "tdengine2.0");
-    mError("failed to get uid from system, set to default val %s", pCluster->uid);
-  } else {
-    mDebug("uid is %s", pCluster->uid);
-  }
-
-  SSdbRow row = {
-    .type   = SDB_OPER_GLOBAL,
-    .pTable = tsClusterSdb,
-    .pObj   = pCluster,
-  };
-
-  return sdbInsertRow(&row);
-}
-
-const char* mnodeGetClusterId() {
-  return tsClusterId;
-}
-
-void mnodeUpdateClusterId() {
-  SClusterObj *pCluster = NULL;
-  void *pIter = mnodeGetNextCluster(NULL, &pCluster);
-  if (pCluster != NULL) {
-    tstrncpy(tsClusterId, pCluster->uid, TSDB_CLUSTER_ID_LEN);
-    mDebug("cluster id is set to %s", tsClusterId);
-  }
-
-  mnodeDecClusterRef(pCluster);
-  mnodeCancelGetNextCluster(pIter);
-}
-
-static int32_t mnodeGetClusterMeta(STableMetaMsg *pMeta, SShowObj *pShow, void *pConn) {
-  int32_t cols = 0;
-  SSchema *pSchema = pMeta->schema;
-
-  pShow->bytes[cols] = TSDB_CLUSTER_ID_LEN + VARSTR_HEADER_SIZE;
-  pSchema[cols].type = TSDB_DATA_TYPE_BINARY;
-  strcpy(pSchema[cols].name, "clusterId");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = 8;
-  pSchema[cols].type = TSDB_DATA_TYPE_TIMESTAMP;
-  strcpy(pSchema[cols].name, "create_time");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pMeta->numOfColumns = htons(cols);
-  strcpy(pMeta->tableFname, "show cluster");
-  pShow->numOfColumns = cols;
-
-  pShow->offset[0] = 0;
-  for (int32_t i = 1; i < cols; ++i) {
-    pShow->offset[i] = pShow->offset[i - 1] + pShow->bytes[i - 1];
-  }
-
-  pShow->numOfRows = 1;
-  pShow->rowSize = pShow->offset[cols - 1] + pShow->bytes[cols - 1];
-
-  return 0;
-}
-
-static int32_t mnodeRetrieveClusters(SShowObj *pShow, char *data, int32_t rows, void *pConn) {
-  int32_t numOfRows = 0;
-  int32_t cols = 0;
-  char *  pWrite;
-  SClusterObj *pCluster = NULL;
-
-  while (numOfRows < rows) {
-    pShow->pIter = mnodeGetNextCluster(pShow->pIter, &pCluster);
-    if (pCluster == NULL) break;
-    
-    cols = 0;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    STR_WITH_MAXSIZE_TO_VARSTR(pWrite, pCluster->uid, TSDB_CLUSTER_ID_LEN);
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    *(int64_t *) pWrite = pCluster->createdTime;
-    cols++;
-
-    mnodeDecClusterRef(pCluster);
-    numOfRows++;
-  }
-
-  mnodeVacuumResult(data, pShow->numOfColumns, numOfRows, rows, pShow);
-  pShow->numOfReads += numOfRows;
-  return numOfRows;
-}
-
-int32_t mnodeCompactCluster() {
-  SClusterObj *pCluster = NULL;
-  void *pIter;
-  
-  mInfo("start to compact cluster table...");
-
-  pIter = mnodeGetNextCluster(NULL, &pCluster);
-  while (pCluster) {
-    SSdbRow row = {
-      .type   = SDB_OPER_GLOBAL,
-      .pTable = tsClusterSdb,
-      .pObj   = pCluster,      
-    };
-
-    sdbInsertCompactRow(&row);
-
-    pIter = mnodeGetNextCluster(pIter, &pCluster);
-  }
-
-  mInfo("end to compact cluster table...");
-
-  return 0;
-}
\ No newline at end of file

src/mnode/src/mnodeFunc.c

-/*
- * 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/>.
- */
-
-#define _DEFAULT_SOURCE
-#include "os.h"
-#include "trpc.h"
-#include "tutil.h"
-#include "tglobal.h"
-#include "tgrant.h"
-#include "tdataformat.h"
-#include "tkey.h"
-#include "mnode.h"
-#include "dnode.h"
-#include "mnodeDef.h"
-#include "mnodeInt.h"
-#include "mnodeAcct.h"
-#include "mnodeUser.h"
-#include "mnodeMnode.h"
-#include "mnodeSdb.h"
-#include "mnodeShow.h"
-#include "mnodeFunc.h"
-#include "mnodeWrite.h"
-#include "mnodeRead.h"
-#include "mnodePeer.h"
-
-int64_t        tsFuncRid = -1;
-static void *  tsFuncSdb = NULL;
-static int32_t tsFuncUpdateSize = 0;
-static int32_t mnodeGetFuncMeta(STableMetaMsg *pMeta, SShowObj *pShow, void *pConn);
-static int32_t mnodeRetrieveFuncs(SShowObj *pShow, char *data, int32_t rows, void *pConn);
-static int32_t mnodeProcessRetrieveFuncImplMsg(SMnodeMsg *pMsg);
-static int32_t mnodeProcessCreateFuncMsg(SMnodeMsg *pMsg);
-static int32_t mnodeProcessDropFuncMsg(SMnodeMsg *pMsg);
-
-static int32_t mnodeFuncActionDestroy(SSdbRow *pRow) {
-  tfree(pRow->pObj);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeFuncActionInsert(SSdbRow *pRow) {
-  SFuncObj *pFunc = pRow->pObj;
-
-  mTrace("func:%s, contLen: %d, insert into sdb", pFunc->name, pFunc->contLen);
-
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeFuncActionDelete(SSdbRow *pRow) {
-  SFuncObj *pFunc = pRow->pObj;
-
-  mTrace("func:%s, length: %d, delete from sdb", pFunc->name, pFunc->contLen);
-
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeFuncActionUpdate(SSdbRow *pRow) {
-  SFuncObj *pFunc = pRow->pObj;
-
-  SFuncObj *pSaved = mnodeGetFunc(pFunc->name);
-  if (pFunc != pSaved) {
-    memcpy(pSaved, pFunc, tsFuncUpdateSize);
-    free(pFunc);
-  }
-
-  mnodeDecFuncRef(pSaved);
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeFuncActionEncode(SSdbRow *pRow) {
-  SFuncObj *pFunc = pRow->pObj;
-
-  memcpy(pRow->rowData, pFunc, tsFuncUpdateSize);
-  pRow->rowSize = tsFuncUpdateSize;
-
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeFuncActionDecode(SSdbRow *pRow) {
-  SFuncObj *pFunc = (SFuncObj *)calloc(1, sizeof(SFuncObj));
-  if (pFunc == NULL) return TSDB_CODE_MND_OUT_OF_MEMORY;
-
-  memcpy(pFunc, pRow->rowData, tsFuncUpdateSize);
-  pRow->pObj = pFunc;
-
-  return TSDB_CODE_SUCCESS;
-}
-
-static int32_t mnodeFuncActionRestored() {
-  int64_t numOfRows = sdbGetNumOfRows(tsFuncSdb);
-
-  if (numOfRows <= 0 && dnodeIsFirstDeploy()) {
-    mInfo("dnode first deploy, func restored.");
-  }
-
-  return TSDB_CODE_SUCCESS;
-}
-
-int32_t mnodeInitFuncs() {
-  SFuncObj tObj;
-  tsFuncUpdateSize = (int32_t)((int8_t *)tObj.updateEnd - (int8_t *)&tObj);
-
-  SSdbTableDesc desc = {
-    .id           = SDB_TABLE_FUNC,
-    .name         = "funcs",
-    .hashSessions = TSDB_DEFAULT_USERS_HASH_SIZE,
-    .maxRowSize   = tsFuncUpdateSize,
-    .refCountPos  = (int32_t)((int8_t *)(&tObj.refCount) - (int8_t *)&tObj),
-    .keyType      = SDB_KEY_STRING,
-    .fpInsert     = mnodeFuncActionInsert,
-    .fpDelete     = mnodeFuncActionDelete,
-    .fpUpdate     = mnodeFuncActionUpdate,
-    .fpEncode     = mnodeFuncActionEncode,
-    .fpDecode     = mnodeFuncActionDecode,
-    .fpDestroy    = mnodeFuncActionDestroy,
-    .fpRestored   = mnodeFuncActionRestored
-  };
-
-  tsFuncRid = sdbOpenTable(&desc);
-  tsFuncSdb = sdbGetTableByRid(tsFuncRid);
-  if (tsFuncSdb == NULL) {
-    mError("table:%s, failed to create hash", desc.name);
-    return -1;
-  }
-
-  mnodeAddWriteMsgHandle(TSDB_MSG_TYPE_CM_CREATE_FUNCTION, mnodeProcessCreateFuncMsg);
-  mnodeAddWriteMsgHandle(TSDB_MSG_TYPE_CM_DROP_FUNCTION, mnodeProcessDropFuncMsg);
-  mnodeAddReadMsgHandle(TSDB_MSG_TYPE_CM_RETRIEVE_FUNC, mnodeProcessRetrieveFuncImplMsg);
-
-  mnodeAddShowMetaHandle(TSDB_MGMT_TABLE_FUNCTION, mnodeGetFuncMeta);
-  mnodeAddShowRetrieveHandle(TSDB_MGMT_TABLE_FUNCTION, mnodeRetrieveFuncs);
-  mnodeAddShowFreeIterHandle(TSDB_MGMT_TABLE_FUNCTION, mnodeCancelGetNextFunc);
-
-  mDebug("table:%s, hash is created", desc.name);
-
-  return 0;
-}
-
-void mnodeCleanupFuncs() {
-  sdbCloseTable(tsFuncRid);
-  tsFuncSdb = NULL;
-}
-
-SFuncObj *mnodeGetFunc(char *name) {
-  return (SFuncObj *)sdbGetRow(tsFuncSdb, name);
-}
-
-void *mnodeGetNextFunc(void *pIter, SFuncObj **pFunc) {
-  return sdbFetchRow(tsFuncSdb, pIter, (void **)pFunc);
-}
-
-void mnodeCancelGetNextFunc(void *pIter) {
- sdbFreeIter(tsFuncSdb, pIter);
-}
-
-void mnodeIncFuncRef(SFuncObj *pFunc) {
-  sdbIncRef(tsFuncSdb, pFunc);
-}
-
-void mnodeDecFuncRef(SFuncObj *pFunc) {
-  sdbDecRef(tsFuncSdb, pFunc);
-}
-/*
-static int32_t mnodeUpdateFunc(SFuncObj *pFunc, void *pMsg) {
-  SSdbRow row = {
-    .type   = SDB_OPER_GLOBAL,
-    .pTable = tsFuncSdb,
-    .pObj   = pFunc,
-    .pMsg   = pMsg
-  };
-
-  int32_t code = sdbUpdateRow(&row);
-  if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) {
-    mError("func:%s, failed to alter by %s, reason:%s", pFunc->name, mnodeGetUserFromMsg(pMsg), tstrerror(code));
-  } else {
-    mLInfo("func:%s, is altered by %s", pFunc->name, mnodeGetUserFromMsg(pMsg));
-  }
-
-  return code;
-}
-*/
-int32_t mnodeCreateFunc(SAcctObj *pAcct, char *name, int32_t codeLen, char *codeScript, char *path, uint8_t outputType, int16_t outputLen, int32_t funcType, int32_t bufSize, SMnodeMsg *pMsg) {
-  if (grantCheck(TSDB_GRANT_TIME) != TSDB_CODE_SUCCESS) {
-    return TSDB_CODE_GRANT_EXPIRED;
-  }
-
-  if (!pMsg->pUser->writeAuth) {
-    return TSDB_CODE_MND_NO_RIGHTS;
-  }
-
-  int32_t code = acctCheck(pAcct, ACCT_GRANT_USER);
-  if (code != TSDB_CODE_SUCCESS) {
-    return code;
-  }
-
-  code = grantCheck(TSDB_GRANT_USER);
-  if (code != TSDB_CODE_SUCCESS) {
-    return code;
-  }
-
-  if (name[0] == 0) {
-    return TSDB_CODE_MND_INVALID_FUNC_NAME;
-  }
-
-  if (codeScript[0] == 0) {
-    return TSDB_CODE_MND_INVALID_FUNC_CODE;
-  }
-
-  if (codeLen < 0 || codeLen > TSDB_FUNC_CODE_LEN) {
-    return TSDB_CODE_MND_INVALID_FUNC_CODE;
-  }
-
-  if (bufSize < 0 || bufSize > TSDB_FUNC_BUF_SIZE) {
-    return TSDB_CODE_MND_INVALID_FUNC_BUFSIZE;
-  }
-
-  SFuncObj *pFunc = mnodeGetFunc(name);
-  if (pFunc != NULL) {
-    mDebug("func:%s, is already there", name);
-    mnodeDecFuncRef(pFunc);
-    return TSDB_CODE_MND_FUNC_ALREADY_EXIST;
-  }
-
-  pFunc = calloc(1, sizeof(SFuncObj));
-  tstrncpy(pFunc->name, name, TSDB_FUNC_NAME_LEN);
-  tstrncpy(pFunc->path, path, tListLen(pFunc->path));
-  memcpy(pFunc->cont, codeScript, codeLen);
-  pFunc->contLen     = codeLen;
-  pFunc->createdTime = taosGetTimestampMs();
-  pFunc->resType     = outputType;
-  pFunc->resBytes    = outputLen;
-  pFunc->funcType    = funcType;
-  pFunc->bufSize     = bufSize;
-  pFunc->sig  = 0;
-  pFunc->type = 1; //lua script, refactor
-
-  SSdbRow row = {
-    .type     = SDB_OPER_GLOBAL,
-    .pTable   = tsFuncSdb,
-    .pObj     = pFunc,
-    .rowSize  = sizeof(SFuncObj),
-    .pMsg     = pMsg
-  };
-
-  code = sdbInsertRow(&row);
-  if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) {
-    mError("func:%s, failed to create by %s, reason:%s", pFunc->name, mnodeGetUserFromMsg(pMsg), tstrerror(code));
-    tfree(pFunc);
-  } else {
-    mLInfo("func:%s, is created by %s", pFunc->name, mnodeGetUserFromMsg(pMsg));
-  }
-
-  return code;
-}
-
-static int32_t mnodeDropFunc(SFuncObj *pFunc, void *pMsg) {
-  SSdbRow row = {
-    .type   = SDB_OPER_GLOBAL,
-    .pTable = tsFuncSdb,
-    .pObj   = pFunc,
-    .pMsg   = pMsg
-  };
-
-  int32_t code = sdbDeleteRow(&row);
-  if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) {
-    mError("func:%s, failed to drop by %s, reason:%s", pFunc->name, mnodeGetUserFromMsg(pMsg), tstrerror(code));
-  } else {
-    mLInfo("func:%s, is dropped by %s", pFunc->name, mnodeGetUserFromMsg(pMsg));
-  }
-
-  return code;
-}
-
-static int32_t mnodeGetFuncsNum() {
-  return (int32_t)sdbGetNumOfRows(tsFuncSdb);
-}
-
-static int32_t mnodeGetFuncMeta(STableMetaMsg *pMeta, SShowObj *pShow, void *pConn) {
-  SUserObj *pUser = mnodeGetUserFromConn(pConn);
-  if (pUser == NULL) {
-    return TSDB_CODE_MND_NO_USER_FROM_CONN;
-  }
-
-  int32_t cols = 0;
-  SSchema *pSchema = pMeta->schema;
-
-  pShow->bytes[cols] = TSDB_FUNC_NAME_LEN + VARSTR_HEADER_SIZE;
-  pSchema[cols].type = TSDB_DATA_TYPE_BINARY;
-  strcpy(pSchema[cols].name, "name");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = PATH_MAX + VARSTR_HEADER_SIZE;
-  pSchema[cols].type = TSDB_DATA_TYPE_BINARY;
-  strcpy(pSchema[cols].name, "path");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = 4;
-  pSchema[cols].type = TSDB_DATA_TYPE_INT;
-  strcpy(pSchema[cols].name, "aggregate");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = TSDB_TYPE_STR_MAX_LEN + VARSTR_HEADER_SIZE;
-  pSchema[cols].type = TSDB_DATA_TYPE_BINARY;
-  strcpy(pSchema[cols].name, "outputtype");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = 8;
-  pSchema[cols].type = TSDB_DATA_TYPE_TIMESTAMP;
-  strcpy(pSchema[cols].name, "create_time");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = 4;
-  pSchema[cols].type = TSDB_DATA_TYPE_INT;
-  strcpy(pSchema[cols].name, "code_len");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pShow->bytes[cols] = 4;
-  pSchema[cols].type = TSDB_DATA_TYPE_INT;
-  strcpy(pSchema[cols].name, "bufsize");
-  pSchema[cols].bytes = htons(pShow->bytes[cols]);
-  cols++;
-
-  pMeta->numOfColumns = htons(cols);
-  strcpy(pMeta->tableFname, "show funcs");
-  pShow->numOfColumns = cols;
-
-  pShow->offset[0] = 0;
-  for (int32_t i = 1; i < cols; ++i) {
-    pShow->offset[i] = pShow->offset[i - 1] + pShow->bytes[i - 1];
-  }
-
-  pShow->numOfRows = mnodeGetFuncsNum();
-  pShow->rowSize = pShow->offset[cols - 1] + pShow->bytes[cols - 1];
-
-  mnodeDecUserRef(pUser);
-
-  return 0;
-}
-
-static void* mnodeGenTypeStr(char *buf, int32_t buflen, uint8_t type, int16_t len) {
-  char *msg = "unknown";
-  if (type >= sizeof(tDataTypes)/sizeof(tDataTypes[0])) {
-    return msg;
-  }
-  
-  if (type == TSDB_DATA_TYPE_NCHAR || type == TSDB_DATA_TYPE_BINARY) {
-    int32_t bytes = len > 0 ? (int)(len - VARSTR_HEADER_SIZE) : len;
-    
-    snprintf(buf, buflen - 1, "%s(%d)", tDataTypes[type].name, type == TSDB_DATA_TYPE_NCHAR ? bytes/4 : bytes);
-    buf[buflen - 1] = 0;
-
-    return buf;
-  }
-  
-  return tDataTypes[type].name;
-}
-
-static int32_t mnodeRetrieveFuncs(SShowObj *pShow, char *data, int32_t rows, void *pConn) {
-  int32_t   numOfRows = 0;
-  SFuncObj *pFunc    = NULL;
-  int32_t   cols      = 0;
-  char     *pWrite;
-  char      buf[TSDB_TYPE_STR_MAX_LEN];
-
-  while (numOfRows < rows) {
-    pShow->pIter = mnodeGetNextFunc(pShow->pIter, &pFunc);
-    if (pFunc == NULL) break;
-
-    cols = 0;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    STR_WITH_MAXSIZE_TO_VARSTR(pWrite, pFunc->name, pShow->bytes[cols]);
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    STR_WITH_MAXSIZE_TO_VARSTR(pWrite, pFunc->path, pShow->bytes[cols]);
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    *(int32_t *)pWrite = pFunc->funcType == TSDB_UDF_TYPE_AGGREGATE ? 1 : 0;
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    STR_WITH_MAXSIZE_TO_VARSTR(pWrite, mnodeGenTypeStr(buf, TSDB_TYPE_STR_MAX_LEN, pFunc->resType, pFunc->resBytes), pShow->bytes[cols]);
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    *(int64_t *)pWrite = pFunc->createdTime;
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    *(int32_t *)pWrite = pFunc->contLen;
-    cols++;
-
-    pWrite = data + pShow->offset[cols] * rows + pShow->bytes[cols] * numOfRows;
-    *(int32_t *)pWrite = pFunc->bufSize;
-    cols++;
-
-    numOfRows++;
-    mnodeDecFuncRef(pFunc);
-  }
-
-  mnodeVacuumResult(data, pShow->numOfColumns, numOfRows, rows, pShow);
-  pShow->numOfReads += numOfRows;
-  return numOfRows;
-}
-
-static int32_t mnodeProcessCreateFuncMsg(SMnodeMsg *pMsg) {
-  SCreateFuncMsg *pCreate    = pMsg->rpcMsg.pCont;
-  pCreate->codeLen       = htonl(pCreate->codeLen);
-  pCreate->outputLen     = htons(pCreate->outputLen);
-  pCreate->funcType      = htonl(pCreate->funcType);
-  pCreate->bufSize       = htonl(pCreate->bufSize);
-
-  return mnodeCreateFunc(pMsg->pUser->pAcct, pCreate->name, pCreate->codeLen, pCreate->code, pCreate->path, pCreate->outputType, pCreate->outputLen, pCreate->funcType, pCreate->bufSize, pMsg);
-}
-
-static int32_t mnodeProcessDropFuncMsg(SMnodeMsg *pMsg) {
-  SDropFuncMsg *pDrop = pMsg->rpcMsg.pCont;
-
-  SFuncObj *pFunc = mnodeGetFunc(pDrop->name);
-  if (pFunc == NULL) {
-    return TSDB_CODE_MND_INVALID_FUNC;
-  }
-
-  return mnodeDropFunc(pFunc, pMsg);
-}
-
-static int32_t mnodeProcessRetrieveFuncImplMsg(SMnodeMsg *pMsg) {
-  SRetrieveFuncMsg *pInfo = pMsg->rpcMsg.pCont;
-  pInfo->num = htonl(pInfo->num);
-
-  int32_t t = sizeof(SUdfFuncMsg) + (sizeof(SFunctionInfoMsg) + TSDB_FUNC_CODE_LEN) * pInfo->num + 16384;
-
-  SUdfFuncMsg *pFuncMsg = rpcMallocCont(t);
-  pFuncMsg->num = htonl(pInfo->num);
-  char* pOutput = pFuncMsg->content;
-  tstr* name = (tstr*) pInfo->name;
-
-  for(int32_t i = 0; i < pInfo->num; ++i) {
-    char buf[TSDB_FUNC_NAME_LEN] = {0};
-    tstrncpy(buf, name->data, htons(name->len) + 1);
-
-    SFuncObj* pFuncObj = mnodeGetFunc(buf);
-    if (pFuncObj == NULL) {
-      mError("function %s does not exist", buf);
-      return TSDB_CODE_MND_INVALID_FUNC;
-    }
-    
-    SFunctionInfoMsg* pFuncInfo = (SFunctionInfoMsg*) pOutput;
-
-    strcpy(pFuncInfo->name, buf);
-    pFuncInfo->len = htonl(pFuncObj->contLen);
-    memcpy(pFuncInfo->content, pFuncObj->cont, pFuncObj->contLen);
-
-    pFuncInfo->funcType = htonl(pFuncObj->funcType);
-    pFuncInfo->resType = pFuncObj->resType;
-    pFuncInfo->resBytes = htons(pFuncObj->resBytes);
-    pFuncInfo->bufSize  = htonl(pFuncObj->bufSize);
-    
-    pOutput += sizeof(SFunctionInfoMsg) + pFuncObj->contLen;
-    name =(tstr *)((char *)name + sizeof(*name) + htons(name->len));
-  }
-
-  pMsg->rpcRsp.rsp = pFuncMsg;
-  pMsg->rpcRsp.len = (int32_t)(pOutput - (char*)pFuncMsg);
-  return TSDB_CODE_SUCCESS;
-}

src/mnode/src/mnodeGrant.c

-/*
- * 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/>.
- */
-
-#define _DEFAULT_SOURCE
-#ifndef _GRANT
-#include "os.h"
-#include "taoserror.h"
-#include "tgrant.h"
-#include "mnodeInt.h"
-
-int32_t grantInit() { return TSDB_CODE_SUCCESS; }
-void    grantCleanUp() {}
-void    grantParseParameter() { mError("can't parsed parameter k"); }
-int32_t grantCheck(EGrantType grant) { return TSDB_CODE_SUCCESS; }
-void    grantReset(EGrantType grant, uint64_t value) {}
-void    grantAdd(EGrantType grant, uint64_t value) {}
-void    grantRestore(EGrantType grant, uint64_t value) {}
-
-#endif
\ No newline at end of file