File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -482,7 +482,11 @@ void _applyMongoOptions() {
482
482
if (_options .slaveOk ) slaveOk ();
483
483
setWriteConcern ( _options .getWriteConcern () );
484
484
}
485
-
485
+
486
+ DBTCPConnector getConnector () {
487
+ return _connector ;
488
+ }
489
+
486
490
final ServerAddress _addr ;
487
491
final List <ServerAddress > _addrs ;
488
492
final MongoOptions _options ;
Original file line number Diff line number Diff line change @@ -304,6 +304,10 @@ synchronized void updateAll(){
304
304
it .remove ();
305
305
}
306
306
}
307
+
308
+ // force check on master
309
+ // otherwise master change may go unnoticed for a while if no write concern
310
+ _mongo .getConnector ().checkMaster (true , false );
307
311
}
308
312
309
313
List <ServerAddress > getServerAddressList () {
You can’t perform that action at this time.
0 commit comments