- if (!in)
- break;
- IMsg_Thread *out = in->handle();
- pthread_mutex_lock(&m_mutex_output_data);
- m_output.enqueue(out);
- pthread_cond_signal(&m_cond_output_data);
- pthread_mutex_unlock(&m_mutex_output_data);
-
- write(m_fd[1], "", 1);
-
- pthread_mutex_lock(&m_mutex_input_data);