inotify通知机制

2024-01-22 14:38
文章标签 机制 通知 inotify

本文主要是介绍inotify通知机制,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

#include <unistd.h>
#include <stdio.h>
#include <sys/inotify.h>
#include <string.h>
#include <errno.h>/**参考: frameworks\native\services\inputflinger\EventHub.cpp*//*Usage: inotify <dir> *//*
*	inotify主要功能:它是一个内核用于通知用户空间程序文件系统变化的机制
*	众所周知,Linux 桌面系统与 MAC 或 Windows 相比有许多不如人意的地方,为了改善这种状况,开源社区提出用户态需要内核提供一些机制,以便用户态能够及时地得知内核或底层硬件设备发生了什么,从而能够更好地管理设备,给用户提供更好的服务,如 hotplug、udev 和 inotify 就是这种需求催生的。Hotplug 是一种内核向用户态应用通报关于热插拔设备一些事件发生的机制,桌面系统能够利用它对设备进行有效的管理udev 动态地维护 /dev 下的设备文件inotify 是一种文件系统的变化通知机制,如文件增加、删除等事件可以立刻让用户态得知,该机制是著名的桌面搜索引擎项目 beagle 引入的,并在Gamin 等项目中被应用。
*	
*/#if 0
len长度分配以16字节对齐分配
如name为hi,len为16name为hello_world_123456 len为48struct inotify_event {__s32           wd;             /* watch descriptor */__u32           mask;           /* watch mask */__u32           cookie;         /* cookie to synchronize two events */__u32           len;            /* length (including nulls) of name */char            name[0];        /* stub for possible name */
};
#endifint read_process_inotify_fd(int fd)
{int res;char event_buf[512];int event_size;int event_pos = 0;struct inotify_event *event;/* read */	res = read(fd, event_buf, sizeof(event_buf));printf("res:%d (int)sizeof(*event):%d\n",res,(int)sizeof(*event));if(res < (int)sizeof(*event)) {if(errno == EINTR)return 0;printf("could not get event, %s\n", strerror(errno));return -1;}/* process* 读到的数据是1个或者多个inotify_event,如touch/rm 多个文件,需要遍历处理* 它们的长度不一样,逐个处理*/while(res >= (int)sizeof(*event)) {event = (struct inotify_event *)(event_buf + event_pos);printf("event->wd:%d event->mask:0x%x event->len:%d event->name:%s\n",event->wd,event->mask,event->len,event->name);if(event->len) {if(event->mask & IN_CREATE) {printf("create file: %s\n", event->name);} else {printf("delete file: %s\n", event->name);}}event_size = sizeof(*event) + event->len;res -= event_size;event_pos += event_size;}return 0;
}int main(int argc, char **argv)
{int mINotifyFd;int result;if (argc != 2){printf("Usage: %s <dir>\n", argv[0]);return -1;}/* 1.inotify_init 创建 inotify 实例*/mINotifyFd = inotify_init();/* 每一个 inotify 实例对应一个独立的排序的队列。文件系统的变化事件被称做 watches 的一个对象管理,每一个 watch 是一个二元组(目标,事件掩码),目标可以是文件或目录,事件掩码表示应用希望关注的 inotify 事件,每一个位对应一个 inotify 事件。Watch 对象通过 watch描述符引用,watches 通过文件或目录的路径名来添加。目录 watches 将返回在该目录下的所有文件上面发生的事件。*//* 2.add watch 添加一个 watchint inotify_add_watch(int fd, const char *pathname, uint32_t mask)fd: 		fd是inotify_init()返回的文件描述符pathname: 	pathname是被监视的目标的路径名,即文件名或目录名mask:		mask是事件掩码, 在头文件linux/inotify.h中定义了每一位代表的事件IN_DELETE:监听删除IN_CREATE:监听创建return value:返回非负的watch descriptor(监听描述符)*/result = inotify_add_watch(mINotifyFd, argv[1], IN_DELETE | IN_CREATE);/* read */while (1) {read_process_inotify_fd(mINotifyFd);}return 0;
}
调试结果:
lisongze@lisongze-ubuntu:~/code/C$ gcc inotify.c -o inotify.c
lisongze@lisongze-ubuntu:~/code/C$ mkdir tmp
lisongze@lisongze-ubuntu:~/code/C$ ./inotify tmp&
lisongze@lisongze-ubuntu:~/code/C$ touch tmp/test tmp/hello
res:32 (int)sizeof(*event):16
event->wd:1 event->mask:0x100 event->len:16 event->name:test
create file: test
res:32 (int)sizeof(*event):16
event->wd:1 event->mask:0x100 event->len:16 event->name:hello
create file: hello
lisongze@lisongze-ubuntu:~/code/C$ rm tmp/test tmp/hello
res:32 (int)sizeof(*event):16
event->wd:1 event->mask:0x200 event->len:16 event->name:test
delete file: test
res:32 (int)sizeof(*event):16
event->wd:1 event->mask:0x200 event->len:16 event->name:hello
delete file: hello

