0
0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
This commit is contained in:
Alberto Lerner 2010-09-20 13:43:20 -04:00
parent 090d0d09ae
commit 56d8f75f9d

View File

@ -32,6 +32,8 @@
using namespace std;
namespace mongo {
// a map from mongos's serverIDs to queues of "rejected" operations
// an operation is rejected if it targets data that does not live on this shard anymore
typedef map< string , BlockingQueue<BSONObj>* > WriteBackQueuesMap;
// 'writebackQueueLock' protects only the map itself, since each queue is syncrhonized.
@ -68,7 +70,8 @@ namespace mongo {
errmsg = "need oid as first value";
return 0;
}
// get the command issuer's (a mongos) serverID
const OID id = e.__oid();
// the command issuer is blocked awaiting a response