+ My_Timer_Thread *m_timer;
+};
+
+class My_Timer_Thread : public ISocketObserver {
+private:
+ ISocketObservable *m_obs;
+ yp2::Pipe m_pipe;
+ 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);