Method Execute

engine/Poseidon/Dev/Debug/DebugTrap.cpp:83–136

}

DWORD DebugThreadWatch::Execute()
{
    DWORD lastAlive = ::GetTickCount();
    for (;;)
    {
        Foundation::SignaledObject* wait[] = {&_terminate, &_keepAlive};
        int waitTime, waitTime0;
        {
            Foundation::ScopeLockSection lock(_lock);
            waitTime0 = waitTime = _timeOut;
            if (waitTime < 0 || waitTime > 10000)
            {
                waitTime = 10000;
            }
        }
        DWORD start = ::GetTickCount();
        int which = Foundation::SignaledObject::WaitForMultiple(wait, sizeof(wait) / sizeof(*wait), waitTime);
        if (which == 0)
        {
            return 0; // _terminate event
        }
        else if (which == 1) // alive event
        {
            lastAlive = ::GetTickCount();
            DWORD delay = lastAlive - start;
            if (delay > static_cast<DWORD>(waitTime - 2000) ||
                delay > 2500) // waitTime clamped to [0,10000], safe to cast
            {
                LOG_DEBUG(Core, "No alive in {} of {} ms", delay, waitTime);
                LOG_DEBUG(Core, "  check another threads -- add ProgressRefresh()");
            }
            // no more event expected until told by NextAlive
        }
        else
        {
            if (waitTime0 >= 0 && waitTime0 < 20000 && _enable > 0)
            {
                LOG_DEBUG(Core, "Freeze detected: no alive in {} ms", waitTime);
                ::SuspendThread(_mainThreadHandle);
                if (::GetTickCount() - lastAlive >= 30000)
                {
                    // fatal situation - terminate
                    ::DDTerm();
                    exit(1);
                }
                else
                {
                    ::ResumeThread(_mainThreadHandle);
                }
            }
        }
    }
    // Unreachable - infinite loop above always returns via _terminate event
}

DebugThreadWatch::~DebugThreadWatch() = default;