Commit 977e7324 authored by Julian Watson's avatar Julian Watson Committed by Commit Bot

crostini: use ContainerId instead of pair/tuple

Change-Id: I7be1eae82702d0576e6bcd701c985be97724c7dc
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1839279
Commit-Queue: Julian Watson <juwa@google.com>
Commit-Queue: Nicholas Verne <nverne@chromium.org>
Auto-Submit: Julian Watson <juwa@google.com>
Reviewed-by: default avatarNicholas Verne <nverne@chromium.org>
Cr-Commit-Position: refs/heads/master@{#703537}
parent b2d6fe49
...@@ -98,8 +98,8 @@ void InvokeAndErasePendingContainerCallbacks( ...@@ -98,8 +98,8 @@ void InvokeAndErasePendingContainerCallbacks(
const std::string& vm_name, const std::string& vm_name,
const std::string& container_name, const std::string& container_name,
CrostiniResult result) { CrostiniResult result) {
auto range = container_callbacks->equal_range( auto range =
std::make_tuple(vm_name, container_name)); container_callbacks->equal_range(ContainerId(vm_name, container_name));
for (auto it = range.first; it != range.second; ++it) { for (auto it = range.first; it != range.second; ++it) {
std::move(it->second).Run(result); std::move(it->second).Run(result);
} }
...@@ -1076,7 +1076,7 @@ void CrostiniManager::OnDeleteLxdContainer( ...@@ -1076,7 +1076,7 @@ void CrostiniManager::OnDeleteLxdContainer(
VLOG(1) << "Awaiting LxdContainerDeletedSignal for " << vm_name << ", " VLOG(1) << "Awaiting LxdContainerDeletedSignal for " << vm_name << ", "
<< container_name; << container_name;
delete_lxd_container_callbacks_.emplace( delete_lxd_container_callbacks_.emplace(
std::make_tuple(vm_name, container_name), std::move(callback)); ContainerId(vm_name, container_name), std::move(callback));
} else if (response->status() == } else if (response->status() ==
vm_tools::cicerone::DeleteLxdContainerResponse::DOES_NOT_EXIST) { vm_tools::cicerone::DeleteLxdContainerResponse::DOES_NOT_EXIST) {
...@@ -1630,7 +1630,7 @@ CrostiniManager::RestartId CrostiniManager::RestartCrostini( ...@@ -1630,7 +1630,7 @@ CrostiniManager::RestartId CrostiniManager::RestartCrostini(
std::move(callback)); std::move(callback));
if (observer) if (observer)
restarter->AddObserver(observer); restarter->AddObserver(observer);
auto key = std::make_pair(restarter->vm_name(), restarter->container_name()); auto key = ContainerId(restarter->vm_name(), restarter->container_name());
restarters_by_container_.emplace(key, restarter->restart_id()); restarters_by_container_.emplace(key, restarter->restart_id());
restarters_by_id_[restarter->restart_id()] = restarter; restarters_by_id_[restarter->restart_id()] = restarter;
if (restarters_by_container_.count(key) > 1) { if (restarters_by_container_.count(key) > 1) {
...@@ -1661,8 +1661,8 @@ void CrostiniManager::OnAbortRestartCrostini( ...@@ -1661,8 +1661,8 @@ void CrostiniManager::OnAbortRestartCrostini(
CrostiniManager::RestartId restart_id, CrostiniManager::RestartId restart_id,
base::OnceClosure callback) { base::OnceClosure callback) {
auto restarter_it = restarters_by_id_.find(restart_id); auto restarter_it = restarters_by_id_.find(restart_id);
auto key = std::make_pair(restarter_it->second->vm_name(), auto key = ContainerId(restarter_it->second->vm_name(),
restarter_it->second->container_name()); restarter_it->second->container_name());
if (restarter_it != restarters_by_id_.end()) { if (restarter_it != restarters_by_id_.end()) {
auto range = restarters_by_container_.equal_range(key); auto range = restarters_by_container_.equal_range(key);
for (auto it = range.first; it != range.second; ++it) { for (auto it = range.first; it != range.second; ++it) {
...@@ -2023,7 +2023,7 @@ void CrostiniManager::OnContainerShutdown( ...@@ -2023,7 +2023,7 @@ void CrostiniManager::OnContainerShutdown(
return; return;
// Find the callbacks to call, then erase them from the map. // Find the callbacks to call, then erase them from the map.
auto range_callbacks = shutdown_container_callbacks_.equal_range( auto range_callbacks = shutdown_container_callbacks_.equal_range(
std::make_tuple(signal.vm_name(), signal.container_name())); ContainerId(signal.vm_name(), signal.container_name()));
for (auto it = range_callbacks.first; it != range_callbacks.second; ++it) { for (auto it = range_callbacks.first; it != range_callbacks.second; ++it) {
std::move(it->second).Run(); std::move(it->second).Run();
} }
...@@ -2303,7 +2303,7 @@ void CrostiniManager::OnLxdContainerDeleted( ...@@ -2303,7 +2303,7 @@ void CrostiniManager::OnLxdContainerDeleted(
// Find the callbacks to call, then erase them from the map. // Find the callbacks to call, then erase them from the map.
auto range = delete_lxd_container_callbacks_.equal_range( auto range = delete_lxd_container_callbacks_.equal_range(
std::make_tuple(signal.vm_name(), signal.container_name())); ContainerId(signal.vm_name(), signal.container_name()));
for (auto it = range.first; it != range.second; ++it) { for (auto it = range.first; it != range.second; ++it) {
std::move(it->second).Run(success); std::move(it->second).Run(success);
} }
...@@ -2316,7 +2316,7 @@ void CrostiniManager::OnLxdContainerDownloading( ...@@ -2316,7 +2316,7 @@ void CrostiniManager::OnLxdContainerDownloading(
return; return;
} }
auto range = restarters_by_container_.equal_range( auto range = restarters_by_container_.equal_range(
std::make_pair(signal.vm_name(), signal.container_name())); ContainerId(signal.vm_name(), signal.container_name()));
for (auto it = range.first; it != range.second; ++it) { for (auto it = range.first; it != range.second; ++it) {
restarters_by_id_[it->second]->OnContainerDownloading( restarters_by_id_[it->second]->OnContainerDownloading(
signal.download_progress()); signal.download_progress());
...@@ -2528,7 +2528,7 @@ void CrostiniManager::OnRemoveCrostini(CrostiniResult result) { ...@@ -2528,7 +2528,7 @@ void CrostiniManager::OnRemoveCrostini(CrostiniResult result) {
void CrostiniManager::FinishRestart(CrostiniRestarter* restarter, void CrostiniManager::FinishRestart(CrostiniRestarter* restarter,
CrostiniResult result) { CrostiniResult result) {
auto key = std::make_pair(restarter->vm_name(), restarter->container_name()); auto key = ContainerId(restarter->vm_name(), restarter->container_name());
auto range = restarters_by_container_.equal_range(key); auto range = restarters_by_container_.equal_range(key);
std::vector<scoped_refptr<CrostiniRestarter>> pending_restarters; std::vector<scoped_refptr<CrostiniRestarter>> pending_restarters;
// Erase first, because restarter->RunCallback() may modify our maps. // Erase first, because restarter->RunCallback() may modify our maps.
...@@ -2625,7 +2625,7 @@ void CrostiniManager::OnExportLxdContainerProgress( ...@@ -2625,7 +2625,7 @@ void CrostiniManager::OnExportLxdContainerProgress(
} }
// Invoke original callback with either success or failure. // Invoke original callback with either success or failure.
auto key = std::make_pair(signal.vm_name(), signal.container_name()); auto key = ContainerId(signal.vm_name(), signal.container_name());
auto it = export_lxd_container_callbacks_.find(key); auto it = export_lxd_container_callbacks_.find(key);
if (it == export_lxd_container_callbacks_.end()) { if (it == export_lxd_container_callbacks_.end()) {
LOG(ERROR) << "No export callback for " << signal.vm_name() << ", " LOG(ERROR) << "No export callback for " << signal.vm_name() << ", "
...@@ -2725,7 +2725,7 @@ void CrostiniManager::OnImportLxdContainerProgress( ...@@ -2725,7 +2725,7 @@ void CrostiniManager::OnImportLxdContainerProgress(
// Invoke original callback with either success or failure. // Invoke original callback with either success or failure.
if (call_original_callback) { if (call_original_callback) {
auto key = std::make_pair(signal.vm_name(), signal.container_name()); auto key = ContainerId(signal.vm_name(), signal.container_name());
auto it = import_lxd_container_callbacks_.find(key); auto it = import_lxd_container_callbacks_.find(key);
if (it == import_lxd_container_callbacks_.end()) { if (it == import_lxd_container_callbacks_.end()) {
LOG(ERROR) << "No import callback for " << signal.vm_name() << ", " LOG(ERROR) << "No import callback for " << signal.vm_name() << ", "
......
...@@ -66,8 +66,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallWithNoIcons) { ...@@ -66,8 +66,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallWithNoIcons) {
profile_.get(), profile_.get(),
CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL, CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL,
PackageOperationStatus::RUNNING, PackageOperationStatus::RUNNING,
std::pair<std::string, std::string>(kCrostiniDefaultVmName, ContainerId(kCrostiniDefaultVmName, kCrostiniDefaultContainerName),
kCrostiniDefaultContainerName),
base::string16(), kNotificationId, service_.get()); base::string16(), kNotificationId, service_.get());
notification.UpdateProgress(PackageOperationStatus::SUCCEEDED, 100); notification.UpdateProgress(PackageOperationStatus::SUCCEEDED, 100);
...@@ -79,8 +78,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallWithOneIcon) { ...@@ -79,8 +78,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallWithOneIcon) {
profile_.get(), profile_.get(),
CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL, CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL,
PackageOperationStatus::RUNNING, PackageOperationStatus::RUNNING,
std::pair<std::string, std::string>(kCrostiniDefaultVmName, ContainerId(kCrostiniDefaultVmName, kCrostiniDefaultContainerName),
kCrostiniDefaultContainerName),
base::string16(), kNotificationId, service_.get()); base::string16(), kNotificationId, service_.get());
auto app = CrostiniTestHelper::BasicApp(kDefaultAppFileId); auto app = CrostiniTestHelper::BasicApp(kDefaultAppFileId);
...@@ -95,8 +93,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallWithTwoIcons) { ...@@ -95,8 +93,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallWithTwoIcons) {
profile_.get(), profile_.get(),
CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL, CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL,
PackageOperationStatus::RUNNING, PackageOperationStatus::RUNNING,
std::pair<std::string, std::string>(kCrostiniDefaultVmName, ContainerId(kCrostiniDefaultVmName, kCrostiniDefaultContainerName),
kCrostiniDefaultContainerName),
base::string16(), kNotificationId, service_.get()); base::string16(), kNotificationId, service_.get());
auto app = CrostiniTestHelper::BasicApp(kDefaultAppFileId); auto app = CrostiniTestHelper::BasicApp(kDefaultAppFileId);
...@@ -117,8 +114,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallIgnorePreviousIcons) { ...@@ -117,8 +114,7 @@ TEST_F(CrostiniPackageNotificationTest, InstallIgnorePreviousIcons) {
profile_.get(), profile_.get(),
CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL, CrostiniPackageNotification::NotificationType::PACKAGE_INSTALL,
PackageOperationStatus::RUNNING, PackageOperationStatus::RUNNING,
std::pair<std::string, std::string>(kCrostiniDefaultVmName, ContainerId(kCrostiniDefaultVmName, kCrostiniDefaultContainerName),
kCrostiniDefaultContainerName),
base::string16(), kNotificationId, service_.get()); base::string16(), kNotificationId, service_.get());
app = CrostiniTestHelper::BasicApp(kSecondAppFileId); app = CrostiniTestHelper::BasicApp(kSecondAppFileId);
......
...@@ -260,7 +260,7 @@ void CrostiniPackageService::OnInstallLinuxPackageProgress( ...@@ -260,7 +260,7 @@ void CrostiniPackageService::OnInstallLinuxPackageProgress(
if (status == InstallLinuxPackageProgressStatus::INSTALLING) if (status == InstallLinuxPackageProgressStatus::INSTALLING)
display_progress += 50; // Second phase display_progress += 50; // Second phase
UpdatePackageOperationStatus(std::make_pair(vm_name, container_name), UpdatePackageOperationStatus(ContainerId(vm_name, container_name),
InstallStatusToOperationStatus(status), InstallStatusToOperationStatus(status),
display_progress); display_progress);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment