fix: af_netlink problems in the new branch reported by RA

.vscode/settings.json

@@ -159,4 +159,8 @@
         "check",
 
     ],
+    "rust-analyzer.showUnlinkedFileNotification": false,
+    "files.autoSave": "onFocusChange",
+    "editor.fontSize": 17,
+    "editor.accessibilityPageSize": 15,
 }

kernel/src/driver/acpi/sysfs.rs

@@ -22,7 +22,8 @@ use log::{debug, error, warn};
 use system_error::SystemError;
 
 use super::{acpi_kset, AcpiManager};
-
+use crate::driver::base::uevent::kobject_uevent::kobject_uevent;
+use crate::driver::base::uevent::KobjectAction;
 static mut __HOTPLUG_KSET_INSTANCE: Option<Arc<KSet>> = None;
 static mut __ACPI_TABLES_KSET_INSTANCE: Option<Arc<KSet>> = None;
 static mut __ACPI_TABLES_DATA_KSET_INSTANCE: Option<Arc<KSet>> = None;
@@ -115,7 +116,12 @@ impl AcpiManager {
             acpi_table_attr_list().write().push(attr);
             self.acpi_table_data_init(&header)?;
         }
-
+        // TODO:UEVENT
+        unsafe{
+            let _ = kobject_uevent(acpi_tables_kset.clone() as Arc<dyn KObject>, KobjectAction::KOBJADD);
+            let _ = kobject_uevent( __ACPI_TABLES_DATA_KSET_INSTANCE.as_ref().map(|kset| kset.clone() as Arc<dyn KObject>).unwrap(), KobjectAction::KOBJADD);
+            let _ = kobject_uevent(__ACPI_TABLES_DYNAMIC_KSET_INSTANCE.as_ref().map(|kset| kset.clone() as Arc<dyn KObject>).unwrap(), KobjectAction::KOBJADD);
+        }
         return Ok(());
     }
 

kernel/src/driver/base/device/dd.rs

@@ -571,6 +571,7 @@ impl DriverManager {
         }
 
         // todo: 发送kobj bind的uevent
+        // kobject_uevent();
     }
 
     fn driver_is_bound(&self, device: &Arc<dyn Device>) -> bool {

kernel/src/driver/base/device/driver.rs

@@ -2,6 +2,8 @@ use super::{
     bus::{bus_manager, Bus},
     Device, DeviceMatchName, DeviceMatcher, IdTable,
 };
+use crate::driver::base::uevent::kobject_uevent::kobject_uevent;
+use crate::driver::base::uevent::KobjectAction;
 use crate::{
     driver::base::{
         device::{bus::BusNotifyEvent, dd::DeviceAttrCoredump, device_manager},
@@ -17,7 +19,6 @@ use alloc::{
 use core::fmt::Debug;
 use log::error;
 use system_error::SystemError;
-
 /// @brief: Driver error
 #[allow(dead_code)]
 #[derive(Debug, PartialEq, Eq, Clone, Copy)]
@@ -218,7 +219,9 @@ impl DriverManager {
                 bus_manager().remove_driver(&driver);
             })?;
 
-        // todo: 发送uevent
+        // todo: 发送uevent，类型问题
+        let _ = kobject_uevent(driver.clone() as Arc<dyn KObject>, KobjectAction::KOBJADD);
+        // deferred_probe_extend_timeout();
 
         return Ok(());
     }

kernel/src/driver/base/device/mod.rs

@@ -521,7 +521,7 @@ impl DeviceManager {
         }
 
         // todo: 发送uevent: KOBJ_ADD
-
+        // kobject_uevent();
         // probe drivers for a new device
         bus_probe_device(&device);
 

kernel/src/driver/base/kobject.rs

@@ -1,6 +1,7 @@
 use core::{any::Any, fmt::Debug, hash::Hash, ops::Deref};
 
 use alloc::{
+    boxed::Box,
     string::String,
     sync::{Arc, Weak},
 };
@@ -21,7 +22,7 @@ use crate::{
 
 use system_error::SystemError;
 
-use super::kset::KSet;
+use super::{kset::KSet, uevent::kobject_uevent};
 
 pub trait KObject: Any + Send + Sync + Debug + CastFromSync {
     fn as_any_ref(&self) -> &dyn core::any::Any;
@@ -104,9 +105,7 @@ bitflags! {
         const REMOVE_UEVENT_SENT = 1 << 2;
         const INITIALIZED = 1 << 3;
     }
-
 }
-
 #[derive(Debug)]
 pub struct LockedKObjectState(RwLock<KObjectState>);
 
@@ -252,7 +251,7 @@ impl KObjectManager {
         }
 
         // todo: 发送uevent: KOBJ_REMOVE
-
+        // kobject_uevent();
         sysfs_instance().remove_dir(&kobj);
         kobj.update_kobj_state(None, Some(KObjectState::IN_SYSFS));
         let kset = kobj.kset();
@@ -261,6 +260,70 @@ impl KObjectManager {
         }
         kobj.set_parent(None);
     }
+
+    fn get_kobj_path_length(kobj: &Arc<dyn KObject>) -> usize {
+        let mut length = 1;
+        let mut parent = kobj.parent().unwrap().upgrade().unwrap();
+        /* walk up the ancestors until we hit the one pointing to the
+         * root.
+         * Add 1 to strlen for leading '/' of each level.
+         */
+        loop {
+            if parent.name().is_empty() {
+                break;
+            }
+            length += parent.name().len() + 1;
+            if let Some(weak_parent) = parent.parent() {
+                parent = weak_parent.upgrade().unwrap();
+            }
+        }
+        return length;
+    }
+
+    /*
+        static void fill_kobj_path(struct kobject *kobj, char *path, int length)
+    {
+        struct kobject *parent;
+
+        --length;
+        for (parent = kobj; parent; parent = parent->parent) {
+            int cur = strlen(kobject_name(parent));
+            /* back up enough to print this name with '/' */
+            length -= cur;
+            memcpy(path + length, kobject_name(parent), cur);
+            *(path + --length) = '/';
+        }
+
+        pr_debug("kobject: '%s' (%p): %s: path = '%s'\n", kobject_name(kobj),
+             kobj, __func__, path);
+    }
+         */
+    fn fill_kobj_path(kobj: &Arc<dyn KObject>, path: *mut u8, length: usize) {
+        let mut parent = kobj.parent().unwrap().upgrade().unwrap();
+        let mut length = length;
+        length -= 1;
+        loop {
+            let cur = parent.name().len();
+            length -= cur;
+            unsafe {
+                core::ptr::copy_nonoverlapping(parent.name().as_ptr(), path.add(length), cur);
+                *path.add(length - 1) = b'/';
+            }
+            if let Some(weak_parent) = parent.parent() {
+                parent = weak_parent.upgrade().unwrap();
+            }
+        }
+    }
+    // TODO: 实现kobject_get_path
+    // https://code.dragonos.org.cn/xref/linux-6.1.9/lib/kobject.c#139
+    pub fn kobject_get_path(kobj: &Arc<dyn KObject>) -> String {
+        let length = Self::get_kobj_path_length(kobj);
+        let path_raw = vec![0u8; length].into_boxed_slice();
+        let path = Box::into_raw(path_raw) as *mut u8;
+        Self::fill_kobj_path(kobj, path, length);
+        let path_string = unsafe { String::from_raw_parts(path, length, length) };
+        path_string
+    }
 }
 
 /// 动态创建的kobject对象的ktype

