diff options
| author | riastradh <riastradh@NetBSD.org> | 2021-12-19 00:56:25 +0000 |
|---|---|---|
| committer | riastradh <riastradh@NetBSD.org> | 2021-12-19 00:56:25 +0000 |
| commit | 7dbbf4effeacadf21bc6a2ec04476f34d9914e1a (patch) | |
| tree | dcacd32f6b64835002afd133ea2f4373e3d61618 /sys/external/bsd/common/include/linux | |
| parent | f9b03381c0e8f0945a0d8496549772d90c797b43 (diff) | |
Implement wait_for_completion_timeout.
Diffstat (limited to 'sys/external/bsd/common/include/linux')
| -rw-r--r-- | sys/external/bsd/common/include/linux/completion.h | 39 |
1 files changed, 38 insertions, 1 deletions
diff --git a/sys/external/bsd/common/include/linux/completion.h b/sys/external/bsd/common/include/linux/completion.h index 44c66e229b8..c39bfadb6d0 100644 --- a/sys/external/bsd/common/include/linux/completion.h +++ b/sys/external/bsd/common/include/linux/completion.h @@ -1,4 +1,4 @@ -/* $NetBSD: completion.h,v 1.7 2020/07/03 16:23:02 maxv Exp $ */ +/* $NetBSD: completion.h,v 1.8 2021/12/19 00:56:25 riastradh Exp $ */ /*- * Copyright (c) 2013 The NetBSD Foundation, Inc. @@ -226,6 +226,43 @@ out: mutex_exit(&completion->c_lock); } } +static inline int +wait_for_completion_timeout(struct completion *completion, unsigned long ticks) +{ + /* XXX Arithmetic overflow...? */ + unsigned int start = hardclock_ticks, now; + int error; + + mutex_enter(&completion->c_lock); + + /* Wait until c_done is nonzero. */ + while (completion->c_done == 0) { + error = cv_timedwait(&completion->c_cv, &completion->c_lock, + ticks); + if (error) + goto out; + now = hardclock_ticks; + if (ticks < (now - start)) { + error = EWOULDBLOCK; + goto out; + } + ticks -= (now - start); + start = now; + } + + /* Success! */ + _completion_claim(completion); + error = 0; + +out: mutex_exit(&completion->c_lock); + if (error == EWOULDBLOCK) { + return 0; + } else { + KASSERTMSG((error == 0), "error = %d", error); + return ticks; + } +} + /* * Wait interruptibly for someone to call complete or complete_all. */ |
