嵌入式 linux下kernel中kobject之kobject_uevent.c文件分析

2024-01-05 11:58

本文主要是介绍嵌入式 linux下kernel中kobject之kobject_uevent.c文件分析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

struct      kset_uevent_ops {

       int                 (*filter)(struct kset *kset, struct kobject *kobj);          //过滤函数,kset中的kobj是否需要处理

       const char      *(*name)(struct kset *kset, struct kobject *kobj);        //返回name

       int                 (*uevent)(struct kset *kset, struct kobject *kobj,         //uevent函数

                    struct kobj_uevent_env *env);

};

 

struct      kobj_uevent_env {

       char       *envp[UEVENT_NUM_ENVP];         //buf中每一段字符串的开始地址

       int          envp_idx;                                          //有几个envp,或者说buf中有几段字符串

       char       buf[UEVENT_BUFFER_SIZE];          //缓存(可以保存好几段字符串)

       int          buflen;                                              //buf尾

};


int   kobject_uevent_env(struct kobject *kobj, enum kobject_action action, char *envp_ext[])

调用kset-> uevent_ops-> uevent()函数

 

int   add_uevent_var(struct kobj_uevent_env *env, const char *format, ...)

将格式化信息保存进env->buf中,关于env结构体可参考kobject.c的文件分析开头

 

int   kobject_action_type(const char *buf, size_t count,      enum kobject_action *type)

查找buf属于哪一个action动作,属于的动作返回到type中


由于kref.c代码很少,所以就把这两个文件合在一起分析了


//原子的操作refcount,将其设置为1

void       kref_init(struct kref *kref)

{

       atomic_set(&kref->refcount,1);

       smp_mb();

}


//计数加1

void       kref_get(struct kref *kref)

{

       atomic_inc(&kref->refcount);

       smp_mb__after_atomic_inc();

}


//计数减1,为0则调用release函数

int   kref_put(struct kref *kref,    void (*release)(struct kref *kref))

{

       if (atomic_dec_and_test(&kref->refcount)) {

              release(kref);

              return 1;

       }

       return 0;

}


//关于uevent,目前猜测他应该是和热插拔有关

u64        uevent_seqnum;

char       uevent_helper[UEVENT_HELPER_PATH_LEN] =           //256

       CONFIG_UEVENT_HELPER_PATH;        // "/sbin/hotplug",这个定义在autoconf中

 

static      DEFINE_SPINLOCK(sequence_lock);

static      struct sock     *uevent_sock;

 

//这几个状态都是定义在kobject.h的枚举结构之中

static const char     *kobject_actions[] = {

       [KOBJ_ADD] =                   "add",

       [KOBJ_REMOVE] =           "remove",

       [KOBJ_CHANGE] =            "change",

       [KOBJ_MOVE] =                "move",

       [KOBJ_ONLINE] =             "online",

       [KOBJ_OFFLINE] =            "offline",

};


跳读一下,在分析kobject.c文件时,我们看得最多的是kobject_uevent和kobject_uevent_env函数,所以我们先来看看这两个函数是干什么用的。


//这个基本没什么说的了,直接调用了env

int   kobject_uevent(struct kobject *kobj,    enum kobject_action action)

{

       return     kobject_uevent_env(kobj, action, NULL);

}

EXPORT_SYMBOL_GPL(kobject_uevent);


//好长一个函数啊,为了方便理解,我们先从kobject.c中拿出一个调用实例来比较

//在rename函数中有这样的调用:

kobject_uevent_env(kobj, KOBJ_MOVE, envp);

其中envp的第一个元素保存的是更名前的kobj路径,第二个元素为空

sprintf(devpath_string, "DEVPATH_OLD=%s", devpath);

envp[0] = devpath_string;

envp[1] = NULL;

 

这个函数很长,但也是超级的绕,绕到最后,其实就一个核心操作:

retval = uevent_ops->uevent(kset, kobj, env);

其中kset为kobj的宿主kset, kobj的参数传入,而env则是一些字符串信息

int   kobject_uevent_env(

       struct kobject                      *kobj,                  //操作obj

       enum kobject_action     action,                   //动作( KOBJ_MOVE )

       char                            *envp_ext[])          //这个信息也只是添加进env->buf

