summaryrefslogtreecommitdiff
path: root/src/mongo/db/timeseries
diff options
context:
space:
mode:
authorLouis Williams <louis.williams@mongodb.com>2023-02-10 14:35:56 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2023-02-22 20:50:53 +0000
commitdab496ed148b2b5895780e6fd4208bddae2424c5 (patch)
tree3e72d2a1ac546e6be9a72880e1511a205c5565cb /src/mongo/db/timeseries
parent8bea11983310ab5be581d59bd84573a2089c8825 (diff)
downloadmongo-dab496ed148b2b5895780e6fd4208bddae2424c5.tar.gz
SERVER-73873 Remove opCtx captures from onCommit/onRollback handlers
Diffstat (limited to 'src/mongo/db/timeseries')
-rw-r--r--src/mongo/db/timeseries/bucket_catalog/bucket_catalog_helpers.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/timeseries/bucket_catalog/bucket_catalog_helpers.cpp b/src/mongo/db/timeseries/bucket_catalog/bucket_catalog_helpers.cpp
index edc6b60bf39..e8e616d2ddf 100644
--- a/src/mongo/db/timeseries/bucket_catalog/bucket_catalog_helpers.cpp
+++ b/src/mongo/db/timeseries/bucket_catalog/bucket_catalog_helpers.cpp
@@ -332,13 +332,13 @@ void handleDirectWrite(OperationContext* opCtx, const NamespaceString& ns, const
// Then register callbacks so we can let the BucketCatalog know that we are done with our direct
// write after the actual write takes place (or is abandoned), and allow reopening.
- opCtx->recoveryUnit()->onCommit(
- [svcCtx = opCtx->getServiceContext(), resolvedNs, bucketId](boost::optional<Timestamp>) {
- auto& bucketCatalog = BucketCatalog::get(svcCtx);
- bucketCatalog.directWriteFinish(resolvedNs, bucketId);
- });
+ opCtx->recoveryUnit()->onCommit([svcCtx = opCtx->getServiceContext(), resolvedNs, bucketId](
+ OperationContext*, boost::optional<Timestamp>) {
+ auto& bucketCatalog = BucketCatalog::get(svcCtx);
+ bucketCatalog.directWriteFinish(resolvedNs, bucketId);
+ });
opCtx->recoveryUnit()->onRollback(
- [svcCtx = opCtx->getServiceContext(), resolvedNs, bucketId]() {
+ [svcCtx = opCtx->getServiceContext(), resolvedNs, bucketId](OperationContext*) {
auto& bucketCatalog = BucketCatalog::get(svcCtx);
bucketCatalog.directWriteFinish(resolvedNs, bucketId);
});