OpenEdv-开源电子网

 找回密码
 立即注册
正点原子全套STM32/Linux/FPGA开发资料,上千讲STM32视频教程免费下载...
查看: 6370|回复: 0
打印 上一主题 下一主题

【正点原子Linux连载】第五十二章Linux阻塞和非阻塞IO实验--摘自【正点原子】I.MX6U嵌入式Linux驱动开发指南V1.0

[复制链接]

1212

主题

1226

帖子

2

精华

超级版主

Rank: 8Rank: 8

积分
5221
金钱
5221
注册时间
2019-5-8
在线时间
1316 小时
跳转到指定楼层
楼主
发表于 2020-2-28 10:57:59 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式
1)实验平台:正点原子阿尔法Linux开发板
2)平台购买地址::https://item.taobao.com/item.htm?id=603672744434
2)全套实验源码+手册+视频下载地址:http://www.openedv.com/thread-300792-1-1.html
3)本章实例源码下载: Linux阻塞和非阻塞IO实验.zip (15.8 KB, 下载次数: 1)
4)对正点原子Linux感兴趣的同学可以加群讨论:935446741
5)关注正点原子公众号,获取最新资料更新

第五十二章Linux阻塞和非阻塞IO实验
       阻塞和非阻塞IOLinux驱动开发里面很常见的两种设备访问模式,在编写驱动的时候一定要考虑到阻塞和非阻塞。本章我们就来学习一下阻塞和非阻塞IO,以及如何在驱动程序中处理阻塞与非阻塞,如何在驱动程序使用等待队列和poll机制。

52.1 阻塞和非阻塞IO52.1.1 阻塞和非阻塞简介
       这里的“IO”并不是我们学习STM32或者其他单片机的时候所说的“GPIO(也就是引脚)。这里的IO指的是Input/Output,也就是输入/输出,是应用程序对驱动设备的输入/输出操作。当应用程序对设备驱动进行操作的时候,如果不能获取到设备资源,那么阻塞式IO就会将应用程序对应的线程挂起,直到设备资源可以才做为止。对于非阻塞IO,应用程序对应的线程不会挂起,它要么一直轮询等待,直到设备资源可以使用,要么就直接放弃。阻塞式IO如图52.1.1.1所示:

52.1.1.1 阻塞IO访问示意图。
       52.1.1.1中应用程序调用read函数从设备中读取数据,当设备不可用或数据未准备好的时候就会进入到休眠态。等设备可用的时候就会从休眠态唤醒,然后从设备中读取数据返回给应用程序。非阻塞IO如图52.1.2所示:

52.1.1.2 非阻塞IO访问示意图
       从图52.1.1.2可以看出,应用程序使用非阻塞访问方式从设备读取数据,当设备不可用或数据未准备好的时候会立即向内核返回一个错误码,表示数据读取失败。应用程序会再次重新读取数据,这样一直往复循环,直到数据读取成功。
       应用程序可以使用如下所示示例代码来实现阻塞访问:
示例代码52.1.1.1 应用程序阻塞读取数据
  1. int fd;
  2. int data =0;

  3. fd = open("/dev/xxx_dev", O_RDWR);      /* 阻塞方式打开  */
  4. ret = read(fd,&data,sizeof(data));   /* 读取数据     */
复制代码
       从示例代码52.1.1.1可以看出,对于设备驱动文件的默认读取方式就是阻塞式的,所以我们前面所有的例程测试APP都是采用阻塞IO
       如果应用程序要采用非阻塞的方式来访问驱动设备文件,可以使用如下所示代码:
示例代码52.1.1.2 应用程序非阻塞读取数据
  1. int fd;
  2. int data =0;

  3. fd = open("/dev/xxx_dev", O_RDWR | O_NONBLOCK);    /* 非阻塞方式打开 */
  4. ret = read(fd,&data,sizeof(data));             /* 读取数据 */
复制代码
       4行使用open函数打开“/dev/xxx-_dev”设备文件的时候添加了参数“O_NONBLOCK”,表示以非阻塞方式打开设备,这样从设备中读取数据的时候就是非阻塞方式的了。
52.1.2 等待队列
       1、等待队列头
       阻塞访问最大的好处就是当设备文件不可操作的时候进程可以进入休眠态,这样可以将CPU资源让出来。但是,当设备文件可以操作的时候就必须唤醒进程,一般在中断函数里面完成唤醒工作。Linux内核提供了等待队列(waitqueue)来实现阻塞进程的唤醒工作,如果我们要在驱动中使用等待队列,必须创建并初始化一个等待队列头,等待队列头使用结构体wait_queue_head_t表示,wait_queue_head_t结构体定义在文件include/linux/wait.h中,结构体内容如下所示:
示例代码52.1.2.1wait_queue_head_t结构体
  1. struct __wait_queue_head {
  2.   spinlock_t      lock;
  3. struct list_head   task_list;
  4. };
  5. typedefstruct __wait_queue_head wait_queue_head_t;
复制代码
       定义好等待队列头以后需要初始化,使数init_waitqueue_head函数初始化等待队列头,函数原型如下:
  1. void init_waitqueue_head(wait_queue_head_t *q)
复制代码
       参数q就是要初始化的等待队列头。
       也可以使用宏DECLARE_WAIT_QUEUE_HEAD来一次性完成等待队列头的定义的初始化。
2、等待队列项
       等待队列头就是一个等待队列的头部,每个访问设备的进程都是一个队列项,当设备不可用的时候就要将这些进程对应的等待队列项添加到等待队列里面。结构体wait_queue_t表示等待队列项,结构体内容如下:
示例代码52.1.2.2 wait_queue_t 结构体
  1. struct __wait_queue {
  2. unsignedint   flags;
  3. void       *private;
  4.    wait_queue_func_t     func;
  5. struct list_head      task_list;
  6. };
  7. typedefstruct __wait_queue wait_queue_t;
复制代码
       使用宏DECLARE_WAITQUEUE定义并初始化一个等待队列项,宏的内容如下:
  1. DECLARE_WAITQUEUE(name, tsk)
