initial code repo

[stor4nfv.git] / src / ceph / src / journal / Future.h

diff --git a/src/ceph/src/journal/Future.h b/src/ceph/src/journal/Future.h
new file mode 100644 (file)
index 0000000..1ddb606
--- /dev/null
+++ b/src/ceph/src/journal/Future.h
@@ -0,0 +1,58 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#ifndef CEPH_JOURNAL_FUTURE_H
+#define CEPH_JOURNAL_FUTURE_H
+
+#include "include/int_types.h"
+#include <string>
+#include <iosfwd>
+#include <boost/intrusive_ptr.hpp>
+#include "include/assert.h"
+
+class Context;
+
+namespace journal {
+
+class FutureImpl;
+
+class Future {
+public:
+  typedef boost::intrusive_ptr<FutureImpl> FutureImplPtr;
+
+  Future() {}
+  Future(const FutureImplPtr &future_impl) : m_future_impl(future_impl) {}
+
+  inline bool is_valid() const {
+    return m_future_impl.get() != nullptr;
+  }
+
+  void flush(Context *on_safe);
+  void wait(Context *on_safe);
+
+  bool is_complete() const;
+  int get_return_value() const;
+
+private:
+  friend class Journaler;
+  friend std::ostream& operator<<(std::ostream&, const Future&);
+
+  inline FutureImplPtr get_future_impl() const {
+    return m_future_impl;
+  }
+
+  FutureImplPtr m_future_impl;
+};
+
+void intrusive_ptr_add_ref(FutureImpl *p);
+void intrusive_ptr_release(FutureImpl *p);
+
+std::ostream &operator<<(std::ostream &os, const Future &future);
+
+} // namespace journal
+
+using journal::intrusive_ptr_add_ref;
+using journal::intrusive_ptr_release;
+using journal::operator<<;
+
+#endif // CEPH_JOURNAL_FUTURE_H