diff options
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; |