diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2007-07-27 17:19:30 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2007-07-27 17:19:30 +0000 |
| commit | 65ea2f177bd0810590895d89a490af8cea60253b (patch) | |
| tree | 1a1432d706ac5f43dc8cdd5fdb0d7b5566dd5d06 /cpp/src/qpid/sys/Poller.h | |
| parent | 0a7f3f5dde40e59e90588e4ab7ba2ba99651c0f4 (diff) | |
| download | qpid-python-65ea2f177bd0810590895d89a490af8cea60253b.tar.gz | |
* Asynchronous network IO subsystem
- This is now implemented such that it very nearly only depends on the platform
code (Socker & Poller), this is not 100% true at present, but should be simple
to finish.
- This is still not the default (use "./configure --disable-apr-netio" to get it)
- Interrupting the broker gives a known error
- Default for number of broker io threads is not correct (needs to be number of CPUs -
it will run slower with too many io threads)
* EventChannel code
- Deleted all EventChannel code as it's entirely superceded by this new shiny code ;-)
* Rearranged the platform Socket implementations a bit for better abstraction
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@560323 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/Poller.h')
| -rw-r--r-- | cpp/src/qpid/sys/Poller.h | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/cpp/src/qpid/sys/Poller.h b/cpp/src/qpid/sys/Poller.h index 55fead55aa..843295e268 100644 --- a/cpp/src/qpid/sys/Poller.h +++ b/cpp/src/qpid/sys/Poller.h @@ -23,6 +23,7 @@ */ #include "Time.h" +#include "Socket.h" #include <stdint.h> @@ -39,14 +40,14 @@ class PollerHandlePrivate; class PollerHandle { friend class Poller; - PollerHandlePrivate* impl; - const int fd; + PollerHandlePrivate* const impl; + const Socket& socket; public: - PollerHandle(int fd0); + PollerHandle(const Socket& s); virtual ~PollerHandle(); - - int getFD() const { return fd; } + + const Socket& getSocket() const {return socket;} }; /** @@ -55,7 +56,7 @@ public: */ class PollerPrivate; class Poller { - PollerPrivate* impl; + PollerPrivate* const impl; public: typedef boost::shared_ptr<Poller> shared_ptr; |
