X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;f=src%2Fthread_pool_observer.cpp;h=061ec8f209e2d82bdfa41d9a6d801d19d05c91f9;hb=9dec54edaf1536d72030e95123c77040fc951185;hp=9c7dfda85c23346eccef8e5cd903e59349da06bc;hpb=305de106cba7adf288c9349072084bdec12a436b;p=metaproxy-moved-to-github.git diff --git a/src/thread_pool_observer.cpp b/src/thread_pool_observer.cpp index 9c7dfda..061ec8f 100644 --- a/src/thread_pool_observer.cpp +++ b/src/thread_pool_observer.cpp @@ -1,6 +1,6 @@ -/* $Id: thread_pool_observer.cpp,v 1.13 2005-11-07 22:46:42 adam Exp $ - Copyright (c) 2005, Index Data. +/* $Id: thread_pool_observer.cpp,v 1.16 2006-06-09 14:12:13 adam Exp $ + Copyright (c) 2005-2006, Index Data. %LICENSE% */ @@ -26,13 +26,13 @@ #include -#include +#include #include #include "thread_pool_observer.hpp" #include "pipe.hpp" -namespace yp2 { +namespace metaproxy_1 { class ThreadPoolSocketObserver::Worker { public: Worker(ThreadPoolSocketObserver *s) : m_s(s) {}; @@ -63,9 +63,9 @@ namespace yp2 { using namespace yazpp_1; -using namespace yp2; +using namespace metaproxy_1; -ThreadPoolSocketObserver::Rep::Rep(ISocketObservable *obs) +ThreadPoolSocketObserver::Rep::Rep(yazpp_1::ISocketObservable *obs) : m_socketObservable(obs), m_pipe(9123) { } @@ -79,8 +79,8 @@ IThreadPoolMsg::~IThreadPoolMsg() } -ThreadPoolSocketObserver::ThreadPoolSocketObserver(ISocketObservable *obs, - int no_threads) +ThreadPoolSocketObserver::ThreadPoolSocketObserver( + yazpp_1::ISocketObservable *obs, int no_threads) : m_p(new Rep(obs)) { obs->addObserver(m_p->m_pipe.read_fd(), this);