Updated copyright headers. Omit CVS ID.
[metaproxy-moved-to-github.git] / src / thread_pool_observer.hpp
1 /* This file is part of Metaproxy.
2    Copyright (C) 2005-2008 Index Data
3
4 Metaproxy is free software; you can redistribute it and/or modify it under
5 the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2, or (at your option) any later
7 version.
8
9 Metaproxy is distributed in the hope that it will be useful, but WITHOUT ANY
10 WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
12 for more details.
13
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
17 */
18
19 #ifndef YP2_THREAD_POOL_OBSERVER_HPP
20 #define YP2_THREAD_POOL_OBSERVER_HPP
21
22 #include <boost/scoped_ptr.hpp>
23
24 #include <yazpp/socket-observer.h>
25 #include <yaz/yconfig.h>
26
27 namespace metaproxy_1 {
28     class IThreadPoolMsg {
29     public:
30         virtual IThreadPoolMsg *handle() = 0;
31         virtual void result() = 0;
32         virtual ~IThreadPoolMsg();
33     };
34
35     class ThreadPoolSocketObserver : public yazpp_1::ISocketObserver {
36         class Rep;
37         class Worker;
38     public:
39         ThreadPoolSocketObserver(yazpp_1::ISocketObservable *obs,
40                                  int no_threads);
41         virtual ~ThreadPoolSocketObserver();
42         void put(IThreadPoolMsg *m);
43         IThreadPoolMsg *get();
44         void run(void *p);
45     private:
46         void socketNotify(int event);
47         boost::scoped_ptr<Rep> m_p;
48
49     };
50 }
51 #endif
52 /*
53  * Local variables:
54  * c-basic-offset: 4
55  * indent-tabs-mode: nil
56  * c-file-style: "stroustrup"
57  * End:
58  * vim: shiftwidth=4 tabstop=8 expandtab
59  */
60