当前位置: 技术问答>linux和unix
由异步通知引起的问题!
来源: 互联网 发布时间:2016-05-14
本文导语: 大家好,本人想实现异步通知的程序,就是当在用户空间往内核空间里写的时候希望可以触发信号, 从而触发用户空间的对应信号处理函数的执行。其中主要程序如下: 用户空间的测试函数如下: void write_to_file_tes...
大家好,本人想实现异步通知的程序,就是当在用户空间往内核空间里写的时候希望可以触发信号,
从而触发用户空间的对应信号处理函数的执行。其中主要程序如下:
用户空间的测试函数如下:
void write_to_file_test(void)
{
printf("get data!n");
}
int main()
{
signal(SIGIO,write_to_file_test);
fcntl(fd,F_SETOWN,getpid());
oflags = fcntl(fd,F_GETFL);
fcntl(fd,F_SETFL,oflags|FASYNC);
char *inin = "hello";
sleep(5);
write(fd,inin,5);
printf("write after!n");
return 0;
}
内核空间主要结构体:
struct globalfifo_dev{
//struct cdev cdev; /*cdev结构体(注释掉了,不然的话会出现has incomplete type的错误)*/
WORD current_len; /*fifo有效数据长度*/
BYTE mem[GLOBALFIFO_SIZE]; /*全局内存*/
struct semaphore sem; /*并发控制用的信号量*/
wait_queue_head_t r_wait; /*阻塞读用的等待队列头*/
wait_queue_head_t w_wait; /*阻塞写用的等待队列头*/
struct fasync_struct *async_queue;/*异步结构体指针,用于读 */
};
内核空间驱动程序中的uspi_write函数主要实现:
static ssize_t uspi_write(struct file *fp, const char *buf, size_t count, loff_t *off)
{
struct globalfifo_dev *dev = fp->private_data;/*获得设备结构体指针*/
int rest;
DECLARE_WAITQUEUE(wait,current);/* 定义等待队列 */
down(&dev->sem);/* 获得信号量(执行到这儿出现下面提示的错误) */
add_wait_queue(&dev->w_wait, &wait);/* 进入写等待队列头 */
if (fp->f_flags &O_NONBLOCK)
{
rest = - EAGAIN;
goto out;
}
__set_current_state(TASK_INTERRUPTIBLE); //改变进程状态为睡眠
up(&dev->sem);
schedule(); //调度其他进程执行
if (signal_pending(current)) //如果是因为信号唤醒
{
rest = - ERESTARTSYS;
goto out2;
}
down(&dev->sem); /* 获得信号量 */
char *get_buf;
get_buf = SRAMalloc(30);
if (copy_from_user(get_buf,buf,10))
{
printk("errohahah!n");
rest = -EFAULT;
goto out;
}else
{
printk("get_buf =%sn",get_buf);
SRAMfree(get_buf);
wake_up_interruptible(&dev->w_wait); /* 唤醒等待队列 */
/* 产生异步读信号 */
if(dev->async_queue)
kill_fasync(&dev->async_queue,SIGIO,POLL_OUT);
rest = 1;
}
out: up(&dev->sem); //释放信号量
out2:remove_wait_queue(&dev->w_wait, &wait); //从附属的等待队列头移除
set_current_state(TASK_RUNNING);
return sizeof(int);
}
内核空间驱动程序中的uspi_fasync函数主要实现:
static int uspi_fasync(int fd,struct file *filp,int mode)
{
struct globalfifo_dev *dev = filp->private_data;
return fasync_helper(fd,filp,mode,&dev->async_queue);
}
内核空间驱动程序中的uspi_release函数主要实现:
static int uspi_release(struct inode *inode, struct file *fp)
{
/* 将文件从异步通知表中删除 */
struct globalfifo_dev *dev1 = fp->private_data;
globalfifo_fasync(-1,fp,0);
return 0;
}
编译后没有错误,可是在运行后却出现如下错误:
Call Trace:
[] fasync_helper+0x7c/0x198
[] uspi_release+0x6c/0x80 [zigbeerfd]
[] __fput+0xb4/0x280
[] filp_close+0x6c/0xb0
[] put_files_struct+0x1f8/0x260
[] do_exit+0x194/0x92c
[] do_group_exit+0x3c/0xe8
[] get_signal_to_deliver+0x370/0x5e4
[] do_notify_resume+0x90/0x460
[] work_notifysig+0xc/0x14
以上的源程序我基本是按书上抄的啊,怎么会出现错误呢?
请各位指点一二,谢谢!
从而触发用户空间的对应信号处理函数的执行。其中主要程序如下:
用户空间的测试函数如下:
void write_to_file_test(void)
{
printf("get data!n");
}
int main()
{
signal(SIGIO,write_to_file_test);
fcntl(fd,F_SETOWN,getpid());
oflags = fcntl(fd,F_GETFL);
fcntl(fd,F_SETFL,oflags|FASYNC);
char *inin = "hello";
sleep(5);
write(fd,inin,5);
printf("write after!n");
return 0;
}
内核空间主要结构体:
struct globalfifo_dev{
//struct cdev cdev; /*cdev结构体(注释掉了,不然的话会出现has incomplete type的错误)*/
WORD current_len; /*fifo有效数据长度*/
BYTE mem[GLOBALFIFO_SIZE]; /*全局内存*/
struct semaphore sem; /*并发控制用的信号量*/
wait_queue_head_t r_wait; /*阻塞读用的等待队列头*/
wait_queue_head_t w_wait; /*阻塞写用的等待队列头*/
struct fasync_struct *async_queue;/*异步结构体指针,用于读 */
};
内核空间驱动程序中的uspi_write函数主要实现:
static ssize_t uspi_write(struct file *fp, const char *buf, size_t count, loff_t *off)
{
struct globalfifo_dev *dev = fp->private_data;/*获得设备结构体指针*/
int rest;
DECLARE_WAITQUEUE(wait,current);/* 定义等待队列 */
down(&dev->sem);/* 获得信号量(执行到这儿出现下面提示的错误) */
add_wait_queue(&dev->w_wait, &wait);/* 进入写等待队列头 */
if (fp->f_flags &O_NONBLOCK)
{
rest = - EAGAIN;
goto out;
}
__set_current_state(TASK_INTERRUPTIBLE); //改变进程状态为睡眠
up(&dev->sem);
schedule(); //调度其他进程执行
if (signal_pending(current)) //如果是因为信号唤醒
{
rest = - ERESTARTSYS;
goto out2;
}
down(&dev->sem); /* 获得信号量 */
char *get_buf;
get_buf = SRAMalloc(30);
if (copy_from_user(get_buf,buf,10))
{
printk("errohahah!n");
rest = -EFAULT;
goto out;
}else
{
printk("get_buf =%sn",get_buf);
SRAMfree(get_buf);
wake_up_interruptible(&dev->w_wait); /* 唤醒等待队列 */
/* 产生异步读信号 */
if(dev->async_queue)
kill_fasync(&dev->async_queue,SIGIO,POLL_OUT);
rest = 1;
}
out: up(&dev->sem); //释放信号量
out2:remove_wait_queue(&dev->w_wait, &wait); //从附属的等待队列头移除
set_current_state(TASK_RUNNING);
return sizeof(int);
}
内核空间驱动程序中的uspi_fasync函数主要实现:
static int uspi_fasync(int fd,struct file *filp,int mode)
{
struct globalfifo_dev *dev = filp->private_data;
return fasync_helper(fd,filp,mode,&dev->async_queue);
}
内核空间驱动程序中的uspi_release函数主要实现:
static int uspi_release(struct inode *inode, struct file *fp)
{
/* 将文件从异步通知表中删除 */
struct globalfifo_dev *dev1 = fp->private_data;
globalfifo_fasync(-1,fp,0);
return 0;
}
编译后没有错误,可是在运行后却出现如下错误:
Call Trace:
[] fasync_helper+0x7c/0x198
[] uspi_release+0x6c/0x80 [zigbeerfd]
[] __fput+0xb4/0x280
[] filp_close+0x6c/0xb0
[] put_files_struct+0x1f8/0x260
[] do_exit+0x194/0x92c
[] do_group_exit+0x3c/0xe8
[] get_signal_to_deliver+0x370/0x5e4
[] do_notify_resume+0x90/0x460
[] work_notifysig+0xc/0x14
以上的源程序我基本是按书上抄的啊,怎么会出现错误呢?
请各位指点一二,谢谢!
|
我想问一下,你的驱动函数里面,驱动加载的函数在哪里呢?
对 struct globalfifo_dev 结构的变量初始化在哪里?
如果是你上面的一个“down(&dev->sem);/* 获得信号量(执行到这儿出现下面提示的错误) */ ”
那其中有可能就是你没对信号量进行初始化,所以你应该没有对 struct globalfifo_dev 结构的变量进行初始化。
对 struct globalfifo_dev 结构的变量初始化在哪里?
如果是你上面的一个“down(&dev->sem);/* 获得信号量(执行到这儿出现下面提示的错误) */ ”
那其中有可能就是你没对信号量进行初始化,所以你应该没有对 struct globalfifo_dev 结构的变量进行初始化。
|
write(fd,inin,5);
static ssize_t uspi_write(struct file *fp, const char *buf, size_t count, loff_t *off)
有个概念错误:
内核空间的uspi_write是对应于用户空间的read函数的。
所以你应该调用read系统调用,而不是write。
static ssize_t uspi_write(struct file *fp, const char *buf, size_t count, loff_t *off)
有个概念错误:
内核空间的uspi_write是对应于用户空间的read函数的。
所以你应该调用read系统调用,而不是write。
|
帮顶!
|
友情up