Elgato_dark/TDengine
1
0
Fork 0
mirror of https://github.com/taosdata/TDengine synced 2026-05-24 10:09:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

fix: implement retry mechanism for vnodeProcessWriteMsg in vnodeApply… (#31388)

Browse source
This commit is contained in:
dongming chen 2025-06-24 16:53:11 +08:00 committed by GitHub
parent d373a9b83e
commit 73261908b5
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 19 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
source/dnode/vnode/src/vnd/vnodeSync.c
View file

@ -347,10 +347,25 @@ void vnodeApplyWriteMsg(SQueueInfo *pInfo, STaosQall *qall, int32_t numOfMsgs) {
SRpcMsg rsp = {.code = pMsg->code, .info = pMsg->info};
if (rsp.code == 0) {
if (vnodeProcessWriteMsg(pVnode, pMsg, pMsg->info.conn.applyIndex, &rsp) < 0) {
rsp.code = terrno;
vGError(&pMsg->info.traceId, "vgId:%d, msg:%p, failed to apply since %s, index:%" PRId64, vgId, pMsg, terrstr(),
pMsg->info.conn.applyIndex);
int32_t ret = 0;
int32_t count = 0;
while (1) {
ret = vnodeProcessWriteMsg(pVnode, pMsg, pMsg->info.conn.applyIndex, &rsp);
if (ret < 0) {
rsp.code = ret;
vGError(&pMsg->info.traceId, "vgId:%d, msg:%p, failed to apply since %s, index:%" PRId64, vgId, pMsg,
tstrerror(ret), pMsg->info.conn.applyIndex);
}
if (ret == TSDB_CODE_VND_WRITE_DISABLED) {
if (count % 100 == 0)
vGError(&pMsg->info.traceId,
"vgId:%d, msg:%p, failed to apply since %s, retry after 200ms, retry count:%d index:%" PRId64, vgId,
pMsg, tstrerror(ret), count, pMsg->info.conn.applyIndex);
count++;
taosMsleep(200); // wait for a while before retrying
} else{
break;
}
}
}