- Splitt common test code.

- Splitt out HandlerTest.
- Make JobTest parameterized to run with current way of using frozen bucket concept, or future using BucketExecutor and content layer bucket locking.

1 files changed, 7 insertions, 7 deletions

diff --git a/persistence/src/vespa/persistence/dummyimpl/dummy_bucket_executor.cpp b/persistence/src/vespa/persistence/dummyimpl/dummy_bucket_executor.cpp
index 8730e25e52b..9aa647fcc65 100644
--- a/persistence/src/vespa/persistence/dummyimpl/dummy_bucket_executor.cpp
+++ b/persistence/src/vespa/persistence/dummyimpl/dummy_bucket_executor.cpp
@@ -24,14 +24,14 @@ DummyBucketExecutor::~DummyBucketExecutor() {
 
 std::unique_ptr<BucketTask>
 DummyBucketExecutor::execute(const Bucket & bucket, std::unique_ptr<BucketTask> task) {
-    {
-        std::unique_lock guard(_lock);
-        while (_inFlight.contains(bucket.getBucket())) {
-            _cond.wait(guard);
-        }
-        _inFlight.insert(bucket.getBucket());
-    }
     _executor->execute(makeLambdaTask([this, bucket, bucketTask=std::move(task)]() {
+        {
+            std::unique_lock guard(_lock);
+            while (_inFlight.contains(bucket.getBucket())) {
+                _cond.wait(guard);
+            }
+            _inFlight.insert(bucket.getBucket());
+        }
         bucketTask->run(bucket, makeLambdaCallback([this, bucket]() {
             std::unique_lock guard(_lock);
             assert(_inFlight.contains(bucket.getBucket()));