summaryrefslogtreecommitdiff
path: root/sys/external/bsd/common/include/linux
diff options
context:
space:
mode:
authorriastradh <riastradh@NetBSD.org>2021-12-19 00:56:25 +0000
committerriastradh <riastradh@NetBSD.org>2021-12-19 00:56:25 +0000
commit7dbbf4effeacadf21bc6a2ec04476f34d9914e1a (patch)
treedcacd32f6b64835002afd133ea2f4373e3d61618 /sys/external/bsd/common/include/linux
parentf9b03381c0e8f0945a0d8496549772d90c797b43 (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.h39
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.
*/