sync gaussdb kernel bug-fix

2021-04-16 11:48:37 +08:00
parent 5af8c3d0d3
commit b939aee909
12 changed files with 68 additions and 28 deletions
--- a/src/gausskernel/process/threadpool/threadpool_group.cpp
+++ b/src/gausskernel/process/threadpool/threadpool_group.cpp
@ -352,15 +352,7 @@ bool ThreadPoolGroup::IsGroupHang()
        m_idleWorkerNum != 0)
        return false;

-    bool ishang = true;
-    AutoMutexLock alock(&m_mutex);
-    alock.lock();
-    for (int i = 0; i < m_expectWorkerNum; i++) {
-        if (m_workers[i].stat.slotStatus != THREAD_SLOT_UNUSE) {
-            ishang = ishang && WORKER_MAY_HANG(m_workers[i].worker->m_waitState);
-        }
-    }
-    alock.unLock();
+    bool ishang = m_listener->GetSessIshang(&m_current_time, &m_sessionId);
    return ishang;
 }