fix naming conflict
Some checks failed
BlockStorage/repertory/pipeline/head There was a failure building this commit
Some checks failed
BlockStorage/repertory/pipeline/head There was a failure building this commit
This commit is contained in:
@@ -67,7 +67,7 @@ protected:
|
|||||||
-> api_error override;
|
-> api_error override;
|
||||||
|
|
||||||
public:
|
public:
|
||||||
void download() override {}
|
void force_download() override {}
|
||||||
|
|
||||||
[[nodiscard]] auto get_source_path() const -> std::string override {
|
[[nodiscard]] auto get_source_path() const -> std::string override {
|
||||||
return "direct";
|
return "direct";
|
||||||
|
@@ -32,7 +32,7 @@ public:
|
|||||||
using native_operation_callback = std::function<api_error(native_handle)>;
|
using native_operation_callback = std::function<api_error(native_handle)>;
|
||||||
|
|
||||||
public:
|
public:
|
||||||
virtual void download() = 0;
|
virtual void force_download() = 0;
|
||||||
|
|
||||||
[[nodiscard]] virtual auto get_api_path() const -> std::string = 0;
|
[[nodiscard]] virtual auto get_api_path() const -> std::string = 0;
|
||||||
|
|
||||||
|
@@ -101,7 +101,7 @@ private:
|
|||||||
public:
|
public:
|
||||||
auto close() -> bool override;
|
auto close() -> bool override;
|
||||||
|
|
||||||
void download() override;
|
void force_download() override;
|
||||||
|
|
||||||
[[nodiscard]] auto get_allocated() const -> bool override;
|
[[nodiscard]] auto get_allocated() const -> bool override;
|
||||||
|
|
||||||
|
@@ -75,7 +75,7 @@ public:
|
|||||||
std::size_t chunk_size,
|
std::size_t chunk_size,
|
||||||
std::size_t ring_size) -> bool;
|
std::size_t ring_size) -> bool;
|
||||||
|
|
||||||
void download() override {}
|
void force_download() override {}
|
||||||
|
|
||||||
[[nodiscard]] auto native_operation(native_operation_callback callback)
|
[[nodiscard]] auto native_operation(native_operation_callback callback)
|
||||||
-> api_error override;
|
-> api_error override;
|
||||||
|
@@ -179,7 +179,7 @@ auto file_manager::download_pinned_file(const std::string &api_path) -> bool {
|
|||||||
|
|
||||||
auto ret = get_open_file(handle, true, open_file);
|
auto ret = get_open_file(handle, true, open_file);
|
||||||
if (ret) {
|
if (ret) {
|
||||||
open_file->download();
|
open_file->force_download();
|
||||||
}
|
}
|
||||||
|
|
||||||
close(handle);
|
close(handle);
|
||||||
@@ -994,7 +994,7 @@ void file_manager::start() {
|
|||||||
: 0U,
|
: 0U,
|
||||||
fsi, provider_, entry.read_state, *this);
|
fsi, provider_, entry.read_state, *this);
|
||||||
open_file_lookup_[entry.api_path] = closeable_file;
|
open_file_lookup_[entry.api_path] = closeable_file;
|
||||||
closeable_file->download();
|
closeable_file->force_download();
|
||||||
|
|
||||||
event_system::instance().raise<download_restored>(
|
event_system::instance().raise<download_restored>(
|
||||||
fsi.api_path, fsi.source_path, function_name);
|
fsi.api_path, fsi.source_path, function_name);
|
||||||
|
@@ -273,7 +273,7 @@ auto open_file::close() -> bool {
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
void open_file::download() {
|
void open_file::force_download() {
|
||||||
unique_recur_mutex_lock rw_lock(rw_mtx_);
|
unique_recur_mutex_lock rw_lock(rw_mtx_);
|
||||||
auto read_chunk = read_chunk_;
|
auto read_chunk = read_chunk_;
|
||||||
rw_lock.unlock();
|
rw_lock.unlock();
|
||||||
|
Reference in New Issue
Block a user