refactor
This commit is contained in:
		| @@ -98,10 +98,9 @@ remote_winfsp_drive::remote_winfsp_drive(app_config &config, | ||||
|       config_(config), | ||||
|       lock_(lock), | ||||
|       factory_(std::move(factory)) { | ||||
|   E_SUBSCRIBE_EXACT(unmount_requested, | ||||
|                     [this](const unmount_requested & /* e */) { | ||||
|                       std::thread([this]() { this->shutdown(); }).detach(); | ||||
|                     }); | ||||
|   E_SUBSCRIBE_EXACT(unmount_requested, [this](const unmount_requested &) { | ||||
|     std::thread([this]() { this->shutdown(); }).detach(); | ||||
|   }); | ||||
| } | ||||
|  | ||||
| auto remote_winfsp_drive::CanDelete(PVOID /*file_node*/, PVOID file_desc, | ||||
|   | ||||
| @@ -111,7 +111,7 @@ auto winfsp_drive::winfsp_service::OnStop() -> NTSTATUS { | ||||
| winfsp_drive::winfsp_drive(app_config &config, lock_data &lock, | ||||
|                            i_provider &provider) | ||||
|     : FileSystemBase(), provider_(provider), config_(config), lock_(lock) { | ||||
|   E_SUBSCRIBE_EXACT(unmount_requested, [this](const unmount_requested & /*e*/) { | ||||
|   E_SUBSCRIBE_EXACT(unmount_requested, [this](const unmount_requested &) { | ||||
|     std::thread([this]() { this->shutdown(); }).detach(); | ||||
|   }); | ||||
| } | ||||
|   | ||||
| @@ -45,9 +45,9 @@ logging_consumer::logging_consumer(const std::string &log_directory, | ||||
|   reopen_log_file(); | ||||
|   E_SUBSCRIBE_ALL(process_event); | ||||
|   E_SUBSCRIBE_EXACT(event_level_changed, | ||||
|                     [this](const event_level_changed &evt) { | ||||
|                     [this](const event_level_changed &changed) { | ||||
|                       event_level_ = event_level_from_string( | ||||
|                           evt.get_new_event_level().get<std::string>()); | ||||
|                           changed.get_new_event_level().get<std::string>()); | ||||
|                     }); | ||||
|   logging_thread_ = | ||||
|       std::make_unique<std::thread>([this] { logging_thread(false); }); | ||||
|   | ||||
| @@ -71,8 +71,8 @@ file_manager::file_manager(app_config &config, i_provider &provider) | ||||
|     upload_active_family_ = handles[idx++]; | ||||
|  | ||||
|     E_SUBSCRIBE_EXACT(file_upload_completed, | ||||
|                       [this](const file_upload_completed &evt) { | ||||
|                         this->upload_completed(evt); | ||||
|                       [this](const file_upload_completed &completed) { | ||||
|                         this->upload_completed(completed); | ||||
|                       }); | ||||
|   } | ||||
| } | ||||
| @@ -742,7 +742,7 @@ void file_manager::start() { | ||||
|     for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { | ||||
|       const auto parts = utils::string::split(iterator->key().ToString(), ':'); | ||||
|       active_items.emplace_back( | ||||
|           active_item{parts[1U], iterator->value().ToString()}); | ||||
|           active_item{parts.at(1U), iterator->value().ToString()}); | ||||
|     } | ||||
|     for (const auto &active_item : active_items) { | ||||
|       queue_upload(active_item.api_path, active_item.source_path, false); | ||||
| @@ -876,7 +876,7 @@ void file_manager::upload_completed(const file_upload_completed &evt) { | ||||
|       for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { | ||||
|         const auto parts = | ||||
|             utils::string::split(iterator->key().ToString(), ':'); | ||||
|         if (parts[1U] == evt.get_api_path().get<std::string>()) { | ||||
|         if (parts.at(1U) == evt.get_api_path().get<std::string>()) { | ||||
|           db_->Delete(rocksdb::WriteOptions(), upload_active_family_, | ||||
|                       iterator->key()); | ||||
|           break; | ||||
|   | ||||
		Reference in New Issue
	
	Block a user