|  | /* | 
|  | * Generic implementation of a polled input device | 
|  |  | 
|  | * Copyright (c) 2007 Dmitry Torokhov | 
|  | * | 
|  | * This program is free software; you can redistribute it and/or modify it | 
|  | * under the terms of the GNU General Public License version 2 as published by | 
|  | * the Free Software Foundation. | 
|  | */ | 
|  |  | 
|  | #include <linux/jiffies.h> | 
|  | #include <linux/mutex.h> | 
|  | #include <linux/input-polldev.h> | 
|  |  | 
|  | MODULE_AUTHOR("Dmitry Torokhov <dtor@mail.ru>"); | 
|  | MODULE_DESCRIPTION("Generic implementation of a polled input device"); | 
|  | MODULE_LICENSE("GPL v2"); | 
|  | MODULE_VERSION("0.1"); | 
|  |  | 
|  | static DEFINE_MUTEX(polldev_mutex); | 
|  | static int polldev_users; | 
|  | static struct workqueue_struct *polldev_wq; | 
|  |  | 
|  | static int input_polldev_start_workqueue(void) | 
|  | { | 
|  | int retval; | 
|  |  | 
|  | retval = mutex_lock_interruptible(&polldev_mutex); | 
|  | if (retval) | 
|  | return retval; | 
|  |  | 
|  | if (!polldev_users) { | 
|  | polldev_wq = create_singlethread_workqueue("ipolldevd"); | 
|  | if (!polldev_wq) { | 
|  | printk(KERN_ERR "input-polldev: failed to create " | 
|  | "ipolldevd workqueue\n"); | 
|  | retval = -ENOMEM; | 
|  | goto out; | 
|  | } | 
|  | } | 
|  |  | 
|  | polldev_users++; | 
|  |  | 
|  | out: | 
|  | mutex_unlock(&polldev_mutex); | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static void input_polldev_stop_workqueue(void) | 
|  | { | 
|  | mutex_lock(&polldev_mutex); | 
|  |  | 
|  | if (!--polldev_users) | 
|  | destroy_workqueue(polldev_wq); | 
|  |  | 
|  | mutex_unlock(&polldev_mutex); | 
|  | } | 
|  |  | 
|  | static void input_polled_device_work(struct work_struct *work) | 
|  | { | 
|  | struct input_polled_dev *dev = | 
|  | container_of(work, struct input_polled_dev, work.work); | 
|  | unsigned long delay; | 
|  |  | 
|  | dev->poll(dev); | 
|  |  | 
|  | delay = msecs_to_jiffies(dev->poll_interval); | 
|  | if (delay >= HZ) | 
|  | delay = round_jiffies_relative(delay); | 
|  |  | 
|  | queue_delayed_work(polldev_wq, &dev->work, delay); | 
|  | } | 
|  |  | 
|  | static int input_open_polled_device(struct input_dev *input) | 
|  | { | 
|  | struct input_polled_dev *dev = input_get_drvdata(input); | 
|  | int error; | 
|  |  | 
|  | error = input_polldev_start_workqueue(); | 
|  | if (error) | 
|  | return error; | 
|  |  | 
|  | if (dev->flush) | 
|  | dev->flush(dev); | 
|  |  | 
|  | queue_delayed_work(polldev_wq, &dev->work, | 
|  | msecs_to_jiffies(dev->poll_interval)); | 
|  |  | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | static void input_close_polled_device(struct input_dev *input) | 
|  | { | 
|  | struct input_polled_dev *dev = input_get_drvdata(input); | 
|  |  | 
|  | cancel_delayed_work_sync(&dev->work); | 
|  | input_polldev_stop_workqueue(); | 
|  | } | 
|  |  | 
|  | /** | 
|  | * input_allocate_polled_device - allocated memory polled device | 
|  | * | 
|  | * The function allocates memory for a polled device and also | 
|  | * for an input device associated with this polled device. | 
|  | */ | 
|  | struct input_polled_dev *input_allocate_polled_device(void) | 
|  | { | 
|  | struct input_polled_dev *dev; | 
|  |  | 
|  | dev = kzalloc(sizeof(struct input_polled_dev), GFP_KERNEL); | 
|  | if (!dev) | 
|  | return NULL; | 
|  |  | 
|  | dev->input = input_allocate_device(); | 
|  | if (!dev->input) { | 
|  | kfree(dev); | 
|  | return NULL; | 
|  | } | 
|  |  | 
|  | return dev; | 
|  | } | 
|  | EXPORT_SYMBOL(input_allocate_polled_device); | 
|  |  | 
|  | /** | 
|  | * input_free_polled_device - free memory allocated for polled device | 
|  | * @dev: device to free | 
|  | * | 
|  | * The function frees memory allocated for polling device and drops | 
|  | * reference to the associated input device (if present). | 
|  | */ | 
|  | void input_free_polled_device(struct input_polled_dev *dev) | 
|  | { | 
|  | if (dev) { | 
|  | input_free_device(dev->input); | 
|  | kfree(dev); | 
|  | } | 
|  | } | 
|  | EXPORT_SYMBOL(input_free_polled_device); | 
|  |  | 
|  | /** | 
|  | * input_register_polled_device - register polled device | 
|  | * @dev: device to register | 
|  | * | 
|  | * The function registers previously initialized polled input device | 
|  | * with input layer. The device should be allocated with call to | 
|  | * input_allocate_polled_device(). Callers should also set up poll() | 
|  | * method and set up capabilities (id, name, phys, bits) of the | 
|  | * corresponing input_dev structure. | 
|  | */ | 
|  | int input_register_polled_device(struct input_polled_dev *dev) | 
|  | { | 
|  | struct input_dev *input = dev->input; | 
|  |  | 
|  | input_set_drvdata(input, dev); | 
|  | INIT_DELAYED_WORK(&dev->work, input_polled_device_work); | 
|  | if (!dev->poll_interval) | 
|  | dev->poll_interval = 500; | 
|  | input->open = input_open_polled_device; | 
|  | input->close = input_close_polled_device; | 
|  |  | 
|  | return input_register_device(input); | 
|  | } | 
|  | EXPORT_SYMBOL(input_register_polled_device); | 
|  |  | 
|  | /** | 
|  | * input_unregister_polled_device - unregister polled device | 
|  | * @dev: device to unregister | 
|  | * | 
|  | * The function unregisters previously registered polled input | 
|  | * device from input layer. Polling is stopped and device is | 
|  | * ready to be freed with call to input_free_polled_device(). | 
|  | * Callers should not attempt to access dev->input pointer | 
|  | * after calling this function. | 
|  | */ | 
|  | void input_unregister_polled_device(struct input_polled_dev *dev) | 
|  | { | 
|  | input_unregister_device(dev->input); | 
|  | dev->input = NULL; | 
|  | } | 
|  | EXPORT_SYMBOL(input_unregister_polled_device); | 
|  |  |