简述linux通知链机制

notifier chain概述

Linux内核中各个子系统相互依赖,当其中某个子系统状态发生改变时,有时需要使用一定的机制告知使用其服务的其他子系统,以便其他子系统采取相应的措施。为满足这样的需求,内核实现了事件通知链机制(notification chain)。

通知链只能用在各个子系统之间(当然一个子系统内部也可以使用),而不能在内核和用户空间进行事件的通知。

事件通知链表是一个事件处理函数的列表,每个通知链都与某个或某些事件有关,当特定的事件发生时,就调用相应的事件通知链中的回调函数,进行相应的处理。

通知链类型

(1) 原子通知链

通知链元素的回调函数必须能在中断或原子操作上下文中运行,不允许阻塞。对应的链表头结构:

struct atomic_notifier_head {  spinlock_t  lock;  struct  notifier_block *head;  
};

(2) 可阻塞通知链

通知链元素的回调函数在进程上下文中运行,允许阻塞。对应的链表头:

struct  blocking_notifier_head {  struct  rw_semaphore  rwsem;  struct  notifier_block  *head;  
};

(3) 原始通知链

对通知链元素的回调函数没有任何限制,所有锁和保护机制都由调用者维护。对应的链表头:

struct  raw_notifier_head {  struct  notifier_block  *head;  
};

(4) notifier_block

notifier_call_chain 会按照通知链上各成员的优先级顺序(.priority)来遍历(next)执行回调函数(notifier_call)

struct notifier_block {notifier_fn_t notifier_call;struct notifier_block __rcu *next;int priority;
};

相应接口

注册通知链,在通知链表注册时,需要有一个链表头,他指向这个通知链表的第一个元素,这样就可以根据这个链表头找到这个链表中的所有数据。

static int notifier_chain_register(struct notifier_block **nl, struct notifier_block *n);
static int notifier_chain_unregister(struct notifier_block **nl, struct notifier_block *n);

通知链表,当有事件发生时,就使用notifier_call_chain向某个通知链表发送消息。这个函数会遍历通知链中所有的元素,然后依次调用每一个的回调函数。

static int __kprobes notifier_call_chain(struct notifier_block **nl, unsigned long val, void *v, int nr_to_call, int *nr_calls)

示例

下面的示例体现了通知链的<事件,优先级,遍历>的特点

#include <linux/module.h>
#include <linux/notifier.h>
#include <linux/init.h>
#include <linux/kernel.h>
#include <linux/fs.h>//static RAW_NOTIFIER_HEAD(test_chain_head);struct raw_notifier_head test_chain_head = {.head = NULL
};#define EVENT_A 0x01
#define EVENT_B 0x02int test_notifier_event1(struct notifier_block *nb, unsigned long event, void *v)
{switch (event) {case EVENT_A:printk("%s: event=EVENT_A\n", __func__);break;case EVENT_B:printk("%s: event=EVENT_B\n", __func__);break;default:break;}return NOTIFY_DONE;
}int test_notifier_event2(struct notifier_block *nb, unsigned long event, void *v)
{switch (event) {case EVENT_A:printk("%s: event=EVENT_A\n", __func__);break;case EVENT_B:printk("%s: event=EVENT_B\n", __func__);break;default:break;}return NOTIFY_DONE;
}static struct notifier_block test_notifier1 = {.notifier_call = test_notifier_event1,.priority = 1,
};static struct notifier_block test_notifier2 = {.notifier_call = test_notifier_event2,.priority = 2,
};static int __init mynotify_init(void)
{printk("raw_notifier_chain_register\n");raw_notifier_chain_register(&test_chain_head, &test_notifier1);raw_notifier_chain_register(&test_chain_head, &test_notifier2);printk("raw_notifier_call_chain\n");raw_notifier_call_chain(&test_chain_head, EVENT_B, NULL);raw_notifier_call_chain(&test_chain_head, EVENT_A, NULL);return 0;
}static void __exit mynotify_exit(void)
{raw_notifier_chain_unregister(&test_chain_head, &test_notifier1);raw_notifier_chain_unregister(&test_chain_head, &test_notifier2);
}module_init(mynotify_init);
module_exit(mynotify_exit);MODULE_LICENSE("GPL");//dmesg
raw_notifier_chain_register
raw_notifier_call_chain
test_notifier_event2: event=EVENT_B
test_notifier_event1: event=EVENT_B
test_notifier_event2: event=EVENT_A
test_notifier_event1: event=EVENT_A

注册机制

 notifier_chain_register

