Skip to content

Commit

Permalink
async: use ULLONG_MAX for infinity cookie value
Browse files Browse the repository at this point in the history
Currently, next_cookie is used as the infinity value.  In most cases,
this should work fine but it theoretically could bring subtle behavior
difference between async_synchronize_full() and
async_synchronize_full_domain().

async_synchronize_full() keeps waiting until there's no registered
async_entry left regardless of what next_cookie was when the function
was called.  It guarantees that the queue is completely drained at
least once before returning.

However, async_synchronize_full_domain() doesn't.  It synchronizes
upto next_cookie and if further async jobs are queued after the
next_cookie value to synchronize is decided, they won't be waited for.

For unrelated async jobs, the behavior difference doesn't matter;
however, if async jobs which are related (nested or otherwise) to the
executing ones are queued while sychronization is in progress, the
resulting behavior difference could be problematic.

This can be easily fixed by using ULLONG_MAX as the infinity value
instead.  Define ASYNC_COOKIE_MAX as ULLONG_MAX and use it as the
infinity value for synchronization.  This makes
async_synchronize_full_domain() fully drain the domain at least once
before returning, making its behavior match async_synchronize_full().

Signed-off-by: Tejun Heo <[email protected]>
Cc: Arjan van de Ven <[email protected]>
Cc: Dan Williams <[email protected]>
Cc: Linus Torvalds <[email protected]>
  • Loading branch information
htejun committed Jan 23, 2013
1 parent 8723d50 commit c68eee1
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions kernel/async.c
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,8 @@ asynchronous and synchronous parts of the kernel.

static async_cookie_t next_cookie = 1;

#define MAX_WORK 32768
#define MAX_WORK 32768
#define ASYNC_COOKIE_MAX ULLONG_MAX /* infinity cookie */

static LIST_HEAD(async_pending);
static ASYNC_DOMAIN(async_dfl_domain);
Expand All @@ -88,8 +89,8 @@ static atomic_t entry_count;
*/
static async_cookie_t __lowest_in_progress(struct async_domain *domain)
{
async_cookie_t first_running = next_cookie; /* infinity value */
async_cookie_t first_pending = next_cookie; /* ditto */
async_cookie_t first_running = ASYNC_COOKIE_MAX;
async_cookie_t first_pending = ASYNC_COOKIE_MAX;
struct async_entry *entry;

/*
Expand Down Expand Up @@ -269,7 +270,7 @@ void async_synchronize_full(void)
domain = list_first_entry(&async_domains, typeof(*domain), node);
spin_unlock_irq(&async_lock);

async_synchronize_cookie_domain(next_cookie, domain);
async_synchronize_cookie_domain(ASYNC_COOKIE_MAX, domain);
} while (!list_empty(&async_domains));
mutex_unlock(&async_register_mutex);
}
Expand Down Expand Up @@ -305,7 +306,7 @@ EXPORT_SYMBOL_GPL(async_unregister_domain);
*/
void async_synchronize_full_domain(struct async_domain *domain)
{
async_synchronize_cookie_domain(next_cookie, domain);
async_synchronize_cookie_domain(ASYNC_COOKIE_MAX, domain);
}
EXPORT_SYMBOL_GPL(async_synchronize_full_domain);

Expand Down

0 comments on commit c68eee1

Please sign in to comment.