fixed

Author: UESTC-AHao

ucm/store/device/cuda/cuda_device.cc

@@ -162,7 +162,7 @@ class CudaDevice : public IBufferedDevice {
         CUfileHandle_t cuFileHandle = nullptr;
         auto status = CuFileHandleRecorder::Instance().Get(path, cuFileHandle,
             [&path](CUfileHandle_t& handle, int& fd) -> Status {
-                return CreateCuFileHandle(path, O_WRONLY | O_CREAT | O_DIRECT, handle, fd);
+                return CreateCuFileHandle(path, O_WRONLY | O_DIRECT, handle, fd);
             });
         if (status.Failure()) {
             return status;

ucm/store/nfsstore/cc/domain/trans/directstorage_queue.cc

@@ -78,9 +78,6 @@ void DirectStorageQueue::Done(Task::Shard& shard, const Device& device, const bo
 {
     if (!success) { this->failureSet_->Insert(shard.owner); }
     if (!shard.done) { return; }
-    if (device) {
-        if (device->Synchronized().Failure()) { this->failureSet_->Insert(shard.owner); }
-    }
     shard.done();
 }
 

ucm/store/task/task_queue.h

@@ -25,6 +25,8 @@
 #define UNIFIEDCACHE_TASK_QUEUE_H
 
 #include "task_shard.h"
+#include "task_set.h"
+#include "../nfsstore/cc/domain/space/space_layout.h"
 
 namespace UC {
 
@@ -33,7 +35,7 @@ class TaskQueue {
     virtual ~TaskQueue() = default;
     virtual void Push(std::list<Task::Shard>& shards) noexcept = 0;
     virtual Status Setup(const int32_t deviceId, const size_t bufferSize, const size_t bufferNumber,
-                 class TaskSet* failureSet, const class SpaceLayout* layout, const size_t timeoutMs, bool transferUseDirect) = 0;
+                 TaskSet* failureSet, const SpaceLayout* layout, const size_t timeoutMs, bool transferUseDirect) = 0;
 };
 
 } // namespace UC