summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl
ModeNameSize
-rw-r--r--README.md127849logplain
-rw-r--r--SConscript48558logplain
-rw-r--r--abstract_async_component.cpp8377logplain
-rw-r--r--abstract_async_component.h11020logplain
-rw-r--r--abstract_async_component_test.cpp21981logplain
-rw-r--r--all_database_cloner.cpp13159logplain
-rw-r--r--all_database_cloner.h6330logplain
-rw-r--r--all_database_cloner_test.cpp27467logplain
-rw-r--r--always_allow_non_local_writes.cpp2326logplain
-rw-r--r--always_allow_non_local_writes.h2270logplain
-rw-r--r--apply_ops.cpp23023logplain
-rw-r--r--apply_ops.h4909logplain
-rw-r--r--apply_ops.idl3676logplain
-rw-r--r--apply_ops_test.cpp19583logplain
-rw-r--r--base_cloner.cpp11889logplain
-rw-r--r--base_cloner.h10653logplain
-rw-r--r--bgsync.cpp41513logplain
-rw-r--r--bgsync.h10591logplain
-rw-r--r--bson_extract_optime.cpp2360logplain
-rw-r--r--bson_extract_optime.h2414logplain
-rw-r--r--callback_completion_guard.h5871logplain
-rw-r--r--check_quorum_for_config_change.cpp13509logplain
-rw-r--r--check_quorum_for_config_change.h6598logplain
-rw-r--r--check_quorum_for_config_change_test.cpp39427logplain
-rw-r--r--cloner_test_fixture.cpp3451logplain
-rw-r--r--cloner_test_fixture.h3137logplain
-rw-r--r--cloner_utils.cpp2455logplain
-rw-r--r--cloner_utils.h2460logplain
-rw-r--r--collection_bulk_loader.h2549logplain
-rw-r--r--collection_bulk_loader_impl.cpp17029logplain
-rw-r--r--collection_bulk_loader_impl.h4642logplain
-rw-r--r--collection_cloner.cpp22760logplain
-rw-r--r--collection_cloner.h10659logplain
-rw-r--r--collection_cloner_test.cpp53199logplain
-rw-r--r--data_replicator_external_state.h5178logplain
-rw-r--r--data_replicator_external_state_impl.cpp7107logplain
-rw-r--r--data_replicator_external_state_impl.h4009logplain
-rw-r--r--data_replicator_external_state_initial_sync.cpp2577logplain
-rw-r--r--data_replicator_external_state_initial_sync.h2445logplain
-rw-r--r--data_replicator_external_state_mock.cpp4800logplain
-rw-r--r--data_replicator_external_state_mock.h4062logplain
-rw-r--r--database_cloner.cpp9227logplain
-rw-r--r--database_cloner.h4503logplain
-rw-r--r--database_cloner.idl2855logplain
-rw-r--r--database_cloner_common.cpp1848logplain
-rw-r--r--database_cloner_common.h1708logplain
-rw-r--r--database_cloner_test.cpp24940logplain
-rw-r--r--dbcheck.cpp19820logplain
-rw-r--r--dbcheck.h7838logplain
-rw-r--r--dbcheck.idl3828logplain
-rw-r--r--dbcheck_idl.cpp3988logplain
-rw-r--r--dbcheck_idl.h3223logplain
-rw-r--r--drop_pending_collection_reaper.cpp9351logplain
-rw-r--r--drop_pending_collection_reaper.h6124logplain
-rw-r--r--drop_pending_collection_reaper_test.cpp14929logplain
-rw-r--r--election_reason_counter.cpp1868logplain
-rw-r--r--election_reason_counter.h2279logplain
-rw-r--r--election_reason_counter.idl2247logplain
-rw-r--r--election_reason_counter_parser.cpp2150logplain
-rw-r--r--election_reason_counter_parser.h1936logplain
-rw-r--r--heartbeat_response_action.cpp2872logplain
-rw-r--r--heartbeat_response_action.h4654logplain
-rw-r--r--idempotency_document_structure.cpp8406logplain
-rw-r--r--idempotency_document_structure.h3676logplain
-rw-r--r--idempotency_document_structure_test.cpp16495logplain
-rw-r--r--idempotency_scalar_generator.cpp3406logplain
-rw-r--r--idempotency_scalar_generator.h2354logplain
-rw-r--r--idempotency_test.cpp13679logplain
-rw-r--r--idempotency_test_fixture.cpp18642logplain
-rw-r--r--idempotency_test_fixture.h7035logplain
-rw-r--r--idempotency_update_sequence.cpp11103logplain
-rw-r--r--idempotency_update_sequence.h4791logplain
-rw-r--r--idempotency_update_sequence_test.cpp11767logplain
-rw-r--r--initial_sync_base_cloner.cpp9725logplain
-rw-r--r--initial_sync_base_cloner.h4178logplain
-rw-r--r--initial_sync_cloner_test_fixture.cpp2582logplain
-rw-r--r--initial_sync_cloner_test_fixture.h2036logplain
-rw-r--r--initial_sync_shared_data.cpp3278logplain
-rw-r--r--initial_sync_shared_data.h7675logplain
-rw-r--r--initial_sync_shared_data_test.cpp9443logplain
-rw-r--r--initial_sync_state.h3009logplain
-rw-r--r--initial_syncer.cpp96913logplain
-rw-r--r--initial_syncer.h31883logplain
-rw-r--r--initial_syncer_test.cpp215921logplain
-rw-r--r--insert_group.cpp7391logplain
-rw-r--r--insert_group.h3451logplain
-rw-r--r--is_master_response.cpp23332logplain
-rw-r--r--is_master_response.h8715logplain
-rw-r--r--isself.cpp15013logplain
-rw-r--r--isself.h2390logplain
-rw-r--r--isself_test.cpp3292logplain
-rw-r--r--last_vote.cpp2966logplain
-rw-r--r--last_vote.h2083logplain
-rw-r--r--local_oplog_info.cpp5481logplain
-rw-r--r--local_oplog_info.h3661logplain
-rw-r--r--member_config.cpp8057logplain
-rw-r--r--member_config.h8778logplain
-rw-r--r--member_config.idl5411logplain
-rw-r--r--member_config_test.cpp41323logplain
-rw-r--r--member_data.cpp7167logplain
-rw-r--r--member_data.h10219logplain
-rw-r--r--member_id.h3882logplain
-rw-r--r--member_state.h5172logplain
-rw-r--r--mock_repl_coord_server_fixture.cpp4856logplain
-rw-r--r--mock_repl_coord_server_fixture.h2415logplain
-rw-r--r--multiapplier.cpp6518logplain
-rw-r--r--multiapplier.h5419logplain
-rw-r--r--multiapplier_test.cpp12162logplain
-rw-r--r--noop_writer.cpp7446logplain
-rw-r--r--noop_writer.h2819logplain
-rw-r--r--oplog.cpp83998logplain
-rw-r--r--oplog.h10081logplain
-rw-r--r--oplog_applier.cpp6004logplain
-rw-r--r--oplog_applier.h8932logplain
-rw-r--r--oplog_applier_impl.cpp38824logplain
-rw-r--r--oplog_applier_impl.h6924logplain
-rw-r--r--oplog_applier_impl_test.cpp170090logplain
-rw-r--r--oplog_applier_impl_test_fixture.cpp18622logplain
-rw-r--r--oplog_applier_impl_test_fixture.h9103logplain
-rw-r--r--oplog_applier_test.cpp15532logplain
-rw-r--r--oplog_applier_utils.cpp15489logplain
-rw-r--r--oplog_applier_utils.h6067logplain
-rw-r--r--oplog_batcher.cpp15115logplain
-rw-r--r--oplog_batcher.h7619logplain
-rw-r--r--oplog_batcher_test_fixture.cpp15002logplain
-rw-r--r--oplog_batcher_test_fixture.h4343logplain
-rw-r--r--oplog_buffer.h8060logplain
-rw-r--r--oplog_buffer_blocking_queue.cpp4557logplain
-rw-r--r--oplog_buffer_blocking_queue.h3187logplain
-rw-r--r--oplog_buffer_collection.cpp15510logplain
-rw-r--r--oplog_buffer_collection.h7615logplain
-rw-r--r--oplog_buffer_collection_test.cpp44913logplain
-rw-r--r--oplog_buffer_proxy.cpp4790logplain
-rw-r--r--oplog_buffer_proxy.h3532logplain
-rw-r--r--oplog_buffer_proxy_test.cpp12895logplain
-rw-r--r--oplog_entry.cpp18288logplain
-rw-r--r--oplog_entry.h15987logplain
-rw-r--r--oplog_entry.idl6219logplain
-rw-r--r--oplog_entry_or_grouped_inserts.cpp3744logplain
-rw-r--r--oplog_entry_or_grouped_inserts.h3505logplain
-rw-r--r--oplog_entry_test.cpp5965logplain
-rw-r--r--oplog_entry_test_helpers.cpp12137logplain
-rw-r--r--oplog_entry_test_helpers.h6631logplain
-rw-r--r--oplog_fetcher.cpp42593logplain
-rw-r--r--oplog_fetcher.h18172logplain
-rw-r--r--oplog_fetcher_mock.cpp8990logplain
-rw-r--r--oplog_fetcher_mock.h4188logplain
-rw-r--r--oplog_fetcher_test.cpp105795logplain
-rw-r--r--oplog_interface.h3136logplain
-rw-r--r--oplog_interface_local.cpp4422logplain
-rw-r--r--oplog_interface_local.h2220logplain
-rw-r--r--oplog_interface_mock.cpp5670logplain
-rw-r--r--oplog_interface_mock.h2661logplain
-rw-r--r--oplog_interface_remote.cpp4332logplain
-rw-r--r--oplog_interface_remote.h2605logplain
-rw-r--r--oplog_test.cpp16087logplain
-rw-r--r--optime.cpp4720logplain
-rw-r--r--optime.h6689logplain
-rw-r--r--optime_and_wall_time_base.idl2413logplain
-rw-r--r--optime_extract_test.cpp3038logplain
-rw-r--r--optime_with.h2472logplain
-rw-r--r--primary_only_service.cpp21123logplain
-rw-r--r--primary_only_service.h15162logplain
-rw-r--r--primary_only_service_op_observer.cpp3771logplain
-rw-r--r--primary_only_service_op_observer.h9075logplain
-rw-r--r--primary_only_service_test.cpp24741logplain
-rw-r--r--read_concern_args.cpp13911logplain
-rw-r--r--read_concern_args.h8601logplain
-rw-r--r--read_concern_args.idl1861logplain
-rw-r--r--read_concern_args_test.cpp22337logplain
-rw-r--r--read_concern_level.h2731logplain
-rw-r--r--repl_client_info.cpp6878logplain
-rw-r--r--repl_client_info.h4512logplain
-rw-r--r--repl_server_parameters.idl13701logplain
-rw-r--r--repl_set_command.cpp2163logplain
-rw-r--r--repl_set_command.h2430logplain
-rw-r--r--repl_set_commands.cpp32850logplain
-rw-r--r--repl_set_config.cpp29222logplain
-rw-r--r--repl_set_config.h18849logplain
-rw-r--r--repl_set_config.idl8922logplain
-rw-r--r--repl_set_config_checks.cpp18891logplain
-rw-r--r--repl_set_config_checks.h4834logplain
-rw-r--r--repl_set_config_checks_test.cpp70001logplain
-rw-r--r--repl_set_config_params.idl1857logplain
-rw-r--r--repl_set_config_test.cpp109202logplain
-rw-r--r--repl_set_config_validators.cpp2044logplain
-rw-r--r--repl_set_config_validators.h4160logplain
-rw-r--r--repl_set_get_status_cmd.cpp3279logplain
-rw-r--r--repl_set_heartbeat_args_v1.cpp6812logplain
-rw-r--r--repl_set_heartbeat_args_v1.h5381logplain
-rw-r--r--repl_set_heartbeat_response.cpp11834logplain
-rw-r--r--repl_set_heartbeat_response.h5936logplain
-rw-r--r--repl_set_heartbeat_response_test.cpp18016logplain
-rw-r--r--repl_set_request_votes.cpp3038logplain
-rw-r--r--repl_set_request_votes_args.cpp6508logplain
-rw-r--r--repl_set_request_votes_args.h3367logplain
-rw-r--r--repl_set_tag.cpp9195logplain
-rw-r--r--repl_set_tag.h10284logplain
-rw-r--r--repl_set_tag_test.cpp6467logplain
-rw-r--r--repl_set_test_egress.cpp5782logplain
-rw-r--r--repl_set_test_egress.idl2271logplain
-rw-r--r--repl_set_write_concern_mode_definitions.cpp5173logplain
-rw-r--r--repl_set_write_concern_mode_definitions.h3144logplain
-rw-r--r--repl_set_write_concern_mode_definitions_test.cpp9485logplain
-rw-r--r--repl_settings.cpp2642logplain
-rw-r--r--repl_settings.h2372logplain
-rw-r--r--repl_settings.idl2259logplain
-rw-r--r--repl_sync_shared_data.cpp2084logplain
-rw-r--r--repl_sync_shared_data.h3003logplain
-rw-r--r--replica_set_aware_service.cpp3745logplain
-rw-r--r--replica_set_aware_service.h9579logplain
-rw-r--r--replica_set_aware_service_test.cpp8122logplain
-rw-r--r--replication_auth.cpp2477logplain
-rw-r--r--replication_auth.h1913logplain
-rw-r--r--replication_consistency_markers.cpp1814logplain
-rw-r--r--replication_consistency_markers.h12625logplain
-rw-r--r--replication_consistency_markers.idl3921logplain
-rw-r--r--replication_consistency_markers_impl.cpp27021logplain
-rw-r--r--replication_consistency_markers_impl.h7103logplain
-rw-r--r--replication_consistency_markers_impl_test.cpp13306logplain
-rw-r--r--replication_consistency_markers_mock.cpp5725logplain
-rw-r--r--replication_consistency_markers_mock.h4400logplain
-rw-r--r--replication_coordinator.cpp3548logplain
-rw-r--r--replication_coordinator.h44959logplain
-rw-r--r--replication_coordinator_external_state.h11822logplain
-rw-r--r--replication_coordinator_external_state_impl.cpp48491logplain
-rw-r--r--replication_coordinator_external_state_impl.h10818logplain
-rw-r--r--replication_coordinator_external_state_mock.cpp11465logplain
-rw-r--r--replication_coordinator_external_state_mock.h9100logplain
-rw-r--r--replication_coordinator_fwd.h1628logplain
-rw-r--r--replication_coordinator_impl.cpp251071logplain
-rw-r--r--replication_coordinator_impl.h71075logplain
-rw-r--r--replication_coordinator_impl.idl3139logplain
-rw-r--r--replication_coordinator_impl_elect_v1.cpp19154logplain
-rw-r--r--replication_coordinator_impl_elect_v1_test.cpp158273logplain
-rw-r--r--replication_coordinator_impl_heartbeat.cpp54238logplain
-rw-r--r--replication_coordinator_impl_heartbeat_v1_test.cpp64510logplain
-rw-r--r--replication_coordinator_impl_reconfig_test.cpp101396logplain
-rw-r--r--replication_coordinator_impl_test.cpp393096logplain
-rw-r--r--replication_coordinator_mock.cpp23198logplain
-rw-r--r--replication_coordinator_mock.h15990logplain
-rw-r--r--replication_coordinator_noop.cpp17346logplain
-rw-r--r--replication_coordinator_noop.h12121logplain
-rw-r--r--replication_coordinator_test_fixture.cpp21638logplain
-rw-r--r--replication_coordinator_test_fixture.h11695logplain
-rw-r--r--replication_info.cpp23219logplain
-rw-r--r--replication_metrics.cpp16767logplain
-rw-r--r--replication_metrics.h6408logplain
-rw-r--r--replication_metrics.idl10089logplain
-rw-r--r--replication_process.cpp6673logplain
-rw-r--r--replication_process.h4785logplain
-rw-r--r--replication_process_test.cpp5620logplain
-rw-r--r--replication_recovery.cpp34833logplain
-rw-r--r--replication_recovery.h6556logplain
-rw-r--r--replication_recovery_mock.h2236logplain
-rw-r--r--replication_recovery_test.cpp69259logplain
-rw-r--r--replication_types.idl1784logplain
-rw-r--r--reporter.cpp14327logplain
-rw-r--r--reporter.h7854logplain
-rw-r--r--reporter_test.cpp29782logplain
-rw-r--r--roll_back_local_operations.cpp8819logplain
-rw-r--r--roll_back_local_operations.h5215logplain
-rw-r--r--roll_back_local_operations_test.cpp17133logplain
-rw-r--r--rollback.h2271logplain
-rw-r--r--rollback.idl2384logplain
-rw-r--r--rollback_checker.cpp5517logplain
-rw-r--r--rollback_checker.h6125logplain
-rw-r--r--rollback_checker_test.cpp7187logplain
-rw-r--r--rollback_impl.cpp61694logplain
-rw-r--r--rollback_impl.h20114logplain
-rw-r--r--rollback_impl.idl2458logplain
-rw-r--r--rollback_impl_test.cpp90413logplain
-rw-r--r--rollback_source.h3749logplain
-rw-r--r--rollback_source_impl.cpp4671logplain
-rw-r--r--rollback_source_impl.h3165logplain
-rw-r--r--rollback_test_fixture.cpp15168logplain
-rw-r--r--rollback_test_fixture.h13558logplain
-rw-r--r--rs_rollback.cpp106622logplain
-rw-r--r--rs_rollback.h18402logplain
-rw-r--r--rs_rollback_test.cpp132009logplain
-rw-r--r--scatter_gather_algorithm.cpp1727logplain
-rw-r--r--scatter_gather_algorithm.h3240logplain
-rw-r--r--scatter_gather_runner.cpp6738logplain
-rw-r--r--scatter_gather_runner.h5696logplain
-rw-r--r--scatter_gather_test.cpp19588logplain
-rw-r--r--session_update_tracker.cpp12819logplain
-rw-r--r--session_update_tracker.h4161logplain
-rw-r--r--speculative_auth.cpp2930logplain
-rw-r--r--speculative_auth.h1954logplain
-rw-r--r--speculative_majority_read_info.cpp3064logplain
-rw-r--r--speculative_majority_read_info.h5290logplain
-rw-r--r--speculative_majority_read_info_test.cpp5300logplain
-rw-r--r--split_horizon.cpp9657logplain
-rw-r--r--split_horizon.h4996logplain
-rw-r--r--split_horizon_test.cpp18773logplain
-rw-r--r--storage_interface.cpp2489logplain
-rw-r--r--storage_interface.h21361logplain
-rw-r--r--storage_interface_impl.cpp61294logplain
-rw-r--r--storage_interface_impl.h9685logplain
-rw-r--r--storage_interface_impl_test.cpp120239logplain
-rw-r--r--storage_interface_mock.cpp4612logplain
-rw-r--r--storage_interface_mock.h20396logplain
-rw-r--r--sync_source_feedback.cpp9971logplain
-rw-r--r--sync_source_feedback.h3641logplain
-rw-r--r--sync_source_resolver.cpp26583logplain
-rw-r--r--sync_source_resolver.h10362logplain
-rw-r--r--sync_source_resolver_test.cpp44847logplain
-rw-r--r--sync_source_selector.h3995logplain
-rw-r--r--sync_source_selector_mock.cpp3165logplain
-rw-r--r--sync_source_selector_mock.h4163logplain
-rw-r--r--task_executor_mock.cpp3644logplain
-rw-r--r--task_executor_mock.h3645logplain
-rw-r--r--task_runner.cpp6614logplain
-rw-r--r--task_runner.h5994logplain
-rw-r--r--task_runner_test.cpp12488logplain
-rw-r--r--task_runner_test_fixture.cpp2652logplain
-rw-r--r--task_runner_test_fixture.h2315logplain
-rw-r--r--tenant_all_database_cloner.cpp8586logplain
-rw-r--r--tenant_all_database_cloner.h4650logplain
-rw-r--r--tenant_all_database_cloner_test.cpp15171logplain
-rw-r--r--tenant_base_cloner.cpp2362logplain
-rw-r--r--tenant_base_cloner.h2466logplain
-rw-r--r--tenant_cloner_test_fixture.cpp2055logplain
-rw-r--r--tenant_cloner_test_fixture.h1958logplain
-rw-r--r--tenant_collection_cloner.cpp17917logplain
-rw-r--r--tenant_collection_cloner.h8548logplain
-rw-r--r--tenant_collection_cloner_test.cpp25433logplain
-rw-r--r--tenant_database_cloner.cpp11485logplain
-rw-r--r--tenant_database_cloner.h5060logplain
-rw-r--r--tenant_database_cloner_test.cpp31971logplain
-rw-r--r--tenant_migration_access_blocker.cpp10375logplain
-rw-r--r--tenant_migration_access_blocker.h7716logplain
-rw-r--r--tenant_migration_access_blocker_by_prefix.cpp4438logplain
-rw-r--r--tenant_migration_access_blocker_by_prefix.h3595logplain
-rw-r--r--tenant_migration_access_blocker_server_status_section.cpp2410logplain
-rw-r--r--tenant_migration_conflict_info.cpp2283logplain
-rw-r--r--tenant_migration_conflict_info.h2282logplain
-rw-r--r--tenant_migration_decoration.cpp1886logplain
-rw-r--r--tenant_migration_decoration.h1952logplain
-rw-r--r--tenant_migration_donor_service.cpp17811logplain
-rw-r--r--tenant_migration_donor_service.h6470logplain
-rw-r--r--tenant_migration_donor_util.cpp9114logplain
-rw-r--r--tenant_migration_donor_util.h5041logplain
-rw-r--r--tenant_migration_recipient_entry_helpers.cpp6054logplain
-rw-r--r--tenant_migration_recipient_entry_helpers.h2660logplain
-rw-r--r--tenant_migration_recipient_service.cpp7305logplain
-rw-r--r--tenant_migration_recipient_service.h3480logplain
-rw-r--r--tenant_migration_recipient_service_test.cpp6879logplain
-rw-r--r--tenant_migration_shared_data.cpp1858logplain
-rw-r--r--tenant_migration_shared_data.h2038logplain
-rw-r--r--tenant_migration_state_machine.idl5455logplain
-rw-r--r--tenant_migration_util.h2136logplain
-rw-r--r--tenant_oplog_applier.cpp22446logplain
-rw-r--r--tenant_oplog_applier.h7227logplain
-rw-r--r--tenant_oplog_applier_test.cpp31331logplain
-rw-r--r--tenant_oplog_batcher.cpp10366logplain
-rw-r--r--tenant_oplog_batcher.h4686logplain
-rw-r--r--tenant_oplog_batcher_test.cpp17605logplain
-rw-r--r--timestamp_block.cpp2221logplain
-rw-r--r--timestamp_block.h2163logplain
d---------tla_plus297logplain
-rw-r--r--topology_coordinator.cpp142335logplain
-rw-r--r--topology_coordinator.h53108logplain
-rw-r--r--topology_coordinator.idl1847logplain
-rw-r--r--topology_coordinator_v1_test.cpp363520logplain
-rw-r--r--topology_version_observer.cpp8412logplain
-rw-r--r--topology_version_observer.h6176logplain
-rw-r--r--topology_version_observer_test.cpp9280logplain
-rw-r--r--transaction_oplog_application.cpp27981logplain
-rw-r--r--transaction_oplog_application.h4035logplain
-rw-r--r--update_position_args.cpp6015logplain
-rw-r--r--update_position_args.h3403logplain
-rw-r--r--vote_requester.cpp8012logplain
-rw-r--r--vote_requester.h5298logplain
-rw-r--r--vote_requester_test.cpp31019logplain
-rw-r--r--wait_for_majority_service.cpp6781logplain
-rw-r--r--wait_for_majority_service.h3525logplain
-rw-r--r--wait_for_majority_service_test.cpp8760logplain