From: Kefu Chai <kchai@redhat.com>
Date: Thu, 7 Jun 2018 12:22:32 +0000 (+0800)
Subject: crimson/thread: add a condition var impl
X-Git-Tag: v14.0.1~1115^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=994410d3e717b5e39f45b5be5ce3825c903e6b5a;p=ceph.git

crimson/thread: add a condition var impl

Signed-off-by: Kefu Chai <kchai@redhat.com>
---

diff --git a/src/crimson/thread/Condition.h b/src/crimson/thread/Condition.h
new file mode 100644
index 000000000000..d5d1f36c534d
--- /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 <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