X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;f=src%2Ftest_thread_pool_observer.cpp;h=38b41166ad8ab9fbc90c27019ec8a6304559d525;hb=f82b19f2b93707657fee804bd1242f2548d51ada;hp=532aefdda50fd1aadfc71225ba0cbb5c60aa11bb;hpb=57c1c4822f1de4d983c1aee3bc6059ad2600d991;p=metaproxy-moved-to-github.git diff --git a/src/test_thread_pool_observer.cpp b/src/test_thread_pool_observer.cpp index 532aefd..38b4116 100644 --- a/src/test_thread_pool_observer.cpp +++ b/src/test_thread_pool_observer.cpp @@ -1,4 +1,9 @@ -/* $Id: test_thread_pool_observer.cpp,v 1.4 2005-10-13 20:06:45 adam Exp $ +/* $Id: test_thread_pool_observer.cpp,v 1.6 2005-10-15 14:09:09 adam Exp $ + Copyright (c) 2005, Index Data. + +%LICENSE% + */ +/* $Id: test_thread_pool_observer.cpp,v 1.6 2005-10-15 14:09:09 adam Exp $ Copyright (c) 1998-2005, Index Data. This file is part of the yaz-proxy. @@ -36,9 +41,9 @@ using namespace yazpp_1; class My_Timer_Thread; -class My_Msg : public IThreadPoolMsg { +class My_Msg : public yp2::IThreadPoolMsg { public: - IThreadPoolMsg *handle(); + yp2::IThreadPoolMsg *handle(); void result(); int m_val; My_Timer_Thread *m_timer; @@ -48,17 +53,17 @@ class My_Timer_Thread : public ISocketObserver { private: ISocketObservable *m_obs; int m_fd[2]; - ThreadPoolSocketObserver *m_t; + yp2::ThreadPoolSocketObserver *m_t; public: int m_sum; int m_requests; int m_responses; - My_Timer_Thread(ISocketObservable *obs, ThreadPoolSocketObserver *t); + My_Timer_Thread(ISocketObservable *obs, yp2::ThreadPoolSocketObserver *t); void socketNotify(int event); }; -IThreadPoolMsg *My_Msg::handle() +yp2::IThreadPoolMsg *My_Msg::handle() { My_Msg *res = new My_Msg; @@ -77,7 +82,7 @@ void My_Msg::result() } My_Timer_Thread::My_Timer_Thread(ISocketObservable *obs, - ThreadPoolSocketObserver *t) : m_obs(obs) + yp2::ThreadPoolSocketObserver *t) : m_obs(obs) { pipe(m_fd); m_t = t; @@ -101,7 +106,7 @@ BOOST_AUTO_TEST_CASE( thread_pool_observer1 ) { SocketManager mySocketManager; - ThreadPoolSocketObserver m(&mySocketManager, 3); + yp2::ThreadPoolSocketObserver m(&mySocketManager, 3); My_Timer_Thread t(&mySocketManager, &m) ; while (t.m_responses < 30 && mySocketManager.processEvent() > 0) ; @@ -113,6 +118,7 @@ BOOST_AUTO_TEST_CASE( thread_pool_observer1 ) * Local variables: * c-basic-offset: 4 * indent-tabs-mode: nil + * c-file-style: "stroustrup" * End: * vim: shiftwidth=4 tabstop=8 expandtab */