{

       struct kobj_uevent_env *env;

       const char *action_string = kobject_actions[action];    //根据动作参数获取字符串"move"

       const char *devpath = NULL;

       const char *subsystem;

       struct kobject *top_kobj;

       struct kset *kset;

       struct kset_uevent_ops *uevent_ops;

       u64 seq;

       int i = 0;

       int retval = 0;

 

       //--------------------------------------------------------------------------------------------

       //这一块代码的功能是找到kobj的宿主kset,然后从中提取出热插拔的操作函数

       //--------------------------------------------------------------------------------------------

       //找到根kobj,或者关联上了kset宿主

       top_kobj = kobj;

       while (!top_kobj->kset && top_kobj->parent)

              top_kobj = top_kobj->parent;

 

       //根obj没有关联kset,出错

       if (!top_kobj->kset) {

              pr_debug("kobject attempted to send uevent without kset!\n");

              return -EINVAL;

       }

 

       //获取宿主kset,并从kset中提取出热插拔操作的ops

       kset = top_kobj->kset;

       uevent_ops = kset->uevent_ops;

 

       //--------------------------------------------------------------------------------------------

       //如果ops的filter()和name()函数有指定,则先执行他们

       //--------------------------------------------------------------------------------------------

       //如果ops存在 且 filter函数(过滤函数)有设置,则执行该函数

       //filter的作用应该是看看kobj是否被kset过滤到

       if (uevent_ops && uevent_ops->filter)

              if (!uevent_ops->filter(kset, kobj)) {

                     pr_debug("kobject filter function caused the event to drop!\n");

                     return 0;

              }

 

       //给subsystem指定name,如果ops->name()函数有指定,则从该函数返回,否则就获取kset->kobj的name。

       if (uevent_ops && uevent_ops->name)

              subsystem = uevent_ops->name(kset, kobj);

       else

              subsystem = kobject_name(&kset->kobj);

 

       //name为空,出错返回

       if (!subsystem) {

              pr_debug("unset subsystem caused the event to drop!\n");

              return 0;

       }

 

       //--------------------------------------------------------------------------------------------

       //申请一块env结构体,并填充他的env->buf字符串信息

       //--------------------------------------------------------------------------------------------

       //申请一快env内存

       env = kzalloc(sizeof(struct kobj_uevent_env), GFP_KERNEL);

       if (!env)

              return -ENOMEM;

 

       //获取kobj的完整路径

       devpath = kobject_get_path(kobj, GFP_KERNEL);

       if (!devpath) {

              retval = -ENOENT;

              goto exit;

       }

 

       //这里出现了一个新的函数,add_uevent_var,OK,我们先中断这里,跳到后面去先分析这个函数

       //分析完add_uevent_var函数后,发现这个函数只是将参数的字符串保存进env->buf中,所以这一串函数只是保存一些字符串信息

       retval = add_uevent_var(env, "ACTION=%s", action_string);    //动作名

       if (retval)

              goto exit;

       retval = add_uevent_var(env, "DEVPATH=%s", devpath);         //kobj路径

       if (retval)

              goto exit;

       retval = add_uevent_var(env, "SUBSYSTEM=%s", subsystem); //subsys名

       if (retval)

              goto exit;

 

       //如果参数三不为空,再保存参数三的字符串信息

       if (envp_ext) {

              for (i = 0; envp_ext[i]; i++) {

                     retval = add_uevent_var(env, envp_ext[i]);

                     if (retval)

                            goto exit;

              }

       }

       //--------------------------------------------------------------------------------------------

 

       //最后执行ops->uevent函数

       //绕了个大圈,最后却又调用了ops中指定的uevent

       if (uevent_ops && uevent_ops->uevent) {

              retval = uevent_ops->uevent(kset, kobj, env);

              if (retval) {

                     pr_debug ("%s - uevent() returned %d\n",

                              __FUNCTION__, retval);

                     goto exit;

              }

       }

 

       //将全局变量uevent_seqnum加1

       spin_lock(&sequence_lock);

       seq = ++uevent_seqnum;

       spin_unlock(&sequence_lock);

       retval = add_uevent_var(env, "SEQNUM=%llu", (unsigned long long)seq);

       if (retval)

              goto exit;

 

       //帮助信息,uevent_helper在申明时就已经给了一个默认的路径

       //这一块的代码实际和这个函数的关联不是很大了,所以可以不用理会

       if (uevent_helper[0]) {

              char *argv [3];

 

              argv [0] = uevent_helper;             // "/sbin/hotplug"

              argv [1] = (char *)subsystem;              // kset的name

              argv [2] = NULL;

              retval = add_uevent_var(env, "HOME=/");

              if (retval)

                     goto exit;

              retval = add_uevent_var(env, "PATH=/sbin:/bin:/usr/sbin:/usr/bin");

              if (retval)

                     goto exit;

 

              //让内核空间的驱动程序启用用户空间的若干应用程序,这个函数的简介可参考这个网址:http://linux.chinaunix.net/techdoc/beginner/2009/05/05/1110318.shtml

              call_usermodehelper (argv[0], argv, env->envp, UMH_WAIT_EXEC);

       }

 

exit:

       kfree(devpath);             //释放kobj路径

       kfree(env);                   //释放env

       return retval;

}