复制代码
       name就是等待队列项的名字,tsk表示这个等待队列项属于哪个任务(进程),一般设置为current,在Linux内核中current相当于一个全局变量,表示当前进程。因此宏DECLARE_WAITQUEUE就是给当前正在运行的进程创建并初始化了一个等待队列项。
       3、将队列项添加/移除等待队列头
       当设备不可访问的时候就需要将进程对应的等待队列项添加到前面创建的等待队列头中,只有添加到等待队列头中以后进程才能进入休眠态。当设备可以访问以后再将进程对应的等待队列项从等待队列头中移除即可,等待队列项添加API函数如下:
  1. void add_wait_queue(wait_queue_head_t    *q,  
  2.                               wait_queue_t            *wait)
复制代码
函数参数和返回值含义如下:
       q等待队列项要加入的等待队列头。
       wait:要加入的等待队列项。
       返回值:无。
       等待队列项移除API函数如下:
  1. void remove_wait_queue(wait_queue_head_t      *q,
  2.                                     wait_queue_t               *wait)
复制代码
函数参数和返回值含义如下:
       q要删除的等待队列项所处的等待队列头。
       wait:要删除的等待队列项。
       返回值:无。
       4、等待唤醒
       当设备可以使用的时候就要唤醒进入休眠态的进程,唤醒可以使用如下两个函数:
  1. void wake_up(wait_queue_head_t *q)
  2. void wake_up_interruptible(wait_queue_head_t *q)
复制代码
       参数q就是要唤醒的等待队列头,这两个函数会将这个等待队列头中的所有进程都唤醒。wake_up函数可以唤醒处于TASK_INTERRUPTIBLETASK_UNINTERRUPTIBLE状态的进程,而wake_up_interruptible函数只能唤醒处于TASK_INTERRUPTIBLE状态的进程。
       5、等待事件
       除了主动唤醒以外,也可以设置等待队列等待某个事件,当这个事件满足以后就自动唤醒等待队列中的进程,和等待事件有关的API函数如表52.1.2.1所示:
表52.1.2.1 等待事件API函数
52.1.3 轮询
       如果用户应用程序以非阻塞的方式访问设备,设备驱动程序就要提供非阻塞的处理方式,也就是轮询。pollepollselect可以用于处理轮询,应用程序通过selectepollpoll函数来查询设备是否可以操作,如果可以操作的话就从设备读取或者向设备写入数据。当应用程序调用selectepollpoll函数的时候设备驱动程序中的poll函数就会执行,因此需要在设备驱动程序中编写poll函数。我们先来看一下应用程序中使用的selectpollepoll这三个函数。
       1、select函数
       select函数原型如下:
  1. int select(int                  nfds,
  2.               fd_set            *readfds,
  3.               fd_set            *writefds,
  4.                      fd_set             *exceptfds,
  5.                      struct timeval  *timeout)
复制代码
函数参数和返回值含义如下:
       nfds要操作的文件描述符个数。
       readfds、writefds和exceptfds:这三个指针指向描述符集合,这三个参数指明了关心哪些描述符、需要满足哪些条件等等,这三个参数都是fd_set类型的,fd_set类型变量的每一个位都代表了一个文件描述符。readfds用于监视指定描述符集的读变化,也就是监视这些文件是否可以读取,只要这些集合里面有一个文件可以读取那么seclect就会返回一个大于0的值表示文件可以读取。如果没有文件可以读取,那么就会根据timeout参数来判断是否超时。可以将readfs设置为NULL,表示不关心任何文件的读变化。writefds和readfs类似,只是writefs用于监视这些文件是否可以进行写操作。exceptfds用于监视这些文件的异常。
比如我们现在要从一个设备文件中读取数据,那么就可以定义一个fd_set变量,这个变量要传递给参数readfds。当我们定义好一个fd_set变量以后可以使用如下所示几个宏进行操作:
  1. void FD_ZERO(fd_set *set)
  2. void FD_SET(int fd, fd_set *set)
  3. void FD_CLR(int fd, fd_set *set)
  4. int FD_ISSET(int fd, fd_set *set)
复制代码
       FD_ZERO用于将fd_set变量的所有位都清零,FD_SET用于将fd_set变量的某个位置1,也就是向fd_set添加一个文件描述符,参数fd就是要加入的文件描述符。FD_CLR用户将fd_set变量的某个位清零,也就是将一个文件描述符从fd_set中删除,参数fd就是要删除的文件描述符。FD_ISSET用于测试fd_set的某个位是否置1,也就是判断某个文件是否可以进行操作,参数fd就是要判断的文件描述符。
       timeout:超时时间,当我们调用select函数等待某些文件描述符可以设置超时时间,超时时间使用结构体timeval表示,结构体定义如下所示:
  1. struct timeval {
  2.               long     tv_sec;          /* 秒         */
  3.               long     tv_usec;         /* 微妙      */   
  4. };
复制代码
       当timeout为NULL的时候就表示无限期的等待。
返回值:0,表示的话就表示超时发生,但是没有任何文件描述符可以进行操作;-1,发生错误;其他值,可以进行操作的文件描述符个数。
使用select函数对某个设备驱动文件进行读非阻塞访问的操作示例如下所示:
示例代码52.1.3.1 select函数非阻塞读访问示例
  1. void main(void)
  2. {
  3.    int ret, fd;  /* 要监视的文件描述符       */
  4.    fd_set readfds;   /* 读操作文件描述符集       */
  5.    struct timeval timeout;  /* 超时结构体              */

  6.    fd = open("dev_xxx", O_RDWR | O_NONBLOCK);    /* 非阻塞式访问 */

  7.    FD_ZERO(&readfds);       /* 清除readfds           */
  8.   FD_SET(fd,&readfds);     /* 将fd添加到readfds里面 */

  9.   /* 构造超时时间 */
  10.   timeout.tv_sec =0;
  11.   timeout.tv_usec =500000; /* 500ms   */

  12.   ret = select(fd +1,&readfds,NULL,NULL,&timeout);
  13.   switch(ret){
  14.   case0:            /* 超时     */
  15.      printf("timeout!\r\n");
  16.      break;
  17.   case-1:              /* 错误     */
  18.      printf("error!\r\n");
  19.      break;
  20.   default:   /* 可以读取数据 */
  21.      if(FD_ISSET(fd,&readfds)){/* 判断是否为fd文件描述符 */
  22.      /* 使用read函数读取数据 */
  23.      }
  24.      break;
  25.   }
  26. }
