From 09753042427a0f1305ef1cc066afb66c8322ba2d Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 12 Dec 2020 15:23:51 +0800 Subject: [PATCH] [TD-225] --- src/query/inc/qUtil.h | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/src/query/inc/qUtil.h b/src/query/inc/qUtil.h index ac7aa75809..12024e7697 100644 --- a/src/query/inc/qUtil.h +++ b/src/query/inc/qUtil.h @@ -33,24 +33,24 @@ void clearResultRow(SQueryRuntimeEnv* pRuntimeEnv, SResultRow* pRow, int16_t typ void copyResultRow(SQueryRuntimeEnv* pRuntimeEnv, SResultRow* dst, const SResultRow* src, int16_t type); SResultRowCellInfo* getResultCell(SQueryRuntimeEnv* pRuntimeEnv, const SResultRow* pRow, int32_t index); -int32_t initWindowResInfo(SResultRowInfo* pWindowResInfo, int32_t size, int16_t type); +int32_t initWindowResInfo(SResultRowInfo* pResultRowInfo, int32_t size, int16_t type); -void cleanupTimeWindowInfo(SResultRowInfo* pWindowResInfo); -void resetTimeWindowInfo(SQueryRuntimeEnv* pRuntimeEnv, SResultRowInfo* pWindowResInfo); +void cleanupTimeWindowInfo(SResultRowInfo* pResultRowInfo); +void resetTimeWindowInfo(SQueryRuntimeEnv* pRuntimeEnv, SResultRowInfo* pResultRowInfo); void clearFirstNWindowRes(SQueryRuntimeEnv *pRuntimeEnv, int32_t num); void clearClosedTimeWindow(SQueryRuntimeEnv* pRuntimeEnv); -int32_t numOfClosedTimeWindow(SResultRowInfo* pWindowResInfo); -void closeTimeWindow(SResultRowInfo* pWindowResInfo, int32_t slot); -void closeAllTimeWindow(SResultRowInfo* pWindowResInfo); -void removeRedundantWindow(SResultRowInfo *pWindowResInfo, TSKEY lastKey, int32_t order); - -static FORCE_INLINE SResultRow *getResultRow(SResultRowInfo *pWindowResInfo, int32_t slot) { - assert(pWindowResInfo != NULL && slot >= 0 && slot < pWindowResInfo->size); - return pWindowResInfo->pResult[slot]; +int32_t numOfClosedTimeWindow(SResultRowInfo* pResultRowInfo); +void closeTimeWindow(SResultRowInfo* pResultRowInfo, int32_t slot); +void closeAllTimeWindow(SResultRowInfo* pResultRowInfo); +void removeRedundantWindow(SResultRowInfo *pResultRowInfo, TSKEY lastKey, int32_t order); + +static FORCE_INLINE SResultRow *getResultRow(SResultRowInfo *pResultRowInfo, int32_t slot) { + assert(pResultRowInfo != NULL && slot >= 0 && slot < pResultRowInfo->size); + return pResultRowInfo->pResult[slot]; } -bool isWindowResClosed(SResultRowInfo *pWindowResInfo, int32_t slot); +bool isWindowResClosed(SResultRowInfo *pResultRowInfo, int32_t slot); int32_t initResultRow(SResultRow *pResultRow); -- GitLab