OLD | NEW |
---|---|
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chromeos/disks/disk_mount_manager.h" | 5 #include "chromeos/disks/disk_mount_manager.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <set> | 10 #include <set> |
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
80 } | 80 } |
81 } | 81 } |
82 cros_disks_client_->Mount( | 82 cros_disks_client_->Mount( |
83 source_path, source_format, mount_label, access_mode, | 83 source_path, source_format, mount_label, access_mode, |
84 // When succeeds, OnMountCompleted will be called by | 84 // When succeeds, OnMountCompleted will be called by |
85 // "MountCompleted" signal instead. | 85 // "MountCompleted" signal instead. |
86 base::Bind(&base::DoNothing), | 86 base::Bind(&base::DoNothing), |
87 base::Bind(&DiskMountManagerImpl::OnMountCompleted, | 87 base::Bind(&DiskMountManagerImpl::OnMountCompleted, |
88 weak_ptr_factory_.GetWeakPtr(), | 88 weak_ptr_factory_.GetWeakPtr(), |
89 MountEntry(MOUNT_ERROR_INTERNAL, source_path, type, ""))); | 89 MountEntry(MOUNT_ERROR_INTERNAL, source_path, type, ""))); |
90 | |
91 // Record the access mode option passed to CrosDisks. | |
92 // This is needed because CrosDisks service methods doesn't return the info | |
93 // via DBus. | |
94 access_modes_.insert(std::make_pair(source_path, access_mode)); | |
90 } | 95 } |
91 | 96 |
92 // DiskMountManager override. | 97 // DiskMountManager override. |
93 void UnmountPath(const std::string& mount_path, | 98 void UnmountPath(const std::string& mount_path, |
94 UnmountOptions options, | 99 UnmountOptions options, |
95 const UnmountPathCallback& callback) override { | 100 const UnmountPathCallback& callback) override { |
96 UnmountChildMounts(mount_path); | 101 UnmountChildMounts(mount_path); |
97 cros_disks_client_->Unmount(mount_path, options, | 102 cros_disks_client_->Unmount(mount_path, options, |
98 base::Bind(&DiskMountManagerImpl::OnUnmountPath, | 103 base::Bind(&DiskMountManagerImpl::OnUnmountPath, |
99 weak_ptr_factory_.GetWeakPtr(), | 104 weak_ptr_factory_.GetWeakPtr(), |
(...skipping 250 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
350 mount_info.mount_type == MOUNT_TYPE_DEVICE && | 355 mount_info.mount_type == MOUNT_TYPE_DEVICE && |
351 !mount_info.source_path.empty() && | 356 !mount_info.source_path.empty() && |
352 !mount_info.mount_path.empty()) { | 357 !mount_info.mount_path.empty()) { |
353 DiskMap::iterator iter = disks_.find(mount_info.source_path); | 358 DiskMap::iterator iter = disks_.find(mount_info.source_path); |
354 if (iter == disks_.end()) { | 359 if (iter == disks_.end()) { |
355 // disk might have been removed by now? | 360 // disk might have been removed by now? |
356 return; | 361 return; |
357 } | 362 } |
358 Disk* disk = iter->second; | 363 Disk* disk = iter->second; |
359 DCHECK(disk); | 364 DCHECK(disk); |
365 // The is_read_only field in *disk may be incorrect when this is called | |
366 // from CrosDisksClientImpl::OnMountCompleted. | |
367 // Overwrite based on the access mode option that was passed when issuing | |
368 // mount command to the same mount path last time. | |
369 AccessModeMap::iterator it = access_modes_.find(disk->device_path()); | |
satorux1
2016/08/23 05:40:49
source_path passed to Mount() and disk->device_pat
yamaguchi
2016/08/23 08:08:52
Added comments to the 2 places looking up the map.
| |
370 if (it != access_modes_.end()) { | |
371 disk->set_read_only(it->second == | |
372 chromeos::MOUNT_ACCESS_MODE_READ_ONLY); | |
373 } | |
360 disk->set_mount_path(mount_info.mount_path); | 374 disk->set_mount_path(mount_info.mount_path); |
361 } | 375 } |
362 } | 376 } |
363 | 377 |
364 // Callback for UnmountPath. | 378 // Callback for UnmountPath. |
365 void OnUnmountPath(const UnmountPathCallback& callback, | 379 void OnUnmountPath(const UnmountPathCallback& callback, |
366 bool success, | 380 bool success, |
367 const std::string& mount_path) { | 381 const std::string& mount_path) { |
368 MountPointMap::iterator mount_points_it = mount_points_.find(mount_path); | 382 MountPointMap::iterator mount_points_it = mount_points_.find(mount_path); |
369 if (mount_points_it == mount_points_.end()) { | 383 if (mount_points_it == mount_points_.end()) { |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
466 disk_info.uuid(), | 480 disk_info.uuid(), |
467 FindSystemPathPrefix(disk_info.system_path()), | 481 FindSystemPathPrefix(disk_info.system_path()), |
468 disk_info.device_type(), | 482 disk_info.device_type(), |
469 disk_info.total_size_in_bytes(), | 483 disk_info.total_size_in_bytes(), |
470 disk_info.is_drive(), | 484 disk_info.is_drive(), |
471 disk_info.is_read_only(), | 485 disk_info.is_read_only(), |
472 disk_info.has_media(), | 486 disk_info.has_media(), |
473 disk_info.on_boot_device(), | 487 disk_info.on_boot_device(), |
474 disk_info.on_removable_device(), | 488 disk_info.on_removable_device(), |
475 disk_info.is_hidden()); | 489 disk_info.is_hidden()); |
490 // If the device was mounted by the instance, apply recorded parameter. | |
491 AccessModeMap::iterator access_mode = | |
satorux1
2016/08/23 05:40:49
maybe just call it |iter|?
yamaguchi
2016/08/23 08:08:52
No, because it collides with the one for DiskMap::
| |
492 access_modes_.find(disk->device_path()); | |
493 if (access_mode != access_modes_.end()) { | |
494 disk->set_read_only(access_mode->second == | |
495 chromeos::MOUNT_ACCESS_MODE_READ_ONLY); | |
496 } | |
476 disks_.insert(std::make_pair(disk_info.device_path(), disk)); | 497 disks_.insert(std::make_pair(disk_info.device_path(), disk)); |
477 NotifyDiskStatusUpdate(is_new ? DISK_ADDED : DISK_CHANGED, disk); | 498 NotifyDiskStatusUpdate(is_new ? DISK_ADDED : DISK_CHANGED, disk); |
478 } | 499 } |
479 | 500 |
480 // Part of EnsureMountInfoRefreshed(). Called after the list of devices are | 501 // Part of EnsureMountInfoRefreshed(). Called after the list of devices are |
481 // enumerated. | 502 // enumerated. |
482 void RefreshAfterEnumerateDevices(const std::vector<std::string>& devices) { | 503 void RefreshAfterEnumerateDevices(const std::vector<std::string>& devices) { |
483 std::set<std::string> current_device_set(devices.begin(), devices.end()); | 504 std::set<std::string> current_device_set(devices.begin(), devices.end()); |
484 for (DiskMap::iterator iter = disks_.begin(); iter != disks_.end(); ) { | 505 for (DiskMap::iterator iter = disks_.begin(); iter != disks_.end(); ) { |
485 if (current_device_set.find(iter->first) == current_device_set.end()) { | 506 if (current_device_set.find(iter->first) == current_device_set.end()) { |
(...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
633 DiskMountManager::MountPointMap mount_points_; | 654 DiskMountManager::MountPointMap mount_points_; |
634 | 655 |
635 typedef std::set<std::string> SystemPathPrefixSet; | 656 typedef std::set<std::string> SystemPathPrefixSet; |
636 SystemPathPrefixSet system_path_prefixes_; | 657 SystemPathPrefixSet system_path_prefixes_; |
637 | 658 |
638 bool already_refreshed_; | 659 bool already_refreshed_; |
639 std::vector<EnsureMountInfoRefreshedCallback> refresh_callbacks_; | 660 std::vector<EnsureMountInfoRefreshedCallback> refresh_callbacks_; |
640 | 661 |
641 std::unique_ptr<SuspendUnmountManager> suspend_unmount_manager_; | 662 std::unique_ptr<SuspendUnmountManager> suspend_unmount_manager_; |
642 | 663 |
664 // Whether the instance attempted to mount a device in read-only mode for | |
665 // each source path. | |
666 typedef std::map<std::string, chromeos::MountAccessMode> AccessModeMap; | |
667 AccessModeMap access_modes_; | |
668 | |
643 base::WeakPtrFactory<DiskMountManagerImpl> weak_ptr_factory_; | 669 base::WeakPtrFactory<DiskMountManagerImpl> weak_ptr_factory_; |
644 | 670 |
645 DISALLOW_COPY_AND_ASSIGN(DiskMountManagerImpl); | 671 DISALLOW_COPY_AND_ASSIGN(DiskMountManagerImpl); |
646 }; | 672 }; |
647 | 673 |
648 } // namespace | 674 } // namespace |
649 | 675 |
650 DiskMountManager::Disk::Disk(const std::string& device_path, | 676 DiskMountManager::Disk::Disk(const std::string& device_path, |
651 const std::string& mount_path, | 677 const std::string& mount_path, |
652 const std::string& system_path, | 678 const std::string& system_path, |
(...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
763 VLOG(1) << "DiskMountManager Shutdown completed"; | 789 VLOG(1) << "DiskMountManager Shutdown completed"; |
764 } | 790 } |
765 | 791 |
766 // static | 792 // static |
767 DiskMountManager* DiskMountManager::GetInstance() { | 793 DiskMountManager* DiskMountManager::GetInstance() { |
768 return g_disk_mount_manager; | 794 return g_disk_mount_manager; |
769 } | 795 } |
770 | 796 |
771 } // namespace disks | 797 } // namespace disks |
772 } // namespace chromeos | 798 } // namespace chromeos |
OLD | NEW |