复制代码
2、poll函数
       在单个线程中,select函数能够监视的文件描述符数量有最大的限制,一般为1024,可以修改内核将监视的文件描述符数量改大,但是这样会降低效率!这个时候就可以使用poll函数,poll函数本质上和select没有太大的差别,但是poll函数没有最大文件描述符限制,Linux应用程序中poll函数原型如下所示:
  1. int poll(struct pollfd  *fds,
  2. nfds_t                nfds,
  3.          int                     timeout)
复制代码
函数参数和返回值含义如下:
       fds要监视的文件描述符集合以及要监视的事件,为一个数组,数组元素都是结构体pollfd类型的,pollfd结构体如下所示:
  1. struct pollfd {
  2.        int   fd;          /* 文件描述符      */
  3.        shortevents;        /* 请求的事件      */
  4.        shortrevents;      /* 返回的事件      */
  5. };
复制代码
       fd是要监视的文件描述符,如果fd无效的话那么events监视事件也就无效,并且revents返回0。events是要监视的事件,可监视的事件类型如下所示:
  1. POLLIN               有数据可以读取。
  2. POLLPRI             有紧急的数据需要读取。
  3. POLLOUT             可以写数据。
  4. POLLERR             指定的文件描述符发生错误。
  5. POLLHUP             指定的文件描述符挂起。
  6. POLLNVAL           无效的请求。
  7. POLLRDNORM     等同于POLLIN
复制代码
       revents是返回参数,也就是返回的事件,有Linux内核设置具体的返回事件。
       nfds:poll函数要监视的文件描述符数量。
       timeout超时时间,单位为ms。
       返回值:返回revents域中不为0的pollfd结构体个数,也就是发生事件或错误的文件描述符数量;0,超时;-1,发生错误,并且设置errno为错误类型。
使用poll函数对某个设备驱动文件进行读非阻塞访问的操作示例如下所示:
示例代码52.1.3.2 poll函数读非阻塞访问示例
  1. void main(void)
  2. {
  3.    int ret;
  4.    int fd;       /* 要监视的文件描述符      */
  5.    struct pollfd fds;

  6.    fd = open(filename, O_RDWR | O_NONBLOCK);/* 非阻塞式访问 */

  7.    /* 构造结构体   */
  8.      fds.fd = fd;
  9.   fds.events = POLLIN;/* 监视数据是否可以读取 */

  10.   ret = poll(&fds,1,500);  /* 轮询文件是否可操作,超时500ms */
  11.   if(ret){      /* 数据有效     */
  12.   ......
  13.   /* 读取数据 */
  14.   ......
  15.   }elseif(ret ==0){    /* 超时     */
  16.   ......
  17.   }elseif(ret <0){     /* 错误     */
  18.   ......
  19.   }
  20. }
复制代码
3、epoll函数
       传统的selcet和poll函数都会随着所监听的fd数量的增加,出现效率低下的问题,而且poll函数每次必须遍历所有的描述符来检查就绪的描述符,这个过程很浪费时间。为此,epoll因运而生,epoll就是为处理大并发而准备的,一般常常在网络编程中使用epoll函数。应用程序需要先使用epoll_create函数创建一个epoll句柄,epoll_create函数原型如下:
  1. int epoll_create(int size)
复制代码
函数参数和返回值含义如下:
       size从Linux2.6.8开始此参数已经没有意义了,随便填写一个大于0的值就可以。
       返回值:epoll句柄,如果为-1的话表示创建失败。
     epoll句柄创建成功以后使用epoll_ctl函数向其中添加要监视的文件描述符以及监视的事件,epoll_ctl函数原型如下所示:
  1. int epoll_ctl(int                           epfd,
  2.                 int                           op,
  3.                 int                            fd,
  4.                 struct epoll_event       *event)
复制代码
函数参数和返回值含义如下:
       epfd要操作的epoll句柄,也就是使用epoll_create函数创建的epoll句柄。
       op表示要对epfd(epoll句柄)进行的操作,可以设置为:
  1. EPOLL_CTL_ADD       向epfd添加文件参数fd表示的描述符。
  2. EPOLL_CTL_MOD       修改参数fd的event事件。
  3. EPOLL_CTL_DEL        从epfd中删除fd描述符。
复制代码
       fd:要监视的文件描述符。
       event要监视的事件类型,为epoll_event结构体类型指针,epoll_event结构体类型如下所示:
  1. struct epoll_event {
  2.        uint32_t      events;         /* epoll事件          */
  3.        epoll_data_t  data;           /*用户数据          */
  4. };
复制代码
       结构体epoll_event的events成员变量表示要监视的事件,可选的事件如下所示:
  1. EPOLLIN              有数据可以读取。
  2. EPOLLOUT          可以写数据。
  3. EPOLLPRI    有紧急的数据需要读取。
  4. EPOLLERR    指定的文件描述符发生错误。
  5. EPOLLHUP   指定的文件描述符挂起。
  6. EPOLLET      设置epoll为边沿触发,默认触发模式为水平触发。
  7. EPOLLONESHOT 一次性的监视,当监视完成以后还需要再次监视某个fd,那么就需要将fd重新添加到epoll里面。
复制代码
       上面这些事件可以进行“或”操作,也就是说可以设置监视多个事件。
       返回值:0,成功;-1,失败,并且设置errno的值为相应的错误码。
       一切都设置好以后应用程序就可以通过epoll_wait函数来等待事件的发生,类似select函数。epoll_wait函数原型如下所示:
  1. int epoll_wait(int                         epfd,
  2.                      structepoll_event  *events,
  3.                      int                        maxevents,
  4.                      int                        timeout)
复制代码
函数参数和返回值含义如下:
       epfd要等待的epoll。
       events指向epoll_event结构体的数组,当有事件发生的时候Linux内核会填写events,调用者可以根据events判断发生了哪些事件。
       maxevents:events数组大小,必须大于0。
       timeout超时时间,单位为ms。
       返回值:0,超时;-1,错误;其他值,准备就绪的文件描述符数量。
       epoll更多的是用在大规模的并发服务器上,因为在这种场合下select和poll并不适合。当设计到的文件描述符(fd)比较少的时候就适合用selcet和poll,本章我们就使用sellect和poll这两个函数。
52.1.4 Linux驱动下的poll操作函数
       当应用程序调用select或poll函数来对驱动程序进行非阻塞访问的时候,驱动程序file_operations操作集中的poll函数就会执行。所以驱动程序的编写者需要提供驱对应的poll函数,poll函数原型如下所示:
  1. unsigned int (*poll) (struct file *filp, structpoll_table_struct *wait)
