diff options
author | Shin Yee Tan <shinyee.tan@mongodb.com> | 2022-07-07 20:24:14 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-07-08 17:16:06 +0000 |
commit | 8d1d449eda96aa774572672c6ceb46da139b31e0 (patch) | |
tree | e6bfca7b9d03d600fcd5d5115fe5490020ffac5d /src/mongo | |
parent | 875f2fa02fe59ec0c97224063dbe545db7666ef3 (diff) | |
download | mongo-8d1d449eda96aa774572672c6ceb46da139b31e0.tar.gz |
SERVER-67507 Move op_observer files to op_observer directory
Diffstat (limited to 'src/mongo')
133 files changed, 302 insertions, 296 deletions
diff --git a/src/mongo/db/SConscript b/src/mongo/db/SConscript index cfc2ef5e665..f579193a566 100644 --- a/src/mongo/db/SConscript +++ b/src/mongo/db/SConscript @@ -33,6 +33,7 @@ env.SConscript( 'process_health', 'index', 'matcher', + 'op_observer', 'ops', 'pipeline', 'query', @@ -1047,68 +1048,6 @@ env.Library( ) env.Library( - target="op_observer", - source=[ - "op_observer.cpp", - ], - LIBDEPS=[ - '$BUILD_DIR/mongo/base', - ], -) - -env.Library( - target="op_observer_util", - source=[ - "op_observer_util.cpp", - ], - LIBDEPS=[ - '$BUILD_DIR/mongo/base', - ], - LIBDEPS_PRIVATE=[ - 'bson/dotted_path_support', - 'catalog/collection_options', - 'index/index_descriptor', - 's/sharding_api_d', - ], -) - -env.Library( - target="op_observer_impl", - source=[ - "op_observer_impl.cpp", - ], - LIBDEPS_PRIVATE=[ - '$BUILD_DIR/mongo/base', - '$BUILD_DIR/mongo/db/catalog/collection_catalog', - '$BUILD_DIR/mongo/db/catalog/collection_options', - '$BUILD_DIR/mongo/db/catalog/commit_quorum_options', - '$BUILD_DIR/mongo/db/catalog/database_holder', - '$BUILD_DIR/mongo/db/catalog/import_collection_oplog_entry', - '$BUILD_DIR/mongo/db/concurrency/exception_util', - '$BUILD_DIR/mongo/db/pipeline/change_stream_pre_image_helpers', - '$BUILD_DIR/mongo/db/pipeline/change_stream_preimage', - '$BUILD_DIR/mongo/db/repl/image_collection_entry', - '$BUILD_DIR/mongo/db/repl/oplog', - '$BUILD_DIR/mongo/db/repl/repl_server_parameters', - '$BUILD_DIR/mongo/db/repl/tenant_migration_access_blocker', - '$BUILD_DIR/mongo/db/s/sharding_api_d', - '$BUILD_DIR/mongo/db/timeseries/bucket_catalog', - '$BUILD_DIR/mongo/db/views/views_mongod', - '$BUILD_DIR/mongo/s/coreshard', - '$BUILD_DIR/mongo/s/grid', - 'batched_write_context', - 'dbhelpers', - 'internal_transactions_feature_flag', - 'multitenancy', - 'op_observer', - 'op_observer_util', - 'read_write_concern_defaults', - 'server_feature_flags', - 'transaction', - ], -) - -env.Library( target="batched_write_context", source=[ "batched_write_context.cpp", @@ -1119,36 +1058,6 @@ env.Library( ) env.Library( - target="fcv_op_observer", - source=[ - "fcv_op_observer.cpp", - ], - LIBDEPS_PRIVATE=[ - '$BUILD_DIR/mongo/base', - '$BUILD_DIR/mongo/db/commands/mongod_fcv', - '$BUILD_DIR/mongo/db/kill_sessions_local', - '$BUILD_DIR/mongo/executor/egress_tag_closer_manager', - 'op_observer', - 'op_observer_util', - ], -) - -env.Library( - target="user_write_block_mode_op_observer", - source=[ - "user_write_block_mode_op_observer.cpp", - ], - LIBDEPS=[ - '$BUILD_DIR/mongo/base', - 'op_observer', - ], - LIBDEPS_PRIVATE=[ - '$BUILD_DIR/mongo/db/s/sharding_api_d', - '$BUILD_DIR/mongo/db/s/user_writes_recoverable_critical_section', - ], -) - -env.Library( target="service_entry_point_common", source=[ "service_entry_point_common.cpp", @@ -2176,8 +2085,8 @@ env.Library( 'service_context', ], LIBDEPS_PRIVATE=[ + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/util/clock_source_mock', - 'op_observer', ], ) @@ -2511,7 +2420,6 @@ env.Library( 'commands/shell_protocol', 'concurrency/flow_control_ticketholder', 'concurrency/lock_manager', - 'fcv_op_observer', 'fle_crud_mongod', 'free_mon/free_mon_mongod', 'ftdc/ftdc_mongod', @@ -2525,7 +2433,9 @@ env.Library( 'mirror_maestro', 'mongod_initializers', 'mongod_options', - 'op_observer', + 'op_observer/fcv_op_observer', + 'op_observer/op_observer', + 'op_observer/user_write_block_mode_op_observer', 'periodic_runner_job_abort_expired_transactions', 'pipeline/process_interface/mongod_process_interface_factory', 'repl/drop_pending_collection_reaper', @@ -2556,7 +2466,6 @@ env.Library( 'storage/storage_engine_common', 'system_index', 'ttl_d', - 'user_write_block_mode_op_observer', 'vector_clock', ], LIBDEPS_TAGS=[ @@ -2623,6 +2532,7 @@ env.Library( '$BUILD_DIR/mongo/db/catalog/database_holder', '$BUILD_DIR/mongo/db/index/index_access_method_factory', '$BUILD_DIR/mongo/db/index/index_access_methods', + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/db/repl/replmocks', '$BUILD_DIR/mongo/db/s/sharding_api_d', '$BUILD_DIR/mongo/db/storage/storage_control', @@ -2630,7 +2540,6 @@ env.Library( '$BUILD_DIR/mongo/db/storage/wiredtiger/storage_wiredtiger', '$BUILD_DIR/mongo/rpc/rpc', '$BUILD_DIR/mongo/unittest/unittest', - 'op_observer', 'service_context_d', ], ) @@ -2689,8 +2598,9 @@ if wiredtiger: 'mirroring_sampler_test.cpp', 'multi_key_path_tracker_test.cpp', 'namespace_string_test.cpp', - 'op_observer_impl_test.cpp', - 'op_observer_registry_test.cpp', + 'op_observer/op_observer_impl_test.cpp', + 'op_observer/op_observer_registry_test.cpp', + 'op_observer/user_write_block_mode_op_observer_test.cpp', 'operation_context_test.cpp', 'operation_cpu_timer_test.cpp', 'operation_id_test.cpp', @@ -2713,7 +2623,6 @@ if wiredtiger: 'transaction_participant_test.cpp', 'ttl_test.cpp', 'update_index_data_test.cpp', - 'user_write_block_mode_op_observer_test.cpp', 'vector_clock_mongod_test.cpp', 'vector_clock_test.cpp', 'wire_version_test.cpp', @@ -2737,6 +2646,11 @@ if wiredtiger: '$BUILD_DIR/mongo/db/catalog/local_oplog_info', '$BUILD_DIR/mongo/db/change_streams_cluster_parameter', '$BUILD_DIR/mongo/db/mongohasher', + '$BUILD_DIR/mongo/db/op_observer/fcv_op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/op_observer_util', + '$BUILD_DIR/mongo/db/op_observer/user_write_block_mode_op_observer', '$BUILD_DIR/mongo/db/ops/write_ops', '$BUILD_DIR/mongo/db/pipeline/change_stream_expired_pre_image_remover', '$BUILD_DIR/mongo/db/query/common_query_enums_and_helpers', @@ -2772,7 +2686,6 @@ if wiredtiger: 'curop', 'dbdirectclient', 'dbmessage', - 'fcv_op_observer', 'fle_crud', 'fle_mocks', 'index_build_entry_helpers', @@ -2788,9 +2701,6 @@ if wiredtiger: 'multitenancy', 'multitenancy_params', 'namespace_string', - 'op_observer', - 'op_observer_impl', - 'op_observer_util', 'operation_time_tracker', 'query_exec', 'range_arithmetic', @@ -2816,7 +2726,6 @@ if wiredtiger: 'transaction_api', 'ttl_d', 'update_index_data', - 'user_write_block_mode_op_observer', 'vector_clock', 'vector_clock_test_fixture', 'write_concern_options', diff --git a/src/mongo/db/auth/SConscript b/src/mongo/db/auth/SConscript index d4c63b1b5de..1df94b4707b 100644 --- a/src/mongo/db/auth/SConscript +++ b/src/mongo/db/auth/SConscript @@ -84,8 +84,8 @@ env.Library( '$BUILD_DIR/mongo/db/audit', '$BUILD_DIR/mongo/db/catalog/collection_options', '$BUILD_DIR/mongo/db/index/index_descriptor', - '$BUILD_DIR/mongo/db/op_observer', - '$BUILD_DIR/mongo/db/op_observer_util', + '$BUILD_DIR/mongo/db/op_observer/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer_util', '$BUILD_DIR/mongo/db/repl/oplog_entry', 'auth', ], diff --git a/src/mongo/db/auth/auth_op_observer.cpp b/src/mongo/db/auth/auth_op_observer.cpp index 167ae156b71..f7a77a7c2a6 100644 --- a/src/mongo/db/auth/auth_op_observer.cpp +++ b/src/mongo/db/auth/auth_op_observer.cpp @@ -34,7 +34,7 @@ #include "mongo/db/audit.h" #include "mongo/db/auth/authorization_manager.h" #include "mongo/db/catalog/collection_options.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/oplog_entry.h" diff --git a/src/mongo/db/auth/auth_op_observer.h b/src/mongo/db/auth/auth_op_observer.h index 4c5b1692dd2..4b2cfffae2b 100644 --- a/src/mongo/db/auth/auth_op_observer.h +++ b/src/mongo/db/auth/auth_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/catalog/SConscript b/src/mongo/db/catalog/SConscript index 63c2608226b..d30c944fd9e 100644 --- a/src/mongo/db/catalog/SConscript +++ b/src/mongo/db/catalog/SConscript @@ -366,7 +366,7 @@ env.Library( '$BUILD_DIR/mongo/db/index/index_access_method_factory', '$BUILD_DIR/mongo/db/index/index_access_methods', '$BUILD_DIR/mongo/db/multitenancy', - '$BUILD_DIR/mongo/db/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/db/record_id_helpers', '$BUILD_DIR/mongo/db/repl/drop_pending_collection_reaper', '$BUILD_DIR/mongo/db/repl/oplog', @@ -651,8 +651,8 @@ if wiredtiger: '$BUILD_DIR/mongo/db/matcher/expressions', '$BUILD_DIR/mongo/db/multitenancy', '$BUILD_DIR/mongo/db/namespace_string', - '$BUILD_DIR/mongo/db/op_observer', - '$BUILD_DIR/mongo/db/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', '$BUILD_DIR/mongo/db/query/datetime/date_time_support', '$BUILD_DIR/mongo/db/query/query_test_service_context', '$BUILD_DIR/mongo/db/repl/drop_pending_collection_reaper', diff --git a/src/mongo/db/catalog/capped_utils.cpp b/src/mongo/db/catalog/capped_utils.cpp index 44556e8977c..00f823bf3cb 100644 --- a/src/mongo/db/catalog/capped_utils.cpp +++ b/src/mongo/db/catalog/capped_utils.cpp @@ -44,7 +44,7 @@ #include "mongo/db/curop.h" #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/internal_plans.h" #include "mongo/db/query/plan_yield_policy.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/catalog/coll_mod.cpp b/src/mongo/db/catalog/coll_mod.cpp index 624b69e758d..56011cd73e1 100644 --- a/src/mongo/db/catalog/coll_mod.cpp +++ b/src/mongo/db/catalog/coll_mod.cpp @@ -48,7 +48,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/s/collection_sharding_state.h" #include "mongo/db/s/database_sharding_state.h" diff --git a/src/mongo/db/catalog/coll_mod_index.h b/src/mongo/db/catalog/coll_mod_index.h index ed6f24f4dd5..a00413a33bb 100644 --- a/src/mongo/db/catalog/coll_mod_index.h +++ b/src/mongo/db/catalog/coll_mod_index.h @@ -31,7 +31,7 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/coll_mod_gen.h" #include "mongo/db/index/index_descriptor.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/storage/key_string.h" diff --git a/src/mongo/db/catalog/collection_impl.cpp b/src/mongo/db/catalog/collection_impl.cpp index 16560953def..1410dcd4981 100644 --- a/src/mongo/db/catalog/collection_impl.cpp +++ b/src/mongo/db/catalog/collection_impl.cpp @@ -59,7 +59,7 @@ #include "mongo/db/matcher/expression_always_boolean.h" #include "mongo/db/matcher/expression_parser.h" #include "mongo/db/matcher/implicit_validator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/ops/update_request.h" #include "mongo/db/query/collation/collator_factory_interface.h" diff --git a/src/mongo/db/catalog/create_collection.cpp b/src/mongo/db/catalog/create_collection.cpp index 2d145eca2e1..7cc18a97b12 100644 --- a/src/mongo/db/catalog/create_collection.cpp +++ b/src/mongo/db/catalog/create_collection.cpp @@ -48,7 +48,7 @@ #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/ops/insert.h" #include "mongo/db/query/collation/collator_factory_interface.h" diff --git a/src/mongo/db/catalog/database_holder_impl.cpp b/src/mongo/db/catalog/database_holder_impl.cpp index 31275bfe514..752a6288f91 100644 --- a/src/mongo/db/catalog/database_holder_impl.cpp +++ b/src/mongo/db/catalog/database_holder_impl.cpp @@ -38,7 +38,7 @@ #include "mongo/db/catalog/database_impl.h" #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/service_context.h" #include "mongo/db/stats/top.h" diff --git a/src/mongo/db/catalog/database_impl.cpp b/src/mongo/db/catalog/database_impl.cpp index 4b5440a42fd..1c71aa4e933 100644 --- a/src/mongo/db/catalog/database_impl.cpp +++ b/src/mongo/db/catalog/database_impl.cpp @@ -54,7 +54,7 @@ #include "mongo/db/index/index_access_method.h" #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/introspect.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/collation/collator_factory_interface.h" #include "mongo/db/query/query_knobs_gen.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" diff --git a/src/mongo/db/catalog/database_test.cpp b/src/mongo/db/catalog/database_test.cpp index 811c30afdd6..a42652457b1 100644 --- a/src/mongo/db/catalog/database_test.cpp +++ b/src/mongo/db/catalog/database_test.cpp @@ -41,9 +41,9 @@ #include "mongo/db/index/index_descriptor.h" #include "mongo/db/jsobj.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog.h" diff --git a/src/mongo/db/catalog/drop_database.cpp b/src/mongo/db/catalog/drop_database.cpp index 3aabb37e237..a0d59ea05ca 100644 --- a/src/mongo/db/catalog/drop_database.cpp +++ b/src/mongo/db/catalog/drop_database.cpp @@ -40,7 +40,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/curop.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/service_context.h" diff --git a/src/mongo/db/catalog/drop_database_test.cpp b/src/mongo/db/catalog/drop_database_test.cpp index e14cf74b809..8ded03ceb48 100644 --- a/src/mongo/db/catalog/drop_database_test.cpp +++ b/src/mongo/db/catalog/drop_database_test.cpp @@ -40,9 +40,9 @@ #include "mongo/db/db_raii.h" #include "mongo/db/jsobj.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog.h" diff --git a/src/mongo/db/catalog/drop_indexes.cpp b/src/mongo/db/catalog/drop_indexes.cpp index a0371a80e0a..54d3ffd1408 100644 --- a/src/mongo/db/catalog/drop_indexes.cpp +++ b/src/mongo/db/catalog/drop_indexes.cpp @@ -43,7 +43,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/repl_set_member_in_standalone_mode.h" #include "mongo/db/s/collection_sharding_state.h" diff --git a/src/mongo/db/catalog/index_catalog_entry_impl.cpp b/src/mongo/db/catalog/index_catalog_entry_impl.cpp index cb47381ae39..81d62cda8b1 100644 --- a/src/mongo/db/catalog/index_catalog_entry_impl.cpp +++ b/src/mongo/db/catalog/index_catalog_entry_impl.cpp @@ -44,7 +44,7 @@ #include "mongo/db/matcher/expression.h" #include "mongo/db/matcher/expression_parser.h" #include "mongo/db/multi_key_path_tracker.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/pipeline/expression_context.h" #include "mongo/db/query/collation/collator_factory_interface.h" diff --git a/src/mongo/db/catalog/multi_index_block.cpp b/src/mongo/db/catalog/multi_index_block.cpp index bce71c5496b..f04cf2712d6 100644 --- a/src/mongo/db/catalog/multi_index_block.cpp +++ b/src/mongo/db/catalog/multi_index_block.cpp @@ -43,7 +43,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/index/multikey_paths.h" #include "mongo/db/multi_key_path_tracker.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/query/collection_query_info.h" #include "mongo/db/repl/repl_set_config.h" diff --git a/src/mongo/db/catalog/rename_collection.cpp b/src/mongo/db/catalog/rename_collection.cpp index 24207dfa7c5..ccba8559e3a 100644 --- a/src/mongo/db/catalog/rename_collection.cpp +++ b/src/mongo/db/catalog/rename_collection.cpp @@ -49,7 +49,7 @@ #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/jsobj.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/insert.h" #include "mongo/db/query/query_knobs_gen.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/catalog/rename_collection_test.cpp b/src/mongo/db/catalog/rename_collection_test.cpp index 77d9f423d74..9b194843fc6 100644 --- a/src/mongo/db/catalog/rename_collection_test.cpp +++ b/src/mongo/db/catalog/rename_collection_test.cpp @@ -46,9 +46,9 @@ #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/jsobj.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog.h" diff --git a/src/mongo/db/catalog/validate_state_test.cpp b/src/mongo/db/catalog/validate_state_test.cpp index 531deab2ca6..ffbd18b9053 100644 --- a/src/mongo/db/catalog/validate_state_test.cpp +++ b/src/mongo/db/catalog/validate_state_test.cpp @@ -36,8 +36,8 @@ #include "mongo/db/catalog/collection.h" #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/storage/snapshot_manager.h" #include "mongo/db/storage/wiredtiger/wiredtiger_global_options.h" diff --git a/src/mongo/db/commands/SConscript b/src/mongo/db/commands/SConscript index e960733b817..c78dc3c069e 100644 --- a/src/mongo/db/commands/SConscript +++ b/src/mongo/db/commands/SConscript @@ -822,7 +822,7 @@ env.CppUnitTest( "$BUILD_DIR/mongo/db/fle_crud", "$BUILD_DIR/mongo/db/fle_mocks", "$BUILD_DIR/mongo/db/multitenancy", - "$BUILD_DIR/mongo/db/op_observer", + "$BUILD_DIR/mongo/db/op_observer/op_observer", "$BUILD_DIR/mongo/db/query/query_planner", "$BUILD_DIR/mongo/db/query/query_test_service_context", "$BUILD_DIR/mongo/db/query_exec", diff --git a/src/mongo/db/commands/collection_to_capped.cpp b/src/mongo/db/commands/collection_to_capped.cpp index 175f0629ffe..80faf2d0f9a 100644 --- a/src/mongo/db/commands/collection_to_capped.cpp +++ b/src/mongo/db/commands/collection_to_capped.cpp @@ -35,7 +35,7 @@ #include "mongo/db/commands.h" #include "mongo/db/db_raii.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/find.h" #include "mongo/db/query/internal_plans.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/commands/create_indexes.cpp b/src/mongo/db/commands/create_indexes.cpp index e97abcac55b..bf8dee07447 100644 --- a/src/mongo/db/commands/create_indexes.cpp +++ b/src/mongo/db/commands/create_indexes.cpp @@ -54,7 +54,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/insert.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/repl_set_config.h" diff --git a/src/mongo/db/commands/dbcommands.cpp b/src/mongo/db/commands/dbcommands.cpp index 71b4c0318b5..a4b3e1970d2 100644 --- a/src/mongo/db/commands/dbcommands.cpp +++ b/src/mongo/db/commands/dbcommands.cpp @@ -70,7 +70,7 @@ #include "mongo/db/json.h" #include "mongo/db/keypattern.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/insert.h" #include "mongo/db/pipeline/document_source_internal_unpack_bucket.h" #include "mongo/db/pipeline/storage_stats_spec_gen.h" diff --git a/src/mongo/db/commands/dbcommands_d.cpp b/src/mongo/db/commands/dbcommands_d.cpp index 458cdd364d2..67d3586cb30 100644 --- a/src/mongo/db/commands/dbcommands_d.cpp +++ b/src/mongo/db/commands/dbcommands_d.cpp @@ -69,7 +69,7 @@ #include "mongo/db/json.h" #include "mongo/db/keypattern.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/insert.h" #include "mongo/db/profile_filter_impl.h" #include "mongo/db/query/collation/collator_factory_interface.h" diff --git a/src/mongo/db/commands/drop_indexes.cpp b/src/mongo/db/commands/drop_indexes.cpp index ef91b031514..0f82ec1dde1 100644 --- a/src/mongo/db/commands/drop_indexes.cpp +++ b/src/mongo/db/commands/drop_indexes.cpp @@ -49,7 +49,7 @@ #include "mongo/db/drop_indexes_gen.h" #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/service_context.h" #include "mongo/db/timeseries/catalog_helper.h" #include "mongo/db/timeseries/timeseries_commands_conversion_helper.h" diff --git a/src/mongo/db/commands/mr_test.cpp b/src/mongo/db/commands/mr_test.cpp index 96bc35f2d89..ef1ad304d87 100644 --- a/src/mongo/db/commands/mr_test.cpp +++ b/src/mongo/db/commands/mr_test.cpp @@ -44,8 +44,8 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/dbdirectclient.h" #include "mongo/db/json.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/repl/storage_interface_impl.h" diff --git a/src/mongo/db/commands/oplog_note.cpp b/src/mongo/db/commands/oplog_note.cpp index a617d9ff12c..040aac464d1 100644 --- a/src/mongo/db/commands/oplog_note.cpp +++ b/src/mongo/db/commands/oplog_note.cpp @@ -42,7 +42,7 @@ #include "mongo/db/curop.h" #include "mongo/db/jsobj.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/commands/rename_collection_cmd.cpp b/src/mongo/db/commands/rename_collection_cmd.cpp index 1e839ca0271..8cf7aa7abf8 100644 --- a/src/mongo/db/commands/rename_collection_cmd.cpp +++ b/src/mongo/db/commands/rename_collection_cmd.cpp @@ -42,7 +42,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/index/index_descriptor.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/insert.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/service_context.h" diff --git a/src/mongo/db/commands/test_commands.cpp b/src/mongo/db/commands/test_commands.cpp index 351b7c99dc7..864c8c762b3 100644 --- a/src/mongo/db/commands/test_commands.cpp +++ b/src/mongo/db/commands/test_commands.cpp @@ -43,7 +43,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/insert.h" #include "mongo/db/query/internal_plans.h" #include "mongo/db/service_context.h" diff --git a/src/mongo/db/commands/txn_cmds.cpp b/src/mongo/db/commands/txn_cmds.cpp index d180b1964a2..0e6b43fae65 100644 --- a/src/mongo/db/commands/txn_cmds.cpp +++ b/src/mongo/db/commands/txn_cmds.cpp @@ -35,7 +35,7 @@ #include "mongo/db/commands.h" #include "mongo/db/commands/txn_cmds_gen.h" #include "mongo/db/curop_failpoint_helpers.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/s/sharding_state.h" diff --git a/src/mongo/db/dbhelpers.cpp b/src/mongo/db/dbhelpers.cpp index bcd4e652387..aaf0551b82f 100644 --- a/src/mongo/db/dbhelpers.cpp +++ b/src/mongo/db/dbhelpers.cpp @@ -40,7 +40,7 @@ #include "mongo/db/keypattern.h" #include "mongo/db/matcher/extensions_callback_real.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/delete.h" #include "mongo/db/ops/update.h" #include "mongo/db/ops/update_request.h" diff --git a/src/mongo/db/exec/batched_delete_stage.cpp b/src/mongo/db/exec/batched_delete_stage.cpp index 588fdfe2b23..fa3af088c97 100644 --- a/src/mongo/db/exec/batched_delete_stage.cpp +++ b/src/mongo/db/exec/batched_delete_stage.cpp @@ -39,7 +39,7 @@ #include "mongo/db/exec/scoped_timer.h" #include "mongo/db/exec/working_set_common.h" #include "mongo/db/exec/write_stage_common.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/canonical_query.h" #include "mongo/db/service_context.h" #include "mongo/logv2/log.h" diff --git a/src/mongo/db/exec/delete_stage.cpp b/src/mongo/db/exec/delete_stage.cpp index 331a2293680..155732e0cbd 100644 --- a/src/mongo/db/exec/delete_stage.cpp +++ b/src/mongo/db/exec/delete_stage.cpp @@ -38,7 +38,7 @@ #include "mongo/db/exec/scoped_timer.h" #include "mongo/db/exec/working_set_common.h" #include "mongo/db/exec/write_stage_common.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/canonical_query.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/s/collection_sharding_state.h" diff --git a/src/mongo/db/exec/update_stage.cpp b/src/mongo/db/exec/update_stage.cpp index 27304f16289..b0b5fcebf8c 100644 --- a/src/mongo/db/exec/update_stage.cpp +++ b/src/mongo/db/exec/update_stage.cpp @@ -44,7 +44,7 @@ #include "mongo/db/exec/shard_filterer_impl.h" #include "mongo/db/exec/working_set_common.h" #include "mongo/db/exec/write_stage_common.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/collection_query_info.h" #include "mongo/db/query/explain.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/free_mon/free_mon_controller_test.cpp b/src/mongo/db/free_mon/free_mon_controller_test.cpp index be3e5bda729..50a8b604ee1 100644 --- a/src/mongo/db/free_mon/free_mon_controller_test.cpp +++ b/src/mongo/db/free_mon/free_mon_controller_test.cpp @@ -51,8 +51,8 @@ #include "mongo/db/ftdc/controller.h" #include "mongo/db/ftdc/ftdc_test.h" #include "mongo/db/jsobj.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/repl/storage_interface.h" #include "mongo/db/repl/storage_interface_impl.h" diff --git a/src/mongo/db/free_mon/free_mon_mongod.h b/src/mongo/db/free_mon/free_mon_mongod.h index 41676ebf3e1..0e0653e6ef7 100644 --- a/src/mongo/db/free_mon/free_mon_mongod.h +++ b/src/mongo/db/free_mon/free_mon_mongod.h @@ -31,7 +31,7 @@ #include <string> -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/service_context.h" namespace mongo { diff --git a/src/mongo/db/free_mon/free_mon_op_observer.h b/src/mongo/db/free_mon/free_mon_op_observer.h index 2a2a0c60097..4dce6801926 100644 --- a/src/mongo/db/free_mon/free_mon_op_observer.h +++ b/src/mongo/db/free_mon/free_mon_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/index_builds_coordinator.cpp b/src/mongo/db/index_builds_coordinator.cpp index 5000a651b36..3fe2f6f7349 100644 --- a/src/mongo/db/index_builds_coordinator.cpp +++ b/src/mongo/db/index_builds_coordinator.cpp @@ -46,7 +46,7 @@ #include "mongo/db/dbhelpers.h" #include "mongo/db/index/wildcard_key_generator.h" #include "mongo/db/index_build_entry_helpers.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/cloner_utils.h" #include "mongo/db/repl/member_state.h" diff --git a/src/mongo/db/mongod_main.cpp b/src/mongo/db/mongod_main.cpp index fdf35fa7b88..b08c954207b 100644 --- a/src/mongo/db/mongod_main.cpp +++ b/src/mongo/db/mongod_main.cpp @@ -79,7 +79,6 @@ #include "mongo/db/dbhelpers.h" #include "mongo/db/dbmessage.h" #include "mongo/db/exec/working_set_common.h" -#include "mongo/db/fcv_op_observer.h" #include "mongo/db/fle_crud.h" #include "mongo/db/free_mon/free_mon_mongod.h" #include "mongo/db/ftdc/ftdc_mongod.h" @@ -104,8 +103,10 @@ #include "mongo/db/mirror_maestro.h" #include "mongo/db/mongod_options.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/fcv_op_observer.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" +#include "mongo/db/op_observer/user_write_block_mode_op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/periodic_runner_job_abort_expired_transactions.h" #include "mongo/db/pipeline/change_stream_expired_pre_image_remover.h" @@ -176,7 +177,6 @@ #include "mongo/db/system_index.h" #include "mongo/db/transaction_participant.h" #include "mongo/db/ttl.h" -#include "mongo/db/user_write_block_mode_op_observer.h" #include "mongo/db/vector_clock_metadata_hook.h" #include "mongo/db/wire_version.h" #include "mongo/executor/network_connection_hook.h" diff --git a/src/mongo/db/op_msg_fuzzer_fixture.cpp b/src/mongo/db/op_msg_fuzzer_fixture.cpp index 190e88e5988..55bfc66c54a 100644 --- a/src/mongo/db/op_msg_fuzzer_fixture.cpp +++ b/src/mongo/db/op_msg_fuzzer_fixture.cpp @@ -40,7 +40,7 @@ #include "mongo/db/client.h" #include "mongo/db/index/index_access_method.h" #include "mongo/db/index/index_access_method_factory_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator_mock.h" diff --git a/src/mongo/db/op_observer/SConscript b/src/mongo/db/op_observer/SConscript new file mode 100644 index 00000000000..12dc84f16ca --- /dev/null +++ b/src/mongo/db/op_observer/SConscript @@ -0,0 +1,97 @@ +# -*- mode: python -*- + +Import("env") + +env = env.Clone() + +env.Library( + target="op_observer", + source=[ + "op_observer.cpp", + ], + LIBDEPS=[ + '$BUILD_DIR/mongo/base', + ], +) + +env.Library( + target="op_observer_util", + source=[ + "op_observer_util.cpp", + ], + LIBDEPS=[ + '$BUILD_DIR/mongo/base', + ], + LIBDEPS_PRIVATE=[ + '$BUILD_DIR/mongo/db/bson/dotted_path_support', + '$BUILD_DIR/mongo/db/catalog/collection_options', + '$BUILD_DIR/mongo/db/index/index_descriptor', + '$BUILD_DIR/mongo/db/s/sharding_api_d', + ], +) + +env.Library( + target="op_observer_impl", + source=[ + "op_observer_impl.cpp", + ], + LIBDEPS_PRIVATE=[ + '$BUILD_DIR/mongo/base', + '$BUILD_DIR/mongo/db/batched_write_context', + '$BUILD_DIR/mongo/db/catalog/collection_catalog', + '$BUILD_DIR/mongo/db/catalog/collection_options', + '$BUILD_DIR/mongo/db/catalog/commit_quorum_options', + '$BUILD_DIR/mongo/db/catalog/database_holder', + '$BUILD_DIR/mongo/db/catalog/import_collection_oplog_entry', + '$BUILD_DIR/mongo/db/concurrency/exception_util', + '$BUILD_DIR/mongo/db/dbhelpers', + '$BUILD_DIR/mongo/db/internal_transactions_feature_flag', + '$BUILD_DIR/mongo/db/multitenancy', + '$BUILD_DIR/mongo/db/pipeline/change_stream_pre_image_helpers', + '$BUILD_DIR/mongo/db/pipeline/change_stream_preimage', + '$BUILD_DIR/mongo/db/read_write_concern_defaults', + '$BUILD_DIR/mongo/db/repl/image_collection_entry', + '$BUILD_DIR/mongo/db/repl/oplog', + '$BUILD_DIR/mongo/db/repl/repl_server_parameters', + '$BUILD_DIR/mongo/db/repl/tenant_migration_access_blocker', + '$BUILD_DIR/mongo/db/s/sharding_api_d', + '$BUILD_DIR/mongo/db/server_feature_flags', + '$BUILD_DIR/mongo/db/timeseries/bucket_catalog', + '$BUILD_DIR/mongo/db/transaction', + '$BUILD_DIR/mongo/db/views/views_mongod', + '$BUILD_DIR/mongo/s/coreshard', + '$BUILD_DIR/mongo/s/grid', + 'op_observer', + 'op_observer_util', + ], +) + +env.Library( + target="fcv_op_observer", + source=[ + "fcv_op_observer.cpp", + ], + LIBDEPS_PRIVATE=[ + '$BUILD_DIR/mongo/base', + '$BUILD_DIR/mongo/db/commands/mongod_fcv', + '$BUILD_DIR/mongo/db/kill_sessions_local', + '$BUILD_DIR/mongo/executor/egress_tag_closer_manager', + 'op_observer', + 'op_observer_util', + ], +) + +env.Library( + target="user_write_block_mode_op_observer", + source=[ + "user_write_block_mode_op_observer.cpp", + ], + LIBDEPS=[ + '$BUILD_DIR/mongo/base', + 'op_observer', + ], + LIBDEPS_PRIVATE=[ + '$BUILD_DIR/mongo/db/s/sharding_api_d', + '$BUILD_DIR/mongo/db/s/user_writes_recoverable_critical_section', + ], +) diff --git a/src/mongo/db/fcv_op_observer.cpp b/src/mongo/db/op_observer/fcv_op_observer.cpp index fa0922a367b..110415de3fd 100644 --- a/src/mongo/db/fcv_op_observer.cpp +++ b/src/mongo/db/op_observer/fcv_op_observer.cpp @@ -28,13 +28,13 @@ */ -#include "mongo/db/fcv_op_observer.h" +#include "mongo/db/op_observer/fcv_op_observer.h" #include "mongo/db/commands/feature_compatibility_version.h" #include "mongo/db/commands/feature_compatibility_version_parser.h" #include "mongo/db/kill_sessions_local.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/server_options.h" diff --git a/src/mongo/db/fcv_op_observer.h b/src/mongo/db/op_observer/fcv_op_observer.h index ac8ebaf923f..9db3f370d32 100644 --- a/src/mongo/db/fcv_op_observer.h +++ b/src/mongo/db/op_observer/fcv_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/util/version/releases.h" namespace mongo { diff --git a/src/mongo/db/op_observer.cpp b/src/mongo/db/op_observer/op_observer.cpp index 7daac6c5cab..a6468ddded7 100644 --- a/src/mongo/db/op_observer.cpp +++ b/src/mongo/db/op_observer/op_observer.cpp @@ -29,7 +29,7 @@ #include "mongo/platform/basic.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" diff --git a/src/mongo/db/op_observer.h b/src/mongo/db/op_observer/op_observer.h index ac8b04fb2f6..ac8b04fb2f6 100644 --- a/src/mongo/db/op_observer.h +++ b/src/mongo/db/op_observer/op_observer.h diff --git a/src/mongo/db/op_observer_impl.cpp b/src/mongo/db/op_observer/op_observer_impl.cpp index 29b894985b7..e89853e92b6 100644 --- a/src/mongo/db/op_observer_impl.cpp +++ b/src/mongo/db/op_observer/op_observer_impl.cpp @@ -30,7 +30,7 @@ #include "mongo/platform/basic.h" -#include "mongo/db/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_impl.h" #include <algorithm> #include <limits> @@ -53,7 +53,7 @@ #include "mongo/db/keys_collection_document_gen.h" #include "mongo/db/logical_time_validator.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/operation_context.h" #include "mongo/db/pipeline/change_stream_pre_image_helpers.h" #include "mongo/db/pipeline/change_stream_preimage_gen.h" diff --git a/src/mongo/db/op_observer_impl.h b/src/mongo/db/op_observer/op_observer_impl.h index 9b291f4a5c7..84e2fee3e59 100644 --- a/src/mongo/db/op_observer_impl.h +++ b/src/mongo/db/op_observer/op_observer_impl.h @@ -29,8 +29,8 @@ #pragma once -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/s/collection_sharding_state.h" namespace mongo { diff --git a/src/mongo/db/op_observer_impl_test.cpp b/src/mongo/db/op_observer/op_observer_impl_test.cpp index 2393df72299..f9bf11fd5a5 100644 --- a/src/mongo/db/op_observer_impl_test.cpp +++ b/src/mongo/db/op_observer/op_observer_impl_test.cpp @@ -43,9 +43,9 @@ #include "mongo/db/logical_time_validator.h" #include "mongo/db/multitenancy_gen.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/pipeline/change_stream_preimage_gen.h" #include "mongo/db/read_write_concern_defaults.h" #include "mongo/db/read_write_concern_defaults_cache_lookup_mock.h" diff --git a/src/mongo/db/op_observer_noop.h b/src/mongo/db/op_observer/op_observer_noop.h index 155a13819bc..b2ef86e5a89 100644 --- a/src/mongo/db/op_observer_noop.h +++ b/src/mongo/db/op_observer/op_observer_noop.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/op_observer_registry.h b/src/mongo/db/op_observer/op_observer_registry.h index 56323d628cb..8df5611dadc 100644 --- a/src/mongo/db/op_observer_registry.h +++ b/src/mongo/db/op_observer/op_observer_registry.h @@ -33,7 +33,7 @@ #include <memory> #include <vector> -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/op_observer_registry_test.cpp b/src/mongo/db/op_observer/op_observer_registry_test.cpp index 39a6f3208f4..6d7c9a8acb5 100644 --- a/src/mongo/db/op_observer_registry_test.cpp +++ b/src/mongo/db/op_observer/op_observer_registry_test.cpp @@ -29,9 +29,9 @@ #include "mongo/platform/basic.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" -#include "mongo/db/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_noop.h" #include "mongo/db/operation_context_noop.h" #include "mongo/db/repl/optime.h" #include "mongo/unittest/death_test.h" diff --git a/src/mongo/db/op_observer_util.cpp b/src/mongo/db/op_observer/op_observer_util.cpp index 99d8bdd4a89..d833dcee1c0 100644 --- a/src/mongo/db/op_observer_util.cpp +++ b/src/mongo/db/op_observer/op_observer_util.cpp @@ -29,7 +29,7 @@ #include "mongo/platform/basic.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/bson/dotted_path_support.h" #include "mongo/db/index/index_descriptor.h" diff --git a/src/mongo/db/op_observer_util.h b/src/mongo/db/op_observer/op_observer_util.h index dc6f24f30a2..7be84f69eee 100644 --- a/src/mongo/db/op_observer_util.h +++ b/src/mongo/db/op_observer/op_observer_util.h @@ -31,7 +31,7 @@ #include "mongo/db/catalog/collection_options.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo::repl { BSONObj makeCollModCmdObj(const BSONObj& collModCmd, diff --git a/src/mongo/db/user_write_block_mode_op_observer.cpp b/src/mongo/db/op_observer/user_write_block_mode_op_observer.cpp index 9ebdd053f21..ca779532085 100644 --- a/src/mongo/db/user_write_block_mode_op_observer.cpp +++ b/src/mongo/db/op_observer/user_write_block_mode_op_observer.cpp @@ -29,7 +29,7 @@ #include "mongo/platform/basic.h" -#include "mongo/db/user_write_block_mode_op_observer.h" +#include "mongo/db/op_observer/user_write_block_mode_op_observer.h" #include "mongo/db/s/global_user_write_block_state.h" #include "mongo/db/s/user_writes_critical_section_document_gen.h" diff --git a/src/mongo/db/user_write_block_mode_op_observer.h b/src/mongo/db/op_observer/user_write_block_mode_op_observer.h index d339c38925f..2194d03c172 100644 --- a/src/mongo/db/user_write_block_mode_op_observer.h +++ b/src/mongo/db/op_observer/user_write_block_mode_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/user_write_block_mode_op_observer_test.cpp b/src/mongo/db/op_observer/user_write_block_mode_op_observer_test.cpp index 88958c48cb8..39c6c3a3b90 100644 --- a/src/mongo/db/user_write_block_mode_op_observer_test.cpp +++ b/src/mongo/db/op_observer/user_write_block_mode_op_observer_test.cpp @@ -30,11 +30,11 @@ #include "mongo/platform/basic.h" #include "mongo/db/auth/authorization_session.h" +#include "mongo/db/op_observer/user_write_block_mode_op_observer.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/repl/storage_interface_mock.h" #include "mongo/db/s/global_user_write_block_state.h" #include "mongo/db/service_context_d_test_fixture.h" -#include "mongo/db/user_write_block_mode_op_observer.h" #include "mongo/db/write_block_bypass.h" namespace mongo { diff --git a/src/mongo/db/ops/update.cpp b/src/mongo/db/ops/update.cpp index b949dbbfcbe..f019e0d780c 100644 --- a/src/mongo/db/ops/update.cpp +++ b/src/mongo/db/ops/update.cpp @@ -40,7 +40,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/exec/update_stage.h" #include "mongo/db/matcher/extensions_callback_real.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/explain.h" #include "mongo/db/query/get_executor.h" #include "mongo/db/query/plan_summary_stats.h" diff --git a/src/mongo/db/read_concern_mongod.cpp b/src/mongo/db/read_concern_mongod.cpp index fca51eacb0e..536dbec1741 100644 --- a/src/mongo/db/read_concern_mongod.cpp +++ b/src/mongo/db/read_concern_mongod.cpp @@ -34,7 +34,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/curop_failpoint_helpers.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/read_concern.h" #include "mongo/db/read_concern_mongod_gen.h" diff --git a/src/mongo/db/repl/SConscript b/src/mongo/db/repl/SConscript index 43520c0dfaf..66ae76d0e07 100644 --- a/src/mongo/db/repl/SConscript +++ b/src/mongo/db/repl/SConscript @@ -81,8 +81,8 @@ env.Library( '$BUILD_DIR/mongo/db/dbhelpers', '$BUILD_DIR/mongo/db/index_builds_coordinator_interface', '$BUILD_DIR/mongo/db/multitenancy', - '$BUILD_DIR/mongo/db/op_observer', - '$BUILD_DIR/mongo/db/op_observer_util', + '$BUILD_DIR/mongo/db/op_observer/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer_util', '$BUILD_DIR/mongo/db/ops/write_ops', '$BUILD_DIR/mongo/db/pipeline/change_stream_pre_image_helpers', '$BUILD_DIR/mongo/db/pipeline/change_stream_preimage', @@ -172,7 +172,7 @@ env.Library( ], LIBDEPS_PRIVATE=[ '$BUILD_DIR/mongo/db/concurrency/exception_util', - '$BUILD_DIR/mongo/db/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/executor/thread_pool_task_executor', 'repl_server_parameters', ], @@ -500,7 +500,7 @@ env.Library( ], LIBDEPS=[ '$BUILD_DIR/mongo/db/multitenancy', - '$BUILD_DIR/mongo/db/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/db/query_exec', '$BUILD_DIR/mongo/db/read_write_concern_defaults_mock', '$BUILD_DIR/mongo/db/service_context_d_test_fixture', @@ -1499,7 +1499,7 @@ env.Library( '$BUILD_DIR/mongo/db/kill_sessions_local', '$BUILD_DIR/mongo/db/logical_time', '$BUILD_DIR/mongo/db/not_primary_error_tracker', - '$BUILD_DIR/mongo/db/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/db/query_exec', '$BUILD_DIR/mongo/db/service_context', '$BUILD_DIR/mongo/db/stats/counters', @@ -1565,7 +1565,7 @@ env.Library( '$BUILD_DIR/mongo/db/service_context_d_test_fixture', ], LIBDEPS_PRIVATE=[ - '$BUILD_DIR/mongo/db/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', 'primary_only_service', 'repl_coordinator_interface', 'replmocks', @@ -1627,7 +1627,7 @@ if wiredtiger: ], LIBDEPS=[ '$BUILD_DIR/mongo/client/replica_set_monitor_protocol_test_util', - '$BUILD_DIR/mongo/db/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', '$BUILD_DIR/mongo/transport/transport_layer_egress_init', '$BUILD_DIR/mongo/unittest/unittest', '$BUILD_DIR/mongo/util/clock_source_mock', @@ -1709,7 +1709,7 @@ if wiredtiger: '$BUILD_DIR/mongo/db/logical_session_id_helpers', '$BUILD_DIR/mongo/db/logical_time', '$BUILD_DIR/mongo/db/multitenancy', - '$BUILD_DIR/mongo/db/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', '$BUILD_DIR/mongo/db/pipeline/change_stream_expired_pre_image_remover', '$BUILD_DIR/mongo/db/query/command_request_response', '$BUILD_DIR/mongo/db/s/sharding_runtime_d', diff --git a/src/mongo/db/repl/apply_ops.cpp b/src/mongo/db/repl/apply_ops.cpp index 546f7ad01a1..47efc80ba9f 100644 --- a/src/mongo/db/repl/apply_ops.cpp +++ b/src/mongo/db/repl/apply_ops.cpp @@ -46,7 +46,7 @@ #include "mongo/db/index/index_descriptor.h" #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/matcher/matcher.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/query/collation/collation_spec.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/repl/apply_ops_test.cpp b/src/mongo/db/repl/apply_ops_test.cpp index a5994b3c5ac..abbcdac1463 100644 --- a/src/mongo/db/repl/apply_ops_test.cpp +++ b/src/mongo/db/repl/apply_ops_test.cpp @@ -34,7 +34,7 @@ #include "mongo/db/catalog/collection_options.h" #include "mongo/db/catalog/database_holder.h" #include "mongo/db/client.h" -#include "mongo/db/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_noop.h" #include "mongo/db/repl/apply_ops.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator_mock.h" diff --git a/src/mongo/db/repl/drop_pending_collection_reaper_test.cpp b/src/mongo/db/repl/drop_pending_collection_reaper_test.cpp index 3d12d1acde4..b6517b044d6 100644 --- a/src/mongo/db/repl/drop_pending_collection_reaper_test.cpp +++ b/src/mongo/db/repl/drop_pending_collection_reaper_test.cpp @@ -34,7 +34,7 @@ #include "mongo/db/catalog/collection_catalog.h" #include "mongo/db/client.h" #include "mongo/db/jsobj.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/optime.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/repl/noop_writer.cpp b/src/mongo/db/repl/noop_writer.cpp index 3f0d52efbfa..d07a04d4190 100644 --- a/src/mongo/db/repl/noop_writer.cpp +++ b/src/mongo/db/repl/noop_writer.cpp @@ -37,7 +37,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/curop.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/noop_writer.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/repl_server_parameters_gen.h" diff --git a/src/mongo/db/repl/oplog.cpp b/src/mongo/db/repl/oplog.cpp index 3fad6ccec9b..b67acd0c653 100644 --- a/src/mongo/db/repl/oplog.cpp +++ b/src/mongo/db/repl/oplog.cpp @@ -73,8 +73,8 @@ #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/keypattern.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/ops/delete.h" #include "mongo/db/ops/delete_request_gen.h" #include "mongo/db/ops/update.h" diff --git a/src/mongo/db/repl/oplog_applier_impl_test_fixture.cpp b/src/mongo/db/repl/oplog_applier_impl_test_fixture.cpp index 53b640225c2..d0162b855a7 100644 --- a/src/mongo/db/repl/oplog_applier_impl_test_fixture.cpp +++ b/src/mongo/db/repl/oplog_applier_impl_test_fixture.cpp @@ -37,7 +37,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/query/internal_plans.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog_applier.h" diff --git a/src/mongo/db/repl/oplog_applier_impl_test_fixture.h b/src/mongo/db/repl/oplog_applier_impl_test_fixture.h index 6b99e660880..afe2a9afa2b 100644 --- a/src/mongo/db/repl/oplog_applier_impl_test_fixture.h +++ b/src/mongo/db/repl/oplog_applier_impl_test_fixture.h @@ -33,7 +33,7 @@ #include "mongo/db/concurrency/lock_manager_defs.h" #include "mongo/db/db_raii.h" #include "mongo/db/logical_session_id.h" -#include "mongo/db/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_noop.h" #include "mongo/db/repl/oplog_applier_impl.h" #include "mongo/db/repl/replication_consistency_markers.h" #include "mongo/db/service_context_d_test_fixture.h" diff --git a/src/mongo/db/repl/primary_only_service_op_observer.h b/src/mongo/db/repl/primary_only_service_op_observer.h index 15673bf3aa8..d39df067da7 100644 --- a/src/mongo/db/repl/primary_only_service_op_observer.h +++ b/src/mongo/db/repl/primary_only_service_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { namespace repl { diff --git a/src/mongo/db/repl/primary_only_service_test_fixture.cpp b/src/mongo/db/repl/primary_only_service_test_fixture.cpp index cb21b22f243..8593585db51 100644 --- a/src/mongo/db/repl/primary_only_service_test_fixture.cpp +++ b/src/mongo/db/repl/primary_only_service_test_fixture.cpp @@ -28,8 +28,8 @@ */ #include "mongo/db/repl/primary_only_service_test_fixture.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/primary_only_service.h" #include "mongo/db/repl/primary_only_service_op_observer.h" diff --git a/src/mongo/db/repl/repl_set_commands.cpp b/src/mongo/db/repl/repl_set_commands.cpp index 826653c9717..e50c9a48f16 100644 --- a/src/mongo/db/repl/repl_set_commands.cpp +++ b/src/mongo/db/repl/repl_set_commands.cpp @@ -45,7 +45,7 @@ #include "mongo/db/commands.h" #include "mongo/db/commands/server_status_metric.h" #include "mongo/db/dbhelpers.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/repl_set_heartbeat_args_v1.h" diff --git a/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp b/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp index 17f32375ee8..89c44f3cb1b 100644 --- a/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp +++ b/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp @@ -58,7 +58,7 @@ #include "mongo/db/jsobj.h" #include "mongo/db/kill_sessions_local.h" #include "mongo/db/logical_time_validator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/query/query_feature_flags_gen.h" #include "mongo/db/repl/always_allow_non_local_writes.h" #include "mongo/db/repl/bgsync.h" diff --git a/src/mongo/db/repl/replication_recovery_test.cpp b/src/mongo/db/repl/replication_recovery_test.cpp index 5d7bc3264df..dc2287e9f03 100644 --- a/src/mongo/db/repl/replication_recovery_test.cpp +++ b/src/mongo/db/repl/replication_recovery_test.cpp @@ -33,8 +33,8 @@ #include "mongo/db/client.h" #include "mongo/db/db_raii.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog_applier_impl_test_fixture.h" diff --git a/src/mongo/db/repl/rollback_impl.h b/src/mongo/db/repl/rollback_impl.h index 9fe3206f4f7..33bc856b5f3 100644 --- a/src/mongo/db/repl/rollback_impl.h +++ b/src/mongo/db/repl/rollback_impl.h @@ -32,7 +32,7 @@ #include <functional> #include "mongo/base/status_with.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/oplog_entry.h" #include "mongo/db/repl/roll_back_local_operations.h" #include "mongo/db/repl/rollback.h" diff --git a/src/mongo/db/repl/rollback_test_fixture.cpp b/src/mongo/db/repl/rollback_test_fixture.cpp index 6372b635d3c..7d296aa3208 100644 --- a/src/mongo/db/repl/rollback_test_fixture.cpp +++ b/src/mongo/db/repl/rollback_test_fixture.cpp @@ -37,8 +37,8 @@ #include "mongo/db/catalog/database_holder.h" #include "mongo/db/client.h" #include "mongo/db/db_raii.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/read_write_concern_defaults_cache_lookup_mock.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/replication_consistency_markers_mock.h" diff --git a/src/mongo/db/repl/storage_timestamp_test.cpp b/src/mongo/db/repl/storage_timestamp_test.cpp index 2732b2cd5e7..ade57925c5e 100644 --- a/src/mongo/db/repl/storage_timestamp_test.cpp +++ b/src/mongo/db/repl/storage_timestamp_test.cpp @@ -56,8 +56,8 @@ #include "mongo/db/index_build_entry_helpers.h" #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/multi_key_path_tracker.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/query/wildcard_multikey_paths.h" #include "mongo/db/repl/apply_ops.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" diff --git a/src/mongo/db/repl/tenant_collection_cloner_test.cpp b/src/mongo/db/repl/tenant_collection_cloner_test.cpp index 978a5efe234..08c7f6b0299 100644 --- a/src/mongo/db/repl/tenant_collection_cloner_test.cpp +++ b/src/mongo/db/repl/tenant_collection_cloner_test.cpp @@ -32,8 +32,8 @@ #include <vector> #include "mongo/bson/bsonmisc.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/repl_server_parameters_gen.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/repl/storage_interface.h" diff --git a/src/mongo/db/repl/tenant_migration_access_blocker_util.cpp b/src/mongo/db/repl/tenant_migration_access_blocker_util.cpp index fc693f64c20..6689604b762 100644 --- a/src/mongo/db/repl/tenant_migration_access_blocker_util.cpp +++ b/src/mongo/db/repl/tenant_migration_access_blocker_util.cpp @@ -35,7 +35,7 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/concurrency/exception_util.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/persistent_task_store.h" #include "mongo/db/repl/tenant_migration_access_blocker_registry.h" #include "mongo/db/repl/tenant_migration_conflict_info.h" diff --git a/src/mongo/db/repl/tenant_migration_donor_op_observer.h b/src/mongo/db/repl/tenant_migration_donor_op_observer.h index 1760c8e551a..2046c2b954d 100644 --- a/src/mongo/db/repl/tenant_migration_donor_op_observer.h +++ b/src/mongo/db/repl/tenant_migration_donor_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { namespace repl { diff --git a/src/mongo/db/repl/tenant_migration_donor_service_test.cpp b/src/mongo/db/repl/tenant_migration_donor_service_test.cpp index e76097432b6..1647802dbc5 100644 --- a/src/mongo/db/repl/tenant_migration_donor_service_test.cpp +++ b/src/mongo/db/repl/tenant_migration_donor_service_test.cpp @@ -34,8 +34,8 @@ #include "mongo/client/replica_set_monitor.h" #include "mongo/client/replica_set_monitor_protocol_test_util.h" #include "mongo/config.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/primary_only_service.h" #include "mongo/db/repl/primary_only_service_op_observer.h" #include "mongo/db/repl/replication_coordinator_mock.h" diff --git a/src/mongo/db/repl/tenant_migration_recipient_op_observer.h b/src/mongo/db/repl/tenant_migration_recipient_op_observer.h index 33b15910776..0177bbd5771 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_op_observer.h +++ b/src/mongo/db/repl/tenant_migration_recipient_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { namespace repl { diff --git a/src/mongo/db/repl/tenant_migration_recipient_service.cpp b/src/mongo/db/repl/tenant_migration_recipient_service.cpp index 48d514339eb..2a853da345e 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service.cpp +++ b/src/mongo/db/repl/tenant_migration_recipient_service.cpp @@ -47,7 +47,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/write_ops_exec.h" #include "mongo/db/pipeline/process_interface/mongo_process_interface.h" #include "mongo/db/repl/cloner_utils.h" diff --git a/src/mongo/db/repl/tenant_migration_recipient_service_test.cpp b/src/mongo/db/repl/tenant_migration_recipient_service_test.cpp index ea4ea2da1bf..3c8dc68eb7b 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service_test.cpp +++ b/src/mongo/db/repl/tenant_migration_recipient_service_test.cpp @@ -41,8 +41,8 @@ #include "mongo/db/commands/feature_compatibility_version_document_gen.h" #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/oplog_buffer_collection.h" diff --git a/src/mongo/db/repl/tenant_oplog_applier.cpp b/src/mongo/db/repl/tenant_oplog_applier.cpp index 169e51888f3..f5d1c0e1469 100644 --- a/src/mongo/db/repl/tenant_oplog_applier.cpp +++ b/src/mongo/db/repl/tenant_oplog_applier.cpp @@ -40,7 +40,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/db_raii.h" #include "mongo/db/dbhelpers.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/repl/apply_ops.h" #include "mongo/db/repl/cloner_utils.h" #include "mongo/db/repl/insert_group.h" diff --git a/src/mongo/db/repl/tenant_oplog_applier_test.cpp b/src/mongo/db/repl/tenant_oplog_applier_test.cpp index bdafadb1fb1..3af7f8fa545 100644 --- a/src/mongo/db/repl/tenant_oplog_applier_test.cpp +++ b/src/mongo/db/repl/tenant_oplog_applier_test.cpp @@ -35,8 +35,8 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/logical_session_id_helpers.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/oplog_applier_impl_test_fixture.h" #include "mongo/db/repl/oplog_batcher_test_fixture.h" #include "mongo/db/repl/oplog_entry_test_helpers.h" diff --git a/src/mongo/db/s/README.md b/src/mongo/db/s/README.md index eb2ea0062d8..53953dc657b 100644 --- a/src/mongo/db/s/README.md +++ b/src/mongo/db/s/README.md @@ -930,14 +930,14 @@ to disk and [updates](https://github.com/mongodb/mongo/blob/r4.3.4/src/mongo/db/ For most writes, persisting only the (lsid, txnId) pair alone is sufficient to reconstruct a response. For findAndModify however, we also need to respond with the document that would have originally been returned. In version 5.0 and earlier, the default behavior is to -[record the document image into the oplog](https://github.com/mongodb/mongo/blob/33ad68c0dc4bda897a5647608049422ae784a15e/src/mongo/db/op_observer_impl.cpp#L191) +[record the document image into the oplog](https://github.com/mongodb/mongo/blob/33ad68c0dc4bda897a5647608049422ae784a15e/src/mongo/db/op_observer/op_observer_impl.cpp#L191) as a no-op entry. The oplog entries generated would look something like: * `{ op: "d", o: {_id: 1}, ts: Timestamp(100, 2), preImageOpTime: Timestamp(100, 1), lsid: ..., txnNumber: ...}` * `{ op: "n", o: {_id: 1, imageBeforeDelete: "foobar"}, ts: Timestamp(100, 1)}` There's a cost in "explicitly" replicating these images via the oplog. We've addressed this cost -with 5.1 where the default is to instead [save the image into a side collection](https://github.com/mongodb/mongo/blob/33ad68c0dc4bda897a5647608049422ae784a15e/src/mongo/db/op_observer_impl.cpp#L646-L650) +with 5.1 where the default is to instead [save the image into a side collection](https://github.com/mongodb/mongo/blob/33ad68c0dc4bda897a5647608049422ae784a15e/src/mongo/db/op_observer/op_observer_impl.cpp#L646-L650) with the namespace `config.image_collection`. A primary will add `needsRetryImage: <preImage/postImage>` to the oplog entry to communicate to secondaries that they must make a corollary write to `config.image_collection`. @@ -1360,7 +1360,7 @@ privilege. The `UserWriteBlockModeOpObserver` is responsible for blocking disallowed writes. Upon any operation which writes, this `OpObserver` checks whether the `GlobalUserWriteBlockState` [allows writes to the target -namespace](https://github.com/10gen/mongo/blob/25377181476e4140c970afa5b018f9b4fcc951e8/src/mongo/db/user_write_block_mode_op_observer.cpp#L276-L283). +namespace](https://github.com/10gen/mongo/blob/25377181476e4140c970afa5b018f9b4fcc951e8/src/mongo/db/op_observer/user_write_block_mode_op_observer.cpp#L276-L283). The `GlobalUserWriteBlockState` stores whether user write blocking is enabled in a given `ServiceContext`. As part of its write access check, it [checks whether the `WriteBlockBypass` associated with the given `OperationContext` is @@ -1400,7 +1400,7 @@ those operations from completing. #### Code references * The [`UserWriteBlockModeOpObserver` - class](https://github.com/10gen/mongo/blob/25377181476e4140c970afa5b018f9b4fcc951e8/src/mongo/db/user_write_block_mode_op_observer.h#L40) + class](https://github.com/10gen/mongo/blob/25377181476e4140c970afa5b018f9b4fcc951e8/src/mongo/db/op_observer/user_write_block_mode_op_observer.h#L40) * The [`GlobalUserWriteBlockState` class](https://github.com/10gen/mongo/blob/25377181476e4140c970afa5b018f9b4fcc951e8/src/mongo/db/s/global_user_write_block_state.h#L37) * The [`WriteBlockBypass` diff --git a/src/mongo/db/s/SConscript b/src/mongo/db/s/SConscript index 872328bd0e2..ac26896e278 100644 --- a/src/mongo/db/s/SConscript +++ b/src/mongo/db/s/SConscript @@ -146,7 +146,7 @@ env.Library( '$BUILD_DIR/mongo/db/concurrency/exception_util', '$BUILD_DIR/mongo/db/db_raii', '$BUILD_DIR/mongo/db/dbhelpers', - '$BUILD_DIR/mongo/db/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', '$BUILD_DIR/mongo/db/ops/write_ops_exec', '$BUILD_DIR/mongo/db/pipeline/aggregation_request_helper', '$BUILD_DIR/mongo/db/repl/abstract_async_component', @@ -626,8 +626,8 @@ env.CppUnitTest( '$BUILD_DIR/mongo/db/exec/document_value/document_value_test_util', '$BUILD_DIR/mongo/db/keys_collection_client_direct', '$BUILD_DIR/mongo/db/logical_session_cache_impl', - '$BUILD_DIR/mongo/db/op_observer', - '$BUILD_DIR/mongo/db/op_observer_util', + '$BUILD_DIR/mongo/db/op_observer/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer_util', '$BUILD_DIR/mongo/db/ops/write_ops_exec', '$BUILD_DIR/mongo/db/pipeline/document_source_mock', '$BUILD_DIR/mongo/db/pipeline/expression_context', diff --git a/src/mongo/db/s/config/config_server_test_fixture.cpp b/src/mongo/db/s/config/config_server_test_fixture.cpp index d697528a86d..194d59e8ab9 100644 --- a/src/mongo/db/s/config/config_server_test_fixture.cpp +++ b/src/mongo/db/s/config/config_server_test_fixture.cpp @@ -42,9 +42,9 @@ #include "mongo/db/client.h" #include "mongo/db/commands.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/ops/write_ops.h" #include "mongo/db/query/cursor_response.h" #include "mongo/db/query/query_request_helper.h" diff --git a/src/mongo/db/s/config_server_op_observer.h b/src/mongo/db/s/config_server_op_observer.h index 134edc88933..1f6f97c5aae 100644 --- a/src/mongo/db/s/config_server_op_observer.h +++ b/src/mongo/db/s/config_server_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/platform/mutex.h" namespace mongo { diff --git a/src/mongo/db/s/flush_resharding_state_change_command.cpp b/src/mongo/db/s/flush_resharding_state_change_command.cpp index 95439564643..2e665e5a280 100644 --- a/src/mongo/db/s/flush_resharding_state_change_command.cpp +++ b/src/mongo/db/s/flush_resharding_state_change_command.cpp @@ -37,7 +37,7 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/client.h" #include "mongo/db/commands.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/s/resharding/resharding_util.h" diff --git a/src/mongo/db/s/migration_destination_manager.cpp b/src/mongo/db/s/migration_destination_manager.cpp index fd823932380..2d083b510f7 100644 --- a/src/mongo/db/s/migration_destination_manager.cpp +++ b/src/mongo/db/s/migration_destination_manager.cpp @@ -45,7 +45,7 @@ #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/logical_session_id_helpers.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/ops/delete.h" #include "mongo/db/ops/write_ops_exec.h" diff --git a/src/mongo/db/s/migration_source_manager.cpp b/src/mongo/db/s/migration_source_manager.cpp index b08ed206901..11184b4b5a0 100644 --- a/src/mongo/db/s/migration_source_manager.cpp +++ b/src/mongo/db/s/migration_source_manager.cpp @@ -34,7 +34,7 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/logical_session_cache.h" #include "mongo/db/logical_session_id_helpers.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/read_concern.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp index 70748623b53..e5e16d971ad 100644 --- a/src/mongo/db/s/migration_util.cpp +++ b/src/mongo/db/s/migration_util.cpp @@ -44,7 +44,7 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/logical_session_cache.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/write_ops.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/db/s/op_observer_sharding_impl.h b/src/mongo/db/s/op_observer_sharding_impl.h index f9005497c57..aa47a4026c8 100644 --- a/src/mongo/db/s/op_observer_sharding_impl.h +++ b/src/mongo/db/s/op_observer_sharding_impl.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_impl.h" namespace mongo { diff --git a/src/mongo/db/s/op_observer_sharding_test.cpp b/src/mongo/db/s/op_observer_sharding_test.cpp index 2c4859ba782..19efe36166a 100644 --- a/src/mongo/db/s/op_observer_sharding_test.cpp +++ b/src/mongo/db/s/op_observer_sharding_test.cpp @@ -28,7 +28,7 @@ */ #include "mongo/db/catalog_raii.h" -#include "mongo/db/op_observer_util.h" +#include "mongo/db/op_observer/op_observer_util.h" #include "mongo/db/s/collection_sharding_runtime.h" #include "mongo/db/s/op_observer_sharding_impl.h" #include "mongo/db/s/operation_sharding_state.h" diff --git a/src/mongo/db/s/refine_collection_shard_key_coordinator.cpp b/src/mongo/db/s/refine_collection_shard_key_coordinator.cpp index b8d981bb4ce..bfeec770791 100644 --- a/src/mongo/db/s/refine_collection_shard_key_coordinator.cpp +++ b/src/mongo/db/s/refine_collection_shard_key_coordinator.cpp @@ -34,7 +34,7 @@ #include "mongo/db/commands.h" #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/db_raii.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/s/dist_lock_manager.h" #include "mongo/db/s/shard_key_util.h" #include "mongo/db/s/sharding_ddl_util.h" diff --git a/src/mongo/db/s/reshard_collection_coordinator.cpp b/src/mongo/db/s/reshard_collection_coordinator.cpp index e0dec68a1a6..da1c65e01d3 100644 --- a/src/mongo/db/s/reshard_collection_coordinator.cpp +++ b/src/mongo/db/s/reshard_collection_coordinator.cpp @@ -33,7 +33,7 @@ #include "mongo/db/catalog/collection_uuid_mismatch.h" #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/db_raii.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/s/reshard_collection_coordinator.h" #include "mongo/logv2/log.h" #include "mongo/s/grid.h" diff --git a/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp b/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp index 1fc380093bf..54b686ef632 100644 --- a/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp +++ b/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp @@ -32,9 +32,9 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/logical_session_cache_noop.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/primary_only_service_test_fixture.h" #include "mongo/db/repl/wait_for_majority_service.h" #include "mongo/db/s/config/config_server_test_fixture.h" diff --git a/src/mongo/db/s/resharding/resharding_donor_service.cpp b/src/mongo/db/s/resharding/resharding_donor_service.cpp index dd1c510accf..95d31bda195 100644 --- a/src/mongo/db/s/resharding/resharding_donor_service.cpp +++ b/src/mongo/db/s/resharding/resharding_donor_service.cpp @@ -41,7 +41,7 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/dbhelpers.h" #include "mongo/db/index_builds_coordinator.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/delete.h" #include "mongo/db/persistent_task_store.h" #include "mongo/db/repl/repl_client_info.h" diff --git a/src/mongo/db/s/resharding/resharding_donor_service_test.cpp b/src/mongo/db/s/resharding/resharding_donor_service_test.cpp index 4d83cfe5e44..604e171bbb4 100644 --- a/src/mongo/db/s/resharding/resharding_donor_service_test.cpp +++ b/src/mongo/db/s/resharding/resharding_donor_service_test.cpp @@ -34,8 +34,8 @@ #include <utility> #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/ops/update.h" #include "mongo/db/ops/update_request.h" #include "mongo/db/persistent_task_store.h" diff --git a/src/mongo/db/s/resharding/resharding_op_observer.h b/src/mongo/db/s/resharding/resharding_op_observer.h index d3343f40276..c3821e4f446 100644 --- a/src/mongo/db/s/resharding/resharding_op_observer.h +++ b/src/mongo/db/s/resharding/resharding_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include <boost/optional.hpp> diff --git a/src/mongo/db/s/resharding/resharding_oplog_batch_applier_test.cpp b/src/mongo/db/s/resharding/resharding_oplog_batch_applier_test.cpp index ca596e65e16..f3f96e86761 100644 --- a/src/mongo/db/s/resharding/resharding_oplog_batch_applier_test.cpp +++ b/src/mongo/db/s/resharding/resharding_oplog_batch_applier_test.cpp @@ -36,7 +36,7 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/logical_session_cache_noop.h" #include "mongo/db/logical_session_id.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/persistent_task_store.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator_mock.h" diff --git a/src/mongo/db/s/resharding/resharding_oplog_crud_application_test.cpp b/src/mongo/db/s/resharding/resharding_oplog_crud_application_test.cpp index 19fb3864915..f8636f7f0de 100644 --- a/src/mongo/db/s/resharding/resharding_oplog_crud_application_test.cpp +++ b/src/mongo/db/s/resharding/resharding_oplog_crud_application_test.cpp @@ -31,7 +31,7 @@ #include "mongo/db/catalog/collection_options.h" #include "mongo/db/catalog_raii.h" #include "mongo/db/logical_session_cache_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/persistent_task_store.h" #include "mongo/db/query/internal_plans.h" #include "mongo/db/repl/apply_ops.h" diff --git a/src/mongo/db/s/resharding/resharding_oplog_fetcher_test.cpp b/src/mongo/db/s/resharding/resharding_oplog_fetcher_test.cpp index 60d66a06c16..ddf8e673240 100644 --- a/src/mongo/db/s/resharding/resharding_oplog_fetcher_test.cpp +++ b/src/mongo/db/s/resharding/resharding_oplog_fetcher_test.cpp @@ -40,7 +40,7 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/dbhelpers.h" #include "mongo/db/logical_session_cache_noop.h" -#include "mongo/db/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_impl.h" #include "mongo/db/pipeline/document_source_mock.h" #include "mongo/db/repl/storage_interface_impl.h" #include "mongo/db/repl/wait_for_majority_service.h" diff --git a/src/mongo/db/s/resharding/resharding_recipient_service_test.cpp b/src/mongo/db/s/resharding/resharding_recipient_service_test.cpp index 4e6a5489f71..191cd76c2c6 100644 --- a/src/mongo/db/s/resharding/resharding_recipient_service_test.cpp +++ b/src/mongo/db/s/resharding/resharding_recipient_service_test.cpp @@ -32,8 +32,8 @@ #include "mongo/bson/timestamp.h" #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/persistent_task_store.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog_entry.h" diff --git a/src/mongo/db/s/resharding/resharding_service_test_helpers.h b/src/mongo/db/s/resharding/resharding_service_test_helpers.h index b687cf6b5b4..7d123dde7ff 100644 --- a/src/mongo/db/s/resharding/resharding_service_test_helpers.h +++ b/src/mongo/db/s/resharding/resharding_service_test_helpers.h @@ -31,7 +31,7 @@ #include "mongo/platform/basic.h" -#include "mongo/db/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_noop.h" namespace mongo { namespace resharding_service_test_helpers { diff --git a/src/mongo/db/s/resharding/resharding_util.cpp b/src/mongo/db/s/resharding/resharding_util.cpp index cef05c8547f..4ff2c9e3643 100644 --- a/src/mongo/db/s/resharding/resharding_util.cpp +++ b/src/mongo/db/s/resharding/resharding_util.cpp @@ -40,7 +40,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/exec/document_value/document.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/pipeline/document_source_add_fields.h" #include "mongo/db/pipeline/document_source_find_and_modify_image_lookup.h" diff --git a/src/mongo/db/s/session_catalog_migration_source.cpp b/src/mongo/db/s/session_catalog_migration_source.cpp index 50a442ffd25..e97005571ef 100644 --- a/src/mongo/db/s/session_catalog_migration_source.cpp +++ b/src/mongo/db/s/session_catalog_migration_source.cpp @@ -37,7 +37,7 @@ #include "mongo/db/concurrency/exception_util.h" #include "mongo/db/dbdirectclient.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/write_ops_retryability.h" #include "mongo/db/repl/apply_ops_command_info.h" #include "mongo/db/repl/image_collection_entry_gen.h" diff --git a/src/mongo/db/s/shard_server_op_observer.cpp b/src/mongo/db/s/shard_server_op_observer.cpp index b0e82c3e738..427208baec6 100644 --- a/src/mongo/db/s/shard_server_op_observer.cpp +++ b/src/mongo/db/s/shard_server_op_observer.cpp @@ -35,7 +35,7 @@ #include "mongo/bson/util/bson_extract.h" #include "mongo/db/catalog/database_holder_impl.h" #include "mongo/db/catalog_raii.h" -#include "mongo/db/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_impl.h" #include "mongo/db/s/balancer_stats_registry.h" #include "mongo/db/s/chunk_split_state_driver.h" #include "mongo/db/s/chunk_splitter.h" diff --git a/src/mongo/db/s/shard_server_op_observer.h b/src/mongo/db/s/shard_server_op_observer.h index 4d615cbf5ea..88faf326640 100644 --- a/src/mongo/db/s/shard_server_op_observer.h +++ b/src/mongo/db/s/shard_server_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/s/sharding_initialization_mongod_test.cpp b/src/mongo/db/s/sharding_initialization_mongod_test.cpp index f090c769f69..d27301ddfe2 100644 --- a/src/mongo/db/s/sharding_initialization_mongod_test.cpp +++ b/src/mongo/db/s/sharding_initialization_mongod_test.cpp @@ -33,7 +33,7 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/concurrency/d_concurrency.h" #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/s/collection_sharding_state_factory_shard.h" #include "mongo/db/s/collection_sharding_state_factory_standalone.h" diff --git a/src/mongo/db/s/sharding_initialization_op_observer_test.cpp b/src/mongo/db/s/sharding_initialization_op_observer_test.cpp index f88fc027875..2420e858e54 100644 --- a/src/mongo/db/s/sharding_initialization_op_observer_test.cpp +++ b/src/mongo/db/s/sharding_initialization_op_observer_test.cpp @@ -33,8 +33,8 @@ #include "mongo/db/catalog_raii.h" #include "mongo/db/concurrency/d_concurrency.h" #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/s/config_server_op_observer.h" #include "mongo/db/s/shard_server_catalog_cache_loader.h" diff --git a/src/mongo/db/s/sharding_mongod_test_fixture.cpp b/src/mongo/db/s/sharding_mongod_test_fixture.cpp index 8e445ccce79..679046d5613 100644 --- a/src/mongo/db/s/sharding_mongod_test_fixture.cpp +++ b/src/mongo/db/s/sharding_mongod_test_fixture.cpp @@ -41,8 +41,8 @@ #include "mongo/db/client.h" #include "mongo/db/commands.h" #include "mongo/db/namespace_string.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/query/cursor_response.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/oplog.h" diff --git a/src/mongo/db/serverless/shard_split_donor_op_observer.h b/src/mongo/db/serverless/shard_split_donor_op_observer.h index ab80fe558a8..6cd7f62f292 100644 --- a/src/mongo/db/serverless/shard_split_donor_op_observer.h +++ b/src/mongo/db/serverless/shard_split_donor_op_observer.h @@ -29,7 +29,7 @@ #pragma once -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" namespace mongo { diff --git a/src/mongo/db/serverless/shard_split_donor_service_test.cpp b/src/mongo/db/serverless/shard_split_donor_service_test.cpp index 5824029d097..03afbcbaf10 100644 --- a/src/mongo/db/serverless/shard_split_donor_service_test.cpp +++ b/src/mongo/db/serverless/shard_split_donor_service_test.cpp @@ -37,8 +37,8 @@ #include "mongo/db/catalog/database_holder_mock.h" #include "mongo/db/db_raii.h" #include "mongo/db/dbhelpers.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/primary_only_service.h" #include "mongo/db/repl/primary_only_service_op_observer.h" diff --git a/src/mongo/db/service_context.cpp b/src/mongo/db/service_context.cpp index 750a9671899..013e3209f95 100644 --- a/src/mongo/db/service_context.cpp +++ b/src/mongo/db/service_context.cpp @@ -39,7 +39,7 @@ #include "mongo/bson/bsonobj.h" #include "mongo/db/client.h" #include "mongo/db/default_baton.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/db/storage/recovery_unit_noop.h" #include "mongo/logv2/log.h" diff --git a/src/mongo/db/service_context_d_test_fixture.cpp b/src/mongo/db/service_context_d_test_fixture.cpp index 9eda18d4812..0e40005bde4 100644 --- a/src/mongo/db/service_context_d_test_fixture.cpp +++ b/src/mongo/db/service_context_d_test_fixture.cpp @@ -43,7 +43,7 @@ #include "mongo/db/global_settings.h" #include "mongo/db/index/index_access_method_factory_impl.h" #include "mongo/db/index_builds_coordinator_mongod.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/repl_settings.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/s/collection_sharding_state_factory_shard.h" diff --git a/src/mongo/db/service_context_test_fixture.cpp b/src/mongo/db/service_context_test_fixture.cpp index 87a2ea4ae36..1bc1e9320ce 100644 --- a/src/mongo/db/service_context_test_fixture.cpp +++ b/src/mongo/db/service_context_test_fixture.cpp @@ -35,7 +35,7 @@ #include "mongo/client/replica_set_monitor_manager.h" #include "mongo/db/client.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/util/assert_util.h" #include "mongo/util/clock_source_mock.h" #include "mongo/util/diagnostic_info.h" diff --git a/src/mongo/db/storage/write_unit_of_work.cpp b/src/mongo/db/storage/write_unit_of_work.cpp index 9cf10dcbddc..ea9f65909c9 100644 --- a/src/mongo/db/storage/write_unit_of_work.cpp +++ b/src/mongo/db/storage/write_unit_of_work.cpp @@ -32,7 +32,7 @@ #include "mongo/db/storage/write_unit_of_work.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/operation_context.h" #include "mongo/util/fail_point.h" #include "mongo/util/time_support.h" diff --git a/src/mongo/db/transaction_participant.cpp b/src/mongo/db/transaction_participant.cpp index b68c4d3b98e..ce2de3e9490 100644 --- a/src/mongo/db/transaction_participant.cpp +++ b/src/mongo/db/transaction_participant.cpp @@ -54,7 +54,7 @@ #include "mongo/db/index/index_access_method.h" #include "mongo/db/internal_transactions_feature_flag_gen.h" #include "mongo/db/logical_session_id.h" -#include "mongo/db/op_observer.h" +#include "mongo/db/op_observer/op_observer.h" #include "mongo/db/ops/update.h" #include "mongo/db/ops/write_ops_retryability.h" #include "mongo/db/query/get_executor.h" diff --git a/src/mongo/db/transaction_participant_retryable_writes_test.cpp b/src/mongo/db/transaction_participant_retryable_writes_test.cpp index a7459fd5ffa..48679012051 100644 --- a/src/mongo/db/transaction_participant_retryable_writes_test.cpp +++ b/src/mongo/db/transaction_participant_retryable_writes_test.cpp @@ -34,8 +34,8 @@ #include "mongo/db/client.h" #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/mock_repl_coord_server_fixture.h" #include "mongo/db/repl/oplog.h" diff --git a/src/mongo/db/transaction_participant_test.cpp b/src/mongo/db/transaction_participant_test.cpp index 0da9d47cddd..95748462bdb 100644 --- a/src/mongo/db/transaction_participant_test.cpp +++ b/src/mongo/db/transaction_participant_test.cpp @@ -36,8 +36,8 @@ #include "mongo/db/concurrency/replication_state_transition_lock_guard.h" #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" -#include "mongo/db/op_observer_noop.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/repl/mock_repl_coord_server_fixture.h" #include "mongo/db/repl/oplog.h" diff --git a/src/mongo/db/vector_clock_mongod_test.cpp b/src/mongo/db/vector_clock_mongod_test.cpp index 9351b6438ff..963d969226a 100644 --- a/src/mongo/db/vector_clock_mongod_test.cpp +++ b/src/mongo/db/vector_clock_mongod_test.cpp @@ -32,8 +32,8 @@ #include "mongo/db/keys_collection_client_direct.h" #include "mongo/db/keys_collection_manager.h" #include "mongo/db/logical_time_validator.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/s/sharding_mongod_test_fixture.h" #include "mongo/db/vector_clock_mutable.h" diff --git a/src/mongo/db/vector_clock_test_fixture.cpp b/src/mongo/db/vector_clock_test_fixture.cpp index 13814076081..df54ddf341d 100644 --- a/src/mongo/db/vector_clock_test_fixture.cpp +++ b/src/mongo/db/vector_clock_test_fixture.cpp @@ -35,8 +35,8 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/logical_time.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/service_context.h" #include "mongo/db/signed_logical_time.h" diff --git a/src/mongo/dbtests/SConscript b/src/mongo/dbtests/SConscript index 65722cdf4f2..88ebb5bf98a 100644 --- a/src/mongo/dbtests/SConscript +++ b/src/mongo/dbtests/SConscript @@ -35,7 +35,7 @@ env.Library( '$BUILD_DIR/mongo/db/index/index_access_method_factory', '$BUILD_DIR/mongo/db/index/index_access_methods', '$BUILD_DIR/mongo/db/index_builds_coordinator_mongod', - '$BUILD_DIR/mongo/db/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', '$BUILD_DIR/mongo/db/service_context_d', '$BUILD_DIR/mongo/db/storage/storage_control', '$BUILD_DIR/mongo/scripting/scripting_common', @@ -153,7 +153,7 @@ env.Program( "$BUILD_DIR/mongo/db/logical_time_metadata_hook", "$BUILD_DIR/mongo/db/mongohasher", "$BUILD_DIR/mongo/db/multitenancy", - "$BUILD_DIR/mongo/db/op_observer_impl", + "$BUILD_DIR/mongo/db/op_observer/op_observer_impl", "$BUILD_DIR/mongo/db/ops/write_ops", "$BUILD_DIR/mongo/db/query/collation/collator_interface_mock", "$BUILD_DIR/mongo/db/query/command_request_response", diff --git a/src/mongo/dbtests/dbhelper_tests.cpp b/src/mongo/dbtests/dbhelper_tests.cpp index bdfd223e8d3..424672c87e6 100644 --- a/src/mongo/dbtests/dbhelper_tests.cpp +++ b/src/mongo/dbtests/dbhelper_tests.cpp @@ -37,8 +37,8 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/dbhelpers.h" #include "mongo/db/global_settings.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/range_arithmetic.h" #include "mongo/db/repl/replication_coordinator.h" diff --git a/src/mongo/dbtests/framework.cpp b/src/mongo/dbtests/framework.cpp index bbc9c9f2ea8..bfdfc2cd1ab 100644 --- a/src/mongo/dbtests/framework.cpp +++ b/src/mongo/dbtests/framework.cpp @@ -44,7 +44,7 @@ #include "mongo/db/dbdirectclient.h" #include "mongo/db/index/index_access_method_factory_impl.h" #include "mongo/db/index_builds_coordinator_mongod.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/s/collection_sharding_state_factory_shard.h" #include "mongo/db/s/sharding_state.h" #include "mongo/db/service_context.h" diff --git a/src/mongo/dbtests/query_stage_batched_delete.cpp b/src/mongo/dbtests/query_stage_batched_delete.cpp index 605c886d84d..426f0d53e66 100644 --- a/src/mongo/dbtests/query_stage_batched_delete.cpp +++ b/src/mongo/dbtests/query_stage_batched_delete.cpp @@ -38,7 +38,7 @@ #include "mongo/db/exec/collection_scan.h" #include "mongo/db/exec/delete_stage.h" #include "mongo/db/exec/queued_data_stage.h" -#include "mongo/db/op_observer_noop.h" +#include "mongo/db/op_observer/op_observer_noop.h" #include "mongo/db/query/canonical_query.h" #include "mongo/db/service_context.h" #include "mongo/dbtests/dbtests.h" diff --git a/src/mongo/dbtests/repltests.cpp b/src/mongo/dbtests/repltests.cpp index 216f93ee72f..7f58a0e5636 100644 --- a/src/mongo/dbtests/repltests.cpp +++ b/src/mongo/dbtests/repltests.cpp @@ -39,7 +39,7 @@ #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" #include "mongo/db/json.h" -#include "mongo/db/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_impl.h" #include "mongo/db/ops/update.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/repl_client_info.h" diff --git a/src/mongo/embedded/SConscript b/src/mongo/embedded/SConscript index 735ba48d05b..9479715f7b9 100644 --- a/src/mongo/embedded/SConscript +++ b/src/mongo/embedded/SConscript @@ -88,14 +88,14 @@ env.Library( '$BUILD_DIR/mongo/db/commands/mongod_fcv', '$BUILD_DIR/mongo/db/commands/standalone', '$BUILD_DIR/mongo/db/concurrency/lock_manager', - '$BUILD_DIR/mongo/db/fcv_op_observer', '$BUILD_DIR/mongo/db/index/index_access_method_factory', '$BUILD_DIR/mongo/db/index/index_access_methods', '$BUILD_DIR/mongo/db/index_builds_coordinator_interface', '$BUILD_DIR/mongo/db/logical_session_cache', '$BUILD_DIR/mongo/db/logical_session_cache_impl', - '$BUILD_DIR/mongo/db/op_observer', - '$BUILD_DIR/mongo/db/op_observer_impl', + '$BUILD_DIR/mongo/db/op_observer/fcv_op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer_impl', '$BUILD_DIR/mongo/db/pipeline/process_interface/mongod_process_interfaces', '$BUILD_DIR/mongo/db/repl/repl_coordinator_interface', '$BUILD_DIR/mongo/db/repl/replica_set_messages', diff --git a/src/mongo/embedded/embedded.cpp b/src/mongo/embedded/embedded.cpp index df5f9ab2356..a1a5eceaaf2 100644 --- a/src/mongo/embedded/embedded.cpp +++ b/src/mongo/embedded/embedded.cpp @@ -49,8 +49,8 @@ #include "mongo/db/index/index_access_method_factory_impl.h" #include "mongo/db/kill_sessions_local.h" #include "mongo/db/logical_session_cache_impl.h" -#include "mongo/db/op_observer_impl.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer_impl.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/repl/storage_interface_impl.h" #include "mongo/db/s/collection_sharding_state_factory_standalone.h" #include "mongo/db/service_liaison_mongod.h" diff --git a/src/mongo/idl/SConscript b/src/mongo/idl/SConscript index df82f0216e1..b732a00dedf 100644 --- a/src/mongo/idl/SConscript +++ b/src/mongo/idl/SConscript @@ -86,7 +86,7 @@ env.Library( ], LIBDEPS_PRIVATE=[ '$BUILD_DIR/mongo/db/dbdirectclient', - '$BUILD_DIR/mongo/db/op_observer', + '$BUILD_DIR/mongo/db/op_observer/op_observer', 'cluster_server_parameter_initializer', ], ) diff --git a/src/mongo/idl/cluster_server_parameter_op_observer.h b/src/mongo/idl/cluster_server_parameter_op_observer.h index f19dcc91337..655689e09f6 100644 --- a/src/mongo/idl/cluster_server_parameter_op_observer.h +++ b/src/mongo/idl/cluster_server_parameter_op_observer.h @@ -35,8 +35,8 @@ #include "mongo/base/status.h" #include "mongo/base/string_data.h" #include "mongo/db/client.h" -#include "mongo/db/op_observer.h" -#include "mongo/db/op_observer_registry.h" +#include "mongo/db/op_observer/op_observer.h" +#include "mongo/db/op_observer/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/service_context.h" |