Add support for AsynchIO::RequestCallback processing

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733966 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 19 insertions, 5 deletions

diff --git a/cpp/src/qpid/sys/windows/IocpPoller.cpp b/cpp/src/qpid/sys/windows/IocpPoller.cpp
index d23dafcd6e..1e24adfb46 100755
--- a/cpp/src/qpid/sys/windows/IocpPoller.cpp
+++ b/cpp/src/qpid/sys/windows/IocpPoller.cpp
@@ -43,16 +43,19 @@ class PollerHandlePrivate {
 
     SOCKET fd;
     AsynchIoResult::Completer cb;
+    AsynchIO::RequestCallback cbRequest;
 
-    PollerHandlePrivate(SOCKET f, AsynchIoResult::Completer cb0 = 0) :
-      fd(f), cb(cb0)
+    PollerHandlePrivate(SOCKET f,
+                        AsynchIoResult::Completer cb0 = 0,
+                        AsynchIO::RequestCallback rcb = 0)
+      : fd(f), cb(cb0), cbRequest(rcb)
     {
     }
     
 };
 
 PollerHandle::PollerHandle(const IOHandle& h) :
-    impl(new PollerHandlePrivate(toFd(h.impl), h.impl->event))
+  impl(new PollerHandlePrivate(toFd(h.impl), h.impl->event, h.impl->cbRequest))
 {}
 
 PollerHandle::~PollerHandle() {
@@ -114,8 +117,19 @@ void Poller::addFd(PollerHandle& handle, Direction dir) {
         QPID_WINDOWS_CHECK_NULL(iocpHandle);
     }
     else {
-        AsynchWriteWanted *result = new AsynchWriteWanted(handle.impl->cb);
-        PostQueuedCompletionStatus(impl->iocp, 0, 0, result->overlapped());
+        // INPUT is used to request a callback; OUTPUT to request a write
+        assert(dir == Poller::INPUT || dir == Poller::OUTPUT);
+
+        if (dir == Poller::OUTPUT) {
+            AsynchWriteWanted *result = new AsynchWriteWanted(handle.impl->cb);
+            PostQueuedCompletionStatus(impl->iocp, 0, 0, result->overlapped());
+        }
+        else {
+            AsynchCallbackRequest *result =
+                new AsynchCallbackRequest(handle.impl->cb,
+                                          handle.impl->cbRequest);
+            PostQueuedCompletionStatus(impl->iocp, 0, 0, result->overlapped());
+        }
     }
 }