| 2364 | |
| 2365 | private: |
| 2366 | void SendProgress_(const T *data, size_t count) { |
| 2367 | T *new_data = new T[count]; |
| 2368 | std::copy(data, data + count, new_data); |
| 2369 | |
| 2370 | uv_mutex_lock(&async_lock); |
| 2371 | asyncdata_.push(std::pair<T*, size_t>(new_data, count)); |
| 2372 | uv_mutex_unlock(&async_lock); |
| 2373 | |
| 2374 | uv_async_send(&this->async); |
| 2375 | } |
| 2376 | |
| 2377 | uv_mutex_t async_lock; |
| 2378 | std::queue<std::pair<T*, size_t> > asyncdata_; |
nothing calls this directly
no outgoing calls
no test coverage detected