From 968d7fd6a2edb1f99ffab980d8130abbd854adc5 Mon Sep 17 00:00:00 2001 From: "Stephen D. Huston" Date: Mon, 12 Jan 2009 23:31:49 +0000 Subject: Add support for AsynchIO::RequestCallback processing git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@733966 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/sys/windows/IocpPoller.cpp | 24 +++++++++++++++++++----- 1 file changed, 19 insertions(+), 5 deletions(-) (limited to 'cpp/src/qpid/sys/windows/IocpPoller.cpp') 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()); + } } } -- cgit v1.2.1