| Index: content/browser/media_device_notifications_linux.cc
|
| ===================================================================
|
| --- content/browser/media_device_notifications_linux.cc (revision 131949)
|
| +++ content/browser/media_device_notifications_linux.cc (working copy)
|
| @@ -1,278 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -// MediaDeviceNotificationsLinux implementation.
|
| -
|
| -#include "content/browser/media_device_notifications_linux.h"
|
| -
|
| -#include <mntent.h>
|
| -#include <stdio.h>
|
| -
|
| -#include <vector>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/file_path.h"
|
| -#include "base/file_util.h"
|
| -#include "base/string_util.h"
|
| -#include "base/system_monitor/system_monitor.h"
|
| -#include "content/public/browser/browser_thread.h"
|
| -
|
| -namespace {
|
| -
|
| -const char kDCIMDirName[] = "DCIM";
|
| -
|
| -// List of file systems we care about.
|
| -const char* const kKnownFileSystems[] = {
|
| - "ext2",
|
| - "ext3",
|
| - "ext4",
|
| - "fat",
|
| - "hfsplus",
|
| - "iso9660",
|
| - "msdos",
|
| - "ntfs",
|
| - "udf",
|
| - "vfat",
|
| -};
|
| -
|
| -} // namespace
|
| -
|
| -namespace content {
|
| -
|
| -using base::SystemMonitor;
|
| -
|
| -// A simple pass-through class. MediaDeviceNotificationsLinux cannot directly
|
| -// inherit from FilePathWatcher::Delegate due to multiple inheritance.
|
| -class MediaDeviceNotificationsLinux::WatcherDelegate
|
| - : public base::files::FilePathWatcher::Delegate {
|
| - public:
|
| - explicit WatcherDelegate(MediaDeviceNotificationsLinux* notifier);
|
| -
|
| - // base::files::FilePathWatcher::Delegate implementation.
|
| - virtual void OnFilePathChanged(const FilePath& path) OVERRIDE;
|
| -
|
| - private:
|
| - friend class base::RefCountedThreadSafe<WatcherDelegate>;
|
| -
|
| - // Avoids code deleting the object while there are references to it.
|
| - // Aside from the base::RefCountedThreadSafe friend class, any attempts to
|
| - // call this dtor will result in a compile-time error.
|
| - virtual ~WatcherDelegate();
|
| -
|
| - // The MediaDeviceNotificationsLinux instance that owns this WatcherDelegate.
|
| - // Since |notifier_| will destroy this WatcherDelegate before it goes away,
|
| - // the pointer is always valid. No need to add a reference count, as that
|
| - // would create a circular reference.
|
| - MediaDeviceNotificationsLinux* const notifier_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(WatcherDelegate);
|
| -};
|
| -
|
| -MediaDeviceNotificationsLinux::WatcherDelegate::WatcherDelegate(
|
| - MediaDeviceNotificationsLinux* notifier)
|
| - : notifier_(notifier) {
|
| -}
|
| -
|
| -MediaDeviceNotificationsLinux::WatcherDelegate::~WatcherDelegate() {
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::WatcherDelegate::OnFilePathChanged(
|
| - const FilePath& path) {
|
| - notifier_->OnFilePathChanged(path);
|
| -}
|
| -
|
| -MediaDeviceNotificationsLinux::MediaDeviceNotificationsLinux(
|
| - const FilePath& path)
|
| - : initialized_(false),
|
| - mtab_path_(path),
|
| - current_device_id_(0U) {
|
| - CHECK(!path.empty());
|
| -
|
| - // Put |kKnownFileSystems| in std::set to get O(log N) access time.
|
| - for (size_t i = 0; i < arraysize(kKnownFileSystems); ++i) {
|
| - known_file_systems_.insert(kKnownFileSystems[i]);
|
| - }
|
| -}
|
| -
|
| -MediaDeviceNotificationsLinux::~MediaDeviceNotificationsLinux() {
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::Init() {
|
| - BrowserThread::PostTask(
|
| - BrowserThread::FILE, FROM_HERE,
|
| - base::Bind(&MediaDeviceNotificationsLinux::InitOnFileThread, this));
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::OnFilePathChanged(const FilePath& path) {
|
| - if (path != mtab_path_) {
|
| - // This cannot happen unless FileWatcher is buggy. Just ignore this
|
| - // notification and do nothing.
|
| - NOTREACHED();
|
| - return;
|
| - }
|
| -
|
| - UpdateMtab();
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::InitOnFileThread() {
|
| - DCHECK(!initialized_);
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| - initialized_ = true;
|
| -
|
| - watcher_delegate_ = new WatcherDelegate(this);
|
| - if (!file_watcher_.Watch(mtab_path_, watcher_delegate_)) {
|
| - LOG(ERROR) << "Adding watch for " << mtab_path_.value() << " failed";
|
| - return;
|
| - }
|
| -
|
| - UpdateMtab();
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::UpdateMtab() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| -
|
| - MountMap new_mtab;
|
| - ReadMtab(&new_mtab);
|
| -
|
| - // Check existing mtab entries for unaccounted mount points.
|
| - // These mount points must have been removed in the new mtab.
|
| - std::vector<std::string> mount_points_to_erase;
|
| - for (MountMap::const_iterator it = mtab_.begin(); it != mtab_.end(); ++it) {
|
| - const std::string& mount_point = it->first;
|
| - // |mount_point| not in |new_mtab|.
|
| - if (new_mtab.find(mount_point) == new_mtab.end()) {
|
| - const SystemMonitor::DeviceIdType& device_id = it->second.second;
|
| - RemoveOldDevice(device_id);
|
| - mount_points_to_erase.push_back(mount_point);
|
| - }
|
| - }
|
| - // Erase the |mtab_| entries afterwards. Erasing in the loop above using the
|
| - // iterator is slightly more efficient, but more tricky, since calling
|
| - // std::map::erase() on an iterator invalidates it.
|
| - for (size_t i = 0; i < mount_points_to_erase.size(); ++i)
|
| - mtab_.erase(mount_points_to_erase[i]);
|
| -
|
| - // Check new mtab entries against existing ones.
|
| - for (MountMap::iterator newiter = new_mtab.begin();
|
| - newiter != new_mtab.end();
|
| - ++newiter) {
|
| - const std::string& mount_point = newiter->first;
|
| - const MountDeviceAndId& mount_device_and_id = newiter->second;
|
| - const std::string& mount_device = mount_device_and_id.first;
|
| - SystemMonitor::DeviceIdType& id = newiter->second.second;
|
| - MountMap::iterator olditer = mtab_.find(mount_point);
|
| - // Check to see if it is a new mount point.
|
| - if (olditer == mtab_.end()) {
|
| - if (IsMediaDevice(mount_point)) {
|
| - AddNewDevice(mount_device, mount_point, &id);
|
| - mtab_.insert(std::make_pair(mount_point, mount_device_and_id));
|
| - }
|
| - continue;
|
| - }
|
| -
|
| - // Existing mount point. Check to see if a new device is mounted there.
|
| - const MountDeviceAndId& old_mount_device_and_id = olditer->second;
|
| - if (mount_device == old_mount_device_and_id.first)
|
| - continue;
|
| -
|
| - // New device mounted.
|
| - RemoveOldDevice(old_mount_device_and_id.second);
|
| - if (IsMediaDevice(mount_point)) {
|
| - AddNewDevice(mount_device, mount_point, &id);
|
| - olditer->second = mount_device_and_id;
|
| - }
|
| - }
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::ReadMtab(MountMap* mtab) {
|
| - FILE* fp = setmntent(mtab_path_.value().c_str(), "r");
|
| - if (!fp)
|
| - return;
|
| -
|
| - MountMap& new_mtab = *mtab;
|
| - mntent entry;
|
| - char buf[512];
|
| - SystemMonitor::DeviceIdType mount_position = 0;
|
| - typedef std::pair<std::string, SystemMonitor::DeviceIdType> MountPointAndId;
|
| - typedef std::map<std::string, MountPointAndId> DeviceMap;
|
| - DeviceMap device_map;
|
| - while (getmntent_r(fp, &entry, buf, sizeof(buf))) {
|
| - // We only care about real file systems.
|
| - if (known_file_systems_.find(entry.mnt_type) == known_file_systems_.end())
|
| - continue;
|
| - // Add entries, but overwrite entries for the same mount device. Keep track
|
| - // of the entry positions in the device id field and use that below to
|
| - // resolve multiple devices mounted at the same mount point.
|
| - MountPointAndId mount_point_and_id =
|
| - std::make_pair(entry.mnt_dir, mount_position++);
|
| - DeviceMap::iterator it = device_map.find(entry.mnt_fsname);
|
| - if (it == device_map.end()) {
|
| - device_map.insert(it,
|
| - std::make_pair(entry.mnt_fsname, mount_point_and_id));
|
| - } else {
|
| - it->second = mount_point_and_id;
|
| - }
|
| - }
|
| - endmntent(fp);
|
| -
|
| - for (DeviceMap::const_iterator device_it = device_map.begin();
|
| - device_it != device_map.end();
|
| - ++device_it) {
|
| - const std::string& device = device_it->first;
|
| - const std::string& mount_point = device_it->second.first;
|
| - const SystemMonitor::DeviceIdType& position = device_it->second.second;
|
| -
|
| - // No device at |mount_point|, save |device| to it.
|
| - MountMap::iterator mount_it = new_mtab.find(mount_point);
|
| - if (mount_it == new_mtab.end()) {
|
| - new_mtab.insert(std::make_pair(mount_point,
|
| - std::make_pair(device, position)));
|
| - continue;
|
| - }
|
| -
|
| - // There is already a device mounted at |mount_point|. Check to see if
|
| - // the existing mount entry is newer than the current one.
|
| - std::string& existing_device = mount_it->second.first;
|
| - SystemMonitor::DeviceIdType& existing_position = mount_it->second.second;
|
| - if (existing_position > position)
|
| - continue;
|
| -
|
| - // The current entry is newer, update the mount point entry.
|
| - existing_device = device;
|
| - existing_position = position;
|
| - }
|
| -}
|
| -
|
| -bool MediaDeviceNotificationsLinux::IsMediaDevice(
|
| - const std::string& mount_point) {
|
| - FilePath dcim_path(mount_point);
|
| - FilePath::StringType dcim_dir = kDCIMDirName;
|
| - if (!file_util::DirectoryExists(dcim_path.Append(dcim_dir))) {
|
| - // Check for lowercase 'dcim' as well.
|
| - FilePath dcim_path_lower(dcim_path.Append(StringToLowerASCII(dcim_dir)));
|
| - if (!file_util::DirectoryExists(dcim_path_lower)) {
|
| - return false;
|
| - }
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::AddNewDevice(
|
| - const std::string& mount_device,
|
| - const std::string& mount_point,
|
| - base::SystemMonitor::DeviceIdType* device_id) {
|
| - *device_id = current_device_id_++;
|
| - base::SystemMonitor* system_monitor = base::SystemMonitor::Get();
|
| - system_monitor->ProcessMediaDeviceAttached(*device_id,
|
| - mount_device,
|
| - FilePath(mount_point));
|
| -}
|
| -
|
| -void MediaDeviceNotificationsLinux::RemoveOldDevice(
|
| - const base::SystemMonitor::DeviceIdType& device_id) {
|
| - base::SystemMonitor* system_monitor = base::SystemMonitor::Get();
|
| - system_monitor->ProcessMediaDeviceDetached(device_id);
|
| -}
|
| -
|
| -} // namespace content
|
|
|