这篇关于inotify通知机制的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

基于Redis自动过期的流处理暂停机制

《基于Redis自动过期的流处理暂停机制》基于Redis自动过期的流处理暂停机制是一种高效、可靠且易于实现的解决方案,防止延时过大的数据影响实时处理自动恢复处理,以避免积压的数据影响实时性,下面就来详... 目录核心思路代码实现1. 初始化Redis连接和键前缀2. 接收数据时检查暂停状态3. 检测到延时过

Redis中哨兵机制和集群的区别及说明

《Redis中哨兵机制和集群的区别及说明》Redis哨兵通过主从复制实现高可用,适用于中小规模数据;集群采用分布式分片,支持动态扩展,适合大规模数据,哨兵管理简单但扩展性弱,集群性能更强但架构复杂,根... 目录一、架构设计与节点角色1. 哨兵机制(Sentinel)2. 集群(Cluster)二、数据分片

深入理解go中interface机制

《深入理解go中interface机制》本文主要介绍了深入理解go中interface机制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前言interface使用类型判断总结前言go的interface是一组method的集合,不

C# async await 异步编程实现机制详解

《C#asyncawait异步编程实现机制详解》async/await是C#5.0引入的语法糖,它基于**状态机(StateMachine)**模式实现,将异步方法转换为编译器生成的状态机类,本... 目录一、async/await 异步编程实现机制1.1 核心概念1.2 编译器转换过程1.3 关键组件解析

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

Spring Security 单点登录与自动登录机制的实现原理

《SpringSecurity单点登录与自动登录机制的实现原理》本文探讨SpringSecurity实现单点登录(SSO)与自动登录机制,涵盖JWT跨系统认证、RememberMe持久化Token... 目录一、核心概念解析1.1 单点登录(SSO)1.2 自动登录(Remember Me)二、代码分析三、

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

Spring Boot 中的默认异常处理机制及执行流程

《SpringBoot中的默认异常处理机制及执行流程》SpringBoot内置BasicErrorController,自动处理异常并生成HTML/JSON响应,支持自定义错误路径、配置及扩展,如... 目录Spring Boot 异常处理机制详解默认错误页面功能自动异常转换机制错误属性配置选项默认错误处理

Java中的xxl-job调度器线程池工作机制

《Java中的xxl-job调度器线程池工作机制》xxl-job通过快慢线程池分离短时与长时任务,动态降级超时任务至慢池,结合异步触发和资源隔离机制,提升高频调度的性能与稳定性,支撑高并发场景下的可靠... 目录⚙️ 一、调度器线程池的核心设计 二、线程池的工作流程 三、线程池配置参数与优化 四、总结:线程

Android ClassLoader加载机制详解

《AndroidClassLoader加载机制详解》Android的ClassLoader负责加载.dex文件,基于双亲委派模型,支持热修复和插件化,需注意类冲突、内存泄漏和兼容性问题,本文给大家介... 目录一、ClassLoader概述1.1 类加载的基本概念1.2 android与Java Class