| 6860 | |
| 6861 | template <class T> |
| 6862 | inline void AsyncProgressWorker<T>::SendProgress_(const T* data, size_t count) { |
| 6863 | T* new_data = new T[count]; |
| 6864 | std::copy(data, data + count, new_data); |
| 6865 | |
| 6866 | T* old_data; |
| 6867 | { |
| 6868 | std::lock_guard<std::mutex> lock(this->_mutex); |
| 6869 | old_data = _asyncdata; |
| 6870 | _asyncdata = new_data; |
| 6871 | _asyncsize = count; |
| 6872 | _signaled = false; |
| 6873 | } |
| 6874 | this->NonBlockingCall(nullptr); |
| 6875 | |
| 6876 | delete[] old_data; |
| 6877 | } |
| 6878 | |
| 6879 | template <class T> |
| 6880 | inline void AsyncProgressWorker<T>::Signal() { |
no test coverage detected