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 11:25:40 +08:00
parent bc1f9bca93
commit 4d572ebe88
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -121,11 +121,15 @@ static void *dmNotifyThreadFp(void *param) {
if (head < 0) head += TIMESERIES_STASH_NUM; if (head < 0) head += 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];
if (timeDiff > 0 && timeDiff < 1e9 && tsDiff > 0) { if (tsDiff > 0) {
if (timeDiff > 0 && timeDiff < 1e9) {
approximateTimeSeries = (double)tsDiff * 1e9 / timeDiff; approximateTimeSeries = (double)tsDiff * 1e9 / timeDiff;
if ((approximateTimeSeries * nDnode) > remainTimeSeries) { if ((approximateTimeSeries * nDnode) > remainTimeSeries) {
dmSendNotifyReq(pMgmt, &req); dmSendNotifyReq(pMgmt, &req);
} }
} else {
dmSendNotifyReq(pMgmt, &req);
}
} }
} else { } else {
dmSendNotifyReq(pMgmt, &req); dmSendNotifyReq(pMgmt, &req);