|
@ -393,7 +393,6 @@ inline std::unique_ptr<dsacache::CacheData> dsacache::Cache::Access(uint8_t* dat |
|
|
// data source location
|
|
|
// data source location
|
|
|
|
|
|
|
|
|
if (CheckFlag(flags, FLAG_ACCESS_WEAK)) { |
|
|
if (CheckFlag(flags, FLAG_ACCESS_WEAK)) { |
|
|
std::cerr << "[x] WEAK ACCESS FAILED!" << std::endl; |
|
|
|
|
|
task->SetCacheToSource(); |
|
|
task->SetCacheToSource(); |
|
|
return std::move(task); |
|
|
return std::move(task); |
|
|
} |
|
|
} |
|
@ -778,7 +777,6 @@ inline void dsacache::CacheData::WaitOnCompletion() { |
|
|
|
|
|
|
|
|
for (auto& handler : *local_handlers) { |
|
|
for (auto& handler : *local_handlers) { |
|
|
if (CheckFlag(flags_, FLAG_WAIT_WEAK) && !handler.is_finished()) { |
|
|
if (CheckFlag(flags_, FLAG_WAIT_WEAK) && !handler.is_finished()) { |
|
|
std::cerr << "[x] WEAK WAIT FAIL!" << std::endl; |
|
|
|
|
|
handlers_->store(local_handlers); |
|
|
handlers_->store(local_handlers); |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
@ -786,8 +784,6 @@ inline void dsacache::CacheData::WaitOnCompletion() { |
|
|
auto result = handler.get(); |
|
|
auto result = handler.get(); |
|
|
|
|
|
|
|
|
if (result.status != dml::status_code::ok) { |
|
|
if (result.status != dml::status_code::ok) { |
|
|
// if one of the copy tasks failed we abort the whole task
|
|
|
|
|
|
// after all operations are completed on it
|
|
|
|
|
|
std::cerr << "[x] ERROR (" << dml::StatusCodeToString(result.status) << ") FOUND FOR TASK IN WAIT!" << std::endl; |
|
|
std::cerr << "[x] ERROR (" << dml::StatusCodeToString(result.status) << ") FOUND FOR TASK IN WAIT!" << std::endl; |
|
|
error = true; |
|
|
error = true; |
|
|
} |
|
|
} |
|
|