-Proxy_Thread::Proxy_Thread(IYazSocketObservable *obs)
- : m_obs(obs)
-{
- pthread_mutex_init(&m_mutex_input_data, 0);
- pthread_cond_init(&m_cond_input_data, 0);
- pthread_mutex_init(&m_mutex_output_data, 0);
- pthread_cond_init(&m_cond_output_data, 0);
- m_fd[0] = m_fd[1] = -1;
- if (pipe(m_fd) != 0)
- return;
- m_obs->addObserver(m_fd[0], this);
- m_obs->timeoutObserver(this, 2000);
- m_obs->maskObserver(this, YAZ_SOCKET_OBSERVE_READ);
-
- pthread_create(&m_thread_id, 0, tfunc, this);
-}
-
-Proxy_Thread::~Proxy_Thread()
-{
-
-}
-
-void Proxy_Thread::socketNotify(int event)
-{
- char buf[2];
- read(m_fd[0], buf, 1);
- pthread_mutex_lock(&m_mutex_output_data);
- Proxy_Msg *out = m_output.dequeue();
- pthread_mutex_unlock(&m_mutex_output_data);
- if (out)
- out->result();
-}
-
-void Proxy_Thread::run(void *p)
-{
- while(1)
- {
- pthread_mutex_lock(&m_mutex_input_data);
- pthread_cond_wait(&m_cond_input_data, &m_mutex_input_data);
- while(1)
- {
- Proxy_Msg *in = m_input.dequeue();
- pthread_mutex_unlock(&m_mutex_input_data);
- if (!in)
- break;
- Proxy_Msg *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);
- }
- }
-}
-
-void Proxy_Thread::put(Proxy_Msg *m)
-{
- pthread_mutex_lock(&m_mutex_input_data);
- m_input.enqueue(m);
- pthread_cond_signal(&m_cond_input_data);
- int in_size = m_input.size();
- pthread_mutex_unlock(&m_mutex_input_data);
- int out_size = m_output.size();
- printf("in-size=%d out-size=%d\n", in_size, out_size);
-}
-
-class My_Msg : public Proxy_Msg {