| 2338 | } |
| 2339 | |
| 2340 | void WorkProgress() { |
| 2341 | uv_mutex_lock(&async_lock); |
| 2342 | |
| 2343 | while (!asyncdata_.empty()) { |
| 2344 | std::pair<T*, size_t> &datapair = asyncdata_.front(); |
| 2345 | |
| 2346 | T *data = datapair.first; |
| 2347 | size_t size = datapair.second; |
| 2348 | |
| 2349 | asyncdata_.pop(); |
| 2350 | uv_mutex_unlock(&async_lock); |
| 2351 | |
| 2352 | // Don't send progress events after we've already completed. |
| 2353 | if (this->callback) { |
| 2354 | this->HandleProgressCallback(data, size); |
| 2355 | } |
| 2356 | |
| 2357 | delete[] data; |
| 2358 | |
| 2359 | uv_mutex_lock(&async_lock); |
| 2360 | } |
| 2361 | |
| 2362 | uv_mutex_unlock(&async_lock); |
| 2363 | } |
| 2364 | |
| 2365 | private: |
| 2366 | void SendProgress_(const T *data, size_t count) { |
nothing calls this directly
no test coverage detected