(unet2): мелкие правки

extensions/UNet2/UNetReceiver.cc

@@ -7,6 +7,7 @@ using namespace std;
 using namespace UniSetTypes;
 using namespace UniSetExtensions;
 // -----------------------------------------------------------------------------
+/*
 bool UNetReceiver::PacketCompare::operator()(const UniSetUDP::UDPMessage& lhs,
 											const UniSetUDP::UDPMessage& rhs) const
 {
@@ -15,6 +16,7 @@ bool UNetReceiver::PacketCompare::operator()(const UniSetUDP::UDPMessage& lhs,
 
 	return lhs.num > rhs.num;
 }
+*/
 // ------------------------------------------------------------------------------------------
 UNetReceiver::UNetReceiver( const std::string s_host, const ost::tpport_t port, SMInterface* smi ):
 shm(smi),
@@ -72,7 +74,6 @@ a_cache_init_ok(false)
 	r_thr = new ThreadCreator<UNetReceiver>(this, &UNetReceiver::receive);
 	u_thr = new ThreadCreator<UNetReceiver>(this, &UNetReceiver::update);
 
-
 	ptRecvTimeout.setTiming(recvTimeout);
 }
 // -----------------------------------------------------------------------------
@@ -186,8 +187,8 @@ void UNetReceiver::update()
 void UNetReceiver::real_update()
 {
 	UniSetUDP::UDPMessage p;
-	// обрабатываем пока, очередь либо не опустеет
-	// либо обнаружится "дырка" в последовательности
+	// обрабатываем, пока очередь либо не опустеет,
+	// либо обнаружится "дырка" в последовательности,
 	// но при этом обрабатываем не больше maxProcessingCount
 	// за один раз..
 	int k = maxProcessingCount;
@@ -283,7 +284,7 @@ void UNetReceiver::real_update()
 			}
 		}
 
-		// Обрабока аналоговых
+		// Обработка аналоговых
 		for( size_t i=0; i<p.acount; i++ )
 		{
 			try

extensions/UNet2/UNetReceiver.h

@@ -117,8 +117,9 @@ class UNetReceiver
 		struct PacketCompare:
 		public std::binary_function<UniSetUDP::UDPMessage, UniSetUDP::UDPMessage, bool>
 		{
-			bool operator()(const UniSetUDP::UDPMessage& lhs,
-							const UniSetUDP::UDPMessage& rhs) const;
+			inline bool operator()(const UniSetUDP::UDPMessage& lhs,
+							const UniSetUDP::UDPMessage& rhs) const
+					{ return lhs.num > rhs.num; }
 		};
 		typedef std::priority_queue<UniSetUDP::UDPMessage,std::vector<UniSetUDP::UDPMessage>,PacketCompare> PacketQueue;
 		PacketQueue qpack;	/*!< очередь принятых пакетов (отсортированных по возрастанию номера пакета) */