| 2229 | } |
| 2230 | |
| 2231 | void WorkProgress() { |
| 2232 | uv_mutex_lock(&this->async_lock); |
| 2233 | T *data = asyncdata_; |
| 2234 | size_t size = asyncsize_; |
| 2235 | asyncdata_ = NULL; |
| 2236 | asyncsize_ = 0; |
| 2237 | uv_mutex_unlock(&this->async_lock); |
| 2238 | |
| 2239 | // Don't send progress events after we've already completed. |
| 2240 | if (this->callback) { |
| 2241 | this->HandleProgressCallback(data, size); |
| 2242 | } |
| 2243 | delete[] data; |
| 2244 | } |
| 2245 | |
| 2246 | private: |
| 2247 | void SendProgress_(const T *data, size_t count) { |
no test coverage detected