[PATCH] Added the libudev python bindings

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



Also rewrote the baseudev.py to use the bindings instead of parsing
the udev db file
---
 baseudev.py |   66 ++++++----------------
 pyudev.py   |  180 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 197 insertions(+), 49 deletions(-)
 create mode 100644 pyudev.py

diff --git a/baseudev.py b/baseudev.py
index 76b14cc..978bae0 100644
--- a/baseudev.py
+++ b/baseudev.py
@@ -23,6 +23,7 @@
 
 import iutil
 import os
+import pyudev
 
 import logging
 log = logging.getLogger("storage")
@@ -43,20 +44,24 @@ def udev_get_device(sysfs_path):
         log.debug("%s does not exist" % sysfs_path)
         return None
 
-    db_entry = sysfs_path.replace("/", "\\x2f")
-    db_root = "/dev/.udev/db"
-    db_path = os.path.normpath("%s/%s" % (db_root, db_entry))
-    if not os.access(db_path, os.R_OK):
-        log.debug("db entry %s does not exist" % db_path)
-        return None
+    udev = pyudev.Udev()
+    # XXX we remove the /sys part when enumerating devices,
+    # so we have to prepend it when creating the device
+    udev_device = udev.create_device("/sys" + sysfs_path)
+    udev.teardown()
+
+    dev = udev_device.properties
+
+    if dev:
+        # remove the /dev/ part from beginning of devnode and set as name
+        dev["name"] = udev_device.devnode[5:]
+
+        dev["symlinks"] = dev["DEVLINKS"].split()
+        dev["sysfs_path"] = sysfs_path
 
-    entry = open(db_path).read()
-    dev = udev_parse_entry(entry)
-    if dev.has_key("name"):
-        dev['sysfs_path'] = sysfs_path
+        # now add in the contents of the uevent file since they're handy
         dev = udev_parse_uevent_file(dev)
 
-    # now add in the contents of the uevent file since they're handy
     return dev
 
 def udev_get_devices(deviceClass="block"):
@@ -68,45 +73,8 @@ def udev_get_devices(deviceClass="block"):
             entries.append(entry)
     return entries
 
-def udev_parse_entry(buf):
-    dev = {}
-
-    for line in buf.splitlines():
-        line.strip()
-        (tag, sep, val) = line.partition(":")
-        if not sep:
-            continue
-
-        if tag == "N":
-            dev['name'] = val
-        elif tag == "S":
-            if dev.has_key('symlinks'):
-                dev['symlinks'].append(val)
-            else:
-                dev['symlinks'] = [val]
-        elif tag == "E":
-            if val.count("=") > 1 and val.count(" ") > 0:
-                # eg: LVM2_LV_NAME when querying the VG for its LVs
-                vars = val.split()
-                vals = []
-                var_name = None
-                for (index, subval) in enumerate(vars):
-                    (var_name, sep, var_val) = subval.partition("=")
-                    if sep:
-                        vals.append(var_val)
-
-                dev[var_name] = vals
-            else:
-                (var_name, sep, var_val) = val.partition("=")
-                if not sep:
-                    continue
-
-                dev[var_name] = var_val
-
-    return dev
-
 def udev_parse_uevent_file(dev):
-    path = os.path.normpath("/sys/%s/uevent" % dev['sysfs_path'])
+    path = os.path.normpath("/sys/%s/uevent" % dev["sysfs_path"])
     if not os.access(path, os.R_OK):
         return dev
 
