X-Git-Url: http://git.indexdata.com/?p=yazproxy-moved-to-github.git;a=blobdiff_plain;f=src%2Fmsg-thread.h;h=b7e4e577be0be8ad7be23a92201563a030c600e0;hp=8e8a5650f81eb736117110324198849440357987;hb=ce193eb0444478dc61e832497ab7f4a7ae73c0c6;hpb=8b633921805ae0410a059fc30698735311ad1e6d diff --git a/src/msg-thread.h b/src/msg-thread.h index 8e8a565..b7e4e57 100644 --- a/src/msg-thread.h +++ b/src/msg-thread.h @@ -1,4 +1,4 @@ -/* $Id: msg-thread.h,v 1.9 2006-03-30 10:31:25 adam Exp $ +/* $Id: msg-thread.h,v 1.10 2006-03-30 13:29:23 adam Exp $ Copyright (c) 1998-2006, Index Data. This file is part of the yazproxy. @@ -19,14 +19,9 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ -#include #include #include -#if HAVE_DLFCN_H -#include -#endif - #include #include @@ -55,6 +50,7 @@ class Msg_Thread_Queue { }; class Msg_Thread : public yazpp_1::ISocketObserver { + class Private; public: Msg_Thread(yazpp_1::ISocketObservable *obs, int no_threads); virtual ~Msg_Thread(); @@ -62,17 +58,8 @@ class Msg_Thread : public yazpp_1::ISocketObserver { void put(IMsg_Thread *m); IMsg_Thread *get(); void run(void *p); - int m_fd[2]; private: - yazpp_1::ISocketObservable *m_SocketObservable; - int m_no_threads; - 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; - bool m_stop_flag; + class Private *m_p; }; /*