| 2317 | } |
| 2318 | |
| 2319 | virtual ~AsyncProgressQueueWorker() { |
| 2320 | uv_mutex_lock(&async_lock); |
| 2321 | |
| 2322 | while (!asyncdata_.empty()) { |
| 2323 | std::pair<T*, size_t> &datapair = asyncdata_.front(); |
| 2324 | T *data = datapair.first; |
| 2325 | |
| 2326 | asyncdata_.pop(); |
| 2327 | |
| 2328 | delete[] data; |
| 2329 | } |
| 2330 | |
| 2331 | uv_mutex_unlock(&async_lock); |
| 2332 | uv_mutex_destroy(&async_lock); |
| 2333 | } |
| 2334 | |
| 2335 | void WorkComplete() { |
| 2336 | WorkProgress(); |
nothing calls this directly
no outgoing calls
no test coverage detected