diff options
-rw-r--r-- | persistence/src/vespa/persistence/spi/bucket_tasks.h | 3 | ||||
-rw-r--r-- | storage/src/vespa/storage/persistence/messages.h | 7 |
2 files changed, 8 insertions, 2 deletions
diff --git a/persistence/src/vespa/persistence/spi/bucket_tasks.h b/persistence/src/vespa/persistence/spi/bucket_tasks.h index 12daa463e2b..0b9c283817d 100644 --- a/persistence/src/vespa/persistence/spi/bucket_tasks.h +++ b/persistence/src/vespa/persistence/spi/bucket_tasks.h @@ -6,6 +6,9 @@ namespace storage::spi { +/** + * Simple Bucket task that wraps a lambda that does the job. + */ template<class FunctionType> class LambdaBucketTask : public BucketTask { public: diff --git a/storage/src/vespa/storage/persistence/messages.h b/storage/src/vespa/storage/persistence/messages.h index 55ca87a1941..3b49365d560 100644 --- a/storage/src/vespa/storage/persistence/messages.h +++ b/storage/src/vespa/storage/persistence/messages.h @@ -238,6 +238,9 @@ public: void print(std::ostream& out, bool verbose, const std::string& indent) const override; }; + +// Internal Command task for bringing along a Bucket and a BucketTask in +// the inner workings of the storagelink chain. class RunTaskCommand : public api::InternalCommand { public: static const uint32_t ID = 1011; @@ -252,9 +255,10 @@ public: private: std::unique_ptr<spi::BucketTask> _task; - spi::Bucket _bucket; + spi::Bucket _bucket; }; +// Simple reply for matching the RunTaskCommand class RunTaskReply : public api::InternalReply { public: @@ -263,6 +267,5 @@ private: static const uint32_t ID = 1012; }; - } // ns storage |