fix mem leak
This commit is contained in:
parent
bb8252df16
commit
6cab686e82
|
@ -60,7 +60,6 @@ int32_t sndExpandTask(SSnode *pSnode, SStreamTask *pTask, int64_t nextProcessVer
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
pTask->pBackend = NULL;
|
pTask->pBackend = NULL;
|
||||||
ASSERT(0);
|
|
||||||
|
|
||||||
streamTaskOpenAllUpstreamInput(pTask);
|
streamTaskOpenAllUpstreamInput(pTask);
|
||||||
|
|
||||||
|
@ -448,4 +447,4 @@ int32_t sndProcessStreamMsg(SSnode *pSnode, SRpcMsg *pMsg) {
|
||||||
ASSERT(0);
|
ASSERT(0);
|
||||||
}
|
}
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
Loading…
Reference in New Issue