Skip to content

Commit 3e96c2f

Browse files
committed
JAVA-428: Support new ReadPreference semantics, deprecate SlaveOK
1 parent 7d8159c commit 3e96c2f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/com/mongodb/DBTCPConnector.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,8 @@ public Response call( DB db , DBCollection coll , OutMessage m , ServerAddress h
196196

197197
@Override
198198
public Response call( DB db, DBCollection coll, OutMessage m, ServerAddress hostNeeded, int retries, ReadPreference readPref, DBDecoder decoder ) throws MongoException{
199+
if (readPref == null)
200+
readPref = ReadPreference.PRIMARY;
199201
if (readPref == ReadPreference.PRIMARY && m.hasOption( Bytes.QUERYOPTION_SLAVEOK ))
200202
readPref = ReadPreference.SECONDARY;
201203

0 commit comments

Comments
 (0)