| 94 | } |
| 95 | |
| 96 | ThreadQueueBasePtr IOThread::getOutputQueue(const std::string& qname) { |
| 97 | std::lock_guard < std::mutex > lock(m_queue_bindings_mutex); |
| 98 | return output_queues[qname]; |
| 99 | } |
| 100 | |
| 101 | bool IOThread::isTerminated(int waitMs) { |
| 102 |
nothing calls this directly
no outgoing calls
no test coverage detected