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

fix(stream): add logs and set the reset-stream rsp.

This commit is contained in:
Haojun Liao 2024-12-30 14:26:20 +08:00
parent 0bf9fb1e31
commit f03e2305e0
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/common/test/msgTypeTable.ini
View File

@ -439,6 +439,7 @@ TDMT_STREAM_DROP_RSP = 1054
TDMT_STREAM_RETRIEVE_TRIGGER = 1055 TDMT_STREAM_RETRIEVE_TRIGGER = 1055
TDMT_STREAM_RETRIEVE_TRIGGER_RSP = 1056 TDMT_STREAM_RETRIEVE_TRIGGER_RSP = 1056
TDMT_MND_RESET_STREAM = 1057 TDMT_MND_RESET_STREAM = 1057
TDMT_MND_RESET_STREAM_RSP = 1058
TDMT_SYNC_TIMEOUT = 1537 TDMT_SYNC_TIMEOUT = 1537
TDMT_SYNC_TIMEOUT_RSP = 1538 TDMT_SYNC_TIMEOUT_RSP = 1538
TDMT_SYNC_TIMEOUT_ELECTION = 1539 TDMT_SYNC_TIMEOUT_ELECTION = 1539

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

@ -1914,6 +1914,8 @@ static int32_t mndProcessResetStreamReq(SRpcMsg *pReq) {
TAOS_RETURN(TSDB_CODE_INVALID_MSG); TAOS_RETURN(TSDB_CODE_INVALID_MSG);
} }
mDebug("recv reset stream req, stream:%s", resetReq.name);
code = mndAcquireStream(pMnode, resetReq.name, &pStream); code = mndAcquireStream(pMnode, resetReq.name, &pStream);
if (pStream == NULL || code != 0) { if (pStream == NULL || code != 0) {
if (resetReq.igNotExists) { if (resetReq.igNotExists) {