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

[unet-zero-copy]: minor fixes for pref test

parent 33fc7108
...@@ -33,7 +33,7 @@ shared_ptr<SMInterface> smiInstance() ...@@ -33,7 +33,7 @@ shared_ptr<SMInterface> smiInstance()
return smi; return smi;
} }
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
static void run_senders( size_t max, const std::string& s_host, size_t count = 2000, timeout_t usecpause = 50 ) static void run_senders( size_t max, const std::string& s_host, size_t count = 3000, timeout_t usecpause = 50 )
{ {
std::vector< std::shared_ptr<UDPSocketU> > vsend; std::vector< std::shared_ptr<UDPSocketU> > vsend;
vsend.reserve(max); vsend.reserve(max);
...@@ -145,6 +145,8 @@ static void run_test( size_t max, const std::string& host ) ...@@ -145,6 +145,8 @@ static void run_test( size_t max, const std::string& host )
auto t = unisetstd::make_unique<uniset::UDPReceiveTransport>(host, begPort + i); auto t = unisetstd::make_unique<uniset::UDPReceiveTransport>(host, begPort + i);
auto r = make_shared<UNetReceiver>(std::move(t), smiInstance()); auto r = make_shared<UNetReceiver>(std::move(t), smiInstance());
r->setLockUpdate(true); r->setLockUpdate(true);
r->setReceiveTimeout(5);
r->setBufferSize(1000);
vrecv.emplace_back(r); vrecv.emplace_back(r);
} }
......
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