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

limit queueing

Browse Source
This commit is contained in:
Dwight 2007-11-18 19:15:36 -05:00
parent 4f17681bdb
commit 01986ab502
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
grid/protorecv.cpp
View File

@ -46,10 +46,25 @@ void ProtocolConnection::init() {
/* find message for fragment */
MR* CR::getPendingMsg(F *fr, EndPoint& fromAddr) {
MR *m;
map<int,MR*>::iterator i = pendingMessages.find(fr->__msgid());
if( i == pendingMessages.end() ) {
if( pendingMessages.size() > 20 ) {
cout << ".warning: pendingMessages.size()>20, ignoring msg until we dequeue" << endl;
return 0;
}
m = new MR(&pc, fr->__msgid(), fromAddr);
pendingMessages[fr->__msgid()] = m;
}
else
m = i->second;
return m;
/*
MR*& m = pendingMessages[fr->__msgid()];
if( m == 0 )
m = new MR(&pc, fr->__msgid(), fromAddr);
return m;
*/
}
void MR::removeFromReceivingList() {