| 114 | } |
| 115 | |
| 116 | static void addSources(ExchangeQueue& queue, int32_t numSources) { |
| 117 | { |
| 118 | std::lock_guard<std::mutex> l(queue.mutex()); |
| 119 | for (auto i = 0; i < numSources; ++i) { |
| 120 | queue.addSourceLocked(); |
| 121 | } |
| 122 | } |
| 123 | queue.noMoreSources(); |
| 124 | } |
| 125 | |
| 126 | static void enqueue( |
| 127 | ExchangeQueue& queue, |
nothing calls this directly
no test coverage detected