X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Feventdispatcher.cpp;h=49b28ac78bf436997f74d2d8fecb740aebf47fb5;hp=cf37c1e7e1fbd81155608895bd14ebe9bd882e10;hb=0f32d120e05ebc207dcd2ea733714f29795cb26b;hpb=7ca970e5db84020e4735afccf43ede4d52ac0bf0

diff --git a/source/io/eventdispatcher.cpp b/source/io/eventdispatcher.cpp
index cf37c1e..49b28ac 100644
--- a/source/io/eventdispatcher.cpp
+++ b/source/io/eventdispatcher.cpp
@@ -4,23 +4,19 @@
 #include "eventobject.h"
 #include "poll.h"
 
+using namespace std;
+
 namespace Msp {
 namespace IO {
 
-EventDispatcher::EventDispatcher()
-{ }
-
-EventDispatcher::~EventDispatcher()
-{ }
-
 void EventDispatcher::add(EventObject &obj)
 {
-	SlotMap::iterator i = objects.find(&obj);
+	Slot slot(*this, obj);
+	set<Slot>::iterator i = objects.find(slot);
 	if(i==objects.end())
 	{
-		i = objects.insert(SlotMap::value_type(&obj, Slot(&obj))).first;
-		i->second.evch_conn = obj.signal_events_changed.connect(sigc::bind(sigc::mem_fun(this, &EventDispatcher::object_events_changed), &obj));
-		i->second.del_conn = obj.signal_deleted.connect(sigc::bind(sigc::mem_fun(this, &EventDispatcher::object_deleted), &obj));
+		i = objects.insert(slot).first;
+		i->connect_signals();
 
 		if(obj.get_events())
 			poller.set_object(obj, obj.get_events());
@@ -29,11 +25,9 @@ void EventDispatcher::add(EventObject &obj)
 
 void EventDispatcher::remove(EventObject &obj)
 {
-	SlotMap::iterator i = objects.find(&obj);
+	set<Slot>::iterator i = objects.find(Slot(*this, obj));
 	if(i!=objects.end())
 	{
-		i->second.evch_conn.disconnect();
-		i->second.del_conn.disconnect();
 		objects.erase(i);
 
 		poller.set_object(obj, P_NONE);
@@ -67,21 +61,34 @@ void EventDispatcher::tick(const Time::Timer &timer)
 		tick();
 }
 
-void EventDispatcher::object_events_changed(PollEvent ev, EventObject *obj)
+void EventDispatcher::dispatch()
 {
-	poller.set_object(*obj, ev);
+	const vector<Poller::PolledObject> &result = poller.get_result();
+	for(vector<Poller::PolledObject>::const_iterator i=result.begin(); i!=result.end(); ++i)
+		if(objects.count(Slot(*this, *i->object)))
+			i->object->event(i->events);
 }
 
-void EventDispatcher::object_deleted(EventObject *obj)
+
+EventDispatcher::Slot::Slot(EventDispatcher &d, EventObject &o):
+	disp(d),
+	obj(o)
+{ }
+
+void EventDispatcher::Slot::connect_signals() const
 {
-	remove(*obj);
+	obj.signal_events_changed.connect(sigc::mem_fun(this, &Slot::events_changed));
+	obj.signal_deleted.connect(sigc::mem_fun(this, &Slot::deleted));
 }
 
-void EventDispatcher::dispatch()
+void EventDispatcher::Slot::events_changed(PollEvent ev) const
+{
+	disp.poller.set_object(obj, ev);
+}
+
+void EventDispatcher::Slot::deleted() const
 {
-	const Poller::SlotList &result = poller.get_result();
-	for(Poller::SlotList::const_iterator i=result.begin(); i!=result.end(); ++i)
-		i->object->event(i->events);
+	disp.remove(obj);
 }
 
 } // namespace IO