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

fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2024-09-29 14:18:24 +08:00
parent 70c96783c0
commit 8d29726511
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/mnode/impl/src/mndStream.c
View File

@ -209,10 +209,11 @@ SSdbRow *mndStreamActionDecode(SSdbRaw *pRaw) {
tDecoderInit(&decoder, buf, tlen + 1); tDecoderInit(&decoder, buf, tlen + 1);
if (tDecodeSStreamObj(&decoder, pStream, sver) < 0) { if (tDecodeSStreamObj(&decoder, pStream, sver) < 0) {
tDecoderClear(&decoder); tDecoderClear(&decoder);
tFreeStreamObj(pStream);
goto STREAM_DECODE_OVER; goto STREAM_DECODE_OVER;
} }
tDecoderClear(&decoder);
tDecoderClear(&decoder);
terrno = TSDB_CODE_SUCCESS; terrno = TSDB_CODE_SUCCESS;
STREAM_DECODE_OVER: STREAM_DECODE_OVER: