UNet2: сделал вместо номера пакета "время". Постоянно растущие секунды..

extensions/UDPExchange/UDPPacket.h

@@ -3,9 +3,7 @@
 #ifndef UDPPacket_H_
 #define UDPPacket_H_
 // -----------------------------------------------------------------------------
-#include <list>
-#include <limits>
-#include <ostream>
+#include <cc++/socket.h>
 #include "UniSetTypes.h"
 // -----------------------------------------------------------------------------
 namespace UniSetUDP
@@ -13,7 +11,7 @@ namespace UniSetUDP
 	struct UDPHeader
 	{
 		UDPHeader():num(0),nodeID(0),procID(0),dcount(0){}
-		unsigned long num;
+		timeout_t num;
 		long nodeID;
 		long procID;
 		size_t dcount;
@@ -21,7 +19,7 @@ namespace UniSetUDP
 		friend std::ostream& operator<<( std::ostream& os, UDPHeader& p );
 	}__attribute__((packed));
 
-	static unsigned long MaxPacketNum = 50; // std::numeric_limits<unsigned long>::max();
+	// static unsigned long MaxPacketNum = 50; // std::numeric_limits<unsigned long>::max();
 
 	struct UDPData
 	{

extensions/UDPExchange/UDPReceiver.cc

@@ -300,8 +300,8 @@ void UDPReceiver::recv()
 		}
 
 
-//		cerr << myname << "(receive): recv DATA OK. ret=" << ret << " sizeof=" << sz
-//			  << " header: " << pack.msg.header << endl;
+		cerr << myname << "(receive): recv DATA OK. ret=" << ret << " sizeof=" << sz
+			  << " header: " << pack.msg.header << endl;
 /*
 		if( labs(pack.msg.header.num - pnum) > 1 )
 		{

extensions/UDPExchange/UNetReceiver.cc

@@ -146,10 +146,17 @@ void UNetReceiver::real_update()
 			qpack.pop();
 		}
 
+		cerr << "************ update recv.num=" << p.msg.header.num << " num=" << pnum << endl;
+
 		if( labs(p.msg.header.num - pnum) > 1 )
 		{
-			dlog[Debug::CRIT] << "************ FAILED! ORDER PACKETS! recv.num=" << pack.msg.header.num
+			dlog[Debug::CRIT] << "************ FAILED! ORDER PACKETS! recv.num=" << p.msg.header.num
 				  << " num=" << pnum << endl;
+
+			// запоминаем новый номер и откидываем пакет
+			pnum = p.msg.header.num;
+			k--;
+			continue;
 		}
 
 		pnum = p.msg.header.num;
@@ -251,8 +258,8 @@ bool UNetReceiver::recv()
 	}
 
 
-//	cerr << myname << "(receive): recv DATA OK. ret=" << ret << " sizeof=" << sz
-//		  << " header: " << pack.msg.header << endl;
+	cerr << myname << "(receive): recv DATA OK. ret=" << ret << " sizeof=" << sz
+		  << " header: " << pack.msg.header << endl;
 	{
 		uniset_mutex_lock l(packMutex);
 		qpack.push(pack);

extensions/UDPExchange/UNetSender.cc

@@ -17,9 +17,9 @@ sendpause(150),
 activated(false),
 dlist(100),
 maxItem(0),
-packetnum(1),
 s_thr(0)
 {
+	ptPack.setTiming(UniSetTimer::WaitUpTime);
 
 	{
 		ostringstream s;
@@ -133,7 +133,7 @@ void UNetSender::real_send()
 	h.nodeID = conf->getLocalNode();
 	h.procID = shm->ID();
 	h.dcount = mypack.msg.header.dcount;
-	h.num = packetnum++;
+	h.num = ptPack.getCurrent();
 	mypack.msg.header = h;
 
 //	cout << "************* send header: " << mypack.msg.header << endl;
@@ -143,28 +143,7 @@ void UNetSender::real_send()
 
 	ssize_t ret = udp->send( (char*)&(mypack.msg),sz);
 	if( ret < sz )
-	{
 		dlog[Debug::CRIT] << myname << "(send): FAILED ret=" << ret << " < sizeof=" << sz << endl;
-		return;
-	}
-
-	// если вышли за границы..
-	// посылаем несколько одинаковых пакетов с новыми номерами..
-	// т.к. первый будет откинут (см. UNetReceiver::update)
-	if( packetnum >= UniSetUDP::MaxPacketNum )
-	{
-		packetnum = 1;
-		for( int i=0; i<3; i++ )
-		{
-			mypack.msg.header.num = packetnum++;
-			if( udp->isPending(ost::Socket::pendingOutput) )
-			{
-				ssize_t ret = udp->send( (char*)&(mypack.msg),sz);
-				if( res < sz )
-					dlog[Debug::CRIT] << myname << "(send): FAILED. ret=" << ret << " < sizeof=" << sz << endl;
-			}
-		 }
-	}
 }
 // -----------------------------------------------------------------------------
 void UNetSender::start()

extensions/UDPExchange/UNetSender.h

@@ -14,14 +14,6 @@
 #include "UDPPacket.h"
 #include "UDPNReceiver.h"
 // -----------------------------------------------------------------------------
-/*
- * Для защиты от потери пакета при переполнении "номера пакета".
- * UNetReceiver при обнаружении "разырва" в последовательнности, просто игнорирует пакет, обновляет счётчик
- * и начинает обработку уже со следующего.
- * Соотвественно здесь, реализован следующий механизм: При переходе номера пакета через maxnum,
- * в сеть посылается один и тоже пакет данных с номерами идущими подряд.
- * В результате первй будет откинут, как идущий "не подряд", а второй - будет обработан.
- */
 class UNetSender
 {
 	public:
@@ -84,7 +76,7 @@ class UNetSender
 		typedef std::vector<UItem> DMap;
 		DMap dlist;
 		int maxItem;
-		long packetnum;
+		PassiveTimer ptPack;
 
 		ThreadCreator<UNetSender>* s_thr;	// send thread
 };