复制代码
函数参数和返回值含义如下:
       filp要打开的设备文件(文件描述符)。
       wait结构体poll_table_struct类型指针,又应用程序传递进来的。一般将此参数传递给poll_wait函数。
       返回值:向应用程序返回设备或者资源状态,可以返回的资源状态如下:
  1. POLLIN               有数据可以读取。
  2. POLLPRI             有紧急的数据需要读取。
  3. POLLOUT             可以写数据。
  4. POLLERR             指定的文件描述符发生错误。
  5. POLLHUP             指定的文件描述符挂起。
  6. POLLNVAL           无效的请求。
  7. POLLRDNORM     等同于POLLIN,普通数据可读
复制代码
       我们需要在驱动程序的poll函数中调用poll_wait函数,poll_wait函数不会引起阻塞,只是将应用程序添加到poll_table中,poll_wait函数原型如下:
  1. void poll_wait(struct file * filp,wait_queue_head_t * wait_address, poll_table *p)
复制代码
       参数wait_address是要添加到poll_table中的等待队列头,参数p就是poll_table,就是file_operations中poll函数的wait参数。
52.2 阻塞IO实验
       在上一章Linux中断实验中,我们直接在应用程序中通过read函数不断的读取按键状态,当按键有效的时候就打印出按键值。这种方法有个缺点,那就是imx6uirqApp这个测试应用程序拥有很高的CPU占用率,大家可以在开发板中加载上一章的驱动程序模块imx6uirq.ko,然后以后台运行模式打开imx6uirqApp这个测试软件,命令如下:
  1. ./imx6uirqApp /dev/imx6uirq &
复制代码
       测试驱动是否正常工作,如果驱动工作正常的话输入“top”命令查看imx6uirqApp这个应用程序的CPU使用率,结果如图52.2.1所示:

52.2.1 CPU使用率
       从图52.2.1可以看出,imx6uirqApp这个应用程序的CPU使用率竟然高达99.6%,这仅仅是一个读取按键值的应用程序,这么高的CPU使用率显然是有问题的!原因就在于我们是直接在while循环中通过read函数读取按键值,因此imx6uirqApp这个软件会一直运行,一直读取按键值,CPU使用率肯定就会很高。最好的方法就是在没有有效的按键事件发生的时候,imx6uirqApp这个应用程序应该处于休眠状态,当有按键事件发生以后imx6uirqApp这个应用程序才运行,打印出按键值,这样就会降低CPU使用率,本小节我们就使用阻塞IO来实现此功能。
52.2.1 硬件原理图分析
本章实验硬件原理图参考15.2小节即可。
52.2.2 实验程序编写
       1、驱动程序编写
