Skip to content

U
uniset2
Commit 6d07d074 authored by Pavel Vainerman's avatar Pavel Vainerman
Browse files
Options

Небольшие исправления типа ssize_t --> size_t

parent 32093382
Show whitespace changes
Inline Side-by-side
Showing with 26 additions and 27 deletions
extensions/UDPExchange/UDPExchange.cc
View file @ 6d07d074
...@@ -231,8 +231,8 @@ void UDPExchange::send() ...@@ -231,8 +231,8 @@ void UDPExchange::send()
h.dcount = mypack.size(); h.dcount = mypack.size();
if( udp->isPending(ost::Socket::pendingOutput) ) if( udp->isPending(ost::Socket::pendingOutput) )
{ {
ssize_t ret = udp->send((char*)(&h),sizeof(h)); size_t ret = udp->send((char*)(&h),sizeof(h));
if( ret<(ssize_t)sizeof(h) ) if( ret<(size_t)sizeof(h) )
{ {
cerr << myname << "(send data header): ret=" << ret << " sizeof=" << sizeof(h) << endl; cerr << myname << "(send data header): ret=" << ret << " sizeof=" << sizeof(h) << endl;
return; return;
...@@ -247,8 +247,8 @@ void UDPExchange::send() ...@@ -247,8 +247,8 @@ void UDPExchange::send()
// msleep(30); // msleep(30);
cout << myname << "(send): " << (*it) << endl; cout << myname << "(send): " << (*it) << endl;
ssize_t ret = udp->send((char*)(&(*it)),sizeof(UniSetUDP::UDPData)); size_t ret = udp->send((char*)(&(*it)),sizeof(UniSetUDP::UDPData));
if( ret<(ssize_t)sizeof(UniSetUDP::UDPData) ) if( ret<(size_t)sizeof(UniSetUDP::UDPData) )
{ {
cerr << myname << "(send data): ret=" << ret << " sizeof=" << sizeof(UniSetUDP::UDPData) << endl; cerr << myname << "(send data): ret=" << ret << " sizeof=" << sizeof(UniSetUDP::UDPData) << endl;
break; break;
......
extensions/UDPExchange/UDPNReceiver.cc
View file @ 6d07d074
...@@ -89,8 +89,8 @@ void UDPNReceiver::recv() ...@@ -89,8 +89,8 @@ void UDPNReceiver::recv()
if( udp->isInputReady(recvTimeout) ) if( udp->isInputReady(recvTimeout) )
{ {
/* /*
ssize_t ret = udp->UDPReceive::receive(&h,sizeof(h)); size_t ret = udp->UDPReceive::receive(&h,sizeof(h));
if( ret<(ssize_t)sizeof(h) ) if( ret<(size_t)sizeof(h) )
{ {
cerr << myname << "(receive): ret=" << ret << " sizeof=" << sizeof(h) << endl; cerr << myname << "(receive): ret=" << ret << " sizeof=" << sizeof(h) << endl;
return; return;
...@@ -110,18 +110,17 @@ void UDPNReceiver::recv() ...@@ -110,18 +110,17 @@ void UDPNReceiver::recv()
{ {
for( int i=0; i<h.dcount;i++ ) for( int i=0; i<h.dcount;i++ )
{ {
ssize_t ret = udp->UDPReceive::receive(&d,sizeof(d)); size_t ret = udp->UDPReceive::receive(&d,sizeof(d));
if( ret < (ssize_t)sizeof(d) ) if( ret < (size_t)sizeof(d) )
return; return;
} }
return; return;
} }
#endif #endif
cout << "***** request: " << udp->UDPSocket::getIPV4Peer() << endl;
for( int i=0; i<100;i++ ) for( int i=0; i<100;i++ )
{ {
ssize_t ret = udp->UDPReceive::receive(&d,sizeof(d)); size_t ret = udp->UDPReceive::receive(&d,sizeof(d));
if( ret<(ssize_t)sizeof(d) ) if( ret<(size_t)sizeof(d) )
{ {
cerr << myname << "(receive data " << i << "): ret=" << ret << " sizeof=" << sizeof(d) << endl; cerr << myname << "(receive data " << i << "): ret=" << ret << " sizeof=" << sizeof(d) << endl;
break; break;
......
extensions/UDPExchange/UDPReceiver.cc
View file @ 6d07d074
...@@ -212,8 +212,8 @@ void UDPReceiver::recv() ...@@ -212,8 +212,8 @@ void UDPReceiver::recv()
// receive // receive
if( udp->isInputReady(recvTimeout) ) if( udp->isInputReady(recvTimeout) )
{ {
ssize_t ret = udp->UDPReceive::receive(&h,sizeof(h)); size_t ret = udp->UDPReceive::receive(&h,sizeof(h));
if( ret<(ssize_t)sizeof(h) ) if( ret < sizeof(h) )
{ {
cerr << myname << "(receive): ret=" << ret << " sizeof=" << sizeof(h) << endl; cerr << myname << "(receive): ret=" << ret << " sizeof=" << sizeof(h) << endl;
return; return;
...@@ -233,8 +233,8 @@ void UDPReceiver::recv() ...@@ -233,8 +233,8 @@ void UDPReceiver::recv()
{ {
for( int i=0; i<h.dcount;i++ ) for( int i=0; i<h.dcount;i++ )
{ {
ssize_t ret = udp->UDPReceive::receive(&d,sizeof(d)); size_t ret = udp->UDPReceive::receive(&d,sizeof(d));
if( ret < (ssize_t)sizeof(d) ) if( ret < sizeof(d) )
return; return;
} }
return; return;
...@@ -242,8 +242,8 @@ void UDPReceiver::recv() ...@@ -242,8 +242,8 @@ void UDPReceiver::recv()
#endif #endif
for( int i=0; i<h.dcount;i++ ) for( int i=0; i<h.dcount;i++ )
{ {
ssize_t ret = udp->UDPReceive::receive(&d,sizeof(d)); size_t ret = udp->UDPReceive::receive(&d,sizeof(d));
if( ret<(ssize_t)sizeof(d) ) if( ret < sizeof(d) )
{ {
cerr << myname << "(receive data " << i << "): ret=" << ret << " sizeof=" << sizeof(d) << endl; cerr << myname << "(receive data " << i << "): ret=" << ret << " sizeof=" << sizeof(d) << endl;
break; break;
......
extensions/UDPExchange/UDPSender.cc
View file @ 6d07d074
...@@ -223,8 +223,8 @@ void UDPSender::send() ...@@ -223,8 +223,8 @@ void UDPSender::send()
h.procID = getId(); h.procID = getId();
h.dcount = mypack.size(); h.dcount = mypack.size();
// receive // receive
ssize_t ret = udp->send((char*)(&h),sizeof(h)); size_t ret = udp->send((char*)(&h),sizeof(h));
if( ret<(ssize_t)sizeof(h) ) if( ret<(size_t)sizeof(h) )
{ {
cerr << myname << "(send data header): ret=" << ret << " sizeof=" << sizeof(h) << endl; cerr << myname << "(send data header): ret=" << ret << " sizeof=" << sizeof(h) << endl;
return; return;
...@@ -235,8 +235,8 @@ void UDPSender::send() ...@@ -235,8 +235,8 @@ void UDPSender::send()
for( ; it!=mypack.dlist.end(); ++it ) for( ; it!=mypack.dlist.end(); ++it )
{ {
cout << myname << "(send): " << (*it) << endl; cout << myname << "(send): " << (*it) << endl;
ssize_t ret = udp->send((char*)(&(*it)),sizeof(*it)); size_t ret = udp->send((char*)(&(*it)),sizeof(*it));
if( ret<(ssize_t)sizeof(*it) ) if( ret<(size_t)sizeof(*it) )
{ {
cerr << myname << "(send data): ret=" << ret << " sizeof=" << sizeof(*it) << endl; cerr << myname << "(send data): ret=" << ret << " sizeof=" << sizeof(*it) << endl;
break; break;
......
extensions/UDPExchange/UNetReceiver.cc
View file @ 6d07d074
...@@ -268,14 +268,14 @@ bool UNetReceiver::recv() ...@@ -268,14 +268,14 @@ bool UNetReceiver::recv()
if( !udp->isInputReady(recvTimeout) ) if( !udp->isInputReady(recvTimeout) )
return false; return false;
ssize_t ret = udp->UDPReceive::receive(&(pack.msg),sizeof(pack.msg)); size_t ret = udp->UDPReceive::receive(&(pack.msg),sizeof(pack.msg));
if( ret < sizeof(UniSetUDP::UDPHeader) ) if( ret < sizeof(UniSetUDP::UDPHeader) )
{ {
dlog[Debug::CRIT] << myname << "(receive): FAILED header ret=" << ret << " sizeof=" << sizeof(UniSetUDP::UDPHeader) << endl; dlog[Debug::CRIT] << myname << "(receive): FAILED header ret=" << ret << " sizeof=" << sizeof(UniSetUDP::UDPHeader) << endl;
return false; return false;
} }
ssize_t sz = pack.msg.header.dcount * sizeof(UniSetUDP::UDPData) + sizeof(UniSetUDP::UDPHeader); size_t sz = pack.msg.header.dcount * sizeof(UniSetUDP::UDPData) + sizeof(UniSetUDP::UDPHeader);
if( ret < sz ) if( ret < sz )
{ {
dlog[Debug::CRIT] << myname << "(receive): FAILED data ret=" << ret << " sizeof=" << sz dlog[Debug::CRIT] << myname << "(receive): FAILED data ret=" << ret << " sizeof=" << sz
......
extensions/UDPExchange/UNetSender.cc
View file @ 6d07d074
...@@ -143,7 +143,7 @@ void UNetSender::real_send() ...@@ -143,7 +143,7 @@ void UNetSender::real_send()
if( !udp->isPending(ost::Socket::pendingOutput) ) if( !udp->isPending(ost::Socket::pendingOutput) )
return; return;
ssize_t ret = udp->send( (char*)&(mypack.msg),sz); size_t ret = udp->send( (char*)&(mypack.msg),sz);
if( ret < sz ) if( ret < sz )
dlog[Debug::CRIT] << myname << "(send): FAILED ret=" << ret << " < sizeof=" << sz << endl; dlog[Debug::CRIT] << myname << "(send): FAILED ret=" << ret << " < sizeof=" << sz << endl;
} }
......
extensions/UNet2/UNetReceiver.cc
View file @ 6d07d074
...@@ -268,14 +268,14 @@ bool UNetReceiver::recv() ...@@ -268,14 +268,14 @@ bool UNetReceiver::recv()
if( !udp->isInputReady(recvTimeout) ) if( !udp->isInputReady(recvTimeout) )
return false; return false;
ssize_t ret = udp->UDPReceive::receive(&(pack.msg),sizeof(pack.msg)); size_t ret = udp->UDPReceive::receive(&(pack.msg),sizeof(pack.msg));
if( ret < sizeof(UniSetUDP::UDPHeader) ) if( ret < sizeof(UniSetUDP::UDPHeader) )
{ {
dlog[Debug::CRIT] << myname << "(receive): FAILED header ret=" << ret << " sizeof=" << sizeof(UniSetUDP::UDPHeader) << endl; dlog[Debug::CRIT] << myname << "(receive): FAILED header ret=" << ret << " sizeof=" << sizeof(UniSetUDP::UDPHeader) << endl;
return false; return false;
} }
ssize_t sz = pack.msg.header.dcount * sizeof(UniSetUDP::UDPData) + sizeof(UniSetUDP::UDPHeader); size_t sz = pack.msg.header.dcount * sizeof(UniSetUDP::UDPData) + sizeof(UniSetUDP::UDPHeader);
if( ret < sz ) if( ret < sz )
{ {
dlog[Debug::CRIT] << myname << "(receive): FAILED data ret=" << ret << " sizeof=" << sz dlog[Debug::CRIT] << myname << "(receive): FAILED data ret=" << ret << " sizeof=" << sz
......
extensions/UNet2/UNetSender.cc
View file @ 6d07d074
...@@ -143,7 +143,7 @@ void UNetSender::real_send() ...@@ -143,7 +143,7 @@ void UNetSender::real_send()
if( !udp->isPending(ost::Socket::pendingOutput) ) if( !udp->isPending(ost::Socket::pendingOutput) )
return; return;
ssize_t ret = udp->send( (char*)&(mypack.msg),sz); size_t ret = udp->send( (char*)&(mypack.msg),sz);
if( ret < sz ) if( ret < sz )
dlog[Debug::CRIT] << myname << "(send): FAILED ret=" << ret << " < sizeof=" << sz << endl; dlog[Debug::CRIT] << myname << "(send): FAILED ret=" << ret << " < sizeof=" << sz << endl;
} }
......
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