summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/Dispatcher.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/sys/Dispatcher.h')
-rw-r--r--cpp/src/qpid/sys/Dispatcher.h22
1 files changed, 1 insertions, 21 deletions
diff --git a/cpp/src/qpid/sys/Dispatcher.h b/cpp/src/qpid/sys/Dispatcher.h
index 0cfaf8b5d4..7cc4873068 100644
--- a/cpp/src/qpid/sys/Dispatcher.h
+++ b/cpp/src/qpid/sys/Dispatcher.h
@@ -54,33 +54,13 @@ private:
DELAYED_DELETE
} state;
- /**
- * TODO: The following are part of a temporary fix to ensure that
- * where a new event is generated for the same handle while an
- * earlier one is still being processed (due to an interest in
- * writeability being declared) the events are processed serially
- * by the first thread.
- */
- Mutex processLock;
- bool processing;
- bool deleted;
- std::queue<Poller::EventType> events;
-
- bool start(Poller::EventType type);
- void handle(Poller::EventType type);
- void drain();
- bool next(Poller::EventType& type);
- /**************************************************************/
-
public:
DispatchHandle(const Socket& s, Callback rCb, Callback wCb, Callback dCb) :
PollerHandle(s),
readableCallback(rCb),
writableCallback(wCb),
disconnectedCallback(dCb),
- state(IDLE),
- processing(false),
- deleted(false)
+ state(IDLE)
{}
~DispatchHandle();