static int notifier_chain_register(struct notifier_block **nl, //传递进来nl的是指针的指针的副本struct notifier_block *n)
{while ((*nl) != NULL) {if (unlikely((*nl) == n)) {WARN(1, "double register detected");return 0;}if (n->priority > (*nl)->priority)/*step 1*/break; nl = &((*nl)->next); /*step 2 nl副本改变不影响链表头或者链表元素*/}n->next = *nl; /*step 3*/rcu_assign_pointer(*nl, n); /*step 4 *nl对地址副本进行*操作就会改变链表头或者链表元素*/return 0;
}

1.如果链表头的优先级小于新节点,那么退出循环,让新节点当链表头

2.如果链表头的优先级不小于新节点,那么从链表头循环遍历链表

    2.1找到小于新节点优先级的第一个链表元素tnl,则退出循环

tnl = nl->next;/*step 2*/

    将新节点n插到tnl前面       

n->next = tnl;/*step 3*/
*tnl = nl->next = n;/*step 4*/

    2.2.如果找到链表尾都没找到

tnl = nl->next = null;

    将新节点n插在最后一个元素后面当链表尾     

n->next = tnl = null;/*step 3*/
*tnl = nl->next = n;/*step 4*/

notifier_call_chain

直接遍历且执行通知链里的回调函数notifier_call

static int notifier_call_chain(struct notifier_block **nl,unsigned long val, void *v,int nr_to_call, int *nr_calls)
{int ret = NOTIFY_DONE;struct notifier_block *nb, *next_nb;nb = rcu_dereference_raw(*nl);while (nb && nr_to_call) {next_nb = rcu_dereference_raw(nb->next);#ifdef CONFIG_DEBUG_NOTIFIERSif (unlikely(!func_ptr_is_kernel_text(nb->notifier_call))) {WARN(1, "Invalid notifier called!");nb = next_nb;continue;}
#endifret = nb->notifier_call(nb, val, v);if (nr_calls)(*nr_calls)++;if (ret & NOTIFY_STOP_MASK)break;nb = next_nb;nr_to_call--;}return ret;
}
NOKPROBE_SYMBOL(notifier_call_chain);

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/45615.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

IPython:提升Python编程效率的实用技巧与案例

引言 IPython&#xff0c;作为Python的一个交互式计算环境&#xff0c;极大地提升了编程、数据分析和科学计算的效率。它不仅提供了增强的交互式Shell&#xff0c;还集成了丰富的工具和功能&#xff0c;如魔术命令、自动补全、内嵌图形显示等。本文将整理一系列IPython的使用技…

VMWare 下给Centos扩容

目录 参考文档背景介绍扩容查看当前文件磁盘信息增加一个存储分区创建物理卷把物理卷添加到卷组查看卷组名把物理卷并入卷组 对文件系统进行扩容搞定 参考文档 1、百度经验 2、CSDN 3、掘金 背景介绍 测试环境用VMWare 安装centos7&#xff0c;几年下来磁盘空间不够用了&…

【前端项目笔记】10 项目优化上线

项目优化上线 目标&#xff1a;优化Vue项目部署Vue项目&#xff08;上线提供使用&#xff09; 项目优化 项目优化策略&#xff1a; 生成打包报告&#xff1a;根据生成的报告发现问题并解决第三方库启用CDN&#xff1a;提高首屏页面的加载效率Element-UI组件按需加载路由懒加…

数据结构4.0——串的定义和基本操作

串的定义(逻辑结构) 串&#xff0c;即字符串(String)是由零个或多个字符组成的有序数列。 一般记为Sa1a2....an(n>0) 其中&#xff0c;S是串名&#xff0c;单引号括起来的字符序列是串的值;ai可以是字母、数字或其他字符&#xff1b;串中字符的个数n称为串的长度。n0时的…

unity 2020版本packManager没有AssetBundles

1.Packages->manifest.json打开manifest.json文件 2.添加"com.unity.assetbundlebrowser": "1.7.0", 保存即可

以数据编织,重构数据管理新范式

大数据产业创新服务媒体 ——聚焦数据 改变商业 人工智能几乎统一了全球最顶尖科技公司的认知&#xff1a;这个时代&#xff0c;除了AI&#xff0c;没有第二条路可走。 人工智能的技术逻辑颇有一种“暴力美学”&#xff0c;它依托于海量大数据和超高算力的训练和推理&#xff…

医疗健康信息的安全挑战与隐私保护最佳实践

医疗健康信息的安全挑战 医疗健康信息的安全挑战主要包括数据规模庞大、管理困难、数据类型多样导致的安全风险高、以及法律法规与伦理约束带来的挑战。随着医疗信息化的发展&#xff0c;医疗健康数据呈现出爆炸式的增长&#xff0c;医院信息系统、电子病历、健康管理等产生了海…

Spring Boot与MyBatis完美集成指南

Spring Boot与MyBatis完美集成指南 在当今软件开发领域&#xff0c;Spring Boot和MyBatis作为两大流行框架&#xff0c;分别以其简洁高效和灵活易用的特点&#xff0c;在快速构建和数据库交互方面展现了显著优势。本文将深入探讨Spring Boot与MyBatis的基本概念、特点、优势&a…

Xcode依赖管理大师:精通项目依赖的艺术与实践

Xcode依赖管理大师&#xff1a;精通项目依赖的艺术与实践 在现代软件开发中&#xff0c;项目依赖管理是确保项目顺利进行的关键环节。Xcode&#xff0c;作为苹果官方的集成开发环境&#xff08;IDE&#xff09;&#xff0c;提供了一套强大的工具来管理项目依赖。本文将深入探讨…

SpringBoot新手快速入门系列教程十一:基于Docker Compose部署一个最简单分布式服务项目

我的教程都是亲自测试可行才发布的&#xff0c;如果有任何问题欢迎留言或者来群里我每天都会解答。 如果您还对于Docker或者Docker Compose不甚了解&#xff0c;可以劳烦移步到我之前的教程&#xff1a; SpringBoot新手快速入门系列教程九&#xff1a;基于docker容器&#xff…

218.贪心算法:分发糖果(力扣)

核心思想 初始化每个学生的糖果数为1&#xff1a; 确保每个学生至少有一颗糖果。从左到右遍历&#xff1a; 如果当前学生的评分高于前一个学生&#xff0c;则当前学生的糖果数应比前一个学生多一颗。从右到左遍历&#xff1a; 如果当前学生的评分高于后一个学生&#xff0c;则…

Hadoop3:HDFS-通过配置黑白名单对集群进行扩缩容,并实现数据均衡(实用)

一、集群情况介绍 我的本地虚拟机&#xff0c;一共有三个节点&#xff0c;hadoop102、hadoop103、hadoop104 二、白名单 创建白名单文件whitelist&#xff0c;通过白名单的配置&#xff0c;只允许集群包含102和103两台机器可以存储数据&#xff0c;104无法存储数据。 需求 …

react学习——29react之useState使用

useState 是 React Hooks 中的一个重要函数&#xff0c;它用于在函数组件中添加状态。在类组件中&#xff0c;我们通常使用 this.state 和 this.setState 来管理组件的状态&#xff0c;而在函数组件中&#xff0c;我们可以使用 useState 来达到同样的目的。 1、导入 useState&…

C语言 判断素数

写一个判素数的函数,在主函数输入一个整数,输出是否为素数的信息。 #include <stdio.h> #include <stdbool.h>// 判断是否为素数 bool is_prime(int num) {if (num < 1) return false;for (int i 2; i < num / 2; i) {if (num % i 0) return false;}retur…

修改留言板

<!DOCTYPE html> <html lang"zh-CN"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>备忘录</title><!-- <link rel"…

Netty Websocket SpringBoot Starter

netty websocket starter Quick Start Demo 项目 添加依赖 <!--添加源--> <repository><id>github</id><url>https://maven.pkg.github.com</url><snapshots><enabled>true</enabled></snapshots> </reposit…

SchedulerLock分布式定时任务锁

1.pom中引入依赖&#xff0c;这里使用redis作为锁 <dependency><groupId>net.javacrumbs.shedlock</groupId><artifactId>shedlock-spring</artifactId><version>4.12.0</version></dependency><dependency><groupId…

根据脚手架archetype快速构建spring boot/cloud项目

1、找到archetype&#xff0c;并从私仓下载添加archetype到本地 点击IDEA的file&#xff0c;选择new project 选择maven项目&#xff0c;勾选create from archetype 填写archetype信息&#xff0c;&#xff08;repository填写私仓地址&#xff09; 2、选择自定义的脚手架arche…

关于正点原子的alpha开发板的启动函数(汇编,自己的认识)

我傻逼了&#xff0c;这里的注释还是不要用&#xff1b; 全部换成 /* */ 这里就分为两块&#xff0c;一部分是复位中断部分&#xff0c;第二部分就是IRQ部分&#xff08;中断部分最重要&#xff09; 我就围绕着两部分来展开我的认识 首先声明全局 .global_start 在 ARM 架…

数据分包:145字节版本

分包 timescale 1ns / 1ps // // Company: // Engineer: // // Create Date: 2023/08/04 14:35:21 // Design Name: // Module Name: dat_send_blocks_v // Project Name: // Target Devices: // Tool Versions: // Description: // // Dependencies: // // Revisi…