Lines Matching refs:bulk
217 mongoc_bulk_operation_t *bulk; in test_bulk() local
235 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_bulk()
236 BSON_ASSERT (bulk); in test_bulk()
238 mongoc_bulk_operation_insert (bulk, &doc); in test_bulk()
239 mongoc_bulk_operation_insert (bulk, &doc); in test_bulk()
240 mongoc_bulk_operation_insert (bulk, &doc); in test_bulk()
241 mongoc_bulk_operation_insert (bulk, &doc); in test_bulk()
247 mongoc_bulk_operation_update (bulk, &doc, &up, false); in test_bulk()
252 mongoc_bulk_operation_remove (bulk, &del); in test_bulk()
255 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_bulk()
272 mongoc_bulk_operation_destroy (bulk); in test_bulk()
283 mongoc_bulk_operation_t *bulk; in test_bulk_error() local
291 bulk = mongoc_bulk_operation_new (true); in test_bulk_error()
292 mongoc_bulk_operation_set_client (bulk, client); in test_bulk_error()
293 BSON_ASSERT (!mongoc_bulk_operation_execute (bulk, &reply, &error)); in test_bulk_error()
299 mongoc_bulk_operation_destroy (bulk); in test_bulk_error()
311 mongoc_bulk_operation_t *bulk; in test_bulk_error_unordered() local
331 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_bulk_error_unordered()
334 bulk, in test_bulk_error_unordered()
341 future = future_bulk_operation_execute (bulk, &reply, &error); in test_bulk_error_unordered()
377 mongoc_bulk_operation_destroy (bulk); in test_bulk_error_unordered()
385 mongoc_bulk_operation_t *bulk; in test_insert() local
403 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_insert()
404 BSON_ASSERT (bulk); in test_insert()
405 BSON_ASSERT (bulk->flags.ordered == ordered); in test_insert()
407 mongoc_bulk_operation_insert (bulk, &doc); in test_insert()
408 mongoc_bulk_operation_insert (bulk, &doc); in test_insert()
410 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_insert()
435 mongoc_bulk_operation_destroy (bulk); in test_insert()
459 mongoc_bulk_operation_t *bulk; in test_insert_check_keys() local
474 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_insert_check_keys()
475 BSON_ASSERT (bulk); in test_insert_check_keys()
477 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'$dollar': 1}")); in test_insert_check_keys()
478 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_insert_check_keys()
489 mongoc_bulk_operation_destroy (bulk); in test_insert_check_keys()
492 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_insert_check_keys()
493 BSON_ASSERT (bulk); in test_insert_check_keys()
495 mongoc_bulk_operation_insert (bulk, tmp_bson (NULL)); in test_insert_check_keys()
496 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'$dollar': 1}")); in test_insert_check_keys()
497 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_insert_check_keys()
508 mongoc_bulk_operation_destroy (bulk); in test_insert_check_keys()
511 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_insert_check_keys()
512 BSON_ASSERT (bulk); in test_insert_check_keys()
514 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'a.b': 1}")); in test_insert_check_keys()
515 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_insert_check_keys()
526 mongoc_bulk_operation_destroy (bulk); in test_insert_check_keys()
535 mongoc_bulk_operation_t *bulk; in test_upsert() local
552 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_upsert()
553 BSON_ASSERT (bulk); in test_upsert()
558 mongoc_bulk_operation_update (bulk, sel, doc, true); in test_upsert()
560 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_upsert()
575 mongoc_bulk_operation_destroy (bulk); in test_upsert()
577 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_upsert()
578 BSON_ASSERT (bulk); in test_upsert()
584 mongoc_bulk_operation_update (bulk, sel, doc, false); in test_upsert()
585 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_upsert()
602 mongoc_bulk_operation_destroy (bulk); in test_upsert()
627 mongoc_bulk_operation_t *bulk; in test_upsert_unordered_oversized() local
635 bulk = mongoc_collection_create_bulk_operation ( in test_upsert_unordered_oversized()
644 bulk, tmp_bson (NULL), u, tmp_bson ("{'upsert': true}"), &error); in test_upsert_unordered_oversized()
647 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_upsert_unordered_oversized()
662 mongoc_bulk_operation_destroy (bulk); in test_upsert_unordered_oversized()
671 mongoc_bulk_operation_t *bulk; in test_upserted_index() local
689 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_upserted_index()
690 BSON_ASSERT (bulk); in test_upserted_index()
692 mongoc_bulk_operation_insert (bulk, emp); in test_upserted_index()
693 mongoc_bulk_operation_insert (bulk, emp); in test_upserted_index()
694 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'i': 2}")); in test_upserted_index()
695 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 3}"), inc, false); in test_upserted_index()
697 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 4}"), inc, true); in test_upserted_index()
698 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'i': 5}")); in test_upserted_index()
699 mongoc_bulk_operation_remove_one (bulk, tmp_bson ("{'i': 6}")); in test_upserted_index()
700 mongoc_bulk_operation_replace_one (bulk, tmp_bson ("{'i': 7}"), emp, false); in test_upserted_index()
702 mongoc_bulk_operation_replace_one (bulk, tmp_bson ("{'i': 8}"), emp, true); in test_upserted_index()
704 mongoc_bulk_operation_replace_one (bulk, tmp_bson ("{'i': 9}"), emp, true); in test_upserted_index()
705 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'i': 10}")); in test_upserted_index()
706 mongoc_bulk_operation_insert (bulk, emp); in test_upserted_index()
707 mongoc_bulk_operation_insert (bulk, emp); in test_upserted_index()
708 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 13}"), inc, false); in test_upserted_index()
710 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 14}"), inc, true); in test_upserted_index()
711 mongoc_bulk_operation_insert (bulk, emp); in test_upserted_index()
713 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 16}"), inc, true); in test_upserted_index()
714 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 17}"), inc, true); in test_upserted_index()
716 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 18}"), inc, false); in test_upserted_index()
718 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 19}"), inc, true); in test_upserted_index()
719 mongoc_bulk_operation_replace_one (bulk, tmp_bson ("{'i': 20}"), emp, true); in test_upserted_index()
720 mongoc_bulk_operation_replace_one (bulk, tmp_bson ("{'i': 21}"), emp, true); in test_upserted_index()
721 mongoc_bulk_operation_replace_one (bulk, tmp_bson ("{'i': 22}"), emp, true); in test_upserted_index()
722 mongoc_bulk_operation_update (bulk, tmp_bson ("{'i': 23}"), inc, true); in test_upserted_index()
724 mongoc_bulk_operation_update_one (bulk, tmp_bson ("{'i': 24}"), inc, false); in test_upserted_index()
726 mongoc_bulk_operation_update_one (bulk, tmp_bson ("{'i': 25}"), inc, true); in test_upserted_index()
728 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'i': 26}")); in test_upserted_index()
729 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'i': 27}")); in test_upserted_index()
730 mongoc_bulk_operation_update_one (bulk, tmp_bson ("{'i': 28}"), inc, false); in test_upserted_index()
731 mongoc_bulk_operation_update_one (bulk, tmp_bson ("{'i': 29}"), inc, false); in test_upserted_index()
733 mongoc_bulk_operation_update (bulk, emp, inc, false); in test_upserted_index()
734 mongoc_bulk_operation_update (bulk, emp, inc, false); in test_upserted_index()
736 mongoc_bulk_operation_update_one (bulk, tmp_bson ("{'i': 32}"), inc, true); in test_upserted_index()
739 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_upserted_index()
773 mongoc_bulk_operation_destroy (bulk); in test_upserted_index()
796 mongoc_bulk_operation_t *bulk; in test_update_one() local
823 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_update_one()
824 BSON_ASSERT (bulk); in test_update_one()
828 mongoc_bulk_operation_update_one (bulk, sel, doc, true); in test_update_one()
829 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_update_one()
846 mongoc_bulk_operation_destroy (bulk); in test_update_one()
869 mongoc_bulk_operation_t *bulk; in test_replace_one() local
896 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_replace_one()
897 BSON_ASSERT (bulk); in test_replace_one()
901 mongoc_bulk_operation_replace_one (bulk, sel, doc, true); in test_replace_one()
902 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_replace_one()
919 mongoc_bulk_operation_destroy (bulk); in test_replace_one()
928 mongoc_bulk_operation_t *bulk; in _test_replace_one_check_keys() local
938 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_replace_one_check_keys()
943 bulk, tmp_bson ("{}"), tmp_bson ("{'$a': 1}"), NULL, &error); in _test_replace_one_check_keys()
952 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_replace_one_check_keys()
962 bulk, tmp_bson ("{}"), tmp_bson ("{'$a': 1}"), true); in _test_replace_one_check_keys()
964 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_replace_one_check_keys()
975 mongoc_bulk_operation_destroy (bulk); in _test_replace_one_check_keys()
1002 mongoc_bulk_operation_t *bulk; in test_upsert_large() local
1020 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_upsert_large()
1029 mongoc_bulk_operation_update (bulk, selector, &update, true); in test_upsert_large()
1032 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_upsert_large()
1047 mongoc_bulk_operation_destroy (bulk); in test_upsert_large()
1058 mongoc_bulk_operation_t *bulk; in test_upsert_huge() local
1079 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_upsert_huge()
1080 BSON_ASSERT (bulk); in test_upsert_huge()
1090 mongoc_bulk_operation_update (bulk, sel, &doc, true); in test_upsert_huge()
1091 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_upsert_huge()
1113 mongoc_bulk_operation_destroy (bulk); in test_upsert_huge()
1145 mongoc_bulk_operation_t *bulk; in test_update() local
1164 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_update()
1165 BSON_ASSERT (bulk); in test_update()
1170 mongoc_bulk_operation_update (bulk, sel, bad_update_doc, false); in test_update()
1172 BSON_ASSERT (!mongoc_bulk_operation_execute (bulk, &reply, &error)); in test_update()
1180 mongoc_bulk_operation_destroy (bulk); in test_update()
1183 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_update()
1185 mongoc_bulk_operation_update (bulk, sel, update_doc, false); in test_update()
1186 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_update()
1203 mongoc_bulk_operation_destroy (bulk); in test_update()
1228 mongoc_bulk_operation_t *bulk; in _test_update_check_keys() local
1242 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_update_check_keys()
1243 BSON_ASSERT (bulk); in _test_update_check_keys()
1251 bulk, q, u, NULL, &error); in _test_update_check_keys()
1254 bulk, q, u, NULL, &error); in _test_update_check_keys()
1263 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_update_check_keys()
1272 mongoc_bulk_operation_update (bulk, q, u, false); in _test_update_check_keys()
1274 mongoc_bulk_operation_update_one (bulk, q, u, false); in _test_update_check_keys()
1276 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_update_check_keys()
1288 mongoc_bulk_operation_destroy (bulk); in _test_update_check_keys()
1322 typedef void (*update_fn) (mongoc_bulk_operation_t *bulk,
1327 typedef bool (*update_with_opts_fn) (mongoc_bulk_operation_t *bulk,
1346 mongoc_bulk_operation_t *bulk; in _test_update_validate() local
1361 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_update_validate()
1362 BSON_ASSERT (bulk); in _test_update_validate()
1369 r = test->update_with_opts (bulk, q, bad_update, NULL, &error); in _test_update_validate()
1377 r = test->update_with_opts (bulk, q, good_update, NULL, &error); in _test_update_validate()
1379 ASSERT_CMPSIZE_T ((size_t) 1, ==, bulk->commands.len); in _test_update_validate()
1380 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_update_validate()
1385 r = test->update_with_opts (bulk, q, good_update, NULL, &error); in _test_update_validate()
1389 r = test->update_with_opts (bulk, q, bad_update, NULL, &error); in _test_update_validate()
1396 ASSERT_CMPSIZE_T ((size_t) 1, ==, bulk->commands.len); in _test_update_validate()
1397 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_update_validate()
1404 test->update (bulk, q, bad_update, false); in _test_update_validate()
1405 test->update (bulk, q, good_update, false); in _test_update_validate()
1408 ASSERT_CMPSIZE_T ((size_t) 0, ==, bulk->commands.len); in _test_update_validate()
1411 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_update_validate()
1420 test->update (bulk, q, good_update, false); in _test_update_validate()
1421 test->update (bulk, q, bad_update, false); in _test_update_validate()
1423 ASSERT_CMPSIZE_T ((size_t) 1, ==, bulk->commands.len); in _test_update_validate()
1426 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_update_validate()
1437 mongoc_bulk_operation_destroy (bulk); in _test_update_validate()
1622 mongoc_bulk_operation_t *bulk; in _test_insert_invalid() local
1635 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_insert_invalid()
1645 bulk, bad_insert, NULL, &error); in _test_insert_invalid()
1653 bulk, good_insert, NULL, &error); in _test_insert_invalid()
1655 ASSERT_CMPSIZE_T ((size_t) 1, ==, bulk->commands.len); in _test_insert_invalid()
1656 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_insert_invalid()
1662 bulk, good_insert, NULL, &error); in _test_insert_invalid()
1667 bulk, bad_insert, NULL, &error); in _test_insert_invalid()
1672 ASSERT_CMPSIZE_T ((size_t) 1, ==, bulk->commands.len); in _test_insert_invalid()
1673 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_insert_invalid()
1680 mongoc_bulk_operation_insert (bulk, bad_insert); in _test_insert_invalid()
1681 mongoc_bulk_operation_insert (bulk, good_insert); in _test_insert_invalid()
1684 ASSERT_CMPSIZE_T ((size_t) 0, ==, bulk->commands.len); in _test_insert_invalid()
1687 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_insert_invalid()
1694 mongoc_bulk_operation_insert (bulk, good_insert); in _test_insert_invalid()
1695 mongoc_bulk_operation_insert (bulk, bad_insert); in _test_insert_invalid()
1697 ASSERT_CMPSIZE_T ((size_t) 1, ==, bulk->commands.len); in _test_insert_invalid()
1700 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_insert_invalid()
1709 mongoc_bulk_operation_destroy (bulk); in _test_insert_invalid()
1751 mongoc_bulk_operation_t *bulk; in test_insert_into_system_indexes() local
1768 bulk = mongoc_collection_create_bulk_operation (system_indexes, false, NULL); in test_insert_into_system_indexes()
1770 bulk, in test_insert_into_system_indexes()
1779 i = mongoc_bulk_operation_execute (bulk, NULL, &error); in test_insert_into_system_indexes()
1797 mongoc_bulk_operation_destroy (bulk); in test_insert_into_system_indexes()
1804 typedef void (*remove_fn) (mongoc_bulk_operation_t *bulk,
1807 typedef bool (*remove_with_opts_fn) (mongoc_bulk_operation_t *bulk,
1821 mongoc_bulk_operation_t *bulk; in _test_remove_validate() local
1833 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_remove_validate()
1834 BSON_ASSERT (bulk); in _test_remove_validate()
1839 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'$a': 1}")); in _test_remove_validate()
1842 r = test->remove_with_opts (bulk, tmp_bson (NULL), NULL, &error); in _test_remove_validate()
1851 test->remove (bulk, tmp_bson (NULL)); in _test_remove_validate()
1855 ASSERT_CMPSIZE_T ((size_t) 0, ==, bulk->commands.len); in _test_remove_validate()
1858 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in _test_remove_validate()
1868 mongoc_bulk_operation_destroy (bulk); in _test_remove_validate()
1910 mongoc_bulk_operation_t *bulk; in test_index_offset() local
1933 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_index_offset()
1934 BSON_ASSERT (bulk); in test_index_offset()
1939 mongoc_bulk_operation_remove_one (bulk, sel); in test_index_offset()
1940 mongoc_bulk_operation_update (bulk, sel, doc, true); in test_index_offset()
1942 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_index_offset()
1960 mongoc_bulk_operation_destroy (bulk); in test_index_offset()
1972 mongoc_bulk_operation_t *bulk; in test_single_ordered_bulk() local
1983 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_single_ordered_bulk()
1984 BSON_ASSERT (bulk); in test_single_ordered_bulk()
1986 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'a': 1}")); in test_single_ordered_bulk()
1988 bulk, tmp_bson ("{'a': 1}"), tmp_bson ("{'$set': {'b': 1}}"), false); in test_single_ordered_bulk()
1990 bulk, tmp_bson ("{'a': 2}"), tmp_bson ("{'$set': {'b': 2}}"), true); in test_single_ordered_bulk()
1991 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'a': 3}")); in test_single_ordered_bulk()
1992 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'a': 3}")); in test_single_ordered_bulk()
1993 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_single_ordered_bulk()
2008 mongoc_bulk_operation_destroy (bulk); in test_single_ordered_bulk()
2020 mongoc_bulk_operation_t *bulk; in test_insert_continue_on_error() local
2036 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_insert_continue_on_error()
2037 mongoc_bulk_operation_insert (bulk, doc0); in test_insert_continue_on_error()
2038 mongoc_bulk_operation_insert (bulk, doc0); in test_insert_continue_on_error()
2039 mongoc_bulk_operation_insert (bulk, doc1); in test_insert_continue_on_error()
2040 mongoc_bulk_operation_insert (bulk, doc1); in test_insert_continue_on_error()
2041 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_insert_continue_on_error()
2056 mongoc_bulk_operation_destroy (bulk); in test_insert_continue_on_error()
2068 mongoc_bulk_operation_t *bulk; in test_update_continue_on_error() local
2086 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_update_continue_on_error()
2089 bulk, doc0, tmp_bson ("{'$inc': {'b': 1}}"), false); in test_update_continue_on_error()
2092 bulk, doc0, tmp_bson ("{'$set': {'a': 2}}"), false); in test_update_continue_on_error()
2095 bulk, doc1, tmp_bson ("{'$set': {'b': 2}}"), false); in test_update_continue_on_error()
2097 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_update_continue_on_error()
2121 mongoc_bulk_operation_destroy (bulk); in test_update_continue_on_error()
2133 mongoc_bulk_operation_t *bulk; in test_remove_continue_on_error() local
2152 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_remove_continue_on_error()
2154 mongoc_bulk_operation_remove_one (bulk, doc0); in test_remove_continue_on_error()
2156 mongoc_bulk_operation_remove_one (bulk, tmp_bson ("{'a': {'$bad': 1}}")); in test_remove_continue_on_error()
2158 mongoc_bulk_operation_remove_one (bulk, doc1); in test_remove_continue_on_error()
2160 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_remove_continue_on_error()
2175 mongoc_bulk_operation_destroy (bulk); in test_remove_continue_on_error()
2187 mongoc_bulk_operation_t *bulk; in test_single_error_ordered_bulk() local
2201 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_single_error_ordered_bulk()
2202 BSON_ASSERT (bulk); in test_single_error_ordered_bulk()
2203 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 1, 'a': 1}")); in test_single_error_ordered_bulk()
2205 bulk, tmp_bson ("{'b': 2}"), tmp_bson ("{'$set': {'a': 1}}"), true); in test_single_error_ordered_bulk()
2206 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 3, 'a': 2}")); in test_single_error_ordered_bulk()
2208 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_single_error_ordered_bulk()
2231 mongoc_bulk_operation_destroy (bulk); in test_single_error_ordered_bulk()
2243 mongoc_bulk_operation_t *bulk; in test_multiple_error_ordered_bulk() local
2258 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_multiple_error_ordered_bulk()
2259 BSON_ASSERT (bulk); in test_multiple_error_ordered_bulk()
2262 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 1, 'a': 1}")); in test_multiple_error_ordered_bulk()
2265 bulk, tmp_bson ("{'b': 3}"), tmp_bson ("{'$set': {'a': 2}}"), true); in test_multiple_error_ordered_bulk()
2268 bulk, tmp_bson ("{'b': 2}"), tmp_bson ("{'$set': {'a': 1}}"), true); in test_multiple_error_ordered_bulk()
2270 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 4, 'a': 3}")); in test_multiple_error_ordered_bulk()
2272 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_multiple_error_ordered_bulk()
2296 mongoc_bulk_operation_destroy (bulk); in test_multiple_error_ordered_bulk()
2308 mongoc_bulk_operation_t *bulk; in test_single_unordered_bulk() local
2319 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_single_unordered_bulk()
2320 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'a': 1}")); in test_single_unordered_bulk()
2322 bulk, tmp_bson ("{'a': 1}"), tmp_bson ("{'$set': {'b': 1}}"), false); in test_single_unordered_bulk()
2324 bulk, tmp_bson ("{'a': 2}"), tmp_bson ("{'$set': {'b': 2}}"), true); in test_single_unordered_bulk()
2325 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'a': 3}")); in test_single_unordered_bulk()
2326 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'a': 3}")); in test_single_unordered_bulk()
2327 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_single_unordered_bulk()
2342 mongoc_bulk_operation_destroy (bulk); in test_single_unordered_bulk()
2354 mongoc_bulk_operation_t *bulk; in test_single_error_unordered_bulk() local
2369 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_single_error_unordered_bulk()
2372 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 1, 'a': 1}")); in test_single_error_unordered_bulk()
2375 bulk, tmp_bson ("{'b': 2}"), tmp_bson ("{'$set': {'a': 1}}"), true); in test_single_error_unordered_bulk()
2377 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 3, 'a': 2}")); in test_single_error_unordered_bulk()
2378 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_single_error_unordered_bulk()
2398 mongoc_bulk_operation_destroy (bulk); in test_single_error_unordered_bulk()
2411 mongoc_bulk_operation_t *bulk; in _test_write_concern() local
2428 bulk = mongoc_collection_create_bulk_operation (collection, ordered, wc); in _test_write_concern()
2429 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'_id': 1}")); in _test_write_concern()
2430 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'_id': 2}")); in _test_write_concern()
2432 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_write_concern()
2556 mongoc_bulk_operation_destroy (bulk); in _test_write_concern()
2625 mongoc_bulk_operation_t *bulk; in _test_write_concern_err_api() local
2638 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_write_concern_err_api()
2639 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'_id': 1}")); in _test_write_concern_err_api()
2641 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_write_concern_err_api()
2670 mongoc_bulk_operation_destroy (bulk); in _test_write_concern_err_api()
2711 mongoc_bulk_operation_t *bulk; in test_multiple_error_unordered_bulk() local
2726 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_multiple_error_unordered_bulk()
2727 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 1, 'a': 1}")); in test_multiple_error_unordered_bulk()
2729 bulk, tmp_bson ("{'b': 2}"), tmp_bson ("{'$set': {'a': 3}}"), true); in test_multiple_error_unordered_bulk()
2731 bulk, tmp_bson ("{'b': 3}"), tmp_bson ("{'$set': {'a': 4}}"), true); in test_multiple_error_unordered_bulk()
2733 bulk, tmp_bson ("{'b': 4}"), tmp_bson ("{'$set': {'a': 3}}"), true); in test_multiple_error_unordered_bulk()
2734 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 5, 'a': 2}")); in test_multiple_error_unordered_bulk()
2735 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 6, 'a': 1}")); in test_multiple_error_unordered_bulk()
2736 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_multiple_error_unordered_bulk()
2769 mongoc_bulk_operation_destroy (bulk); in test_multiple_error_unordered_bulk()
2781 mongoc_bulk_operation_t *bulk; in _test_wtimeout_plus_duplicate_key_err() local
2794 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in _test_wtimeout_plus_duplicate_key_err()
2795 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'_id': 1}")); in _test_wtimeout_plus_duplicate_key_err()
2796 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'_id': 2}")); in _test_wtimeout_plus_duplicate_key_err()
2797 mongoc_bulk_operation_remove (bulk, tmp_bson ("{'_id': 3}")); in _test_wtimeout_plus_duplicate_key_err()
2798 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_wtimeout_plus_duplicate_key_err()
2909 mongoc_bulk_operation_destroy (bulk); in _test_wtimeout_plus_duplicate_key_err()
2937 mongoc_bulk_operation_t *bulk; in test_large_inserts_ordered() local
2962 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_large_inserts_ordered()
2963 BSON_ASSERT (bulk); in test_large_inserts_ordered()
2964 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 1, 'a': 1}")); in test_large_inserts_ordered()
2965 mongoc_bulk_operation_insert (bulk, huge_doc); in test_large_inserts_ordered()
2966 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 2, 'a': 2}")); in test_large_inserts_ordered()
2968 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_large_inserts_ordered()
2990 mongoc_bulk_operation_destroy (bulk); in test_large_inserts_ordered()
2991 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_large_inserts_ordered()
2992 BSON_ASSERT (bulk); in test_large_inserts_ordered()
3000 mongoc_bulk_operation_insert (bulk, big_doc); in test_large_inserts_ordered()
3003 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_large_inserts_ordered()
3009 mongoc_bulk_operation_destroy (bulk); in test_large_inserts_ordered()
3023 mongoc_bulk_operation_t *bulk; in test_large_inserts_unordered() local
3047 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_large_inserts_unordered()
3048 BSON_ASSERT (bulk); in test_large_inserts_unordered()
3049 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 1, 'a': 1}")); in test_large_inserts_unordered()
3052 mongoc_bulk_operation_insert (bulk, huge_doc); in test_large_inserts_unordered()
3053 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'b': 2, 'a': 2}")); in test_large_inserts_unordered()
3055 r = (bool) mongoc_bulk_operation_execute (bulk, &reply, &error); in test_large_inserts_unordered()
3081 mongoc_bulk_operation_destroy (bulk); in test_large_inserts_unordered()
3082 bulk = mongoc_collection_create_bulk_operation (collection, false, NULL); in test_large_inserts_unordered()
3083 BSON_ASSERT (bulk); in test_large_inserts_unordered()
3091 mongoc_bulk_operation_insert (bulk, big_doc); in test_large_inserts_unordered()
3094 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in test_large_inserts_unordered()
3102 mongoc_bulk_operation_destroy (bulk); in test_large_inserts_unordered()
3113 mongoc_bulk_operation_t *bulk; in _test_numerous() local
3127 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in _test_numerous()
3136 mongoc_bulk_operation_insert (bulk, &doc); in _test_numerous()
3139 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in _test_numerous()
3146 mongoc_bulk_operation_destroy (bulk); in _test_numerous()
3147 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in _test_numerous()
3152 mongoc_bulk_operation_remove_one (bulk, &doc); in _test_numerous()
3155 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in _test_numerous()
3162 mongoc_bulk_operation_destroy (bulk); in _test_numerous()
3163 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in _test_numerous()
3168 mongoc_bulk_operation_remove (bulk, &doc); in _test_numerous()
3171 ASSERT_OR_PRINT ((bool) mongoc_bulk_operation_execute (bulk, &reply, &error), in _test_numerous()
3178 mongoc_bulk_operation_destroy (bulk); in _test_numerous()
3278 mongoc_bulk_operation_t *bulk; in test_bulk_edge_case_372() local
3293 bulk = mongoc_collection_create_bulk_operation (collection, ordered, NULL); in test_bulk_edge_case_372()
3294 BSON_ASSERT (bulk); in test_bulk_edge_case_372()
3298 mongoc_bulk_operation_update_one (bulk, selector, update, true); in test_bulk_edge_case_372()
3302 mongoc_bulk_operation_replace_one (bulk, selector, update, true); in test_bulk_edge_case_372()
3308 mongoc_bulk_operation_replace_one (bulk, selector, update, true); in test_bulk_edge_case_372()
3313 mongoc_bulk_operation_replace_one (bulk, selector, update, true); in test_bulk_edge_case_372()
3316 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_bulk_edge_case_372()
3341 mongoc_bulk_operation_destroy (bulk); in test_bulk_edge_case_372()
3364 mongoc_bulk_operation_t *bulk; in test_bulk_new() local
3377 bulk = mongoc_bulk_operation_new (true); in test_bulk_new()
3378 mongoc_bulk_operation_destroy (bulk); in test_bulk_new()
3380 bulk = mongoc_bulk_operation_new (true); in test_bulk_new()
3382 r = mongoc_bulk_operation_execute (bulk, NULL, &error); in test_bulk_new()
3387 mongoc_bulk_operation_set_database (bulk, "test"); in test_bulk_new()
3388 r = mongoc_bulk_operation_execute (bulk, NULL, &error); in test_bulk_new()
3393 mongoc_bulk_operation_set_collection (bulk, "test"); in test_bulk_new()
3394 r = mongoc_bulk_operation_execute (bulk, NULL, &error); in test_bulk_new()
3399 mongoc_bulk_operation_set_client (bulk, client); in test_bulk_new()
3400 r = mongoc_bulk_operation_execute (bulk, NULL, &error); in test_bulk_new()
3405 mongoc_bulk_operation_insert (bulk, &empty); in test_bulk_new()
3406 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, NULL, &error), error); in test_bulk_new()
3408 mongoc_bulk_operation_destroy (bulk); in test_bulk_new()
3468 mongoc_bulk_operation_t *bulk; in _test_legacy_write_err() local
3493 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_legacy_write_err()
3497 mongoc_bulk_operation_insert (bulk, doc); in _test_legacy_write_err()
3501 bulk, doc, tmp_bson ("{'$inc': {'x': 1}}"), false); in _test_legacy_write_err()
3504 mongoc_bulk_operation_remove (bulk, doc); in _test_legacy_write_err()
3512 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_legacy_write_err()
3569 mongoc_bulk_operation_destroy (bulk); in _test_legacy_write_err()
3588 mongoc_bulk_operation_t *bulk; in test_bulk_write_concern_over_1000() local
3607 bulk = mongoc_bulk_operation_new (true); in test_bulk_write_concern_over_1000()
3608 mongoc_bulk_operation_set_database (bulk, "test"); in test_bulk_write_concern_over_1000()
3609 mongoc_bulk_operation_set_collection (bulk, str); in test_bulk_write_concern_over_1000()
3611 mongoc_bulk_operation_set_write_concern (bulk, write_concern); in test_bulk_write_concern_over_1000()
3612 mongoc_bulk_operation_set_client (bulk, client); in test_bulk_write_concern_over_1000()
3618 mongoc_bulk_operation_insert (bulk, &doc); in test_bulk_write_concern_over_1000()
3623 success = mongoc_bulk_operation_execute (bulk, NULL, &error); in test_bulk_write_concern_over_1000()
3639 mongoc_bulk_operation_destroy (bulk); in test_bulk_write_concern_over_1000()
3674 mongoc_bulk_operation_t *bulk; in _test_bulk_hint() local
3699 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in _test_bulk_hint()
3700 ASSERT_CMPUINT32 ((uint32_t) 0, ==, mongoc_bulk_operation_get_hint (bulk)); in _test_bulk_hint()
3707 mongoc_bulk_operation_set_hint (bulk, server_id); in _test_bulk_hint()
3708 ASSERT_CMPUINT32 (server_id, ==, mongoc_bulk_operation_get_hint (bulk)); in _test_bulk_hint()
3709 mongoc_bulk_operation_insert (bulk, tmp_bson ("{'_id': 1}")); in _test_bulk_hint()
3710 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_bulk_hint()
3742 mongoc_bulk_operation_destroy (bulk); in _test_bulk_hint()
3810 mongoc_bulk_operation_t *bulk; in test_bulk_reply_w0() local
3818 bulk = mongoc_collection_create_bulk_operation (collection, true, wc); in test_bulk_reply_w0()
3819 mongoc_bulk_operation_insert (bulk, tmp_bson ("{}")); in test_bulk_reply_w0()
3821 bulk, tmp_bson ("{}"), tmp_bson ("{'$set': {'x': 1}}"), false); in test_bulk_reply_w0()
3822 mongoc_bulk_operation_remove (bulk, tmp_bson ("{}")); in test_bulk_reply_w0()
3824 ASSERT_OR_PRINT (mongoc_bulk_operation_execute (bulk, &reply, &error), in test_bulk_reply_w0()
3830 mongoc_bulk_operation_destroy (bulk); in test_bulk_reply_w0()
3851 mongoc_bulk_operation_t *bulk; in _test_bulk_collation() local
3877 bulk = mongoc_collection_create_bulk_operation (collection, true, wc); in _test_bulk_collation()
3881 bulk, tmp_bson ("{'_id': 1}"), opts, &error); in _test_bulk_collation()
3893 bulk, tmp_bson ("{'_id': 2}"), opts, &error); in _test_bulk_collation()
3905 bulk, tmp_bson ("{'_id': 3}"), tmp_bson ("{'_id': 4}"), opts, &error); in _test_bulk_collation()
3917 bulk, in _test_bulk_collation()
3934 bulk, in _test_bulk_collation()
3953 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_bulk_collation()
3984 mongoc_bulk_operation_destroy (bulk); in _test_bulk_collation()
3998 mongoc_bulk_operation_t *bulk; in _test_bulk_collation_multi() local
4023 bulk = mongoc_collection_create_bulk_operation (collection, true, wc); in _test_bulk_collation_multi()
4025 bulk, tmp_bson ("{'_id': 1}"), NULL, &error); in _test_bulk_collation_multi()
4027 bulk, tmp_bson ("{'_id': 2}"), opts, &error); in _test_bulk_collation_multi()
4028 future = future_bulk_operation_execute (bulk, &reply, &error); in _test_bulk_collation_multi()
4068 mongoc_bulk_operation_destroy (bulk); in _test_bulk_collation_multi()
4144 mongoc_bulk_operation_t *bulk; in test_bulk_update_one_error_message() local
4150 bulk = mongoc_collection_create_bulk_operation (collection, true, NULL); in test_bulk_update_one_error_message()
4152 bulk, in test_bulk_update_one_error_message()
4165 mongoc_bulk_operation_destroy (bulk); in test_bulk_update_one_error_message()