submit dump task

Author: mag1c-h

ucm/store/cache/cc/trans_manager.h

@@ -24,6 +24,7 @@
 #ifndef UNIFIEDCACHE_CACHE_STORE_CC_TRANS_MANAGER_H
 #define UNIFIEDCACHE_CACHE_STORE_CC_TRANS_MANAGER_H
 
+#include "dump_queue.h"
 #include "load_queue.h"
 #include "logger/logger.h"
 #include "template/task_wrapper.h"
@@ -35,6 +36,7 @@ class TransManager : public Detail::TaskWrapper<TransTask, Detail::TaskHandle> {
     size_t shardSize_;
     TransBuffer buffer_;
     LoadQueue loadQ_;
+    DumpQueue dumpQ_;
 
 public:
     Status Setup(const Config& config)
@@ -43,7 +45,9 @@ class TransManager : public Detail::TaskWrapper<TransTask, Detail::TaskHandle> {
         shardSize_ = config.shardSize;
         auto s = buffer_.Setup(config);
         if (s.Failure()) [[unlikely]] { return s; }
-        return loadQ_.Setup(config, &failureSet_, &buffer_);
+        s = loadQ_.Setup(config, &failureSet_, &buffer_);
+        if (s.Failure()) [[unlikely]] { return s; }
+        return dumpQ_.Setup(config, &failureSet_, &buffer_);
     }
 
 protected:
@@ -61,7 +65,8 @@ class TransManager : public Detail::TaskWrapper<TransTask, Detail::TaskHandle> {
         });
         if (t->type == TransTask::Type::LOAD) {
             loadQ_.Submit(t, w);
-            return;
+        } else {
+            dumpQ_.Submit(t, w);
         }
     }
 };