db, bugfix: crash in mongodb.

fibjs · Sep 29, 2018 · 17100aa · 17100aa
1 parent 9be8689
commit 17100aa
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/fibjs/src/db/mongo/MongoCursor.cpp b/fibjs/src/db/mongo/MongoCursor.cpp
@@ -155,7 +155,7 @@ result_t MongoCursor::forEach(v8::Local<v8::Function> func)
     v8::Local<v8::Object> o;
     Isolate* isolate = holder();
 
-    while ((hr = next(o)) != CALL_RETURN_NULL) {
+    while ((hr = next(o)) != CALL_RETURN_NULL && hr >= 0) {
         v8::Local<v8::Value> a = o;
         v8::Local<v8::Value> v = func->Call(v8::Undefined(isolate->m_isolate), 1, &a);
 
@@ -175,7 +175,7 @@ result_t MongoCursor::map(v8::Local<v8::Function> func,
     v8::Local<v8::Array> as = v8::Array::New(isolate->m_isolate);
     int32_t n = 0;
 
-    while ((hr = next(o)) != CALL_RETURN_NULL) {
+    while ((hr = next(o)) != CALL_RETURN_NULL && hr >= 0) {
         v8::Local<v8::Value> a = o;
         v8::Local<v8::Value> v = func->Call(v8::Undefined(isolate->m_isolate), 1, &a);
 
@@ -278,7 +278,7 @@ result_t MongoCursor::toArray(v8::Local<v8::Array>& retVal)
     v8::Local<v8::Array> as = v8::Array::New(holder()->m_isolate);
     int32_t n = 0;
 
-    while ((hr = next(o)) != CALL_RETURN_NULL) {
+    while ((hr = next(o)) != CALL_RETURN_NULL && hr >= 0) {
         as->Set(n, o);
         n++;
     }