From d7ddb1589b309ff3c856c5ff9ab3f85c3b639d0d Mon Sep 17 00:00:00 2001 From: Xiaoyu Wang Date: Mon, 10 Jan 2022 21:44:58 -0500 Subject: [PATCH] TD-12678 datasink interface adjust --- .../libs/executor/inc => include/libs/executor}/dataSinkMgt.h | 4 ++-- source/libs/executor/src/dataSinkMgt.c | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) rename {source/libs/executor/inc => include/libs/executor}/dataSinkMgt.h (96%) diff --git a/source/libs/executor/inc/dataSinkMgt.h b/include/libs/executor/dataSinkMgt.h similarity index 96% rename from source/libs/executor/inc/dataSinkMgt.h rename to include/libs/executor/dataSinkMgt.h index d13423b25d..6470f38ced 100644 --- a/source/libs/executor/inc/dataSinkMgt.h +++ b/include/libs/executor/dataSinkMgt.h @@ -73,9 +73,9 @@ void dsEndPut(DataSinkHandle handle); /** * Get the length of the data returned by the next call to dsGetDataBlock. * @param handle - * @return data length + * @param pLen data length */ -int32_t dsGetDataLength(DataSinkHandle handle, int32_t* pStatus); +void dsGetDataLength(DataSinkHandle handle, int32_t* pLen, int32_t* pStatus); /** * Get data, the caller needs to allocate data memory. diff --git a/source/libs/executor/src/dataSinkMgt.c b/source/libs/executor/src/dataSinkMgt.c index 8a96c5d05f..01cc84c4f7 100644 --- a/source/libs/executor/src/dataSinkMgt.c +++ b/source/libs/executor/src/dataSinkMgt.c @@ -41,9 +41,9 @@ void dsEndPut(DataSinkHandle handle) { return pHandleImpl->fEndPut(pHandleImpl); } -int32_t dsGetDataLength(DataSinkHandle handle, int32_t* pStatus) { +void dsGetDataLength(DataSinkHandle handle, int32_t* pLen, int32_t* pStatus) { SDataSinkHandle* pHandleImpl = (SDataSinkHandle*)handle; - return pHandleImpl->fGetLen(pHandleImpl, pStatus); + *pLen = pHandleImpl->fGetLen(pHandleImpl, pStatus); } int32_t dsGetDataBlock(DataSinkHandle handle, SOutPutData* pOutput, int32_t* pStatus) { -- GitLab