本实验对应的例程路径为:开发板光盘->2、Linux驱动例程->14_blockio。
本章实验我们在上一章的“13_irq”实验的基础上完成,主要是对其添加阻塞访问相关的代码。新建名为“14_blockio”的文件夹,然后在14_blockio文件夹里面创建vscode工程,工作区命名为“blockio”。将“13_irq”实验中的imx6uirq.c复制到14_blockio文件夹中,并重命名为blockio.c。接下来我们就修改blockio.c这个文件,在其中添加阻塞相关的代码,完成以后的blockio.c内容如下所示(因为是在上一章实验的imx6uirq.c文件的基础上修改的,因为了减少篇幅,下面的代码有省略):
示例代码52.2.2.1 blockio.c文件代码(有省略)
  1.    #include <linux/types.h>
  2.    #include <linux/kernel.h>
  3. ......
  4.   #include <asm/mach/map.h>
  5.   #include <asm/uaccess.h>
  6.   #include <asm/io.h>
  7. /***************************************************************
  8.   Copyright ? ALIENTEK Co., Ltd. 1998-2029. Allrights reserved.
  9. 文件名       : block.c
  10. 作者 : 左忠凯
  11. 版本 : V1.0
  12. 描述 : 阻塞IO访问
  13. 其他 : 无
  14. 论坛 : www.openedv.com
  15. 日志 : 初版V1.02019/7/26 左忠凯创建
  16.   ***************************************************************/
  17.   #define IMX6UIRQ_CNT          1   /* 设备号个数       */
  18.   #define IMX6UIRQ_NAME        "blockio"/* 名字    */
  19.   #define KEY0VALUE              0X01   /* KEY0按键值  */
  20.   #define INVAKEY                0XFF   /* 无效的按键值     */
  21.   #define KEY_NUM                1   /* 按键数量     */

  22. /* 中断IO描述结构体 */
  23. struct irq_keydesc {
  24. int gpio;   /* gpio           */
  25. int irqnum; /* 中断号      */
  26. unsignedchar value;    /* 按键对应的键值   */
  27. char name[10];  /* 名字        */
  28.       irqreturn_t (*handler)(int,void*);/* 中断服务函数 */
  29. };

  30. /* imx6uirq设备结构体 */
  31. struct imx6uirq_dev{
  32.       dev_t devid;   /* 设备号                 */
  33. struct cdev cdev;  /* cdev                      */
  34. struct class *class;   /* 类                    */
  35. struct device *device; /* 设备                   */
  36. int major;  /* 主设备号               */
  37. int minor;  /* 次设备号               */
  38. struct device_node  *nd;/* 设备节点              */
  39.       atomic_t keyvalue;    /* 有效的按键键值              */
  40.       atomic_t releasekey;  /* 标记是否完成一次完成的按键 */
  41. struct timer_list timer;  /* 定义一个定时器*/
  42. struct irq_keydesc irqkeydesc[KEY_NUM]; /* 按键init述数组  */
  43. unsignedchar curkeynum;       /* 当前init按键号  */

  44.       wait_queue_head_t r_wait;/* 读等待队列头 */
  45. };

  46. struct imx6uirq_dev imx6uirq; /* irq设备 */

  47. /*@description      : 中断服务函数,开启定时器
  48.    *                     定时器用于按键消抖。
  49.    * @param - irq        : 中断号
  50.    * @param - dev_id    : 设备结构。
  51.    * @return           :中断执行结果
  52.    */
  53. static irqreturn_t key0_handler(int irq,void*dev_id)
  54. {
  55. struct imx6uirq_dev *dev =(struct imx6uirq_dev*)dev_id;

  56.       dev->curkeynum =0;
  57.       dev->timer.data =(volatilelong)dev_id;
  58.       mod_timer(&dev->timer, jiffies + msecs_to_jiffies(10));
  59. return IRQ_RETVAL(IRQ_HANDLED);
  60. }

  61. /* @description    : 定时器服务函数,用于按键消抖,定时器到了以后
  62.    *                    再次读取按键值,如果按键还是处于按下状态就表示按键有效。
  63.    * @param - arg   : 设备结构变量
  64.    * @return        : 无
  65.    */
  66. void timer_function(unsignedlong arg)
  67. {
  68. unsignedchar value;
  69. unsignedchar num;
  70. struct irq_keydesc *keydesc;
  71. struct imx6uirq_dev *dev =(struct imx6uirq_dev *)arg;

  72.       num = dev->curkeynum;
  73.       keydesc =&dev->irqkeydesc[num];

  74.       value = gpio_get_value(keydesc->gpio); /* 读取IO值    */
  75. if(value ==0){     /* 按下按键     */
  76.           atomic_set(&dev->keyvalue, keydesc->value);
  77. }
  78. else{          /* 按键松开     */
  79.          atomic_set(&dev->keyvalue,0x80| keydesc->value);
  80.          atomic_set(&dev->releasekey,1);
  81. }

  82. /* 唤醒进程 */
  83. if(atomic_read(&dev->releasekey)){/* 完成一次按键过程 */
  84. /*wake_up(&dev->r_wait); */
  85.          wake_up_interruptible(&dev->r_wait);
  86. }
  87. }

  88. /*
  89.   * @description   : 按键IO初始化
  90.   * @param         : 无
  91.   * @return        : 无
  92.   */
  93. staticint keyio_init(void)
  94. {
  95. unsignedchar i =0;
  96. char name[10];
  97. int ret =0;
  98. ...
  99. /* 创建定时器 */
  100.      init_timer(&imx6uirq.timer);
  101.      imx6uirq.timer.function = timer_function;

  102. /* 初始化等待队列头 */
  103.      init_waitqueue_head(&imx6uirq.r_wait);
  104. return0;
  105. }

  106. /*
  107.   * @description   : 打开设备
  108.   * @param – inode : 传递给驱动的inode
  109.   * @param - filp  : 设备文件,file结构体有个叫做private_data的成员变量
  110.   *                    一般在open的时候将private_data指向设备结构体。
  111.   * @return         :0 成功;其他失败
  112.   */
  113. staticint imx6uirq_open(struct inode *inode,struct file *filp)
  114. {
  115.      filp->private_data =&imx6uirq;  /* 设置私有数据 */
  116. return0;
  117. }

  118. /*
  119.    * @description      : 从设备读取数据
  120.    * @param - filp     : 要打开的设备文件(文件描述符)
  121.    * @param - buf       : 返回给用户空间的数据缓冲区
  122.    * @param - cnt       : 要读取的数据长度
  123.    * @param - offt     : 相对于文件首地址的偏移
  124.    * @return             :读取的字节数,如果为负值,表示读取失败
  125.    */
  126. static ssize_t imx6uirq_read(struct file *filp,char __user *buf,
  127. size_t cnt, loff_t *offt)
  128. {
  129. int ret =0;
  130. unsignedchar keyvalue =0;
  131. unsignedchar releasekey =0;
  132. struct imx6uirq_dev *dev =(struct imx6uirq_dev *)
  133. filp->private_data;

  134. #if0
  135. /* 加入等待队列,等待被唤醒,也就是有按键按下 */
  136.      ret = wait_event_interruptible(dev->r_wait,
  137. atomic_read(&dev->releasekey));
  138. if(ret){
  139. goto wait_error;
  140. }
  141. #endif

  142.      DECLARE_WAITQUEUE(wait, current);/* 定义一个等待队列 */
  143. if(atomic_read(&dev->releasekey)==0){/* 没有按键按下 */
  144.          add_wait_queue(&dev->r_wait,&wait);/*添加到等待队列头 */
  145.          __set_current_state(TASK_INTERRUPTIBLE);/* 设置任务状态 */
  146.          schedule();/* 进行一次任务切换 */
  147. if(signal_pending(current)){/* 判断是否为信号引起的唤醒 */
  148.              ret =-ERESTARTSYS;
  149. goto wait_error;
  150. }
  151. }
  152.      remove_wait_queue(&dev->r_wait,&wait);/* 唤醒以后将等待队列移除 */

  153.      keyvalue = atomic_read(&dev->keyvalue);
  154.      releasekey = atomic_read(&dev->releasekey);
  155. ......
  156. return0;

  157. wait_error:
  158.      set_current_state(TASK_RUNNING);/* 设置任务为运行态 */
  159.      remove_wait_queue(&dev->r_wait,&wait);/* 将等待队列移除  */
  160. return ret;

  161. data_error:
  162. return-EINVAL;
  163. }

  164. /* 设备操作函数 */
  165. staticstruct file_operations imx6uirq_fops ={
  166. .owner = THIS_MODULE,
  167. .open = imx6uirq_open,
  168. .read = imx6uirq_read,
  169. };

  170. /*
  171.   * @description   : 驱动入口函数
  172.   * @param         : 无
  173.   * @return        : 无
  174.   */
  175. staticint __init imx6uirq_init(void)
  176. {
  177. /* 1、构建设备号 */
  178. if(imx6uirq.major){
  179.          imx6uirq.devid = MKDEV(imx6uirq.major,0);
  180.          register_chrdev_region(imx6uirq.devid, IMX6UIRQ_CNT,
  181. IMX6UIRQ_NAME);
  182. }else{
  183.          alloc_chrdev_region(&imx6uirq.devid,0, IMX6UIRQ_CNT,
  184. IMX6UIRQ_NAME);
  185.          imx6uirq.major = MAJOR(imx6uirq.devid);
  186.          imx6uirq.minor = MINOR(imx6uirq.devid);
  187. }
  188. ......

  189. /* 5、始化按键 */
  190.      atomic_set(&imx6uirq.keyvalue, INVAKEY);
  191.      atomic_set(&imx6uirq.releasekey,0);
  192.      keyio_init();
  193. return0;
  194. }

  195. /*
  196.   * @description   : 驱动出口函数
  197.   * @param         : 无
  198.   * @return        : 无
  199.   */
  200. staticvoid __exit imx6uirq_exit(void)
  201. {
  202. unsigned i =0;
  203. /* 删除定时器 */
  204.      del_timer_sync(&imx6uirq.timer);/* 删除定时器 */
  205. ......
  206.      class_destroy(imx6uirq.class);
  207. }

  208. module_init(imx6uirq_init);
  209. module_exit(imx6uirq_exit);
  210. MODULE_LICENSE("GPL");
