1 files changed, 36 insertions, 0 deletions
diff --git a/src/crimson/thread/Condition.h b/src/crimson/thread/Condition.h
new file mode 100644
index 00000000..2a5c643d
--- /dev/null
+++ b/src/crimson/thread/Condition.h
@@ -0,0 +1,36 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#pragma once
+
+#include <seastar/core/reactor.hh>
+#include <sys/eventfd.h>
+
+namespace ceph::thread {
+
+/// a synchronization primitive can be used to block a seastar thread, until
+/// another thread notifies it.
+class Condition {
+  seastar::file_desc file_desc;
+  int fd;
+  seastar::pollable_fd_state fd_state;
+  eventfd_t event = 0;
+public:
+  Condition()
+    : file_desc{seastar::file_desc::eventfd(0, 0)},
+      fd(file_desc.get()),
+      fd_state{std::move(file_desc)}
+  {}
+  seastar::future<> wait() {
+    return seastar::engine().read_some(fd_state, &event, sizeof(event))
+      .then([](size_t) {
+	  return seastar::now();
+	});
+  }
+  void notify() {
+    eventfd_t result = 1;
+    ::eventfd_write(fd, result);
+  }
+};
+
+} // namespace ceph::thread