ftds for cache dump

Author: mag1c-h

ucm/store/cache/cc/dump_queue.cc

@@ -93,6 +93,7 @@ void DumpQueue::DispatchOneTask(Trans::Stream* stream, size_t tensorSize, TaskPa
 
 Status DumpQueue::DumpOneTask(Trans::Stream* stream, size_t tensorSize, TaskPtr task)
 {
+    auto tp = NowTime::Now();
     Detail::TaskDesc backendTaskDesc;
     backendTaskDesc.brief = "Cache2Backend";
     const auto nShard = task->desc.size();
@@ -117,12 +118,14 @@ Status DumpQueue::DumpOneTask(Trans::Stream* stream, size_t tensorSize, TaskPtr
             Detail::Shard{shard.owner, shard.index, {shardTask.bufferHandle.Data()}});
         backendTaskIndex.emplace_back(i);
     }
+    auto tpMakeBuffer = NowTime::Now();
     if (backendTaskIndex.empty()) { return Status::OK(); }
     auto s = stream->Synchronized();
     if (s.Failure()) [[unlikely]] {
         UC_ERROR("Failed({}) to sync on stream.", s);
         return s;
     }
+    auto tpSyncStream = NowTime::Now();
     for (const auto& i : backendTaskIndex) { shardTasks[i].bufferHandle.MarkReady(); }
     auto res = backend_->Dump(std::move(backendTaskDesc));
     if (!res) [[unlikely]] {
@@ -134,6 +137,9 @@ Status DumpQueue::DumpOneTask(Trans::Stream* stream, size_t tensorSize, TaskPtr
         shardTask.backendTaskHandle = res.Value();
         dumping_.Push(std::move(shardTask));
     }
+    auto tpEnd = NowTime::Now();
+    UC_DEBUG("Cache task({}) mk_buf={:06f}s, sync={:06f}s, back={:06f}s.", task->id,
+             tpMakeBuffer - tp, tpSyncStream - tpMakeBuffer, tpEnd - tpSyncStream);
     return Status::OK();
 }