Commit 85736927 authored by Pavel Vainerman's avatar Pavel Vainerman

(UNet): добавил вывод в vmonit текущиго размера очереди сообщений

parent 67fd0ead
...@@ -633,6 +633,7 @@ bool UNetReceiver::receive() ...@@ -633,6 +633,7 @@ bool UNetReceiver::receive()
try try
{ {
ssize_t ret = udp->receiveBytes(r_buf.data, sizeof(r_buf.data)); ssize_t ret = udp->receiveBytes(r_buf.data, sizeof(r_buf.data));
recvCount++;
//ssize_t ret = udp->receiveFrom(r_buf.data, sizeof(r_buf.data),saddr); //ssize_t ret = udp->receiveFrom(r_buf.data, sizeof(r_buf.data),saddr);
if( ret < 0 ) if( ret < 0 )
...@@ -688,7 +689,6 @@ bool UNetReceiver::receive() ...@@ -688,7 +689,6 @@ bool UNetReceiver::receive()
} }
rnum = pack.num; rnum = pack.num;
recvCount++;
#if 0 #if 0
cerr << myname << "(receive): recv DATA OK. ret=" << ret << " sizeof=" << sz cerr << myname << "(receive): recv DATA OK. ret=" << ret << " sizeof=" << sz
...@@ -875,7 +875,7 @@ const std::string UNetReceiver::getShortInfo() const ...@@ -875,7 +875,7 @@ const std::string UNetReceiver::getShortInfo() const
<< " waitClean=" << waitClean << " waitClean=" << waitClean
<< " ]" << " ]"
<< endl << endl
<< "\t[ recv=" << statRecvPerSec << " update=" << statUpPerSec << " per sec ]"; << "\t[ qsize=" << qpack.size() << " recv=" << statRecvPerSec << " update=" << statUpPerSec << " per sec ]";
return std::move(s.str()); return std::move(s.str());
} }
......
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