X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Fpoll.cpp;h=2e33502e8433969059dccdd1ecbde834a3e6aff7;hp=6da777cf4470778f4e6401dbcc39f1a3a539b4e7;hb=292aed8e23ea543b089d5f2a73000de4640befe7;hpb=df6fc46950e15bb30a92368f34dc2005393b0e5b;ds=sidebyside

diff --git a/source/io/poll.cpp b/source/io/poll.cpp
index 6da777c..2e33502 100644
--- a/source/io/poll.cpp
+++ b/source/io/poll.cpp
@@ -10,6 +10,7 @@ namespace IO {
 
 Poller::Poller():
 	priv(new Private),
+	events_changed(false),
 	objs_changed(false)
 { }
 
@@ -24,26 +25,31 @@ void Poller::set_object(EventObject &obj, PollEvent ev)
 	if(ev)
 		obj.get_event_handle();
 
-	EventMap::iterator i = objects.find(&obj);
-	if(i!=objects.end())
-	{
-		if(ev)
-			i->second = ev;
-		else
-			objects.erase(i);
+	for(vector<Slot>::iterator i=objects.begin(); i!=objects.end(); ++i)
+		if(i->object==&obj)
+		{
+			if(ev)
+				i->events = ev;
+			else
+			{
+				*i = objects.back();
+				objects.pop_back();
+				objs_changed = true;
+			}
+			events_changed = true;
+			return;
+		}
+
+	if(!ev)
+		return;
 
-		objs_changed = true;
-	}
-	else if(ev)
-	{
 #ifdef _WIN32
-		if(objects.size()>=MAXIMUM_WAIT_OBJECTS)
-			throw logic_error("Maximum number of wait objects reached");
+	if(objects.size()>=MAXIMUM_WAIT_OBJECTS)
+		throw logic_error("Maximum number of wait objects reached");
 #endif
-		objects.insert(EventMap::value_type(&obj, ev));
 
-		objs_changed = true;
-	}
+	objects.push_back(Slot(&obj, ev));
+	objs_changed = true;
 }
 
 int Poller::poll()
@@ -61,8 +67,12 @@ int Poller::poll(const Time::TimeDelta &timeout)
 
 int Poller::do_poll(int timeout)
 {
-	if(objs_changed)
+	if(objs_changed || events_changed)
+	{
 		rebuild_array();
+		events_changed = false;
+		objs_changed = false;
+	}
 
 	poll_result.clear();