izackp/mosh
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Always use non-blocking sockets for recvmsg()

Browse Source
This commit is contained in:
John Hood
2017-08-17 11:51:29 -04:00
parent b11d524bb7
commit f3fa4211a2
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/network/network.cc
+3 -5
View File
@@ -435,14 +435,12 @@ string Connection::recv( void )
for ( std::deque< Socket >::const_iterator it = socks.begin();
it != socks.end();
it++ ) {
bool islast = (it + 1) == socks.end();
string payload;
try {
payload = recv_one( it->fd(), !islast );
payload = recv_one( it->fd());
} catch ( NetworkException & e ) {
if ( (e.the_errno == EAGAIN)
|| (e.the_errno == EWOULDBLOCK) ) {
assert( !islast );
continue;
} else {
throw;
@@ -456,7 +454,7 @@ string Connection::recv( void )
throw NetworkException( "No packet received" );
}
string Connection::recv_one( int sock_to_recv, bool nonblocking )
string Connection::recv_one( int sock_to_recv )
{
/* receive source address, ECN, and payload in msghdr structure */
Addr packet_remote_addr;
@@ -483,7 +481,7 @@ string Connection::recv_one( int sock_to_recv, bool nonblocking )
/* receive flags */
header.msg_flags = 0;
ssize_t received_len = recvmsg( sock_to_recv, &header, nonblocking ? MSG_DONTWAIT : 0 );
ssize_t received_len = recvmsg( sock_to_recv, &header, MSG_DONTWAIT );
if ( received_len < 0 ) {
throw NetworkException( "recvmsg", errno );
src/network/network.h
+1 -1
View File
@@ -198,7 +198,7 @@ namespace Network {
void prune_sockets( void );
string recv_one( int sock_to_recv, bool nonblocking );
string recv_one( int sock_to_recv );
void set_MTU( int family );