initial code repo

[stor4nfv.git] / src / ceph / src / mds / SnapRealm.h

diff --git a/src/ceph/src/mds/SnapRealm.h b/src/ceph/src/mds/SnapRealm.h
new file mode 100644 (file)
index 0000000..4a99d63
--- /dev/null
+++ b/src/ceph/src/mds/SnapRealm.h
@@ -0,0 +1,165 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- 
+// vim: ts=8 sw=2 smarttab
+/*
+ * Ceph - scalable distributed file system
+ *
+ * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
+ *
+ * This is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License version 2.1, as published by the Free Software 
+ * Foundation.  See file COPYING.
+ * 
+ */
+
+#ifndef CEPH_MDS_SNAPREALM_H
+#define CEPH_MDS_SNAPREALM_H
+
+#include "mdstypes.h"
+#include "snap.h"
+#include "include/xlist.h"
+#include "include/elist.h"
+#include "common/snap_types.h"
+
+class MDSInternalContextBase;
+
+struct SnapRealm {
+protected:
+  // cache
+  mutable snapid_t cached_seq;           // max seq over self and all past+present parents.
+  mutable snapid_t cached_last_created;  // max last_created over all past+present parents
+  mutable snapid_t cached_last_destroyed;
+  mutable set<snapid_t> cached_snaps;
+  mutable SnapContext cached_snap_context;
+  mutable bufferlist cached_snap_trace;
+
+  void check_cache() const;
+
+public:
+  // realm state
+  sr_t srnode;
+
+  // in-memory state
+  MDCache *mdcache;
+  CInode *inode;
+
+  bool open;                        // set to true once all past_parents are opened
+  SnapRealm *parent;
+  set<SnapRealm*> open_children;    // active children that are currently open
+  set<SnapRealm*> open_past_children;  // past children who has pinned me
+  map<inodeno_t, pair<SnapRealm*, set<snapid_t> > > open_past_parents;  // these are explicitly pinned.
+  unsigned num_open_past_parents;
+
+
+
+  elist<CInode*> inodes_with_caps;             // for efficient realm splits
+  map<client_t, xlist<Capability*>* > client_caps;   // to identify clients who need snap notifications
+
+  SnapRealm(MDCache *c, CInode *in) : 
+    srnode(),
+    mdcache(c), inode(in),
+    open(false), parent(0),
+    num_open_past_parents(0),
+    inodes_with_caps(0) 
+  { }
+
+  bool exists(const string &name) const {
+    for (map<snapid_t,SnapInfo>::const_iterator p = srnode.snaps.begin();
+        p != srnode.snaps.end();
+        ++p) {
+      if (p->second.name == name)
+       return true;
+    }
+    return false;
+  }
+
+  bool is_open() const { return open; }
+  void _close_parents() { open = false; }
+  bool _open_parents(MDSInternalContextBase *retryorfinish, snapid_t first=1, snapid_t last=CEPH_NOSNAP);
+  bool open_parents(MDSInternalContextBase *retryorfinish);
+  void _remove_missing_parent(snapid_t snapid, inodeno_t parent, int err);
+  bool have_past_parents_open(snapid_t first=1, snapid_t last=CEPH_NOSNAP);
+  void add_open_past_parent(SnapRealm *parent, snapid_t last);
+  void remove_open_past_parent(inodeno_t ino, snapid_t last);
+  void close_parents();
+
+  void prune_past_parents();
+  bool has_past_parents() const { return !srnode.past_parents.empty(); }
+
+  void build_snap_set(set<snapid_t>& s, 
+                     snapid_t& max_seq, snapid_t& max_last_created, snapid_t& max_last_destroyed,
+                     snapid_t first, snapid_t last) const;
+  void get_snap_info(map<snapid_t,SnapInfo*>& infomap, snapid_t first=0, snapid_t last=CEPH_NOSNAP);
+
+  const bufferlist& get_snap_trace();
+  void build_snap_trace(bufferlist& snapbl) const;
+
+  const string& get_snapname(snapid_t snapid, inodeno_t atino);
+  snapid_t resolve_snapname(const string &name, inodeno_t atino, snapid_t first=0, snapid_t last=CEPH_NOSNAP);
+
+  const set<snapid_t>& get_snaps() const;
+  const SnapContext& get_snap_context() const;
+  void invalidate_cached_snaps() {
+    cached_seq = 0;
+  }
+  snapid_t get_last_created() {
+    check_cache();
+    return cached_last_created;
+  }
+  snapid_t get_last_destroyed() {
+    check_cache();
+    return cached_last_destroyed;
+  }
+  snapid_t get_newest_snap() {
+    check_cache();
+    if (cached_snaps.empty())
+      return 0;
+    else
+      return *cached_snaps.rbegin();
+  }
+  snapid_t get_newest_seq() {
+    check_cache();
+    return cached_seq;
+  }
+
+  snapid_t get_snap_following(snapid_t follows) {
+    check_cache();
+    const set<snapid_t>& s = get_snaps();
+    set<snapid_t>::const_iterator p = s.upper_bound(follows);
+    if (p != s.end())
+      return *p;
+    return CEPH_NOSNAP;
+  }
+
+  bool has_snaps_in_range(snapid_t first, snapid_t last) {
+    check_cache();
+    const set<snapid_t>& s = get_snaps();
+    set<snapid_t>::const_iterator p = s.lower_bound(first);
+    return (p != s.end() && *p <= last);
+  }
+
+  void adjust_parent();
+
+  void split_at(SnapRealm *child);
+  void join(SnapRealm *child);
+
+  void add_cap(client_t client, Capability *cap) {
+    auto client_caps_entry = client_caps.find(client);
+    if (client_caps_entry == client_caps.end())
+      client_caps_entry = client_caps.emplace(client,
+                                             new xlist<Capability*>).first;
+    client_caps_entry->second->push_back(&cap->item_snaprealm_caps);
+  }
+  void remove_cap(client_t client, Capability *cap) {
+    cap->item_snaprealm_caps.remove_myself();
+    if (client_caps[client]->empty()) {
+      delete client_caps[client];
+      client_caps.erase(client);
+    }
+  }
+
+};
+
+ostream& operator<<(ostream& out, const SnapRealm &realm);
+
+#endif