复制代码
第32行,修改设备文件名字为“blockio”,当驱动程序加载成功以后就会在根文件系统中出现一个名为“/dev/blockio”的文件。
第61行,在设备结构体中添加一个等待队列头r_wait,因为在Linux驱动中处理阻塞IO需要用到等待队列。
       第107~110行,定时器中断处理函数执行,表示有按键按下,先在107行判断一下是否是一次有效的按键,如果是的话就通过wake_up或者wake_up_interruptible函数来唤醒等待队列r_wait。
       第168行,调用init_waitqueue_head函数初始化等待队列头r_wait。
第200~206行,采用等待事件来处理read的阻塞访问,wait_event_interruptible函数等待releasekey有效,也就是有按键按下。如果按键没有按下的话进程就会进入休眠状态,因为采用了wait_event_interruptible函数,因此进入休眠态的进程可以被信号打断。
       第208~218行,首先使用 DECLARE_WAITQUEUE宏定义一个等待队列,如果没有按键按下的话就使用add_wait_queue函数将当前任务的等待队列添加到等待队列头r_wait中。随后调用__set_current_state函数设置当前进程的状态为TASK_INTERRUPTIBLE,也就是可以被信号打断。接下来调用schedule函数进行一次任务切换,当前进程就会进入到休眠态。如果有按键按下,那么进入休眠态的进程就会唤醒,然后接着从休眠点开始运行。在这里也就是从第213行开始运行,首先通过signal_pending函数判断一下进程是不是由信号唤醒的,如果是由信号唤醒的话就直接返回-ERESTARTSYS这个错误码。如果不是由信号唤醒的(也就是被按键唤醒的)那么就在218行调用remove_wait_queue函数将进程从等待队列中删除。
使用等待队列实现阻塞访问重点注意两点:
①、将任务或者进程加入到等待队列头,
②、在合适的点唤醒等待队列,一般都是中断处理函数里面。
2、编写测试APP
本节实验的测试APP直接使用第51.3.3小节所编写的imx6uirqApp.c,将imx6uirqApp.c复制到本节实验文件夹下,并且重命名为blockioApp.c,不需要修改任何内容。
52.2.3 运行测试
1、编译驱动程序和测试APP
       、编译驱动程序
       编写Makefile文件,本章实验的Makefile文件和第四十章实验基本一样,只是将obj-m变量的值改为blockio.oMakefile内容如下所示:
示例代码52.2.3.1 Makefile文件
  1.   KERNELDIR:=/home/zuozhongkai/linux/IMX6ULL/linux/temp/linux-imx-rel_imx_4.1.15_2.1.0_ga_alientek
  2. ......
  3.   obj-m := blockio.o
  4. ......
  5. clean:
  6. $(MAKE) -C $(KERNELDIR) M=$(CURRENT_PATH) clean
复制代码
    第4行,设置obj-m变量的值为blockio.o。
       输入如下命令编译出驱动模块文件:
  1. make-j32
复制代码
       编译成功以后就会生成一个名为“blockio.ko”的驱动模块文件。
       、编译测试APP
       输入如下命令编译测试noblockioApp.c这个测试程序:
  1. arm-linux-gnueabihf-gcc blockioApp.c -o blockioApp
复制代码
       编译成功以后就会生成blcokioApp这个应用程序。
2、运行测试
将上一小节编译出来blockio.ko和blockioApp这两个文件拷贝到rootfs/lib/modules/4.1.15目录中,重启开发板,进入到目录lib/modules/4.1.15中,输入如下命令加载blockio.ko驱动模块:
  1. depmod                        //第一次加载驱动的时候需要运行此命令
  2. modprobe blockio.ko     //加载驱动
复制代码
       驱动加载成功以后使用如下命令打开blockioApp这个测试APP,并且以后台模式运行:
  1. ./blockioApp /dev/blockio &
复制代码
       按下开发板上的KEY0按键,结果如图52.2.3.1所示:

图52.2.3.1 测试APP运行测试
       当按下KEY0按键以后blockioApp这个测试APP就会打印出按键值。输入“top”命令,查看blockioAPP这个应用APP的CPU使用率,如图52.2.3.2所示:

图52.2.3.2 应用程序CPU使用率
       从图52.2.3.2可以看出,当我们在按键驱动程序里面加入阻塞访问以后,blockioApp这个应用程序的CPU使用率从图52.2.1中的99.6%降低到了0.0%。大家注意,这里的0.0%并不是说blockioApp这个应用程序不使用CPU了,只是因为使用率太小了,CPU使用率可能为0.00001%,但是图52.2.3.2只能显示出小数点后一位,因此就显示成了0.0%。
       我们可以使用“kill”命令关闭后台运行的应用程序,比如我们关闭掉blockioApp这个后台运行的应用程序。首先输出“Ctrl+C”关闭top命令界面,进入到命令行模式。然后使用“ps”命令查看一下blockioApp这个应用程序的PID,如图52.2.3.3所示:

图52.2.3.3 当前系统所有进程的ID
       从图图52.2.3.3可以看出,blockioApp这个应用程序的PID为149,使用“kill-9PID”即可“杀死”指定PID的进程,比如我们现在要“杀死”PID为149的blockioApp应用程序,可是使用如下命令:
  1. kill-9 149
复制代码
       输入上述命令以后终端显示如图52.2.3.4所示:

图52.2.3.4 kill命令输出结果
       从图52.2.3.4可以看出,“./blockioApp /dev/blockio”这个应用程序已经被“杀掉”了,在此输入“ps”命令查看当前系统运行的进程,会发现blockioApp已经不见了。这个就是使用kill命令“杀掉”指定进程的方法。
52.3 非阻塞IO实验52.3.1 硬件原理图分析
本章实验硬件原理图参考15.2小节即可。
52.3.2 实验程序编写
       1、驱动程序编写
