Add ReadPreference to testMapReduceInline

breinero-zz · breinero-zz · commit b5900eb7e018 · 2012-07-17T16:15:55.000-07:00
diff --git a/src/main/com/mongodb/DB.java b/src/main/com/mongodb/DB.java
@@ -74,7 +74,7 @@ boolean obeyReadPreference(DBObject command){
         if(comString.equals("mapreduce")) {
             DBObject out = (DBObject)command.get("out");
             if(out != null){
-                Object inline = (DBObject)out.get("inline");
+                Integer inline = ((Integer)out.get("inline"));
                 return ( inline != null && inline.equals(1));
             }
             else
diff --git a/src/test/com/mongodb/JavaClientTest.java b/src/test/com/mongodb/JavaClientTest.java
@@ -472,7 +472,8 @@ public void testMapReduceInline(){
 
         MapReduceOutput out =
             c.mapReduce( "function(){ for ( var i=0; i<this.x.length; i++ ){ emit( this.x[i] , 1 ); } }" ,
-                         "function(key,values){ var sum=0; for( var i=0; i<values.length; i++ ) sum += values[i]; return sum;}" , null, MapReduceCommand.OutputType.INLINE, null);
+                         "function(key,values){ var sum=0; for( var i=0; i<values.length; i++ ) sum += values[i]; return sum;}" , 
+                         null, MapReduceCommand.OutputType.INLINE, null, ReadPreference.primaryPreferred());
 
         Map<String,Integer> m = new HashMap<String,Integer>();
         for ( DBObject r : out.results() ){

Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ boolean obeyReadPreference(DBObject command){`
`74`	`74`	`if(comString.equals("mapreduce")) {`
`75`	`75`	`DBObject out = (DBObject)command.get("out");`
`76`	`76`	`if(out != null){`
`77`		`- Object inline = (DBObject)out.get("inline");`
	`77`	`+ Integer inline = ((Integer)out.get("inline"));`
`78`	`78`	`return ( inline != null && inline.equals(1));`
`79`	`79`	`}`
`80`	`80`	`else`