| 115 | |
| 116 | template<typename T> |
| 117 | void ObjectQueue<T>::abort() { |
| 118 | /* mutex lock */ |
| 119 | std::lock_guard<std::mutex> lock(m_mutex); |
| 120 | |
| 121 | /* stop */ |
| 122 | m_abort = true; |
| 123 | |
| 124 | /* trigger blocked threads */ |
| 125 | tellgChanged.notify_all(); |
| 126 | tellpChanged.notify_all(); |
| 127 | } |
| 128 | |
| 129 | template<typename T> |
| 130 | void ObjectQueue<T>::setFileSize(uint32_t fileSize) { |
no outgoing calls
no test coverage detected