diff --git a/pyudev.py b/pyudev.py
new file mode 100644
index 0000000..8d5a7c2
--- /dev/null
+++ b/pyudev.py
@@ -0,0 +1,180 @@
+import sys
+import os
+import fnmatch
+from ctypes import *
+
+
+# XXX this one may need some tweaking...
+def find_library(name):
+    libdirs = ("/lib64", "/lib")
+
+    for dir in libdirs:
+        files = fnmatch.filter(os.listdir(dir), "*%s*" % name)
+        files = [os.path.join(dir, file) for file in files]
+
+        if files:
+            break
+
+    if files:
+        return files[0]
+    else:
+        return None
+
+
+# find the udev library
+libudev = find_library("udev")
+
+if not libudev or not os.path.exists(libudev):
+    raise ImportError, "No library named %s" % libudev
+
+# load the udev library
+libudev = CDLL(libudev)
+
+
+# create aliases for needed functions and set the return types where needed
+libudev_udev_new = libudev.udev_new
+libudev_udev_unref = libudev.udev_unref
+
+libudev_udev_device_new_from_syspath = libudev.udev_device_new_from_syspath
+libudev_udev_device_unref = libudev.udev_device_unref
+
+libudev_udev_device_get_syspath = libudev.udev_device_get_syspath
+libudev_udev_device_get_sysname = libudev.udev_device_get_sysname
+libudev_udev_device_get_syspath.restype = c_char_p
+libudev_udev_device_get_sysname.restype = c_char_p
+
+libudev_udev_device_get_properties_list_entry = libudev.udev_device_get_properties_list_entry
+libudev_udev_list_entry_get_next = libudev.udev_list_entry_get_next
+
+libudev_udev_list_entry_get_name = libudev.udev_list_entry_get_name
+libudev_udev_list_entry_get_value = libudev.udev_list_entry_get_value
+libudev_udev_list_entry_get_name.restype = c_char_p
+libudev_udev_list_entry_get_value.restype = c_char_p
+
+libudev_udev_enumerate_new = libudev.udev_enumerate_new
+libudev_udev_enumerate_unref = libudev.udev_enumerate_unref
+
+libudev_udev_enumerate_add_match_subsystem = libudev.udev_enumerate_add_match_subsystem
+libudev_udev_enumerate_scan_devices = libudev.udev_enumerate_scan_devices
+libudev_udev_enumerate_get_list_entry = libudev.udev_enumerate_get_list_entry
+
+
+class UdevDevice(object):
+
+    def __init__(self, udev, sysfs_path):
+        self.syspath = None
+        self.sysname = None
+        self.properties = {}
+
+        # create new udev device from syspath
+        udev_device = libudev_udev_device_new_from_syspath(udev, sysfs_path)
+        if not udev_device:
+            # device does not exist
+            return
+
+        # set syspath and sysname properties
+        self.syspath = libudev_udev_device_get_syspath(udev_device)
+        self.sysname = libudev_udev_device_get_sysname(udev_device)
+
+        # get the first property entry
+        property_entry = libudev_udev_device_get_properties_list_entry(udev_device)
+
+        while property_entry:
+            name = libudev_udev_list_entry_get_name(property_entry)
+            value = libudev_udev_list_entry_get_value(property_entry)
+
+            # XXX we have to split some of the values into a list,
+            # the libudev is not so smart :(
+            fields = value.split()
+
+            if len(fields) > 1:
+                value = [fields[0]]
+
+                for item in fields[1:]:
+                    (key, sep, val) = item.partition("=")
+                    if sep:
+                        value.append(val)
+
+                if len(value) == 1:
+                    value = value[0]
+
+            self.properties[name] = value
+
+            # get next property entry
+            property_entry = libudev_udev_list_entry_get_next(property_entry)
+
+        # set additional properties
+        libudev.udev_device_get_devpath.restype = c_char_p
+        self.devpath = libudev.udev_device_get_devpath(udev_device)
+
+        libudev.udev_device_get_subsystem.restype = c_char_p
+        self.subsystem = libudev.udev_device_get_subsystem(udev_device)
+
+        libudev.udev_device_get_devtype.restype = c_char_p
+        self.devtype = libudev.udev_device_get_devtype(udev_device)
+
+        libudev.udev_device_get_sysnum.restype = c_char_p
+        self.sysnum = libudev.udev_device_get_sysnum(udev_device)
+
+        libudev.udev_device_get_devnode.restype = c_char_p
+        self.devnode = libudev.udev_device_get_devnode(udev_device)
+
+        # cleanup
+        libudev_udev_device_unref(udev_device)
+
+    def __str__(self):
+        s = "SYSPATH: %s\n" % self.syspath
+        s += "SYSNAME: %s" % self.sysname
+
+        return s
+
+
+class Udev(object):
+
+    def __init__(self):
+        self.udev = libudev_udev_new()
+
+    def create_device(self, sysfs_path):
+        return UdevDevice(self.udev, sysfs_path)
+
+    def scan_devices(self, subsystem=None):
+        enumerate = libudev_udev_enumerate_new(self.udev)
+
+        # add the match subsystem
+        if subsystem is not None:
+            rc = libudev_udev_enumerate_add_match_subsystem(enumerate, subsystem)
+            if not rc == 0:
+                print >> sys.stderr, "error: unable to add the match subsystem"
+                libudev_udev_enumerate_unref(enumerate)
+                return []
+
+        # scan the devices
+        rc = libudev_udev_enumerate_scan_devices(enumerate)
+        if not rc == 0:
+            print >> sys.stderr, "error: unable to scan the devices"
+            libudev_udev_enumerate_unref(enumerate)
+            return []
+
+        # create the list of devices
+        devices = []
+
+        # get the first device entry
+        device_entry = libudev_udev_enumerate_get_list_entry(enumerate)
+
+        while device_entry:
+            sysfs_path = libudev_udev_list_entry_get_name(device_entry)
+            device = self.create_device(sysfs_path)
+
+            if device.syspath is not None:
+                devices.append(device)
+
+            # get next device entry
+            device_entry = libudev_udev_list_entry_get_next(device_entry)
+
+        # cleanup
+        libudev_udev_enumerate_unref(enumerate)
+
+        return devices
+
+    def teardown(self):
+        libudev_udev_unref(self.udev)
-- 
1.6.5.2

_______________________________________________
Anaconda-devel-list mailing list
Anaconda-devel-list@xxxxxxxxxx
https://www.redhat.com/mailman/listinfo/anaconda-devel-list

[Index of Archives]     [Kickstart]     [Fedora Users]     [Fedora Legacy List]     [Fedora Maintainers]     [Fedora Desktop]     [Fedora SELinux]     [Big List of Linux Books]     [Yosemite News]     [Yosemite Photos]     [KDE Users]     [Fedora Tools]
  Powered by Linux