diff options
author | Antonin Kral <a.kral@bobek.cz> | 2011-06-18 21:24:41 +0200 |
---|---|---|
committer | Antonin Kral <a.kral@bobek.cz> | 2011-06-18 21:24:41 +0200 |
commit | 64b33ee522375a8dc15be2875dfb7db4502259b0 (patch) | |
tree | 44979e0aaf6bb576f4a737a93e071e28809b6779 /s/client.cpp | |
parent | 4d87ff4aa74d7ae975268ac43eee152dc3f5b7e9 (diff) | |
download | mongodb-64b33ee522375a8dc15be2875dfb7db4502259b0.tar.gz |
Imported Upstream version 1.8.2
Diffstat (limited to 's/client.cpp')
-rw-r--r-- | s/client.cpp | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/s/client.cpp b/s/client.cpp index 95e3124..c0d25fb 100644 --- a/s/client.cpp +++ b/s/client.cpp @@ -100,7 +100,11 @@ namespace mongo { return; } - all.push_back( WBInfo( cid.numberLong() , w.OID() ) ); + string ident = ""; + if ( gle["instanceIdent"].type() == String ) + ident = gle["instanceIdent"].String(); + + all.push_back( WBInfo( WriteBackListener::ConnectionIdent( ident , cid.numberLong() ) , w.OID() ) ); } vector<BSONObj> ClientInfo::_handleWriteBacks( vector<WBInfo>& all , bool fromWriteBackListener ) { @@ -115,7 +119,7 @@ namespace mongo { } for ( unsigned i=0; i<all.size(); i++ ) { - res.push_back( WriteBackListener::waitFor( all[i].connectionId , all[i].id ) ); + res.push_back( WriteBackListener::waitFor( all[i].ident , all[i].id ) ); } return res; |