kernel/src/driver/base/kset.rs

@@ -6,8 +6,11 @@ use alloc::{
 
 use core::hash::Hash;
 
-use super::kobject::{
-    DynamicKObjKType, KObjType, KObject, KObjectManager, KObjectState, LockedKObjectState,
+use super::{
+    kobject::{
+        DynamicKObjKType, KObjType, KObject, KObjectManager, KObjectState, LockedKObjectState,
+    },
+    uevent::KobjUeventEnv,
 };
 use crate::{
     filesystem::kernfs::KernFSInode,
@@ -26,6 +29,8 @@ pub struct KSet {
     /// 与父节点有关的一些信息
     parent_data: RwLock<KSetParentData>,
     self_ref: Weak<KSet>,
+    /// kset用于发送uevent的操作函数集。kset能够发送它所包含的各种子kobj、孙kobj的消息，即kobj或其父辈、爷爷辈，都可以发送消息；优先父辈，然后是爷爷辈，以此类推
+    pub uevent_ops: Option<Arc<dyn KSetUeventOps>>,
 }
 
 impl Hash for KSet {
@@ -51,6 +56,7 @@ impl KSet {
             kobj_state: LockedKObjectState::new(None),
             parent_data: RwLock::new(KSetParentData::new(None, None)),
             self_ref: Weak::default(),
+            uevent_ops: Some(Arc::new(KSetUeventOpsDefault)),
         };
 
         let r = Arc::new(r);
@@ -91,6 +97,7 @@ impl KSet {
     pub fn register(&self, join_kset: Option<Arc<KSet>>) -> Result<(), SystemError> {
         return KObjectManager::add_kobj(self.self_ref.upgrade().unwrap(), join_kset);
         // todo: 引入uevent之后，发送uevent
+        // kobject_uevent();
     }
 
     /// 注销一个kset
@@ -232,3 +239,26 @@ impl InnerKSet {
         }
     }
 }
+//https://code.dragonos.org.cn/xref/linux-6.1.9/include/linux/kobject.h#137
+use core::fmt::Debug;
+pub trait KSetUeventOps: Debug + Send + Sync {
+    fn filter(&self) -> Option<i32>;
+    fn uevent_name(&self) -> String;
+    fn uevent(&self, env: &KobjUeventEnv) -> i32;
+}
+#[derive(Debug)]
+pub struct KSetUeventOpsDefault;
+
+impl KSetUeventOps for KSetUeventOpsDefault {
+    fn filter(&self) -> Option<i32> {
+        Some(0)
+    }
+
+    fn uevent_name(&self) -> String {
+        String::new()
+    }
+
+    fn uevent(&self, env: &KobjUeventEnv) -> i32 {
+        0
+    }
+}

kernel/src/driver/base/mod.rs

@@ -12,3 +12,4 @@ pub mod map;
 pub mod platform;
 pub mod subsys;
 pub mod swnode;
+pub mod uevent;