Commit ce8aa489 authored by Linus Torvalds's avatar Linus Torvalds

Merge branch 'for-3.10-async' of git://git.kernel.org/pub/scm/linux/kernel/git/tj/wq

Pull async update from Tejun Heo:
 "This contains three cleanup patches for async from Lai.  All three
  patches are essentially cosmetic."

* 'for-3.10-async' of git://git.kernel.org/pub/scm/linux/kernel/git/tj/wq:
  async: rename and redefine async_func_ptr
  async: remove unused @node from struct async_domain
  async: simplify lowest_in_progress()
parents b97db075 362f2b09
...@@ -35,7 +35,7 @@ static unsigned int nr_ports; ...@@ -35,7 +35,7 @@ static unsigned int nr_ports;
static struct sh7786_pcie_hwops { static struct sh7786_pcie_hwops {
int (*core_init)(void); int (*core_init)(void);
async_func_ptr *port_init_hw; async_func_t port_init_hw;
} *sh7786_pcie_hwops; } *sh7786_pcie_hwops;
static struct resource sh7786_pci0_resources[] = { static struct resource sh7786_pci0_resources[] = {
......
...@@ -16,9 +16,8 @@ ...@@ -16,9 +16,8 @@
#include <linux/list.h> #include <linux/list.h>
typedef u64 async_cookie_t; typedef u64 async_cookie_t;
typedef void (async_func_ptr) (void *data, async_cookie_t cookie); typedef void (*async_func_t) (void *data, async_cookie_t cookie);
struct async_domain { struct async_domain {
struct list_head node;
struct list_head pending; struct list_head pending;
unsigned registered:1; unsigned registered:1;
}; };
...@@ -27,8 +26,7 @@ struct async_domain { ...@@ -27,8 +26,7 @@ struct async_domain {
* domain participates in global async_synchronize_full * domain participates in global async_synchronize_full
*/ */
#define ASYNC_DOMAIN(_name) \ #define ASYNC_DOMAIN(_name) \
struct async_domain _name = { .node = LIST_HEAD_INIT(_name.node), \ struct async_domain _name = { .pending = LIST_HEAD_INIT(_name.pending), \
.pending = LIST_HEAD_INIT(_name.pending), \
.registered = 1 } .registered = 1 }
/* /*
...@@ -36,12 +34,11 @@ struct async_domain { ...@@ -36,12 +34,11 @@ struct async_domain {
* complete, this domain does not participate in async_synchronize_full * complete, this domain does not participate in async_synchronize_full
*/ */
#define ASYNC_DOMAIN_EXCLUSIVE(_name) \ #define ASYNC_DOMAIN_EXCLUSIVE(_name) \
struct async_domain _name = { .node = LIST_HEAD_INIT(_name.node), \ struct async_domain _name = { .pending = LIST_HEAD_INIT(_name.pending), \
.pending = LIST_HEAD_INIT(_name.pending), \
.registered = 0 } .registered = 0 }
extern async_cookie_t async_schedule(async_func_ptr *ptr, void *data); extern async_cookie_t async_schedule(async_func_t func, void *data);
extern async_cookie_t async_schedule_domain(async_func_ptr *ptr, void *data, extern async_cookie_t async_schedule_domain(async_func_t func, void *data,
struct async_domain *domain); struct async_domain *domain);
void async_unregister_domain(struct async_domain *domain); void async_unregister_domain(struct async_domain *domain);
extern void async_synchronize_full(void); extern void async_synchronize_full(void);
......
...@@ -73,7 +73,7 @@ struct async_entry { ...@@ -73,7 +73,7 @@ struct async_entry {
struct list_head global_list; struct list_head global_list;
struct work_struct work; struct work_struct work;
async_cookie_t cookie; async_cookie_t cookie;
async_func_ptr *func; async_func_t func;
void *data; void *data;
struct async_domain *domain; struct async_domain *domain;
}; };
...@@ -84,24 +84,20 @@ static atomic_t entry_count; ...@@ -84,24 +84,20 @@ static atomic_t entry_count;
static async_cookie_t lowest_in_progress(struct async_domain *domain) static async_cookie_t lowest_in_progress(struct async_domain *domain)
{ {
struct async_entry *first = NULL; struct list_head *pending;
async_cookie_t ret = ASYNC_COOKIE_MAX; async_cookie_t ret = ASYNC_COOKIE_MAX;
unsigned long flags; unsigned long flags;
spin_lock_irqsave(&async_lock, flags); spin_lock_irqsave(&async_lock, flags);
if (domain) { if (domain)
if (!list_empty(&domain->pending)) pending = &domain->pending;
first = list_first_entry(&domain->pending, else
struct async_entry, domain_list); pending = &async_global_pending;
} else {
if (!list_empty(&async_global_pending))
first = list_first_entry(&async_global_pending,
struct async_entry, global_list);
}
if (first) if (!list_empty(pending))
ret = first->cookie; ret = list_first_entry(pending, struct async_entry,
domain_list)->cookie;
spin_unlock_irqrestore(&async_lock, flags); spin_unlock_irqrestore(&async_lock, flags);
return ret; return ret;
...@@ -149,7 +145,7 @@ static void async_run_entry_fn(struct work_struct *work) ...@@ -149,7 +145,7 @@ static void async_run_entry_fn(struct work_struct *work)
wake_up(&async_done); wake_up(&async_done);
} }
static async_cookie_t __async_schedule(async_func_ptr *ptr, void *data, struct async_domain *domain) static async_cookie_t __async_schedule(async_func_t func, void *data, struct async_domain *domain)
{ {
struct async_entry *entry; struct async_entry *entry;
unsigned long flags; unsigned long flags;
...@@ -169,13 +165,13 @@ static async_cookie_t __async_schedule(async_func_ptr *ptr, void *data, struct a ...@@ -169,13 +165,13 @@ static async_cookie_t __async_schedule(async_func_ptr *ptr, void *data, struct a
spin_unlock_irqrestore(&async_lock, flags); spin_unlock_irqrestore(&async_lock, flags);
/* low on memory.. run synchronously */ /* low on memory.. run synchronously */
ptr(data, newcookie); func(data, newcookie);
return newcookie; return newcookie;
} }
INIT_LIST_HEAD(&entry->domain_list); INIT_LIST_HEAD(&entry->domain_list);
INIT_LIST_HEAD(&entry->global_list); INIT_LIST_HEAD(&entry->global_list);
INIT_WORK(&entry->work, async_run_entry_fn); INIT_WORK(&entry->work, async_run_entry_fn);
entry->func = ptr; entry->func = func;
entry->data = data; entry->data = data;
entry->domain = domain; entry->domain = domain;
...@@ -202,21 +198,21 @@ static async_cookie_t __async_schedule(async_func_ptr *ptr, void *data, struct a ...@@ -202,21 +198,21 @@ static async_cookie_t __async_schedule(async_func_ptr *ptr, void *data, struct a
/** /**
* async_schedule - schedule a function for asynchronous execution * async_schedule - schedule a function for asynchronous execution
* @ptr: function to execute asynchronously * @func: function to execute asynchronously
* @data: data pointer to pass to the function * @data: data pointer to pass to the function
* *
* Returns an async_cookie_t that may be used for checkpointing later. * Returns an async_cookie_t that may be used for checkpointing later.
* Note: This function may be called from atomic or non-atomic contexts. * Note: This function may be called from atomic or non-atomic contexts.
*/ */
async_cookie_t async_schedule(async_func_ptr *ptr, void *data) async_cookie_t async_schedule(async_func_t func, void *data)
{ {
return __async_schedule(ptr, data, &async_dfl_domain); return __async_schedule(func, data, &async_dfl_domain);
} }
EXPORT_SYMBOL_GPL(async_schedule); EXPORT_SYMBOL_GPL(async_schedule);
/** /**
* async_schedule_domain - schedule a function for asynchronous execution within a certain domain * async_schedule_domain - schedule a function for asynchronous execution within a certain domain
* @ptr: function to execute asynchronously * @func: function to execute asynchronously
* @data: data pointer to pass to the function * @data: data pointer to pass to the function
* @domain: the domain * @domain: the domain
* *
...@@ -226,10 +222,10 @@ EXPORT_SYMBOL_GPL(async_schedule); ...@@ -226,10 +222,10 @@ EXPORT_SYMBOL_GPL(async_schedule);
* synchronization domain is specified via @domain. Note: This function * synchronization domain is specified via @domain. Note: This function
* may be called from atomic or non-atomic contexts. * may be called from atomic or non-atomic contexts.
*/ */
async_cookie_t async_schedule_domain(async_func_ptr *ptr, void *data, async_cookie_t async_schedule_domain(async_func_t func, void *data,
struct async_domain *domain) struct async_domain *domain)
{ {
return __async_schedule(ptr, data, domain); return __async_schedule(func, data, domain);
} }
EXPORT_SYMBOL_GPL(async_schedule_domain); EXPORT_SYMBOL_GPL(async_schedule_domain);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment