Index: chrome/browser/media_gallery/media_device_notifications_linux.cc |
diff --git a/chrome/browser/media_gallery/media_device_notifications_linux.cc b/chrome/browser/media_gallery/media_device_notifications_linux.cc |
index e4d61621989cc055d98b4231c146c988f87f2bfd..91fc1e85f0f31fdd4944a391e4246260688e0688 100644 |
--- a/chrome/browser/media_gallery/media_device_notifications_linux.cc |
+++ b/chrome/browser/media_gallery/media_device_notifications_linux.cc |
@@ -6,6 +6,7 @@ |
#include "chrome/browser/media_gallery/media_device_notifications_linux.h" |
+#include <libudev.h> |
#include <mntent.h> |
#include <stdio.h> |
@@ -13,6 +14,7 @@ |
#include "base/bind.h" |
#include "base/file_path.h" |
+#include "base/metrics/histogram.h" |
#include "base/stl_util.h" |
#include "base/string_number_conversions.h" |
#include "base/system_monitor/system_monitor.h" |
@@ -35,6 +37,104 @@ const char* const kKnownFileSystems[] = { |
"vfat", |
}; |
+// Device property constants. |
+const char kDevName[] = "DEVNAME"; |
+const char kFsUUID[] = "ID_FS_UUID"; |
+const char kLabel[] = "ID_FS_LABEL"; |
+const char kModel[] = "ID_MODEL"; |
+const char kModelID[] = "ID_MODEL_ID"; |
+const char kSeperator[] = "_"; |
+const char kSerial[] = "ID_SERIAL"; |
+const char kSerialShort[] = "ID_SERIAL_SHORT"; |
+const char kVendor[] = "ID_VENDOR"; |
+const char kVendorID[] = "ID_VENDOR_ID"; |
+ |
+// Get the device information using udev library. |
+// Returns true on success, false on failure. |
+bool GetDeviceInfoHelper(const std::string& dev_path, |
+ std::string* id, |
+ string16* name) { |
+ DCHECK(!dev_path.empty()); |
+ |
+ // libudev-related items. |
+ udev* udev_ptr; |
+ udev_ptr = udev_new(); |
Lei Zhang
2012/08/09 03:47:16
nit: combine with previous line.
kmadhusu
2012/08/09 08:10:03
Done.
|
+ CHECK(udev_ptr); |
+ |
+ // Get device file status. |
+ struct stat st; |
+ if (stat(dev_path.c_str(), &st) == -1) { |
Lei Zhang
2012/08/09 03:47:16
usually people do < 0
kmadhusu
2012/08/09 08:10:03
Done.
|
+ udev_unref(udev_ptr); |
+ return false; |
+ } |
+ |
+ // Identify the device type. |
+ char dev_type; |
+ if (S_ISCHR(st.st_mode)) |
+ dev_type = 'c'; |
+ else if (S_ISBLK(st.st_mode)) |
+ dev_type = 'b'; |
+ else |
+ return false; // Not a supported type. |
+ |
+ // Create a new udev_device object from device ID. |
+ udev_device* dev = udev_device_new_from_devnum(udev_ptr, dev_type, |
Lei Zhang
2012/08/09 03:47:16
Can you name this "device"? It's impossible to sea
kmadhusu
2012/08/09 08:10:03
Done.
|
+ st.st_rdev); |
+ if (!dev) { |
+ udev_unref(udev_ptr); |
+ return false; |
+ } |
+ |
+ // Construct a device name using label or manufacturer(vendor and model) |
+ // details. |
+ std::string device_name; |
+ const char* dev_name = NULL; |
+ if ((dev_name = udev_device_get_property_value(dev, kLabel)) || |
+ (dev_name = udev_device_get_property_value(dev, kSerial))) { |
+ device_name = dev_name; |
+ } else { |
+ // Format: VendorInfo_ModelInfo |
+ // Eg: KnCompany_Model2010 |
+ const char *vendor_name = NULL, *model_name = NULL; |
Lei Zhang
2012/08/09 03:47:16
nit: char*
kmadhusu
2012/08/09 08:10:03
Since I am doing multiple declarations on a single
|
+ if ((vendor_name = udev_device_get_property_value(dev, kVendor))) |
Lei Zhang
2012/08/09 03:47:16
nit: extra set of () here and below?
kmadhusu
2012/08/09 08:10:03
Since I am using the result value of the expressio
|
+ device_name = vendor_name; |
+ if ((model_name = udev_device_get_property_value(dev, kModel))) { |
+ if (!device_name.empty()) |
+ device_name.append(kSeperator); |
Lei Zhang
2012/08/09 03:47:16
still got a bunch of appends.
kmadhusu
2012/08/09 08:10:03
Done. I didn't find enough reference to state that
|
+ device_name.append(model_name); |
+ } |
+ } |
+ *name = UTF8ToUTF16(device_name); |
+ |
+ // Construct a unique id using fs uuid or manufacturer(vendor and model) |
+ // details. |
+ const char* uuid = NULL; |
+ if ((uuid = udev_device_get_property_value(dev, kFsUUID))) { |
+ *id = uuid; |
+ } else { |
+ // Format: VendorInfo_ModelInfo_SerialShortInfo |
+ // Eg: Kn_DataTravel_12.10_8000000000006CB02CDB |
+ const char *vendor = NULL, *model = NULL, *serial_short = NULL; |
+ if ((vendor = udev_device_get_property_value(dev, kVendorID))) |
+ *id = vendor; |
+ |
+ if ((model = udev_device_get_property_value(dev, kModelID))) { |
+ if (!id->empty()) |
+ id->append(kSeperator); |
+ id->append(model); |
+ } |
+ if ((serial_short = udev_device_get_property_value(dev, kSerialShort))) { |
+ if (!id->empty()) |
+ id->append(kSeperator); |
+ id->append(serial_short); |
+ } |
+ } |
+ |
+ udev_unref(udev_ptr); |
+ udev_device_unref(dev); |
+ return true; |
+} |
+ |
} // namespace |
namespace chrome { |
@@ -45,8 +145,7 @@ using content::BrowserThread; |
MediaDeviceNotificationsLinux::MediaDeviceNotificationsLinux( |
const FilePath& path) |
: initialized_(false), |
- mtab_path_(path), |
- current_device_id_(0U) { |
+ mtab_path_(path) { |
CHECK(!path.empty()); |
// Put |kKnownFileSystems| in std::set to get O(log N) access time. |
@@ -81,6 +180,15 @@ void MediaDeviceNotificationsLinux::OnFilePathChanged(const FilePath& path, |
UpdateMtab(); |
} |
+bool MediaDeviceNotificationsLinux::GetDeviceInfo(const std::string& dev_path, |
+ std::string* id, |
+ string16* name) { |
+ if (dev_path.empty()) |
+ return false; |
+ |
+ return GetDeviceInfoHelper(dev_path, id, name); |
Lei Zhang
2012/08/09 03:47:16
I don't understand why you need to keep udev out o
kmadhusu
2012/08/09 08:10:03
Done.
|
+} |
+ |
void MediaDeviceNotificationsLinux::InitOnFileThread() { |
DCHECK(!initialized_); |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); |
@@ -104,7 +212,7 @@ void MediaDeviceNotificationsLinux::InitOnFileThread() { |
void MediaDeviceNotificationsLinux::UpdateMtab() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); |
- MountMap new_mtab; |
+ MountPointDeviceMap new_mtab; |
ReadMtab(&new_mtab); |
// Check existing mtab entries for unaccounted mount points. |
@@ -112,8 +220,11 @@ void MediaDeviceNotificationsLinux::UpdateMtab() { |
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 (!ContainsKey(new_mtab, mount_point)) { |
+ const std::string& mount_device = it->second.first; |
+ MountPointDeviceMap::iterator newiter = new_mtab.find(mount_point); |
+ // |mount_point| not in |new_mtab| or |mount_device| is no longer mounted in |
Lei Zhang
2012/08/09 03:47:16
nit: mounted in -> mounted at
kmadhusu
2012/08/09 08:10:03
Done.
|
+ // |mount_point|. |
+ if (newiter == new_mtab.end() || newiter->second == mount_device) { |
const std::string& device_id = it->second.second; |
RemoveOldDevice(device_id); |
mount_points_to_erase.push_back(mount_point); |
@@ -126,63 +237,74 @@ void MediaDeviceNotificationsLinux::UpdateMtab() { |
mtab_.erase(mount_points_to_erase[i]); |
// Check new mtab entries against existing ones. |
- for (MountMap::iterator newiter = new_mtab.begin(); |
+ for (MountPointDeviceMap::iterator newiter = new_mtab.begin(); |
newiter != new_mtab.end(); |
++newiter) { |
+ std::string device_id; |
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; |
- std::string& id = newiter->second.second; |
+ const std::string& mount_device = newiter->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)); |
+ AddNewDevice(mount_device, mount_point, &device_id); |
+ mtab_.insert(std::make_pair(mount_point, |
+ std::make_pair(mount_device, device_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) |
+ if (mount_device == olditer->second.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; |
+ AddNewDevice(mount_device, mount_point, &device_id); |
+ olditer->second = std::make_pair(mount_device, device_id); |
} |
} |
} |
-void MediaDeviceNotificationsLinux::ReadMtab(MountMap* mtab) { |
+void MediaDeviceNotificationsLinux::ReadMtab(MountPointDeviceMap* mtab) { |
FILE* fp = setmntent(mtab_path_.value().c_str(), "r"); |
if (!fp) |
return; |
- MountMap& new_mtab = *mtab; |
+ // (mount point, entry position in mtab file) |
+ typedef std::pair<std::string, int> MountEntryInfo; |
Lei Zhang
2012/08/09 03:47:16
You can probably fold this into the next typedef,
kmadhusu
2012/08/09 08:10:03
Done.
|
+ |
+ // (mount device, MountEntryInfo) |
+ typedef std::map<std::string, MountEntryInfo> DeviceMap; |
+ |
+ // (mount point, entry position in mtab file) |
+ typedef std::map<std::string, int> MountPointsInfoMap; |
+ |
+ // Helper maps to store the device mount point details and mount point |
+ // entries. |
+ DeviceMap device_map; |
+ MountPointsInfoMap mount_points_info_map; |
Lei Zhang
2012/08/09 03:47:16
you can declare this and its typedef further below
kmadhusu
2012/08/09 08:10:03
Done.
|
+ |
+ MountPointDeviceMap& new_mtab = *mtab; |
mntent entry; |
char buf[512]; |
- int mount_position = 0; |
- typedef std::pair<std::string, std::string> MountPointAndId; |
- typedef std::map<std::string, MountPointAndId> DeviceMap; |
- DeviceMap device_map; |
+ |
+ // Keep track of mount point entry positions in mtab file. |
+ int entry_pos = 0; |
+ |
while (getmntent_r(fp, &entry, buf, sizeof(buf))) { |
// We only care about real file systems. |
if (!ContainsKey(known_file_systems_, entry.mnt_type)) |
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, base::IntToString(mount_position++)); |
- DeviceMap::iterator it = device_map.find(entry.mnt_fsname); |
+ const std::string& mount_device = entry.mnt_fsname; |
+ const std::string& mount_point = entry.mnt_dir; |
+ DeviceMap::iterator it = device_map.find(mount_device); |
if (it == device_map.end()) { |
- device_map.insert(std::make_pair(entry.mnt_fsname, mount_point_and_id)); |
+ device_map.insert(std::make_pair(mount_device, |
+ std::make_pair(mount_point, |
+ entry_pos++))); |
} else { |
- it->second = mount_point_and_id; |
+ it->second = std::make_pair(mount_point, entry_pos++); |
} |
} |
endmntent(fp); |
@@ -190,28 +312,25 @@ void MediaDeviceNotificationsLinux::ReadMtab(MountMap* mtab) { |
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_device = device_it->first; |
const std::string& mount_point = device_it->second.first; |
- const std::string& 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; |
+ const int entry_pos = device_it->second.second; |
+ MountPointDeviceMap::iterator new_it = new_mtab.find(mount_point); |
Lei Zhang
2012/08/09 03:47:16
you may want to rename |new_it| and |it| to |new_m
kmadhusu
2012/08/09 08:10:03
Done.
|
+ if (new_it == new_mtab.end()) { |
+ // No device at |mount_point|, save |device| to it. |
+ new_mtab.insert(std::make_pair(mount_point, mount_device)); |
+ mount_points_info_map.insert(std::make_pair(mount_point, entry_pos)); |
+ } else { |
+ MountPointsInfoMap::iterator it = mount_points_info_map.find(mount_point); |
+ DCHECK(it != mount_points_info_map.end()); |
+ // There is already a device mounted at |mount_point|. Check to see if |
+ // the existing mount entry is newer than the current one. |
+ if (it->second < entry_pos) { |
+ // The current entry is newer, update the mount point entry. |
+ it->second = entry_pos; |
+ new_it->second = mount_device; |
+ } |
} |
- |
- // 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; |
- std::string& 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; |
} |
} |
@@ -219,10 +338,22 @@ void MediaDeviceNotificationsLinux::AddNewDevice( |
const std::string& mount_device, |
const std::string& mount_point, |
std::string* device_id) { |
- *device_id = base::IntToString(current_device_id_++); |
+ string16 device_name; |
+ if (!GetDeviceInfo(mount_device, device_id, &device_name)) |
Lei Zhang
2012/08/09 03:47:16
You may also want to keep track of how often this
kmadhusu
2012/08/09 08:10:03
Done.
|
+ return; |
+ |
+ // Keep track of device uuid, to see how often we receive empty values. |
+ UMA_HISTOGRAM_BOOLEAN("MediaDeviceNotification.device_uuid_available", |
+ !device_id->empty()); |
+ UMA_HISTOGRAM_BOOLEAN("MediaDeviceNotification.device_name_available", |
+ !device_name.empty()); |
+ |
+ if (device_id->empty() || device_name.empty()) |
+ return; |
+ |
base::SystemMonitor* system_monitor = base::SystemMonitor::Get(); |
system_monitor->ProcessMediaDeviceAttached(*device_id, |
- UTF8ToUTF16(mount_device), |
+ device_name, |
SystemMonitor::TYPE_PATH, |
mount_point); |
} |