(UNet): added --unet-packsendpause and --unet-packsendpause-factor

extensions/UNetUDP/UNetExchange.cc

@@ -79,6 +79,8 @@ UNetExchange::UNetExchange(uniset::ObjectId objId, uniset::ObjectId shmId, const
 	int evrunTimeout = conf->getArgPInt("--" + prefix + "-evrun-timeout", it.getProp("evrunTimeout"), 60000);
 	int recvpause = conf->getArgPInt("--" + prefix + "-recvpause", it.getProp("recvpause"), 10);
 	int sendpause = conf->getArgPInt("--" + prefix + "-sendpause", it.getProp("sendpause"), 100);
+	int packsendpause = conf->getArgPInt("--" + prefix + "-packsendpause", it.getProp("packsendpause"), 5);
+	int packsendpauseFactor = conf->getArgPInt("--" + prefix + "-packsendpause-factor", it.getProp("packsendpauseFactor"), 0);
 	int updatepause = conf->getArgPInt("--" + prefix + "-updatepause", it.getProp("updatepause"), 100);
 	int lostTimeout = conf->getArgPInt("--" + prefix + "-lost-timeout", it.getProp("lostTimeout"), 2 * updatepause);
 	steptime = conf->getArgPInt("--" + prefix + "-steptime", it.getProp("steptime"), 1000);
@@ -166,6 +168,8 @@ UNetExchange::UNetExchange(uniset::ObjectId objId, uniset::ObjectId shmId, const
 			unetinfo << myname << "(init): init sender.. my node " << n_it.getProp("name") << endl;
 			sender = make_shared<UNetSender>(h, p, shm, false, s_field, s_fvalue, "unet", prefix);
 			sender->setSendPause(sendpause);
+			sender->setPackSendPause(packsendpause);
+			sender->setPackSendPauseFactor(packsendpauseFactor);
 			sender->setCheckConnectionPause(checkConnectionPause);
 			loga->add(sender->getLog());
 

extensions/UNetUDP/UNetExchange.h

@@ -123,6 +123,13 @@ namespace uniset
 		При этом внутри одной группы датчики разбиваются по пакетам согласно заданному максимальному размеру пакета
 		(см. конструктор класса UNetSender()).
 
+		\section pgUNetUDP_PackSendPause Пауза между посылкой пакетов
+		Параметр \b --prefix-packsendpause или \b packsendpause в настаройках позволяет задать паузу (в миллисекундах)
+		между посылками пакетов. Если итоговых пакетов с данными больше чем 1.
+		При этом параметр \b --prefix-packsendpause-factor или \b packsendpauseFactor позволяет указать,
+		что необходимо делать паузы не между каждым пакетом, а через каждый N пакет.
+		По умолчанию \b packsendpause=5 миллисекунд.
+
 		 \section pgUNetUDP_Stat Статистика работы канала
 		 Для возможности мониторинга работы имеются счётчики, которые можно привязать к датчикам,
 		 задав их для соответствующего узла в секции '<nodes>' конфигурационного файла.

extensions/UNetUDP/UNetSender.cc

@@ -43,6 +43,7 @@ namespace uniset
 		saddr(_host, _port),
 		sendpause(150),
 		packsendpause(5),
+		packsendpauseFactor(1),
 		activated(false),
 		packetnum(1),
 		lastcrc(0),
@@ -259,7 +260,18 @@ namespace uniset
 							break;
 
 						real_send(pk[i]);
-						msleep(packsendpause);
+
+						if( packsendpause > 0 && size > 1 )
+						{
+							if( packsendpauseFactor <= 0 )
+							{
+								msleep(packsendpause);
+							}
+							else if( i > 0 && (i % packsendpauseFactor) == 0 )
+							{
+								msleep(packsendpause);
+							}
+						}
 					}
 				}
 
@@ -565,6 +577,8 @@ namespace uniset
 		  << " lastpacknum=" << packetnum
 		  << " lastcrc=" << setw(6) << lastcrc
 		  << " items=" << items.size() << " maxAData=" << getADataSize() << " maxDData=" << getDDataSize()
+		  << " packsendpause[factor=" << packsendpauseFactor << "]=" << packsendpause
+		  << " sendpause=" << sendpause
 		  << endl
 		  << "\t   packs([sendfactor]=num): "
 		  << endl;

extensions/UNetUDP/UNetSender.h

@@ -142,6 +142,10 @@ namespace uniset
 			{
 				packsendpause = msec;
 			}
+			inline void setPackSendPauseFactor( int factor )
+			{
+				packsendpauseFactor = factor;
+			}
 
 			void setCheckConnectionPause( int msec );
 
@@ -204,6 +208,7 @@ namespace uniset
 			std::string myname = { "" };
 			timeout_t sendpause = { 150 };
 			timeout_t packsendpause = { 5 };
+			int packsendpauseFactor = { 1 };
 			timeout_t writeTimeout = { 1000 }; // msec
 			std::atomic_bool activated = { false };
 			PassiveTimer ptCheckConnection;