30 template<
typename Lock>
45 : m_thread_pool(thread_pool), m_stop(false) {
64 message->getProperty(prop);
80 logger.debug() <<
"Starting prefetcher output loop";
97 logger.debug() <<
"ProcessSourceEvent released";
99 ReverseLock<decltype(output_lock)> release_lock(output_lock);
109 logger.debug() <<
"Next source " <<
next.m_source_addr <<
" not done yet";
113 logger.debug() <<
"Source " <<
next.m_source_addr <<
" sent downstream";
115 ReverseLock<decltype(output_lock)> release_lock(output_lock);
126 logger.debug() <<
"Stopping prefetcher output loop";
136 logger.debug() <<
"ProcessSourceEvent received";