本实验对应的例程路径为:开发板光盘->2、Linux驱动例程->15_noblockio。
本章实验我们在52.2小节中的“14_blockio”实验的基础上完成,上一小节实验我们已经在驱动中添加了阻塞IO的代码,本小节我们继续完善驱动,加入非阻塞IO驱动代码。新建名为“15_noblockio”的文件夹,然后在15_noblockio文件夹里面创建vscode工程,工作区命名为“noblockio”。将“14_blockio”实验中的blockio.c复制到15_noblockio文件夹中,并重命名为noblockio.c。接下来我们就修改noblockio.c这个文件,在其中添加非阻塞相关的代码,完成以后的noblockio.c内容如下所示(因为是在上一小节实验的blockio.c文件的基础上修改的,因为了减少篇幅,下面的代码有省略):
示例代码52.3.3.1 noblockio.c文件(有省略)
  1.    #include <linux/types.h>
  2.    #include <linux/kernel.h>
  3. ......
  4.   #include <linux/wait.h>
  5.   #include <linux/poll.h>
  6.   #include <asm/mach/map.h>
  7.   #include <asm/uaccess.h>
  8.   #include <asm/io.h>
  9. /***************************************************************
  10.   Copyright ? ALIENTEK Co., Ltd. 1998-2029. Allrights reserved.
  11. 文件名       : noblock.c
  12. 作者 : 左忠凯
  13. 版本 : V1.0
  14. 描述 : 非阻塞IO访问
  15. 其他 : 无
  16. 论坛 : www.openedv.com
  17. 日志 : 初版V1.02019/7/26 左忠凯创建
  18. ***************************************************************/
  19.   #define IMX6UIRQ_CNT          1      /* 设备号个数       */
  20.   #define IMX6UIRQ_NAME        "noblockio"/* 名字    */
  21. ......
  22. /*
  23.    * @description      : 从设备读取数据
  24.    * @param - filp     : 要打开的设备文件(文件描述符)
  25.    * @param - buf       : 返回给用户空间的数据缓冲区
  26.    * @param - cnt       : 要读取的数据长度
  27.    * @param - offt     : 相对于文件首地址的偏移
  28.    * @return             :读取的字节数,如果为负值,表示读取失败
  29.    */
  30. static ssize_t imx6uirq_read(struct file *filp,char __user *buf,
  31. size_t cnt, loff_t *offt)
  32. {
  33. int ret =0;
  34. unsignedchar keyvalue =0;
  35. unsignedchar releasekey =0;
  36. struct imx6uirq_dev *dev =(struct imx6uirq_dev *)
  37. filp->private_data;

  38. if(filp->f_flags & O_NONBLOCK){/* 非阻塞访问  */
  39. if(atomic_read(&dev->releasekey)==0)/* 没有按键按下*/
  40. return-EAGAIN;
  41. }else{            /* 阻塞访问     */
  42. /* 加入等待队列,等待被唤醒,也就是有按键按下 */
  43.          ret = wait_event_interruptible(dev->r_wait,
  44. atomic_read(&dev->releasekey));
  45. if(ret){
  46. goto wait_error;
  47. }
  48. }
  49. ......
  50. wait_error:
  51. return ret;
  52. data_error:
  53. return-EINVAL;
  54. }

  55. /*
  56.    * @description      :poll函数,用于处理非阻塞访问
  57.    * @param - filp     : 要打开的设备文件(文件描述符)
  58.    * @param - wait     : 等待列表(poll_table)
  59.    * @return             :设备或者资源状态,
  60.    */
  61. unsignedint imx6uirq_poll(struct file *filp,
  62. struct poll_table_struct *wait)
  63. {
  64. unsignedint mask =0;
  65. struct imx6uirq_dev *dev =(struct imx6uirq_dev *)
  66. p->private_data;

  67.      poll_wait(filp,&dev->r_wait, wait);

  68. if(atomic_read(&dev->releasekey)){/* 按键按下    */
  69.          mask = POLLIN | POLLRDNORM;/* 返回PLLIN  */
  70. }
  71. return mask;
  72. }

  73. /* 设备操作函数 */
  74. staticstruct file_operations imx6uirq_fops ={
  75. .owner = THIS_MODULE,
  76. .open = imx6uirq_open,
  77. .read = imx6uirq_read,
  78. .poll = imx6uirq_poll,
  79. };

  80. /*
  81.   * @description   : 驱动入口函数
  82.   * @param         : 无
  83.   * @return        : 无
  84.   */
  85. staticint __init imx6uirq_init(void)
  86. {
  87. ......
  88.      keyio_init();
  89. return0;
  90. }

  91. /*
  92.   * @description   : 驱动出口函数
  93.   * @param         : 无
  94.   * @return        : 无
  95.   */
  96. staticvoid __exit imx6uirq_exit(void)
  97. {
  98. unsigned i =0;
  99. /* 删除定时器 */
  100.      del_timer_sync(&imx6uirq.timer);/* 删除定时器 */
  101. ......
  102.      class_destroy(imx6uirq.class);
  103. }

  104. module_init(imx6uirq_init);
  105. module_exit(imx6uirq_exit);
  106. MODULE_LICENSE("GPL");
复制代码
第32行,修改设备文件名字为“noblockio”,当驱动程序加载成功以后就会在根文件系统中出现一个名为“/dev/noblockio”的文件。
第202~204行,判断是否为非阻塞式读取访问,如果是的话就判断按键是否有效,也就是判断一下有没有按键按下,如果没有的话就返回-EAGAIN。
       第241~252行,imx6uirq_poll函数就是file_operations驱动操作集中的poll函数,当应用程序调用select或者poll函数的时候imx6uirq_poll函数就会执行。第246行调用poll_wait函数将等待队列头添加到poll_table中,第248~250行判断按键是否有效,如果按键有效的话就向应用程序返回POLLIN这个事件,表示有数据可以读取。
       第259行,设置file_operations的poll成员变量为imx6uirq_poll。
