1 files changed, 47 insertions, 0 deletions
diff --git a/jstests/mr_errorhandling.js b/jstests/mr_errorhandling.js
new file mode 100644
index 0000000..57724f1
--- /dev/null
+++ b/jstests/mr_errorhandling.js
@@ -0,0 +1,47 @@
+
+t = db.mr_errorhandling;
+t.drop();
+
+t.save( { a : [ 1 , 2 , 3 ] } )
+t.save( { a : [ 2 , 3 , 4 ] } )
+
+m_good = function(){
+    for ( var i=0; i<this.a.length; i++ ){
+        emit( this.a[i] , 1 );
+    }
+}
+
+m_bad = function(){
+    for ( var i=0; i<this.a.length; i++ ){
+        emit( this.a[i] );
+    }
+}
+
+r = function( k , v ){
+    var total = 0;
+    for ( var i=0; i<v.length; i++ )
+        total += v[i];
+    return total;
+}
+
+res = t.mapReduce( m_good , r );
+assert.eq( { 1 : 1 , 2 : 2 , 3 : 2 , 4 : 1 } , res.convertToSingleObject() , "A" );
+res.drop()
+
+res = null;
+
+theerror = null;
+try {
+    res = t.mapReduce( m_bad , r );
+}
+catch ( e ){
+    theerror = e.toString();
+}
+assert.isnull( res , "B1" );
+assert( theerror , "B2" );
+assert( theerror.indexOf( "emit" ) >= 0 , "B3" );
+
+// test things are still in an ok state
+res = t.mapReduce( m_good , r );
+assert.eq( { 1 : 1 , 2 : 2 , 3 : 2 , 4 : 1 } , res.convertToSingleObject() , "A" );
+res.drop()