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

ehn:TD-33933-decouple-send-heartbeat-fix-case

This commit is contained in:
dmchen 2025-03-04 09:41:15 +08:00
parent 1d435faaa2
commit 379134fd6c
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/util/src/tsched.c
View File

@ -148,7 +148,7 @@ void *taosProcessSchedQueue(void *scheduler) {
snprintf(name, tListLen(name), "%s-taskQ", pSched->label); snprintf(name, tListLen(name), "%s-taskQ", pSched->label);
setThreadName(name); setThreadName(name);
int64_t pid = taosGetSelfPthreadId(); int64_t pid = taosGetSelfPthreadId();
uInfo("scheduler %s is started, thread:%" PRId64, pSched->label, pid); uInfo("scheduler %s is started, thread:%" PRId64, name, pid);
while (1) { while (1) {
if ((ret = tsem_wait(&pSched->fullSem)) != 0) { if ((ret = tsem_wait(&pSched->fullSem)) != 0) {

11
source/util/src/ttimer.c
View File

@ -318,17 +318,22 @@ static void addToExpired(tmr_obj_t* head) {
schedMsg.msg = NULL; schedMsg.msg = NULL;
schedMsg.ahandle = head; schedMsg.ahandle = head;
schedMsg.thandle = NULL; schedMsg.thandle = NULL;
if (head->priority == 1) { uint8_t priority = head->priority;
if (priority == 1) {
if (taosScheduleTask(tmrQhandle, &schedMsg) != 0) { if (taosScheduleTask(tmrQhandle, &schedMsg) != 0) {
tmrError("%s failed to add expired timer[id=%" PRIuPTR "] to queue.", head->ctrl->label, id); tmrError("%s failed to add expired timer[id=%" PRIuPTR "] to queue.", head->ctrl->label, id);
} }
} else if (head->priority == 2) { } else if (priority == 2) {
if (taosScheduleTask(tmrQhandleHigh, &schedMsg) != 0) { if (taosScheduleTask(tmrQhandleHigh, &schedMsg) != 0) {
tmrError("%s failed to add expired timer[id=%" PRIuPTR "] to high level queue.", head->ctrl->label, id); tmrError("%s failed to add expired timer[id=%" PRIuPTR "] to high level queue.", head->ctrl->label, id);
} }
} }
else{
tmrError("%s invalid priority level %d for timer[id=%" PRIuPTR "].", head->ctrl->label, priority, id);
}
tmrDebug("timer[id=%" PRIuPTR "] has been added to queue priority:%d.", id, head->priority); tmrDebug("timer[id=%" PRIuPTR "] has been added to queue priority:%d.", id, priority);
head = next; head = next;
} }
} }