Skip to content

Commit c26e5ff

Browse files
committed
deduplicate array size funcall
1 parent d22a42b commit c26e5ff

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

source/dnode/snode/src/snode.c

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -185,9 +185,11 @@ static int32_t buildStreamFetchRsp(SSDataBlock* pBlock, void** data, size_t* siz
185185
} else {
186186
pRetrieve->numOfRows = htobe64((int64_t)pBlock->info.rows);
187187
pRetrieve->numOfBlocks = htonl(1);
188-
pRetrieve->numOfCols = htonl((uint32_t)taosArrayGetSize(pBlock->pDataBlock));
189188

190-
int32_t actualLen = blockEncodeInternal(pBlock, pRetrieve->data + INT_BYTES * 2, blockSize, taosArrayGetSize(pBlock->pDataBlock));
189+
uint32_t numOfCols = (uint32_t)taosArrayGetSize(pBlock->pDataBlock);
190+
pRetrieve->numOfCols = htonl(numOfCols);
191+
192+
int32_t actualLen = blockEncodeInternal(pBlock, pRetrieve->data + INT_BYTES * 2, blockSize, numOfCols);
191193
if (actualLen < 0) {
192194
code = terrno;
193195
goto end;

0 commit comments

Comments
 (0)