提交 68cdc916 编写于 作者: B Benguang Zhao

fix: consider local timezone offset during computing the number of time intervals

上级 ae737063
...@@ -557,15 +557,17 @@ int64_t taosTimeSub(int64_t timeStamp, int64_t duration, char unit, int32_t prec ...@@ -557,15 +557,17 @@ int64_t taosTimeSub(int64_t timeStamp, int64_t duration, char unit, int32_t prec
return (int64_t)(mktime(&tm) * TSDB_TICK_PER_SECOND(precision)); return (int64_t)(mktime(&tm) * TSDB_TICK_PER_SECOND(precision));
} }
int32_t taosTimeCountInterval(int64_t skey, int64_t ekey, int64_t interval, char unit, int32_t precision) { int32_t taosTimeCountInterval(int64_t skey, int64_t ekey, int64_t interval, char unit, int32_t precision) {
if (ekey < skey) { if (ekey < skey) {
int64_t tmp = ekey; int64_t tmp = ekey;
ekey = skey; ekey = skey;
skey = tmp; skey = tmp;
} }
int64_t tz_offset = -1 * timezone * TSDB_TICK_PER_SECOND(precision);
if (unit != 'n' && unit != 'y') { if (unit != 'n' && unit != 'y') {
return (int32_t)(ekey/interval - skey/interval); return (int32_t)((ekey+tz_offset)/interval - (skey+tz_offset)/interval) + 1;
} }
skey /= (int64_t)(TSDB_TICK_PER_SECOND(precision)); skey /= (int64_t)(TSDB_TICK_PER_SECOND(precision));
...@@ -584,7 +586,7 @@ int32_t taosTimeCountInterval(int64_t skey, int64_t ekey, int64_t interval, char ...@@ -584,7 +586,7 @@ int32_t taosTimeCountInterval(int64_t skey, int64_t ekey, int64_t interval, char
interval *= 12; interval *= 12;
} }
return (int32_t)(emon/interval - smon/interval); return (int32_t)(emon/interval - smon/interval) + 1;
} }
int64_t taosTimeTruncate(int64_t timeStamp, const SInterval* pInterval, int32_t precision) { int64_t taosTimeTruncate(int64_t timeStamp, const SInterval* pInterval, int32_t precision) {
......
...@@ -463,7 +463,6 @@ void taosFillSetInputDataBlock(SFillInfo* pFillInfo, const SSDataBlock* pInput) ...@@ -463,7 +463,6 @@ void taosFillSetInputDataBlock(SFillInfo* pFillInfo, const SSDataBlock* pInput)
pFillInfo->interval.sliding, pFillInfo->interval.sliding,
pFillInfo->interval.slidingUnit, pFillInfo->interval.slidingUnit,
pFillInfo->precision); pFillInfo->precision);
numOfRes += 1;
if(numOfRes < numOfRows || pFillInfo->currentKey < lastKey) { if(numOfRes < numOfRows || pFillInfo->currentKey < lastKey) {
// set currentKey max // set currentKey max
pFillInfo->currentKey = tsList[0]; pFillInfo->currentKey = tsList[0];
...@@ -504,7 +503,6 @@ int64_t getNumOfResultsAfterFillGap(SFillInfo* pFillInfo, TSKEY ekey, int32_t ma ...@@ -504,7 +503,6 @@ int64_t getNumOfResultsAfterFillGap(SFillInfo* pFillInfo, TSKEY ekey, int32_t ma
pFillInfo->interval.sliding, pFillInfo->interval.sliding,
pFillInfo->interval.slidingUnit, pFillInfo->interval.slidingUnit,
pFillInfo->precision); pFillInfo->precision);
numOfRes += 1;
assert(numOfRes >= numOfRows); assert(numOfRes >= numOfRows);
} else { // reach the end of data } else { // reach the end of data
if ((ekey1 < pFillInfo->currentKey && FILL_IS_ASC_FILL(pFillInfo)) || if ((ekey1 < pFillInfo->currentKey && FILL_IS_ASC_FILL(pFillInfo)) ||
...@@ -517,7 +515,6 @@ int64_t getNumOfResultsAfterFillGap(SFillInfo* pFillInfo, TSKEY ekey, int32_t ma ...@@ -517,7 +515,6 @@ int64_t getNumOfResultsAfterFillGap(SFillInfo* pFillInfo, TSKEY ekey, int32_t ma
pFillInfo->interval.sliding, pFillInfo->interval.sliding,
pFillInfo->interval.slidingUnit, pFillInfo->interval.slidingUnit,
pFillInfo->precision); pFillInfo->precision);
numOfRes += 1;
} }
return (numOfRes > maxNumOfRows) ? maxNumOfRows : numOfRes; return (numOfRes > maxNumOfRows) ? maxNumOfRows : numOfRes;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册