2、编写测试APP
新建名为noblockioApp.c测试APP文件,然后在其中输入如下所示内容:
示例代码52.3.3.2 noblockioApp.c文件代码
  1.    #include "stdio.h"
  2.    #include "unistd.h"
  3.    #include "sys/types.h"
  4.    #include "sys/stat.h"
  5.    #include "fcntl.h"
  6.    #include "stdlib.h"
  7.    #include "string.h"
  8.    #include "poll.h"
  9.    #include "sys/select.h"
  10.   #include "sys/time.h"
  11.   #include "linux/ioctl.h"
  12. /***************************************************************
  13.   Copyright ? ALIENTEK Co., Ltd. 1998-2029. Allrights reserved.
  14. 文件名       :noblockApp.c
  15. 作者 : 左忠凯
  16. 版本 : V1.0
  17. 描述 : 非阻塞访问测试APP
  18. 其他 : 无
  19. 使用方法  :./blockApp/dev/blockio 打开测试App
  20. 论坛 : www.openedv.com
  21. 日志 : 初版V1.0 2019/9/8左忠凯创建
  22. ***************************************************************/

  23. /*
  24.    * @description       :main主程序
  25.    * @param - argc      :argv数组元素个数
  26.    * @param - argv      : 具体参数
  27.    * @return           :0 成功;其他失败
  28.    */
  29. int main(int argc,char*argv[])
  30. {
  31. int fd;
  32. int ret =0;
  33. char*filename;
  34. struct pollfd fds;
  35.       fd_set readfds;
  36. struct timeval timeout;
  37. unsignedchar data;

  38. if(argc !=2){
  39.           printf("Error Usage!\r\n");
  40. return-1;
  41. }

  42.       filename = argv[1];
  43.       fd = open(filename, O_RDWR | O_NONBLOCK);/* 非阻塞访问 */
  44. if(fd <0){
  45.           printf("Can't open file %s\r\n", filename);
  46. return-1;
  47. }

  48.   #if0
  49. /* 构造结构体 */
  50.       fds.fd = fd;
  51.       fds.events = POLLIN;

  52. while(1){
  53.           ret = poll(&fds,1,500);
  54. if(ret){/* 数据有效 */
  55.               ret = read(fd,&data,sizeof(data));
  56. if(ret <0){
  57. /* 读取错误 */
  58. }else{
  59. if(data)
  60.                       printf("key value = %d\r\n", data);
  61. }
  62. }elseif(ret ==0){  /* 超时 */
  63. /* 用户自定义超时处理 */
  64. }elseif(ret <0){   /* 错误 */
  65. /* 用户自定义错误处理 */
  66. }
  67. }
  68.   #endif

  69. while(1){
  70.           FD_ZERO(&readfds);
  71.           FD_SET(fd,&readfds);
  72. /* 构造超时时间 */
  73.           timeout.tv_sec =0;
  74.           timeout.tv_usec =500000;/* 500ms */
  75.           ret = select(fd +1,&readfds,NULL,NULL,&timeout);
  76. switch(ret){
  77. case0:/* 超时 */
  78. /* 用户自定义超时处理 */
  79. break;
  80. case-1:/* 错误 */
  81. /* 用户自定义错误处理 */
  82. break;
  83. default:/* 可以读取数据 */
  84. if(FD_ISSET(fd,&readfds)){
  85.                       ret = read(fd,&data,sizeof(data));
  86. if(ret <0){
  87. /* 读取错误 */
  88. }else{
  89. if(data)
  90.                               printf("keyvalue=%d\r\n", data);
  91. }
  92. }
  93. break;
  94. }
  95. }

  96.      close(fd);
  97. return ret;
  98. }
复制代码
    第52~73行,这段代码使用poll函数来实现非阻塞访问,在while循环中使用poll函数不断的轮询,检查驱动程序是否有数据可以读取,如果可以读取的话就调用read函数读取按键数据。
       第75~101行,这段代码使用select函数来实现非阻塞访问。
52.3.3运行测试
       1、编译驱动程序和测试APP
       、编译驱动程序
       编写Makefile文件,本章实验的Makefile文件和第四十章实验基本一样,只是将obj-m变量的值改为noblockio.oMakefile内容如下所示:
示例代码52.3.3.1 Makefile文件
  1.   KERNELDIR:=/home/zuozhongkai/linux/IMX6ULL/linux/temp/linux-imx-rel_imx_4.1.15_2.1.0_ga_alientek
  2. ......
  3.   obj-m := noblockio.o
  4. ......
  5. clean:
  6. $(MAKE) -C $(KERNELDIR) M=$(CURRENT_PATH) clean
复制代码
    第4行,设置obj-m变量的值为noblockio.o。
       输入如下命令编译出驱动模块文件:
  1. make-j32
复制代码
       编译成功以后就会生成一个名为“noblockio.ko”的驱动模块文件。
       、编译测试APP
       输入如下命令编译测试noblockioApp.c这个测试程序:
  1. arm-linux-gnueabihf-gcc noblockioApp.c -o noblockioApp
复制代码
       编译成功以后就会生成noblcokioApp这个应用程序。
2、运行测试
将上一小节编译出来noblockio.ko和noblockioApp这两个文件拷贝到rootfs/lib/modules/4.1.15目录中,重启开发板,进入到目录lib/modules/4.1.15中,输入如下命令加载blockio.ko驱动模块:
  1. depmod                        //第一次加载驱动的时候需要运行此命令
  2. modprobe noblockio.ko //加载驱动
复制代码
       驱动加载成功以后使用如下命令打开noblockioApp这个测试APP,并且以后台模式运行:
  1. ./noblockioApp /dev/noblockio &
复制代码
       按下开发板上的KEY0按键,结果如图52.3.3.1所示:

图52.3.3.1 测试APP运行测试
       当按下KEY0按键以后noblockioApp这个测试APP就会打印出按键值。输入“top”命令,查看noblockioAPP这个应用APP的CPU使用率,如图52.3.3.2所示:

图52.3.3.2 应用程序CPU使用率
       从图52.3.3.2可以看出,采用非阻塞方式读处理以后,noblockioApp的CPU占用率也低至0.0%,和图52.2.3.2中的blockioApp一样,这里的0.0%并不是说noblockioApp这个应用程序不使用CPU了,只是因为使用率太小了,而图中只能显示出小数点后一位,因此就显示成了0.0%。

       如果要“杀掉”处于后台运行模式的noblockioApp这个应用程序,可以参考52.2.3小节讲解的方法。

回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则


关闭

原子哥极力推荐上一条 /1 下一条

正点原子公众号

QQ|手机版|OpenEdv-开源电子网 ( 粤ICP备12000418号-1 )

GMT+8, 2025-12-13 17:17

Powered by OpenEdv-开源电子网

© 2001-2030 OpenEdv-开源电子网

快速回复 返回顶部 返回列表