Модуль ядра linux с потоками, которые используют переменную завершения для синхронизации своей работы - PullRequest
Новая
       4

Модуль ядра linux с потоками, которые используют переменную завершения для синхронизации своей работы

0 голосов
/ 23 апреля 2020

У меня есть программа с потоками, которые используют переменную завершения для синхронизации своей работы. И мне нужна помощь, как это сделать или какую функцию использовать, чтобы поток чтения сообщал потоку записи, что он завершил чтение. 

     #include<linux/module.h>
     #include<linux/kthread.h>
     #include<linux/wait.h>
     #include<linux/completion.h>
     #include<linux/slab.h>
     #include <linux/spinlock.h>




     enum thread_index {WAKING_THREAD, WRITER_THREAD, READER_THREAD};

     static struct thread_structure
     {
     struct task_struct *thread[3];
     } threads;

     static wait_queue_head_t wait_queue;
     static bool condition;
     static DECLARE_COMPLETION(number_completion);
     static int number;




    static int work; 


     static int writer_thread(void *data)
    {
     DEFINE_WAIT(wait);
     for(;;) {

     number++;
     complete(&number_completion);

     add_wait_queue(&wait_queue,&wait);
     while(!condition) {
     prepare_to_wait(&wait_queue,&wait,TASK_INTERRUPTIBLE);
     if(kthread_should_stop())
            return 0;
     printk(KERN_INFO "[writer_thread]: awake\n");
     schedule();
     }
     condition=false;
     finish_wait(&wait_queue,&wait);
     }
     }

     static int reader_thread(void *data)
     {

     DEFINE_WAIT(wait);
    for(;;) {


     wait_for_completion(&number_completion);



     pr_info("[reader_thread] Number value: %d\n",number);

     if(kthread_should_stop())
     return 0;
     schedule();

     }
     }

     static int waking_thread(void *data)
     {
     for(;;) {



     if(kthread_should_stop())
     return 0;
     set_current_state(TASK_INTERRUPTIBLE);
     if(schedule_timeout(1*HZ))
     printk(KERN_INFO "Signal received!\n");
     condition=true;
     wake_up(&wait_queue);
     }

     }

     static int __init threads_init(void)
     {
     init_waitqueue_head(&wait_queue);
     threads.thread[READER_THREAD] = kthread_run(reader_thread,NULL,"reader_thread");
     threads.thread[WRITER_THREAD] = kthread_run(writer_thread,NULL,"writer_thread");
     threads.thread[WAKING_THREAD] = kthread_run(waking_thread,NULL,"waking_thread");

     return 0;
     }

     static void __exit threads_exit(void)
     {

     kthread_stop(threads.thread[READER_THREAD]);
     kthread_stop(threads.thread[WAKING_THREAD]);
     kthread_stop(threads.thread[WRITER_THREAD]);

     }

     module_init(threads_init);
     module_exit(threads_exit);

     MODULE_LICENSE("GPL");
     MODULE_DESCRIPTION("kernel linux threads and a completion variable.");
     MODULE_AUTHOR("Jeka");

программа работает правильно, но мне нужно следовать ей, чтобы Я вижу, что ветка читателя информирует автора о гарантии чтения

...