summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/Poller.h
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2007-07-27 17:19:30 +0000
committerAndrew Stitcher <astitcher@apache.org>2007-07-27 17:19:30 +0000
commit65ea2f177bd0810590895d89a490af8cea60253b (patch)
tree1a1432d706ac5f43dc8cdd5fdb0d7b5566dd5d06 /cpp/src/qpid/sys/Poller.h
parent0a7f3f5dde40e59e90588e4ab7ba2ba99651c0f4 (diff)
downloadqpid-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.h13
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;