| 199 | |
| 200 | private: |
| 201 | void AquireSemaphore() |
| 202 | { |
| 203 | #ifdef __APPLE__ |
| 204 | auto waitResult = semaphore_wait( m_activeWorkersSemaphore ); |
| 205 | if( waitResult != KERN_SUCCESS ) |
| 206 | { |
| 207 | g_messages.AddMessage( "WorkQueue2: Waiting on m_activeWorkersSemaphore failed! Error: %d", waitResult ); |
| 208 | } |
| 209 | #else |
| 210 | DWORD waitResult = WaitForSingleObject( m_activeWorkersSemaphore, INFINITE ); |
| 211 | if( waitResult != WAIT_OBJECT_0 ) |
| 212 | { |
| 213 | if( waitResult == WAIT_FAILED ) |
| 214 | { |
| 215 | g_messages.AddMessage( "WorkQueue2: Waiting on m_activeWorkersSemaphore failed! Error: %d %d", waitResult, GetLastError() ); |
| 216 | } |
| 217 | else |
| 218 | { |
| 219 | g_messages.AddMessage( "WorkQueue2: Waiting on m_activeWorkersSemaphore failed! Error: %d", waitResult ); |
| 220 | } |
| 221 | } |
| 222 | #endif |
| 223 | } |
| 224 | |
| 225 | void FreeSemaphore() |
| 226 | { |
nothing calls this directly
no test coverage detected