1 files changed, 62 insertions, 0 deletions
diff --git a/src/client/Fh.h b/src/client/Fh.h
new file mode 100644
index 000000000..c3355ba6c
--- /dev/null
+++ b/src/client/Fh.h
@@ -0,0 +1,62 @@
+#ifndef CEPH_CLIENT_FH_H
+#define CEPH_CLIENT_FH_H
+
+#include "common/Readahead.h"
+#include "include/types.h"
+#include "InodeRef.h"
+#include "UserPerm.h"
+#include "mds/flock.h"
+
+class Inode;
+
+// file handle for any open file state
+
+struct Fh {
+  InodeRef  inode;
+  int	    _ref;
+  loff_t    pos;
+  int       mds;        // have to talk to mds we opened with (for now)
+  int       mode;       // the mode i opened the file with
+  uint64_t  gen;
+
+  int flags;
+  bool pos_locked;           // pos is currently in use
+  std::list<ceph::condition_variable*> pos_waiters;   // waiters for pos
+
+  UserPerm actor_perms; // perms I opened the file with
+
+  Readahead readahead;
+
+  // file lock
+  std::unique_ptr<ceph_lock_state_t> fcntl_locks;
+  std::unique_ptr<ceph_lock_state_t> flock_locks;
+
+  bool has_any_filelocks() {
+    return
+      (fcntl_locks && !fcntl_locks->empty()) ||
+      (flock_locks && !flock_locks->empty());
+  }
+
+  // IO error encountered by any writeback on this Inode while
+  // this Fh existed (i.e. an fsync on another Fh will still show
+  // up as an async_err here because it could have been the same
+  // bytes we wrote via this Fh).
+  int async_err = {0};
+
+  int take_async_err()
+  {
+      int e = async_err;
+      async_err = 0;
+      return e;
+  }
+
+  Fh() = delete;
+  Fh(InodeRef in, int flags, int cmode, uint64_t gen, const UserPerm &perms);
+  ~Fh();
+
+  void get() { ++_ref; }
+  int put() { return --_ref; }
+};
+
+
+#endif