[TD-16]

src/dnode/src/dnodeMain.c

@@ -28,20 +28,9 @@
 #include "dnodeRead.h"
 #include "dnodeShell.h"
 #include "dnodeWrite.h"
-#ifdef CLUSTER
-#include "account.h"
-#include "admin.h"
-#include "balance.h"
-#include "cluster.h"
-#include "grant.h"
-#include "mpeer.h"
-#include "storage.h"
-#include "vpeer.h"
-#endif
 
 static int32_t dnodeInitSystem();
 static int32_t dnodeInitStorage();
-static void dnodeInitPlugins();
 static void dnodeCleanupStorage();
 static void dnodeCleanUpSystem();
 static void dnodeSetRunStatus(SDnodeRunStatus status);
@@ -51,8 +40,6 @@ static SDnodeRunStatus tsDnodeRunStatus = TSDB_DNODE_RUN_STATUS_STOPPED;
 void (*dnodeParseParameterKFp)() = NULL;
 
 int32_t main(int32_t argc, char *argv[]) {
-  dnodeInitPlugins();
-
   // Set global configuration file
   for (int32_t i = 1; i < argc; ++i) {
     if (strcmp(argv[i], "-c") == 0) {
@@ -244,15 +231,3 @@ static int32_t dnodeInitStorage() {
 }
 
 static void dnodeCleanupStorage() {}
-
-static void dnodeInitPlugins() {
-#ifdef CLUSTER
-//  acctInit();
-//  adminInit();
-//  balanceInit();
-//  clusterInit();
-//  grantInit();
-//  mpeerInit();
-//  storageInit();
-#endif
-}

src/inc/mnode.h

@@ -213,7 +213,8 @@ typedef struct _acctObj {
   SAcctCfg  cfg;
   int32_t   acctId;
   int64_t   createdTime;
-  int8_t    reserved[15];
+  int8_t    dirty;
+  int8_t    reserved[14];
   int8_t    updateEnd[1];
   SAcctInfo acctInfo;
   SDbObj *         pHead;

src/mnode/inc/mgmtAcct.h

@@ -27,7 +27,7 @@ SAcctObj *mgmtGetAcct(char *acctName);
 
 int32_t mgmtCheckUserLimit(SAcctObj *pAcct);
 int32_t mgmtCheckDbLimit(SAcctObj *pAcct);
-int32_t mgmtCheckTableLimit(SAcctObj *pAcct, int32_t numOfTimeSeries);
+int32_t mgmtCheckTableLimit(SAcctObj *pAcct);
 
 int32_t mgmtAddDbIntoAcct(SAcctObj *pAcct, SDbObj *pDb);
 int32_t mgmtRemoveDbFromAcct(SAcctObj *pAcct, SDbObj *pDb);

src/mnode/src/mgmtAcct.c

@@ -15,16 +15,10 @@
 
 #define _DEFAULT_SOURCE
 #include "os.h"
+#include "mnode.h"
 #include "mgmtAcct.h"
 
-static SAcctObj tsAcctObj;
-
-int32_t   (*mgmtInitAcctsFp)() = NULL;
-void      (*mgmtCleanUpAcctsFp)() = NULL;
-SAcctObj *(*mgmtGetAcctFp)(char *acctName) = NULL;
-int32_t   (*mgmtCheckUserLimitFp)(SAcctObj *pAcct) = NULL;
-int32_t   (*mgmtCheckDbLimitFp)(SAcctObj *pAcct) = NULL;
-int32_t   (*mgmtCheckTableLimitFp)(SAcctObj *pAcct, int32_t numOfTimeSeries) = NULL;
+static SAcctObj tsAcctObj = {0};
 
 int32_t mgmtAddDbIntoAcct(SAcctObj *pAcct, SDbObj *pDb) {
   pthread_mutex_lock(&pAcct->mutex);
@@ -88,7 +82,7 @@ int32_t mgmtRemoveUserFromAcct(SAcctObj *pAcct, SUserObj *pUser) {
   if (pUser->next) {
     pUser->next->prev = pUser->prev;
   }
-  
+
   if (pUser->prev == NULL) {
     pAcct->pUser = pUser->next;
   }
@@ -99,49 +93,22 @@ int32_t mgmtRemoveUserFromAcct(SAcctObj *pAcct, SUserObj *pUser) {
   return 0;
 }
 
+#ifndef _ACCOUNT
+
 int32_t mgmtInitAccts() {
-  if (mgmtInitAcctsFp) {
-    return (*mgmtInitAcctsFp)();
-  } else {
-    tsAcctObj.acctId = 0;
-    strcpy(tsAcctObj.user, "root");
-    return 0;
-  }
+  tsAcctObj.acctId = 0;
+  strcpy(tsAcctObj.user, "root");
+  return TSDB_CODE_SUCCESS;
 }
 
-SAcctObj *mgmtGetAcct(char *acctName) {
-  if (mgmtGetAcctFp) {
-    return (*mgmtGetAcctFp)(acctName);
-  } else {
-    return &tsAcctObj;
-  }
-}
+SAcctObj *mgmtGetAcct(char *acctName) { return &tsAcctObj; }
 
-void mgmtCleanUpAccts() {
-  if (mgmtCleanUpAcctsFp) {
-    (*mgmtCleanUpAcctsFp)();
-  }
-}
+void mgmtCleanUpAccts() {}
 
-int32_t mgmtCheckUserLimit(SAcctObj *pAcct) {
-  if (mgmtCheckUserLimitFp) {
-    return (*mgmtCheckUserLimitFp)(pAcct);
-  }
-  return 0;
-}
+int32_t mgmtCheckUserLimit(SAcctObj *pAcct) { return TSDB_CODE_SUCCESS; }
 
-int32_t mgmtCheckDbLimit(SAcctObj *pAcct) {
-  if (mgmtCheckDbLimitFp) {
-    return (*mgmtCheckDbLimitFp)(pAcct);
-  } else {
-    return 0;
-  }
-}
+int32_t mgmtCheckDbLimit(SAcctObj *pAcct) { return TSDB_CODE_SUCCESS; }
 
-int32_t mgmtCheckTableLimit(SAcctObj *pAcct, int32_t numOfTimeSeries) {
-  if (mgmtCheckTableLimitFp) {
-    return (*mgmtCheckTableLimitFp)(pAcct, numOfTimeSeries);
-  } else {
-    return 0;
-  }
-}
\ No newline at end of file
+int32_t mgmtCheckTableLimit(SAcctObj *pAcct) { return TSDB_CODE_SUCCESS; }
+
+#endif
\ No newline at end of file