1 files changed, 21 insertions, 0 deletions
diff --git a/vespalib/src/vespa/vespalib/coro/active_work.cpp b/vespalib/src/vespa/vespalib/coro/active_work.cpp
new file mode 100644
index 00000000000..403da5173fe
--- /dev/null
+++ b/vespalib/src/vespa/vespalib/coro/active_work.cpp
@@ -0,0 +1,21 @@
+// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+
+#include "active_work.h"
+#include <cassert>
+
+namespace vespalib::coro {
+
+bool
+ActiveWork::join_awaiter::await_suspend(std::coroutine_handle<> handle) noexcept
+{
+    self._waiting = handle;
+    return (self._pending.fetch_sub(1, std::memory_order_acq_rel) > 1);
+}
+
+ActiveWork::~ActiveWork()
+{
+    // NB: join must be called, even if there is no other work
+    assert(_pending.load(std::memory_order_relaxed) == 0);
+}
+
+}