refactor: do some internal refactor.
This commit is contained in:
parent
b24e8efa5f
commit
bc14da28e5
|
@ -2420,7 +2420,7 @@ int32_t mndProcessStreamReqCheckpoint(SRpcMsg *pReq) {
|
||||||
if (pStream != NULL) { // TODO:handle error
|
if (pStream != NULL) { // TODO:handle error
|
||||||
code = mndProcessStreamCheckpointTrans(pMnode, pStream, checkpointId, 0, false);
|
code = mndProcessStreamCheckpointTrans(pMnode, pStream, checkpointId, 0, false);
|
||||||
if (code) {
|
if (code) {
|
||||||
mError("failed to create checkpoint trans, code:%s", strerror(code));
|
mError("failed to create checkpoint trans, code:%s", tstrerror(code));
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// todo: wait for the create stream trans completed, and launch the checkpoint trans
|
// todo: wait for the create stream trans completed, and launch the checkpoint trans
|
||||||
|
|
Loading…
Reference in New Issue