@@ -649,7 +649,7 @@ int phongo_execute_command(mongoc_client_t *client, const char *db, const bson_t
649
649
cursor -> limit = 0 ;
650
650
651
651
cid = cursor -> iface_data ;
652
- cid -> has_cursor = true;
652
+ cid -> in_batch = true;
653
653
654
654
while (bson_iter_next (& child )) {
655
655
if (BSON_ITER_IS_KEY (& child , "id" )) {
@@ -660,8 +660,8 @@ int phongo_execute_command(mongoc_client_t *client, const char *db, const bson_t
660
660
ns = bson_iter_utf8 (& child , & cursor -> nslen );
661
661
bson_strncpy (cursor -> ns , ns , sizeof cursor -> ns );
662
662
} else if (BSON_ITER_IS_KEY (& child , "firstBatch" )) {
663
- if (BSON_ITER_HOLDS_ARRAY (& child ) && bson_iter_recurse (& child , & cid -> first_batch_iter )) {
664
- cid -> in_first_batch = true;
663
+ if (BSON_ITER_HOLDS_ARRAY (& child ) && bson_iter_recurse (& child , & cid -> batch_iter )) {
664
+ cid -> in_reader = true;
665
665
}
666
666
}
667
667
}
@@ -1357,10 +1357,8 @@ void php_phongo_cursor_to_zval(zval *retval, php_phongo_cursor_t *cursor) /* {{{
1357
1357
_ADD_BOOL (zcursor , is_command );
1358
1358
_ADD_BOOL (zcursor , sent );
1359
1359
_ADD_BOOL (zcursor , done );
1360
- _ADD_BOOL (zcursor , failed );
1361
1360
_ADD_BOOL (zcursor , end_of_event );
1362
1361
_ADD_BOOL (zcursor , in_exhaust );
1363
- _ADD_BOOL (zcursor , redir_primary );
1364
1362
_ADD_BOOL (zcursor , has_fields );
1365
1363
#undef _ADD_BOOL
1366
1364
0 commit comments