Fixed readPreference for ReadBinding operations

JAVA-1954

Author: rozza

driver-core/src/main/com/mongodb/operation/GroupOperation.java

@@ -187,7 +187,7 @@ public BatchCursor<T> execute(final ReadBinding binding) {
             public BatchCursor<T> call(final ConnectionSource connectionSource, final Connection connection) {
                 return executeWrappedCommandProtocol(namespace.getDatabaseName(), getCommand(),
                                                      CommandResultDocumentCodec.create(decoder, "retval"),
-                                                     connection, transformer(connectionSource, connection));
+                                                     connection, binding.getReadPreference(), transformer(connectionSource, connection));
             }
         });
     }

driver-core/src/main/com/mongodb/operation/ListCollectionsOperation.java

@@ -175,7 +175,7 @@ public BatchCursor<T> call(final ConnectionSource source, final Connection conne
                 if (serverIsAtLeastVersionThreeDotZero(connection.getDescription())) {
                     try {
                         return executeWrappedCommandProtocol(databaseName, getCommand(), createCommandDecoder(), connection,
-                                                             commandTransformer(source));
+                                binding.getReadPreference(), commandTransformer(source));
                     } catch (MongoCommandException e) {
                         return rethrowIfNotNamespaceError(e, createEmptyBatchCursor(createNamespace(), decoder,
                                 source.getServerDescription().getAddress(), batchSize));

driver-core/src/main/com/mongodb/operation/ListIndexesOperation.java

@@ -139,7 +139,7 @@ public BatchCursor<T> call(final ConnectionSource source, final Connection conne
                 if (serverIsAtLeastVersionThreeDotZero(connection.getDescription())) {
                     try {
                         return executeWrappedCommandProtocol(namespace.getDatabaseName(), getCommand(), createCommandDecoder(), connection,
-                                                             transformer(source));
+                                binding.getReadPreference(), transformer(source));
                     } catch (MongoCommandException e) {
                         return rethrowIfNotNamespaceError(e, createEmptyBatchCursor(namespace, decoder,
                                                                                     source.getServerDescription().getAddress(), batchSize));

driver-core/src/main/com/mongodb/operation/MapReduceWithInlineResultsOperation.java

@@ -308,7 +308,7 @@ public MapReduceBatchCursor<T> execute(final ReadBinding binding) {
             public MapReduceBatchCursor<T> call(final ConnectionSource source, final Connection connection) {
                 return executeWrappedCommandProtocol(namespace.getDatabaseName(), getCommand(),
                                                      CommandResultDocumentCodec.create(decoder, "results"),
-                                                     connection, transformer(source, connection));
+                                                     connection, binding.getReadPreference(), transformer(source, connection));
             }
         });
     }

driver-core/src/main/com/mongodb/operation/UserExistsOperation.java

@@ -87,7 +87,8 @@ public void call(final AsyncConnection connection, final Throwable t) {
                 } else {
                     final SingleResultCallback<Boolean> wrappedCallback = releasingCallback(errorHandlingCallback(callback), connection);
                     if (serverIsAtLeastVersionTwoDotSix(connection.getDescription())) {
-                        executeWrappedCommandProtocolAsync(databaseName, getCommand(), connection, transformer(), wrappedCallback);
+                        executeWrappedCommandProtocolAsync(databaseName, getCommand(), new BsonDocumentCodec(), connection,
+                                binding.getReadPreference(), transformer(), wrappedCallback);
                     } else {
                         connection.queryAsync(new MongoNamespace(databaseName, "system.users"),
                                               new BsonDocument("user", new BsonString(userName)), null, 1, 0,