+class My_Timer_Thread : public ISocketObserver {
+private:
+ ISocketObservable *m_obs;
+ int m_fd[2];
+ yp2::ThreadPoolSocketObserver *m_t;
+public:
+ int m_sum;
+ int m_requests;
+ int m_responses;
+ My_Timer_Thread(ISocketObservable *obs, yp2::ThreadPoolSocketObserver *t);
+ void socketNotify(int event);
+};
+
+
+yp2::IThreadPoolMsg *My_Msg::handle()