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

TD-12678 datasink interface adjust

This commit is contained in:
Xiaoyu Wang 2022-01-10 21:44:58 -05:00
parent 4b8cd944ac
commit d7ddb1589b
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/executor/inc/dataSinkMgt.h → include/libs/executor/dataSinkMgt.h
View File

@ -73,9 +73,9 @@ void dsEndPut(DataSinkHandle handle);
/** /**
* Get the length of the data returned by the next call to dsGetDataBlock. * Get the length of the data returned by the next call to dsGetDataBlock.
* @param handle * @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. * Get data, the caller needs to allocate data memory.

4
source/libs/executor/src/dataSinkMgt.c
View File

@ -41,9 +41,9 @@ void dsEndPut(DataSinkHandle handle) {
return pHandleImpl->fEndPut(pHandleImpl); 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; SDataSinkHandle* pHandleImpl = (SDataSinkHandle*)handle;
return pHandleImpl->fGetLen(pHandleImpl, pStatus); *pLen = pHandleImpl->fGetLen(pHandleImpl, pStatus);
} }
int32_t dsGetDataBlock(DataSinkHandle handle, SOutPutData* pOutput, int32_t* pStatus) { int32_t dsGetDataBlock(DataSinkHandle handle, SOutPutData* pOutput, int32_t* pStatus) {