EXPORT_SYMBOL_GPL(kobject_uevent_env);


//直接从上面抓他的一个引用来说问题:

retval = add_uevent_var(env, "ACTION=%s", action_string);

//分析完这个函数后,发现这个函数只是将format中的字符保存进env->buf中

int   add_uevent_var(

       struct kobj_uevent_env *env,

       const char *format, ...)

{

       va_list args;           //获取格式化列表的参数

       int len;

 

       //idx大于等于envp指针数组的大小,出错返回

       if (env->envp_idx >= ARRAY_SIZE(env->envp)) {

              printk(KERN_ERR "add_uevent_var: too many keys\n");

              WARN_ON(1);

              return -ENOMEM;

       }

 

       //将格式化字符打印进env->buf中,

       //开始地址由env->buflen指定

       //最大长度由env->buf的大小 减去 env->buflen开始长度限制,以免越界

       va_start(args, format);

       len = vsnprintf(&env->buf[env->buflen],

                     sizeof(env->buf) - env->buflen,

                     format, args);

       va_end(args);

 

       //实际操作的长度在buf中越界了(实际是不可能的),出错返回

       if (len >= (sizeof(env->buf) - env->buflen)) {

              printk(KERN_ERR "add_uevent_var: buffer size too small\n");

              WARN_ON(1);

              return -ENOMEM;

       }

 

       //记录本段字符串的开始地址

       env->envp[env->envp_idx++] = &env->buf[env->buflen];

       env->buflen += len + 1;

       return 0;

}

EXPORT_SYMBOL_GPL(add_uevent_var);


//根据输入的buf查找该buf属于哪一个action命令

int   kobject_action_type(

       const char      *buf,                    //要处理的字符串

       size_t            count,                   //要处理的字符串的长度

       enum kobject_action     *type)     //返回action类型

{

       enum kobject_action action;

       int ret = -EINVAL;

 

       //从buf中剔除最后一个回车换行字符

       if (count && buf[count-1] == '\n')

              count--;

 

       if (!count)

              goto out;

 

       for (action = 0; action < ARRAY_SIZE(kobject_actions); action++) {

              if (strncmp(kobject_actions[action], buf, count) != 0) //字符串不相等

                     continue;

 

              //长度不相等,以免将“a”,“ab”两个误匹配

              if (kobject_actions[action][count] != '\0')           

                     continue;

      

              //找到匹配的字符串

              *type = action;

              ret = 0;

              break;

       }

out:

       return ret;

}


//创建一个sock,准备发送信息到网络上

static int __init      kobject_uevent_init(void)

{

       uevent_sock = netlink_kernel_create(&init_net, NETLINK_KOBJECT_UEVENT,

                                       1, NULL, NULL, THIS_MODULE);

       if (!uevent_sock) {

              printk(KERN_ERR

                     "kobject_uevent: unable to create netlink socket!\n");

              return -ENODEV;

       }

 

       return 0;

}

 

postcore_initcall(kobject_uevent_init);         //这个函数放置在指定区域,初始化执行

