| 387 | } |
| 388 | |
| 389 | bool HasMessages(HSocket socket) |
| 390 | { |
| 391 | if (!socket) |
| 392 | return false; |
| 393 | |
| 394 | MessageSocket* s = AcquireSocket(socket); |
| 395 | if (s != 0) |
| 396 | { |
| 397 | bool has_messages; |
| 398 | { |
| 399 | DM_MUTEX_SCOPED_LOCK(s->m_Mutex); |
| 400 | has_messages = s->m_Header != 0; |
| 401 | } |
| 402 | ReleaseSocket(s); |
| 403 | return has_messages; |
| 404 | } |
| 405 | return false; |
| 406 | } |
| 407 | |
| 408 | void ResetURL(URL* url) |
| 409 | { |
no test coverage detected