diff options
author | Enrico Golfieri <enrico.golfieri@mongodb.com> | 2022-12-12 11:08:44 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-12-12 12:46:40 +0000 |
commit | 4fc261005c7726a1b99025d60e6ded3f1ba299ca (patch) | |
tree | 69a8e4786a30242b43dae12bcf6c6a14b5edd293 /src/mongo/db/repl | |
parent | 21aba5b624e0371869a453f89ad1b3711ee720b0 (diff) | |
download | mongo-4fc261005c7726a1b99025d60e6ded3f1ba299ca.tar.gz |
SERVER-71754 Define a new remote command to notify the completion of an addShard() operation to other nodes of the cluster
Diffstat (limited to 'src/mongo/db/repl')
-rw-r--r-- | src/mongo/db/repl/change_stream_oplog_notification.cpp | 5 | ||||
-rw-r--r-- | src/mongo/db/repl/change_stream_oplog_notification.h | 7 |
2 files changed, 11 insertions, 1 deletions
diff --git a/src/mongo/db/repl/change_stream_oplog_notification.cpp b/src/mongo/db/repl/change_stream_oplog_notification.cpp index 531f7af2e57..b1c26353d93 100644 --- a/src/mongo/db/repl/change_stream_oplog_notification.cpp +++ b/src/mongo/db/repl/change_stream_oplog_notification.cpp @@ -34,7 +34,6 @@ #include "mongo/db/namespace_string.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/oplog_entry.h" -#include "mongo/logv2/redaction.h" namespace mongo { @@ -70,4 +69,8 @@ void notifyChangeStreamsOnShardCollection(OperationContext* opCtx, wunit.commit(); }); } + +void notifyChangeStreamsOnAddShard(OperationContext* opCtx, + const ShardId& shardName, + const ConnectionString& connStr) {} } // namespace mongo diff --git a/src/mongo/db/repl/change_stream_oplog_notification.h b/src/mongo/db/repl/change_stream_oplog_notification.h index ee746b96167..c999eadc2a8 100644 --- a/src/mongo/db/repl/change_stream_oplog_notification.h +++ b/src/mongo/db/repl/change_stream_oplog_notification.h @@ -30,8 +30,10 @@ #pragma once #include "mongo/bson/bsonobj.h" +#include "mongo/client/connection_string.h" #include "mongo/db/namespace_string.h" #include "mongo/db/operation_context.h" +#include "mongo/db/shard_id.h" #include "mongo/util/uuid.h" namespace mongo { @@ -44,4 +46,9 @@ void notifyChangeStreamsOnShardCollection(OperationContext* opCtx, const NamespaceString& nss, const UUID& uuid, BSONObj cmd); + +void notifyChangeStreamsOnAddShard(OperationContext* opCtx, + const ShardId& shardName, + const ConnectionString& connStr); + } // namespace mongo |