bugfix in trans buffer

Author: mag1c-h

ucm/store/cache/cc/trans_buffer.cc

@@ -374,7 +374,9 @@ size_t TransBuffer::FindAt(size_t iBucket, const Detail::BlockId& blockId, size_
             strategy_->NodeUnlock(iNode);
             break;
         }
+        auto next = meta->next;
         strategy_->NodeUnlock(iNode);
+        iNode = next;
     }
     return iNode;
 }

ucm/store/cache/cc/trans_manager.h

@@ -58,10 +58,11 @@ class TransManager : public Detail::TaskWrapper<TransTask, Detail::TaskHandle> {
         const auto num = t->desc.size();
         const auto size = shardSize_ * num;
         const auto tp = w->startTp;
+        UC_DEBUG("Dispatch one cache task({},{},{},{}).", id, brief, num, size);
         w->SetEpilog([id, brief = std::move(brief), num, size, tp] {
             auto cost = NowTime::Now() - tp;
-            UC_DEBUG("Task({},{},{},{}) finished, cost {:06f}s, bw={:06f}GB/s.", id, brief, num,
-                     size, cost, size / cost / 1e9);
+            UC_DEBUG("Cache task({},{},{},{}) finished, cost {:06f}s, bw={:06f}GB/s.", id, brief,
+                     num, size, cost, size / cost / 1e9);
         });
         if (t->type == TransTask::Type::LOAD) {
             loadQ_.Submit(t, w);

ucm/store/posix/cc/trans_manager.h

@@ -50,10 +50,11 @@ class TransManager : public Detail::TaskWrapper<TransTask, Detail::TaskHandle> {
         const auto num = t->desc.size();
         const auto size = shardSize_ * num;
         const auto tp = w->startTp;
+        UC_DEBUG("Dispatch one posix task({},{},{},{}).", id, brief, num, size);
         w->SetEpilog([id, brief = std::move(brief), num, size, tp] {
             auto cost = NowTime::Now() - tp;
-            UC_DEBUG("Task({},{},{},{}) finished, cost {:06f}s, bw={:06f}GB/s.", id, brief, num,
-                     size, cost, size / cost / 1e9);
+            UC_DEBUG("Posix task({},{},{},{}) finished, cost {:06f}s, bw={:06f}GB/s.", id, brief,
+                     num, size, cost, size / cost / 1e9);
         });
         queue_.Push(t, w);
     }

ucm/store/test/e2e/cache_on_posix_test.py

@@ -63,6 +63,8 @@ def __init__(
         cache_config["block_size"] = chunk_block_size
         cache_config["buffer_size"] = chunk_block_size * 2048
         cache_config["share_buffer_enable"] = True
+        cache_config["waiting_queue_depth"] = 16
+        cache_config["running_queue_depth"] = 1024
         cache_config["transfer_timeout_ms"] = 30000
         self.cache = UcmCacheStore(cache_config)