Commit b9411d81 authored by Pavel Vainerman's avatar Pavel Vainerman Committed by Pavel Vainerman

[unet]: minor fixes

parent 22af42bc
...@@ -880,7 +880,7 @@ void UNetExchange::initUDPTransport( UniXML::iterator n_it, ...@@ -880,7 +880,7 @@ void UNetExchange::initUDPTransport( UniXML::iterator n_it,
// т.е. это "резервный канал", то игнорируем ошибку его создания // т.е. это "резервный канал", то игнорируем ошибку его создания
// при запуске "интерфейс" может быть и не доступен... // при запуске "интерфейс" может быть и не доступен...
sender2 = nullptr; sender2 = nullptr;
unetcrit << myname << "IGNORE! reserv channel create error:" << ex.what() << endl; unetcrit << myname << "(init): IGNORE! channel2 create error: " << ex.what() << endl;
} }
continue; continue;
...@@ -1027,16 +1027,16 @@ void UNetExchange::initUDPTransport( UniXML::iterator n_it, ...@@ -1027,16 +1027,16 @@ void UNetExchange::initUDPTransport( UniXML::iterator n_it,
} }
unetinfo << myname << "(init): (node='" << n << "') add basic receiver " << transport1->ID() << endl; unetinfo << myname << "(init): (node='" << n << "') add basic receiver " << transport1->ID() << endl;
auto r = make_shared<UNetReceiver>(std::move(transport1), shm, false, prefix); auto r1 = make_shared<UNetReceiver>(std::move(transport1), shm, false, prefix);
loga->add(r->getLog()); loga->add(r1->getLog());
// на всякий принудительно разблокируем, // на всякий принудительно разблокируем,
// чтобы не зависеть от значения по умолчанию // чтобы не зависеть от значения по умолчанию
r->setLockUpdate(false); r1->setLockUpdate(false);
r->setRespondID(resp_id, resp_invert); r1->setRespondID(resp_id, resp_invert);
r->setLostPacketsID(lp_id); r1->setLostPacketsID(lp_id);
r->connectEvent( sigc::mem_fun(this, &UNetExchange::receiverEvent) ); r1->connectEvent( sigc::mem_fun(this, &UNetExchange::receiverEvent) );
shared_ptr<UNetReceiver> r2(nullptr); shared_ptr<UNetReceiver> r2(nullptr);
...@@ -1069,7 +1069,7 @@ void UNetExchange::initUDPTransport( UniXML::iterator n_it, ...@@ -1069,7 +1069,7 @@ void UNetExchange::initUDPTransport( UniXML::iterator n_it,
unetcrit << myname << "(ignore): DON`T CREATE reserve 'UNetReceiver'. error: " << ex.what() << endl; unetcrit << myname << "(ignore): DON`T CREATE reserve 'UNetReceiver'. error: " << ex.what() << endl;
} }
ReceiverInfo ri(r, r2); ReceiverInfo ri(r1, r2);
ri.setRespondID(resp_comm_id, resp_invert); ri.setRespondID(resp_comm_id, resp_invert);
ri.setLostPacketsID(lp_comm_id); ri.setLostPacketsID(lp_comm_id);
ri.setChannelNumID(numchannel_id); ri.setChannelNumID(numchannel_id);
...@@ -1172,7 +1172,7 @@ void UNetExchange::initMulticastTransport( UniXML::iterator n_it, ...@@ -1172,7 +1172,7 @@ void UNetExchange::initMulticastTransport( UniXML::iterator n_it,
// т.е. это "резервный канал", то игнорируем ошибку его создания // т.е. это "резервный канал", то игнорируем ошибку его создания
// при запуске "интерфейс" может быть и не доступен... // при запуске "интерфейс" может быть и не доступен...
sender2 = nullptr; sender2 = nullptr;
unetcrit << myname << "IGNORE! reserv channel create error:" << ex.what() << endl; unetcrit << myname << "(init): IGNORE! channel2 create error: " << ex.what() << endl;
} }
break; break;
...@@ -1182,7 +1182,7 @@ void UNetExchange::initMulticastTransport( UniXML::iterator n_it, ...@@ -1182,7 +1182,7 @@ void UNetExchange::initMulticastTransport( UniXML::iterator n_it,
// INIT RECEIVERS // INIT RECEIVERS
if( selfNode == nullptr ) if( selfNode == nullptr )
{ {
unetwarn << myname << "IGNORE! RECEIVE DISABLED.." << endl; unetwarn << myname << "(init): IGNORE! RECEIVE DISABLED.." << endl;
return; return;
} }
...@@ -1369,16 +1369,16 @@ void UNetExchange::initMulticastReceiverForNode(UniXML::iterator n_it, ...@@ -1369,16 +1369,16 @@ void UNetExchange::initMulticastReceiverForNode(UniXML::iterator n_it,
for( const auto& gr : transport1->getGroups() ) for( const auto& gr : transport1->getGroups() )
unetinfo << myname << "(init): " << gr.toString() << endl; unetinfo << myname << "(init): " << gr.toString() << endl;
auto r = make_shared<UNetReceiver>(std::move(transport1), shm, false, prefix); auto r1 = make_shared<UNetReceiver>(std::move(transport1), shm, false, prefix);
loga->add(r->getLog()); loga->add(r1->getLog());
// на всякий принудительно разблокируем, // на всякий принудительно разблокируем,
// чтобы не зависеть от значения по умолчанию // чтобы не зависеть от значения по умолчанию
r->setLockUpdate(false); r1->setLockUpdate(false);
r->setRespondID(resp_id, resp_invert); r1->setRespondID(resp_id, resp_invert);
r->setLostPacketsID(lp_id); r1->setLostPacketsID(lp_id);
r->connectEvent( sigc::mem_fun(this, &UNetExchange::receiverEvent) ); r1->connectEvent( sigc::mem_fun(this, &UNetExchange::receiverEvent) );
shared_ptr<UNetReceiver> r2(nullptr); shared_ptr<UNetReceiver> r2(nullptr);
...@@ -1416,7 +1416,7 @@ void UNetExchange::initMulticastReceiverForNode(UniXML::iterator n_it, ...@@ -1416,7 +1416,7 @@ void UNetExchange::initMulticastReceiverForNode(UniXML::iterator n_it,
unetcrit << myname << "(ignore): DON`T CREATE reserve 'UNetReceiver'. error: " << ex.what() << endl; unetcrit << myname << "(ignore): DON`T CREATE reserve 'UNetReceiver'. error: " << ex.what() << endl;
} }
ReceiverInfo ri(r, r2); ReceiverInfo ri(r1, r2);
ri.setRespondID(resp_comm_id, resp_invert); ri.setRespondID(resp_comm_id, resp_invert);
ri.setLostPacketsID(lp_comm_id); ri.setLostPacketsID(lp_comm_id);
ri.setChannelNumID(numchannel_id); ri.setChannelNumID(numchannel_id);
......
...@@ -472,7 +472,7 @@ TEST_CASE("[UNetUDP]: switching channels", "[unetudp][udp][chswitch]") ...@@ -472,7 +472,7 @@ TEST_CASE("[UNetUDP]: switching channels", "[unetudp][udp][chswitch]")
// поэтому проверить переключение нет возможности // поэтому проверить переключение нет возможности
// остаётся только проверить, что мы не "ушли" с первого канала // остаётся только проверить, что мы не "ушли" с первого канала
// т.к. на втором нет связи и мы не должны на него переключаться // т.к. на втором нет связи и мы не должны на него переключаться
msleep(recvTimeout * 2); msleep(recvTimeout * 3);
REQUIRE( ui->getValue(node1_numchannel_as) == 1 ); REQUIRE( ui->getValue(node1_numchannel_as) == 1 );
// и счётчик переключений каналов остался в нуле // и счётчик переключений каналов остался в нуле
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment