Использование вызова Linux sysfs_notify

Question

Я пытаюсь установить асинхронный обмен данными между драйвером ядра и программой из пользовательского пространства (я знаю, что здесь много вопросов, требующих подобной информации, но я не смог найти ни одного, связанного с sysfs_notify).

Я оставляю правку Вильгельма здесь, но добавляю исходный код как к простому драйверу, использующему sysfs, так и к программе пользовательского пространства для опроса. Драйвер работает нормально (я получил большую часть из сети; ему не хватает кредитов, но я не смог их найти, когда вернулся, чтобы добавить их). К сожалению, программа опроса не работает. Это всегда возвращает успех немедленно. Интересно, что если я не выполню две операции чтения перед опросом, для участников заданий устанавливается значение POLLERR | POLLIN вместо просто POLLIN, как видно из вывода программы.

Выход программы:

root @ ubuntu: / home / wmulcahy / demo #./readhello
срабатывает
Значение файла атрибута: 74 (т) [0]
месть [0]: 00000001
месть [1]: 00000001

Вот драйвер: hello.c (вы можете увидеть, где я начал...)

#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/init.h>
#include <linux/fs.h>
#include <linux/slab.h>

struct my_attr {
    struct attribute attr;
    int value;
};

static struct my_attr notify = {
    .attr.name="notify",
    .attr.mode = 0644,
    .value = 0,
};

static struct my_attr trigger = {
    .attr.name="trigger",
    .attr.mode = 0644,
    .value = 0,
};

static struct attribute * myattr[] = {
    &notify.attr,
    &trigger.attr,
    NULL
};

static ssize_t show(struct kobject *kobj, struct attribute *attr, char *buf)
{
    struct my_attr *a = container_of(attr, struct my_attr, attr);
    printk( "hello: show called (%s)\n", a->attr.name );
    return scnprintf(buf, PAGE_SIZE, "%s: %d\n", a->attr.name, a->value);
}
static struct kobject *mykobj;

static ssize_t store(struct kobject *kobj, struct attribute *attr, const char *buf, size_t len)
{
    struct my_attr *a = container_of(attr, struct my_attr, attr);

    sscanf(buf, "%d", &a->value);
    notify.value = a->value;
    printk("sysfs_notify store %s = %d\n", a->attr.name, a->value);
    sysfs_notify(mykobj, NULL, "notify");
    return sizeof(int);
}

static struct sysfs_ops myops = {
    .show = show,
    .store = store,
};

static struct kobj_type mytype = {
    .sysfs_ops = &myops,
    .default_attrs = myattr,
};

static struct kobject *mykobj;
static int __init hello_module_init(void)
{
    int err = -1;
    printk("Hello: init\n");
    mykobj = kzalloc(sizeof(*mykobj), GFP_KERNEL);
    if (mykobj) {
        kobject_init(mykobj, &mytype);
        if (kobject_add(mykobj, NULL, "%s", "hello")) {
             err = -1;
             printk("Hello: kobject_add() failed\n");
             kobject_put(mykobj);
             mykobj = NULL;
        }
        err = 0;
    }
    return err;
}

static void __exit hello_module_exit(void)
{
    if (mykobj) {
        kobject_put(mykobj);
        kfree(mykobj);
    }
    printk("Hello: exit\n");
}

module_init(hello_module_init);
module_exit(hello_module_exit);
MODULE_LICENSE("GPL");

А вот и программа опроса: readhello.c

#include <stdint.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/types.h> 
#include <sys/stat.h> 
#include <poll.h>

#define TEST_SYSFS_TRIGGER  "/sys/hello/trigger"
#define TEST_SYSFS_NOTIFY   "/sys/hello/notify"

int main(int argc, char **argv)
{
    int cnt, notifyFd, triggerFd, rv;
    char attrData[100];
    struct pollfd ufds[2];

    // Open a connection to the attribute file.
    if ((notifyFd = open(TEST_SYSFS_NOTIFY, O_RDWR)) < 0)
    {
        perror("Unable to open notify");
        exit(1);
    }
    // Open a connection to the attribute file.
    if ((triggerFd = open(TEST_SYSFS_TRIGGER, O_RDWR)) < 0)
    {
        perror("Unable to open trigger");
        exit(1);
    }

    ufds[0].fd = notifyFd;
    ufds[0].events = POLLIN;
    ufds[1].fd = triggerFd;
    ufds[1].events = POLLIN;

    // Someone suggested dummy reads before the poll() call
    cnt = read( notifyFd, attrData, 100 );
    cnt = read( triggerFd, attrData, 100 );
    ufds[0].revents = 0;
    ufds[1].revents = 0;
    if (( rv = poll( ufds, 2, 10000)) < 0 )
    {
        perror("poll error");
    }
    else if (rv == 0)
    {
        printf("Timeout occurred!\n");
    }
    else if (ufds[0].revents & POLLIN)
    {
        printf("triggered\n");
        cnt = read( notifyFd, attrData, 1 );
        printf( "Attribute file value: %02X (%c) [%d]\n", attrData[0], attrData[0], cnt );
    }
    printf( "revents[0]: %08X\n", ufds[0].revents );
    printf( "revents[1]: %08X\n", ufds[1].revents );

    close( triggerFd );
    close( notifyFd );
}

Некоторые предстоящие улучшения sysfs.

Внутренне, патч добавляет заголовок очереди ожидания к каждому kobject в системе; эта очередь вставляется в таблицу опроса в ответ на вызов poll(). Однако у кода sysfs нет возможности узнать, когда значение какого-либо атрибута sysfs изменилось, поэтому подсистема, реализующая атрибут pollable, должна сделать явные вызовы:

void sysfs_notify(struct kobject *kobj, char *dir, char *attr);

Спасибо ли

Answer 1

Блокирующий опрос от пользователя. Пользовательский код может просто сообщить ядру, какие атрибуты ему интересны, а затем заблокировать poll() пока один из них не изменился.

sysfs_notify() это вызов на стороне ядра, который освобождает пространство пользователя poll(), После того, как вы измените значение вашего атрибута ядра, просто позвоните sysfs_notify() позволить любым приложениям пользовательского пространства реагировать на их выдающиеся poll(),

Думать о poll() как "подписка" на уведомления об изменении интересующего атрибута, и sysfs_notify() как "публикация" изменений для любых подписчиков.