Commit c13facda authored by Max Kellermann's avatar Max Kellermann

db/upnp/WorkQueue: pass reference to take()

parent e2594743
......@@ -109,7 +109,7 @@ discoExplorer(void *)
{
for (;;) {
DiscoveredTask *tsk = 0;
if (!discoveredQueue.take(&tsk)) {
if (!discoveredQueue.take(tsk)) {
discoveredQueue.workerExit();
return (void*)1;
}
......
......@@ -241,7 +241,7 @@ public:
* Sleeps if there are not enough. Signal if we go to sleep on empty
* queue: client may be waiting for our going idle.
*/
bool take(T* tp)
bool take(T &tp)
{
const ScopeLock protect(m_mutex);
......@@ -266,7 +266,7 @@ public:
m_workers_waiting--;
}
*tp = m_queue.front();
tp = m_queue.front();
m_queue.pop();
if (m_clients_waiting > 0) {
// No reason to wake up more than one client thread
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment