(CommonEventLoop): переделал на активацию только одного за один раз

conf/libuniset2.spec

@@ -511,6 +511,9 @@ rm -f %buildroot%_libdir/*.la
 * Tue Sep 12 2017 Alexei Takaseev <taf@altlinux.org> 2.6-alt19.1
 - Rebuild with poco 1.7.9
 
+# * Thu Jun 01 2017 Pavel Vainerman <pv@altlinux.ru> 2.6-alt27
+# - test build (devel)
+
 # * Thu Jun 01 2017 Pavel Vainerman <pv@altlinux.ru> 2.6-alt26
 # - test build (devel)
 

include/CommonEventLoop.h

@@ -116,7 +116,7 @@ namespace uniset
 				std::promise<bool>& result;
 			};
 
-			std::queue<WatcherInfo> wactlist;
+			std::shared_ptr<WatcherInfo> wact_info = { nullptr };
 			std::mutex wact_mutex;
 			ev::async evprep;
 

src/Processes/CommonEventLoop.cc

@@ -54,17 +54,18 @@ namespace uniset
 	// ---------------------------------------------------------------------------
 	bool CommonEventLoop::activateWatcher( EvWatcher* w, size_t waitTimeout_msec )
 	{
+		std::lock_guard<std::mutex> l(wact_mutex);
+
 		std::promise<bool> p;
-		WatcherInfo winfo(w,p);
-		auto result = p.get_future();
+		wact_info = std::make_shared<WatcherInfo>(w,p);
 
-		{
-			std::unique_lock<std::mutex> l(wact_mutex);
-			wactlist.push(winfo);
-		}
+		auto result = p.get_future();
 
 		bool ret = true;
 
+		if( !evprep.is_active() )
+			evprep.start();
+
 		// посылаем сигнал для обработки
 		evprep.send(); // будим default loop
 
@@ -88,6 +89,7 @@ namespace uniset
 			}
 		}
 
+		wact_info = nullptr;
 		return ret;
 	}
 	// ---------------------------------------------------------------------------
@@ -196,25 +198,18 @@ namespace uniset
 			return;
 		}
 
-		{
-			std::lock_guard<std::mutex> lock(wact_mutex);
-
-			while( !wactlist.empty() )
-			{
-				auto winf = wactlist.front();
-				wactlist.pop();
+		if( !wact_info )
+			return;
 
-				try
-				{
-					winf.watcher->evprepare(loop);
-					winf.result.set_value(true);
-				}
-				catch( std::exception& ex )
-				{
-					cerr << "(CommonEventLoop::onPrepare): evprepare err: " << ex.what() << endl;
-					winf.result.set_value(false);
-				}
-			}
+		try
+		{
+			wact_info->watcher->evprepare(loop);
+			wact_info->result.set_value(true);
+		}
+		catch( std::exception& ex )
+		{
+			cerr << "(CommonEventLoop::onPrepare): evprepare err: " << ex.what() << endl;
+			wact_info->result.set_value(false);
 		}
 	}
 	// -------------------------------------------------------------------------