xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

enh: batch create table

This commit is contained in:
kailixu 2024-04-28 04:47:00 +08:00
parent 504263315d
commit 3b504e6e96
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
include/common/tgrant.h
View File

@ -58,12 +58,12 @@ typedef enum {
TSDB_GRANT_BACKUP_RESTORE, TSDB_GRANT_BACKUP_RESTORE,
} EGrantType; } EGrantType;
int32_t checkAndGetCryptKey(const char *encryptCode, const char *machineId, char **key); int32_t checkAndGetCryptKey(const char *encryptCode, const char *machineId, char **key);
int32_t generateEncryptCode(const char *key, const char *machineId, char **encryptCode); int32_t generateEncryptCode(const char *key, const char *machineId, char **encryptCode);
uint64_t grantRemain(EGrantType grant); int64_t grantRemain(EGrantType grant);
int32_t grantCheck(EGrantType grant); int32_t grantCheck(EGrantType grant);
int32_t grantCheckExpire(EGrantType grant); int32_t grantCheckExpire(EGrantType grant);
char *tGetMachineId(); char *tGetMachineId();
// #ifndef GRANTS_CFG // #ifndef GRANTS_CFG
#ifdef TD_ENTERPRISE #ifdef TD_ENTERPRISE

4
source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
View File

@ -74,7 +74,7 @@ static void *dmNotifyThreadFp(void *param) {
if (wait) tsem_wait(&dmNotifyHdl.sem); if (wait) tsem_wait(&dmNotifyHdl.sem);
atomic_store_8(&dmNotifyHdl.state, 1); atomic_store_8(&dmNotifyHdl.state, 1);
uint64_t remainTimeSeries = grantRemain(TSDB_GRANT_TIMESERIES); int64_t remainTimeSeries = grantRemain(TSDB_GRANT_TIMESERIES);
if (remainTimeSeries == INT64_MAX || remainTimeSeries <= 0) { if (remainTimeSeries == INT64_MAX || remainTimeSeries <= 0) {
goto _skip; goto _skip;
} }
@ -110,7 +110,7 @@ static void *dmNotifyThreadFp(void *param) {
notifyTimeStamp[tail] = taosGetTimestampNs(); notifyTimeStamp[tail] = taosGetTimestampNs();
++nTotalNotify; ++nTotalNotify;
uint64_t approximateTimeSeries = 0; int64_t approximateTimeSeries = 0;
if (nTotalNotify >= TIMESERIES_STASH_NUM) { if (nTotalNotify >= TIMESERIES_STASH_NUM) {
int64_t timeDiff = notifyTimeStamp[tail] - notifyTimeStamp[head]; int64_t timeDiff = notifyTimeStamp[tail] - notifyTimeStamp[head];
int64_t tsDiff = notifyTimeSeries[tail] - notifyTimeSeries[head]; int64_t tsDiff = notifyTimeSeries[tail] - notifyTimeSeries[head];