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

fix:coredump if saved epoch bigger than request epoch & modify test cases

This commit is contained in:
wangmm0220 2023-08-31 17:35:41 +08:00
parent 7f2a9a7262
commit a02ab4ccfb
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/tq/tqUtil.c
View File

@ -210,8 +210,8 @@ static int32_t extractDataAndRspForDbStbSubscribe(STQ* pTq, STqHandle* pHandle,
// uint64_t st = taosGetTimestampMs(); // uint64_t st = taosGetTimestampMs();
int totalRows = 0; int totalRows = 0;
while (1) { while (1) {
int32_t savedEpoch = atomic_load_32(&pHandle->epoch); // int32_t savedEpoch = atomic_load_32(&pHandle->epoch);
ASSERT (savedEpoch <= pRequest->epoch); // ASSERT (savedEpoch <= pRequest->epoch);
if (tqFetchLog(pTq, pHandle, &fetchVer, pRequest->reqId) < 0) { if (tqFetchLog(pTq, pHandle, &fetchVer, pRequest->reqId) < 0) {
tqOffsetResetToLog(&taosxRsp.rspOffset, fetchVer); tqOffsetResetToLog(&taosxRsp.rspOffset, fetchVer);

2
tests/system-test/7-tmq/tmqMaxGroupIds.py
View File

@ -205,7 +205,7 @@ class TDTestCase:
tdLog.exit("show consumers %d not equal expect num: %d"%(topicNum, expectConsumerNUm)) tdLog.exit("show consumers %d not equal expect num: %d"%(topicNum, expectConsumerNUm))
flag = 0 flag = 0
for i in range(10): while (1):
tdSql.query('show subscriptions;') tdSql.query('show subscriptions;')
subscribeNum = tdSql.queryRows subscribeNum = tdSql.queryRows
tdLog.info(" get subscriptions count: %d"%(subscribeNum)) tdLog.info(" get subscriptions count: %d"%(subscribeNum))