| 128 | } |
| 129 | |
| 130 | bool CThreadManager::DestroyThread(const std::shared_ptr <CThread> & thread) |
| 131 | { |
| 132 | if (!IS_VALID_SMART_PTR(thread) || thread->IsCorrect() == false) |
| 133 | { |
| 134 | DEBUG_LOG(LL_CRI, "Unknown thread! Tid: %u", IS_VALID_SMART_PTR(thread) ? thread->GetId() : (DWORD)-1); |
| 135 | return false; |
| 136 | } |
| 137 | |
| 138 | if (m_vThreadList.empty()) |
| 139 | return false; |
| 140 | |
| 141 | for (const auto & pCurrThread : m_vThreadList) |
| 142 | { |
| 143 | if (pCurrThread->dwThreadId == thread->GetId()) |
| 144 | { |
| 145 | auto threadInfo = GetThreadInfo(pCurrThread->iThreadCode); |
| 146 | if (IS_VALID_SMART_PTR(threadInfo)) |
| 147 | m_vThreadList.erase(std::remove(m_vThreadList.begin(), m_vThreadList.end(), threadInfo), m_vThreadList.end()); |
| 148 | |
| 149 | thread->Terminate(); |
| 150 | |
| 151 | if (IS_VALID_SMART_PTR(pCurrThread->customThread)) |
| 152 | { |
| 153 | pCurrThread->customThread.reset(); |
| 154 | pCurrThread->customThread = nullptr; |
| 155 | } |
| 156 | return true; |
| 157 | } |
| 158 | } |
| 159 | |
| 160 | return false; |
| 161 | } |
| 162 | |
| 163 | void CThreadManager::OnThreadTerminated(DWORD dwThreadId) // TODO: Implement routine |
| 164 | { |
no test coverage detected