diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2009-01-06 23:42:18 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2009-01-06 23:42:18 +0000 |
| commit | 9a933ae9011d343a75929136269fe45c6b863a17 (patch) | |
| tree | 29ebd71241d810af6e0f20d7e5694cba1607486f /cpp/src/qpid/sys/AsynchIO.h | |
| parent | 820071d5a9959a2923269751ddcff2ed085b239a (diff) | |
| download | qpid-python-9a933ae9011d343a75929136269fe45c6b863a17.tar.gz | |
Work on the low level IO code:
* Introduce code so that you can interrupt waiting for a handle and receive
a callback that is correctly serialised with the IO callbacks for that
handle
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732177 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/AsynchIO.h')
| -rw-r--r-- | cpp/src/qpid/sys/AsynchIO.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/sys/AsynchIO.h b/cpp/src/qpid/sys/AsynchIO.h index 68e441349a..0a2a1ca1b4 100644 --- a/cpp/src/qpid/sys/AsynchIO.h +++ b/cpp/src/qpid/sys/AsynchIO.h @@ -114,6 +114,7 @@ public: typedef boost::function2<void, AsynchIO&, const Socket&> ClosedCallback; typedef boost::function1<void, AsynchIO&> BuffersEmptyCallback; typedef boost::function1<void, AsynchIO&> IdleCallback; + typedef boost::function1<void, AsynchIO&> RequestCallback; // Call create() to allocate a new AsynchIO object with the specified // callbacks. This method is implemented in platform-specific code to @@ -138,6 +139,7 @@ public: virtual void queueWriteClose() = 0; virtual bool writeQueueEmpty() = 0; virtual void startReading() = 0; + virtual void requestCallback(RequestCallback) = 0; virtual BufferBase* getQueuedBuffer() = 0; protected: |