summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_chunk_cloner_source.h
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2017-09-19 14:44:36 -0400
committerRandolph Tan <randolph@10gen.com>2017-09-26 19:11:04 -0400
commit85d9721c00d7020af78fe60453f8362380fe697d (patch)
tree197240934bc6e849964449587234b526916e512d /src/mongo/db/s/migration_chunk_cloner_source.h
parent457ecaf9ca73456df43e442ddd758b9067a6a002 (diff)
downloadmongo-85d9721c00d7020af78fe60453f8362380fe697d.tar.gz
SERVER-30894 Implement command for transferring session information during migration
Diffstat (limited to 'src/mongo/db/s/migration_chunk_cloner_source.h')
-rw-r--r--src/mongo/db/s/migration_chunk_cloner_source.h15
1 files changed, 12 insertions, 3 deletions
diff --git a/src/mongo/db/s/migration_chunk_cloner_source.h b/src/mongo/db/s/migration_chunk_cloner_source.h
index 750bcdcda80..9d9a1407f1d 100644
--- a/src/mongo/db/s/migration_chunk_cloner_source.h
+++ b/src/mongo/db/s/migration_chunk_cloner_source.h
@@ -36,6 +36,7 @@ namespace mongo {
class BSONObj;
class OperationContext;
class Status;
+class Timestamp;
/**
* This class is responsible for producing chunk documents to be moved from donor to a recipient
@@ -118,7 +119,9 @@ public:
*
* NOTE: Must be called with at least IX lock held on the collection.
*/
- virtual void onInsertOp(OperationContext* opCtx, const BSONObj& insertedDoc) = 0;
+ virtual void onInsertOp(OperationContext* opCtx,
+ const BSONObj& insertedDoc,
+ const Timestamp& oplogTs) = 0;
/**
* Notifies this cloner that an update happened to the collection, which it owns. It is up to
@@ -127,7 +130,10 @@ public:
*
* NOTE: Must be called with at least IX lock held on the collection.
*/
- virtual void onUpdateOp(OperationContext* opCtx, const BSONObj& updatedDoc) = 0;
+ virtual void onUpdateOp(OperationContext* opCtx,
+ const BSONObj& updatedDoc,
+ const Timestamp& oplogTs,
+ const Timestamp& prePostImageTs) = 0;
/**
* Notifies this cloner that a delede happened to the collection, which it owns. It is up to the
@@ -136,7 +142,10 @@ public:
*
* NOTE: Must be called with at least IX lock held on the collection.
*/
- virtual void onDeleteOp(OperationContext* opCtx, const BSONObj& deletedDocId) = 0;
+ virtual void onDeleteOp(OperationContext* opCtx,
+ const BSONObj& deletedDocId,
+ const Timestamp& oplogTs,
+ const Timestamp& preImageTs) = 0;
protected:
MigrationChunkClonerSource();