mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-11-30 09:06:21 +01:00
Code Issues Releases Activity

SERVER-109 windows multi send fallback

Browse Source
This commit is contained in:
Aaron 2010-05-17 17:26:44 -07:00
parent 14114b403e
commit b55098dd80
1 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
util/message.cpp
View File

@ -460,13 +460,37 @@ namespace mongo {
return;
}
}
send( toSend.allData(), "say" );
}
// sends all data or throws an exception
void MessagingPort::send( const vector< pair< char *, int > > &data, const char *context ){
#if defined(_WIN32)
// TODO use scatter/gather api
for( vector< pair< char *, int > >::const_iterator i = data.begin(); i != data.end(); ++i ) {
char * data = i->first;
int len = i->second;
while( len > 0 ) {
int ret = ::send( sock , data , len , portSendFlags );
if ( ret == -1 ) {
if ( errno != EAGAIN || _timeout == 0 ) {
log(_logLevel) << "MessagingPort " << context << " send() " << errnoWithDescription() << ' ' << farEnd.toString() << endl;
throw SocketException();
} else {
if ( !serverAlive( farEnd.toString() ) ) {
log(_logLevel) << "MessagingPort " << context << " send() remote dead " << farEnd.toString() << endl;
throw SocketException();
}
}
} else {
assert( ret <= len );
len -= ret;
data += ret;
}
}
}
#else
vector< struct iovec > d( data.size() );
for( unsigned i = 0; i < data.size(); ++i ) {
d[ i ].iov_base = data[ i ].first;
@ -504,6 +528,7 @@ namespace mongo {
}
}
}
#endif
}
void MessagingPort::recv( char * buf , int len ){