这篇关于嵌入式 linux下kernel中kobject之kobject_uevent.c文件分析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/572791

相关文章

MySQL表锁、页面锁和行锁的作用及其优缺点对比分析

《MySQL表锁、页面锁和行锁的作用及其优缺点对比分析》MySQL中的表锁、页面锁和行锁各有特点,适用于不同的场景,表锁锁定整个表,适用于批量操作和MyISAM存储引擎,页面锁锁定数据页,适用于旧版本... 目录1. 表锁(Table Lock)2. 页面锁(Page Lock)3. 行锁(Row Lock

linux打包解压命令方式

《linux打包解压命令方式》文章介绍了Linux系统中常用的打包和解压命令,包括tar和zip,使用tar命令可以创建和解压tar格式的归档文件,使用zip命令可以创建和解压zip格式的压缩文件,每... 目录Lijavascriptnux 打包和解压命令打包命令解压命令总结linux 打包和解压命令打

linux如何复制文件夹并重命名

《linux如何复制文件夹并重命名》在Linux系统中,复制文件夹并重命名可以通过使用“cp”和“mv”命令来实现,使用“cp-r”命令可以递归复制整个文件夹及其子文件夹和文件,而使用“mv”命令可以... 目录linux复制文件夹并重命名我们需要使用“cp”命令来复制文件夹我们还可以结合使用“mv”命令总

Linux使用cut进行文本提取的操作方法

《Linux使用cut进行文本提取的操作方法》Linux中的cut命令是一个命令行实用程序,用于从文件或标准输入中提取文本行的部分,本文给大家介绍了Linux使用cut进行文本提取的操作方法,文中有详... 目录简介基础语法常用选项范围选择示例用法-f:字段选择-d:分隔符-c:字符选择-b:字节选择--c

Linux使用nload监控网络流量的方法

《Linux使用nload监控网络流量的方法》Linux中的nload命令是一个用于实时监控网络流量的工具,它提供了传入和传出流量的可视化表示,帮助用户一目了然地了解网络活动,本文给大家介绍了Linu... 目录简介安装示例用法基础用法指定网络接口限制显示特定流量类型指定刷新率设置流量速率的显示单位监控多个

ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法

《ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法》本文介绍了Elasticsearch的基本概念,包括文档和字段、索引和映射,还详细描述了如何通过Docker... 目录1、ElasticSearch概念2、ElasticSearch、Kibana和IK分词器部署

Linux流媒体服务器部署流程

《Linux流媒体服务器部署流程》文章详细介绍了流媒体服务器的部署步骤,包括更新系统、安装依赖组件、编译安装Nginx和RTMP模块、配置Nginx和FFmpeg,以及测试流媒体服务器的搭建... 目录流媒体服务器部署部署安装1.更新系统2.安装依赖组件3.解压4.编译安装(添加RTMP和openssl模块

linux下多个硬盘划分到同一挂载点问题

《linux下多个硬盘划分到同一挂载点问题》在Linux系统中,将多个硬盘划分到同一挂载点需要通过逻辑卷管理(LVM)来实现,首先,需要将物理存储设备(如硬盘分区)创建为物理卷,然后,将这些物理卷组成... 目录linux下多个硬盘划分到同一挂载点需要明确的几个概念硬盘插上默认的是非lvm总结Linux下多

Springboot中分析SQL性能的两种方式详解

《Springboot中分析SQL性能的两种方式详解》文章介绍了SQL性能分析的两种方式:MyBatis-Plus性能分析插件和p6spy框架,MyBatis-Plus插件配置简单,适用于开发和测试环... 目录SQL性能分析的两种方式:功能介绍实现方式:实现步骤:SQL性能分析的两种方式:功能介绍记录

最长公共子序列问题的深度分析与Java实现方式

《最长公共子序列问题的深度分析与Java实现方式》本文详细介绍了最长公共子序列(LCS)问题,包括其概念、暴力解法、动态规划解法,并提供了Java代码实现,暴力解法虽然简单,但在大数据处理中效率较低,... 目录最长公共子序列问题概述问题理解与示例分析暴力解法思路与示例代码动态规划解法DP 表的构建与意义动