diff options
author | Louis Williams <louis.williams@mongodb.com> | 2023-02-10 14:35:56 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-02-22 20:50:53 +0000 |
commit | dab496ed148b2b5895780e6fd4208bddae2424c5 (patch) | |
tree | 3e72d2a1ac546e6be9a72880e1511a205c5565cb /src/mongo/db/timeseries | |
parent | 8bea11983310ab5be581d59bd84573a2089c8825 (diff) | |
download | mongo-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.cpp | 12 |
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); }); |