diff --git a/src/dnode/src/dnodeMain.c b/src/dnode/src/dnodeMain.c index af10fccd01..80b4338df6 100644 --- a/src/dnode/src/dnodeMain.c +++ b/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 -} diff --git a/src/inc/mnode.h b/src/inc/mnode.h index e6cc0f1367..2a5f298afd 100644 --- a/src/inc/mnode.h +++ b/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; diff --git a/src/mnode/inc/mgmtAcct.h b/src/mnode/inc/mgmtAcct.h index a39641a9b6..d1ee070057 100644 --- a/src/mnode/inc/mgmtAcct.h +++ b/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); diff --git a/src/mnode/src/mgmtAcct.c b/src/mnode/src/mgmtAcct.c index 0075f53319..36c41680aa 100644 --- a/src/mnode/src/mgmtAcct.c +++ b/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