summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/session_catalog_migration_source.h
diff options
context:
space:
mode:
authorMatthew Saltz <matthew.saltz@mongodb.com>2018-07-19 14:35:18 -0400
committerMatthew Saltz <matthew.saltz@mongodb.com>2018-07-24 11:35:04 -0400
commit9175c4deba82dc35606d14428d1bf0d8b43d7a6c (patch)
tree799659ebfc5b6cb593cadfb376c677ff6c616b7a /src/mongo/db/s/session_catalog_migration_source.h
parent7f729d704fbf683a8746c8a512a8fd694118e3e7 (diff)
downloadmongo-9175c4deba82dc35606d14428d1bf0d8b43d7a6c.tar.gz
SERVER-35658 Check for rollback at end of each session migration batch
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_source.h')
-rw-r--r--src/mongo/db/s/session_catalog_migration_source.h7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_source.h b/src/mongo/db/s/session_catalog_migration_source.h
index 0ef285e5818..2c53ce2db51 100644
--- a/src/mongo/db/s/session_catalog_migration_source.h
+++ b/src/mongo/db/s/session_catalog_migration_source.h
@@ -109,6 +109,13 @@ public:
*/
void notifyNewWriteOpTime(repl::OpTime opTimestamp);
+ /**
+ * Returns the rollback ID recorded at the beginning of session migration.
+ */
+ int getRollbackIdAtInit() const {
+ return _rollbackIdAtInit;
+ }
+
private:
/**
* An iterator for extracting session write oplogs that need to be cloned during migration.