X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;f=src%2Fmsg-thread.h;h=56722d690670e110eedb43aa02d7d8642eb43412;hb=4e7b65539b3bea310f8d626d42e64cfd9e054dd5;hp=725c8adc2a03a1c14c536f0f4ef079740c48cb4d;hpb=eb2b00deb4ecc5a3fbfbef11f57790c1659ab3e2;p=yazproxy-moved-to-github.git diff --git a/src/msg-thread.h b/src/msg-thread.h index 725c8ad..56722d6 100644 --- a/src/msg-thread.h +++ b/src/msg-thread.h @@ -1,4 +1,4 @@ -/* $Id: msg-thread.h,v 1.2 2005-06-02 06:40:46 adam Exp $ +/* $Id: msg-thread.h,v 1.5 2005-08-15 12:51:57 adam Exp $ Copyright (c) 1998-2005, Index Data. This file is part of the yaz-proxy. @@ -53,9 +53,9 @@ class Msg_Thread_Queue { Msg_Thread_Queue_List *m_list; }; -class Msg_Thread : public yazpp_1::IYazSocketObserver { +class Msg_Thread : public yazpp_1::ISocketObserver { public: - Msg_Thread(yazpp_1::IYazSocketObservable *obs); + Msg_Thread(yazpp_1::ISocketObservable *obs); virtual ~Msg_Thread(); void socketNotify(int event); void put(IMsg_Thread *m); @@ -63,14 +63,21 @@ class Msg_Thread : public yazpp_1::IYazSocketObserver { void run(void *p); int m_fd[2]; private: - yazpp_1::IYazSocketObservable *m_SocketObservable; + yazpp_1::ISocketObservable *m_SocketObservable; pthread_t m_thread_id; Msg_Thread_Queue m_input; Msg_Thread_Queue m_output; pthread_mutex_t m_mutex_input_data; pthread_cond_t m_cond_input_data; pthread_mutex_t m_mutex_output_data; - pthread_cond_t m_cond_output_data; bool m_stop_flag; }; +/* + * Local variables: + * c-basic-offset: 4 + * indent-tabs-mode: nil + * End: + * vim: shiftwidth=4 tabstop=8 expandtab + */ +