diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-02-14 17:01:58 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-02-14 17:01:58 +0000 |
commit | 66e66d08e509a4eabf394442bcd7e733e228fb25 (patch) | |
tree | e9aa07ff8e2debfc93c5e430377848779b315cd5 /searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h | |
parent | 76b1a42ae483ae66a2d1e43ef749f41661754e1c (diff) |
When making callbacks like notifying about new bucket show the gurad that is held.
Then this guard can used instead of possibly making a deadlock if trying to take it yourself.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h b/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h index 4a6bb4fa938..65e206d7327 100644 --- a/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h +++ b/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h @@ -31,13 +31,13 @@ struct MyMoveOperationLimiter : public IMoveOperationLimiter { struct MyMoveHandler : public IDocumentMoveHandler { using MoveOperationVector = std::vector<MoveOperation>; - BucketDBOwner &_bucketDb; + bucketdb::BucketDBOwner &_bucketDb; MoveOperationVector _moves; size_t _numCachedBuckets; bool _storeMoveDoneContexts; std::vector<vespalib::IDestructorCallback::SP> _moveDoneContexts; - MyMoveHandler(BucketDBOwner &bucketDb, bool storeMoveDoneContext = false); + MyMoveHandler(bucketdb::BucketDBOwner &bucketDb, bool storeMoveDoneContext = false); ~MyMoveHandler() override; void handleMove(MoveOperation &op, vespalib::IDestructorCallback::SP moveDoneCtx) override; @@ -103,7 +103,7 @@ struct MySubDb { UserDocuments _docs; bucketdb::BucketDBHandler _bucketDBHandler; - MySubDb(const std::shared_ptr<const DocumentTypeRepo> &repo, std::shared_ptr<BucketDBOwner> bucketDB, + MySubDb(const std::shared_ptr<const DocumentTypeRepo> &repo, std::shared_ptr<bucketdb::BucketDBOwner> bucketDB, uint32_t subDbId, SubDbType subDbType); ~MySubDb(); |