Skip to content

Commit 4eea942

Browse files
Isabella Siuskriptble
authored andcommitted
GODRIVER-561 make Database.RunCommand use provided read preference for server selection
Change-Id: I2e2a2cc1783b1e0cb64d437f6a3e4e3b0124349f
1 parent 37fc458 commit 4eea942

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

mongo/database.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,10 +103,15 @@ func (db *Database) RunCommand(ctx context.Context, runCommand interface{}, opts
103103
rp = sess.CurrentRp // override with transaction read pref if specified
104104
}
105105
if rp == nil {
106-
rp = db.readPreference // inherit from db if nothing specified in options
106+
rp = readpref.Primary() // set to primary if nothing specified in options
107107
}
108108
}
109109

110+
readSelect := description.CompositeSelector([]description.ServerSelector{
111+
description.ReadPrefSelector(rp),
112+
description.LatencySelector(db.client.localThreshold),
113+
})
114+
110115
runCmdDoc, err := transformDocument(db.registry, runCommand)
111116
if err != nil {
112117
return nil, err
@@ -120,7 +125,7 @@ func (db *Database) RunCommand(ctx context.Context, runCommand interface{}, opts
120125
Clock: db.client.clock,
121126
},
122127
db.client.topology,
123-
db.writeSelector,
128+
readSelect,
124129
db.client.id,
125130
db.client.topology.SessionPool,
126131
)

0 commit comments

Comments
 (0)