[ceph.git] / ceph / src / mds / CDentry.h

// -*- 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_CDENTRY_H
#define CEPH_CDENTRY_H

#include <string>
#include <boost/utility/string_view.hpp>
#include <set>

#include "include/counter.h"
#include "include/types.h"
#include "include/buffer_fwd.h"
#include "include/lru.h"
#include "include/elist.h"
#include "include/filepath.h"

#include "MDSCacheObject.h"
#include "SimpleLock.h"
#include "LocalLock.h"
#include "ScrubHeader.h"

class CInode;
class CDir;
class Locker;
class Message;
class CDentry;
class LogSegment;

class Session;


// define an ordering
bool operator<(const CDentry& l, const CDentry& r);

// dentry
class CDentry : public MDSCacheObject, public LRUObject, public Counter<CDentry> {
public:
  MEMPOOL_CLASS_HELPERS();
  friend class CDir;

  struct linkage_t {
    CInode *inode = nullptr;
    inodeno_t remote_ino = 0;
    unsigned char remote_d_type = 0;
    
    linkage_t() {}

    // dentry type is primary || remote || null
    // inode ptr is required for primary, optional for remote, undefined for null
    bool is_primary() const { return remote_ino == 0 && inode != 0; }
    bool is_remote() const { return remote_ino > 0; }
    bool is_null() const { return remote_ino == 0 && inode == 0; }

    CInode *get_inode() { return inode; }
    const CInode *get_inode() const { return inode; }
    inodeno_t get_remote_ino() const { return remote_ino; }
    unsigned char get_remote_d_type() const { return remote_d_type; }
    std::string get_remote_d_type_string() const;

    void set_remote(inodeno_t ino, unsigned char d_type) { 
      remote_ino = ino;
      remote_d_type = d_type;
      inode = 0;
    }
    void link_remote(CInode *in);
  };


  // -- state --
  static const int STATE_NEW =          (1<<0);
  static const int STATE_FRAGMENTING =  (1<<1);
  static const int STATE_PURGING =      (1<<2);
  static const int STATE_BADREMOTEINO = (1<<3);
  static const int STATE_EVALUATINGSTRAY = (1<<4);
  static const int STATE_PURGINGPINNED =  (1<<5);
  static const int STATE_BOTTOMLRU =    (1<<6);
  // stray dentry needs notification of releasing reference
  static const int STATE_STRAY =	STATE_NOTIFYREF;
  static const int MASK_STATE_IMPORT_KEPT = STATE_BOTTOMLRU;

  // -- pins --
  static const int PIN_INODEPIN =     1;  // linked inode is pinned
  static const int PIN_FRAGMENTING = -2;  // containing dir is refragmenting
  static const int PIN_PURGING =      3;
  static const int PIN_SCRUBPARENT =  4;

  static const unsigned EXPORT_NONCE = 1;


  CDentry(boost::string_view n, __u32 h,
	  snapid_t f, snapid_t l) :
    hash(h),
    first(f), last(l),
    item_dirty(this),
    lock(this, &lock_type),
    versionlock(this, &versionlock_type),
    name(n)
  {}
  CDentry(boost::string_view n, __u32 h, inodeno_t ino, unsigned char dt,
	  snapid_t f, snapid_t l) :
    hash(h),
    first(f), last(l),
    item_dirty(this),
    lock(this, &lock_type),
    versionlock(this, &versionlock_type),
    name(n)
  {
    linkage.remote_ino = ino;
    linkage.remote_d_type = dt;
  }

  const char *pin_name(int p) const override {
    switch (p) {
    case PIN_INODEPIN: return "inodepin";
    case PIN_FRAGMENTING: return "fragmenting";
    case PIN_PURGING: return "purging";
    case PIN_SCRUBPARENT: return "scrubparent";
    default: return generic_pin_name(p);
    }
  }

  // -- wait --
  //static const int WAIT_LOCK_OFFSET = 8;

  void add_waiter(uint64_t tag, MDSInternalContextBase *c) override;

  bool is_lt(const MDSCacheObject *r) const override {
    return *this < *static_cast<const CDentry*>(r);
  }

  dentry_key_t key() {
    return dentry_key_t(last, name.c_str(), hash);
  }

  const CDir *get_dir() const { return dir; }
  CDir *get_dir() { return dir; }
  boost::string_view get_name() const { return boost::string_view(name); }

  __u32 get_hash() const { return hash; }

  // linkage
  const linkage_t *get_linkage() const { return &linkage; }
  linkage_t *get_linkage() { return &linkage; }

  linkage_t *_project_linkage() {
    projected.push_back(linkage_t());
    return &projected.back();
  }
  void push_projected_linkage();
  void push_projected_linkage(inodeno_t ino, char d_type) {
    linkage_t *p = _project_linkage();
    p->remote_ino = ino;
    p->remote_d_type = d_type;
  }
  void push_projected_linkage(CInode *inode); 
  linkage_t *pop_projected_linkage();

  bool is_projected() const { return !projected.empty(); }

  linkage_t *get_projected_linkage() {
    if (!projected.empty())
      return &projected.back();
    return &linkage;
  }

  const linkage_t *get_projected_linkage() const {
    if (!projected.empty())
      return &projected.back();
    return &linkage;
  }

  CInode *get_projected_inode() {
    return get_projected_linkage()->inode;
  }

  bool use_projected(client_t client, const MutationRef& mut) const {
    return lock.can_read_projected(client) || 
      lock.get_xlock_by() == mut;
  }
  linkage_t *get_linkage(client_t client, const MutationRef& mut) {
    return use_projected(client, mut) ? get_projected_linkage() : get_linkage();
  }

  // ref counts: pin ourselves in the LRU when we're pinned.
  void first_get() override {
    lru_pin();
  }
  void last_put() override {
    lru_unpin();
  }
  void _put() override;

  // auth pins
  bool can_auth_pin(int *err_ret=nullptr) const override;
  void auth_pin(void *by) override;
  void auth_unpin(void *by) override;
  void adjust_nested_auth_pins(int adjustment, int diradj, void *by);
  bool is_frozen() const override;
  bool is_freezing() const override;
  int get_num_dir_auth_pins() const;
  
  // remote links
  void link_remote(linkage_t *dnl, CInode *in);
  void unlink_remote(linkage_t *dnl);
  
  // copy cons
  CDentry(const CDentry& m);
  const CDentry& operator= (const CDentry& right);

  // misc
  void make_path_string(std::string& s, bool projected=false) const;
  void make_path(filepath& fp, bool projected=false) const;

  // -- version --
  version_t get_version() const { return version; }
  void set_version(version_t v) { projected_version = version = v; }
  version_t get_projected_version() const { return projected_version; }
  void set_projected_version(version_t v) { projected_version = v; }
  
  mds_authority_t authority() const override;

  version_t pre_dirty(version_t min=0);
  void _mark_dirty(LogSegment *ls);
  void mark_dirty(version_t projected_dirv, LogSegment *ls);
  void mark_clean();

  void mark_new();
  bool is_new() const { return state_test(STATE_NEW); }
  void clear_new() { state_clear(STATE_NEW); }
  
  // -- replication
  void encode_replica(mds_rank_t mds, bufferlist& bl, bool need_recover) {
    if (!is_replicated())
      lock.replicate_relax();

    __u32 nonce = add_replica(mds);
    ::encode(nonce, bl);
    ::encode(first, bl);
    ::encode(linkage.remote_ino, bl);
    ::encode(linkage.remote_d_type, bl);
    lock.encode_state_for_replica(bl);
    ::encode(need_recover, bl);
  }
  void decode_replica(bufferlist::iterator& p, bool is_new);

  // -- exporting
  // note: this assumes the dentry already exists.  
  // i.e., the name is already extracted... so we just need the other state.
  void encode_export(bufferlist& bl) {
    ::encode(first, bl);
    ::encode(state, bl);
    ::encode(version, bl);
    ::encode(projected_version, bl);
    ::encode(lock, bl);
    ::encode(get_replicas(), bl);
    get(PIN_TEMPEXPORTING);
  }
  void finish_export() {
    // twiddle
    clear_replica_map();
    replica_nonce = EXPORT_NONCE;
    state_clear(CDentry::STATE_AUTH);
    if (is_dirty())
      mark_clean();
    put(PIN_TEMPEXPORTING);
  }
  void abort_export() {
    put(PIN_TEMPEXPORTING);
  }
  void decode_import(bufferlist::iterator& blp, LogSegment *ls) {
    ::decode(first, blp);
    __u32 nstate;
    ::decode(nstate, blp);
    ::decode(version, blp);
    ::decode(projected_version, blp);
    ::decode(lock, blp);
    ::decode(get_replicas(), blp);

    // twiddle
    state &= MASK_STATE_IMPORT_KEPT;
    state_set(CDentry::STATE_AUTH);
    if (nstate & STATE_DIRTY)
      _mark_dirty(ls);
    if (is_replicated())
      get(PIN_REPLICATED);
    replica_nonce = 0;
  }

  // -- locking --
  SimpleLock* get_lock(int type) override {
    assert(type == CEPH_LOCK_DN);
    return &lock;
  }
  void set_object_info(MDSCacheObjectInfo &info) override;
  void encode_lock_state(int type, bufferlist& bl) override;
  void decode_lock_state(int type, bufferlist& bl) override;

  // ---------------------------------------------
  // replicas (on clients)

  bool is_any_leases() const {
    return !client_lease_map.empty();
  }
  const ClientLease *get_client_lease(client_t c) const {
    if (client_lease_map.count(c))
      return client_lease_map.find(c)->second;
    return 0;
  }
  ClientLease *get_client_lease(client_t c) {
    if (client_lease_map.count(c))
      return client_lease_map.find(c)->second;
    return 0;
  }
  bool have_client_lease(client_t c) const {
    const ClientLease *l = get_client_lease(c);
    if (l) 
      return true;
    else
      return false;
  }

  ClientLease *add_client_lease(client_t c, Session *session);
  void remove_client_lease(ClientLease *r, Locker *locker);  // returns remaining mask (if any), and kicks locker eval_gathers
  void remove_client_leases(Locker *locker);

  ostream& print_db_line_prefix(ostream& out) override;
  void print(ostream& out) override;
  void dump(Formatter *f) const;


  __u32 hash;
  snapid_t first, last;

  elist<CDentry*>::item item_dirty, item_dir_dirty;
  elist<CDentry*>::item item_stray;

  // lock
  static LockType lock_type;
  static LockType versionlock_type;

  SimpleLock lock; // FIXME referenced containers not in mempool
  LocalLock versionlock; // FIXME referenced containers not in mempool

  mempool::mds_co::map<client_t,ClientLease*> client_lease_map;


protected:
  friend class Migrator;
  friend class Locker;
  friend class MDCache;
  friend class StrayManager;
  friend class CInode;
  friend class C_MDC_XlockRequest;

  CDir *dir = nullptr;     // containing dirfrag
  linkage_t linkage;
  mempool::mds_co::list<linkage_t> projected;

  version_t version = 0;  // dir version when last touched.
  version_t projected_version = 0;  // what it will be when i unlock/commit.

private:
  mempool::mds_co::string name;
};

ostream& operator<<(ostream& out, const CDentry& dn);


#endif
Commit	Line	Data
7c673cae FG	1	// -- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t --
	2	// vim: ts=8 sw=2 smarttab
	3	/*
	4	* Ceph - scalable distributed file system
	5	*
	6	* Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
	7	*
	8	* This is free software; you can redistribute it and/or
	9	* modify it under the terms of the GNU Lesser General Public
	10	* License version 2.1, as published by the Free Software
	11	* Foundation. See file COPYING.
	12	*
	13	*/
	14
	15
	16
	17	#ifndef CEPH_CDENTRY_H
	18	#define CEPH_CDENTRY_H
	19
	20	#include <string>
94b18763	21	#include <boost/utility/string_view.hpp>
7c673cae FG	22	#include <set>
	23
	24	#include "include/counter.h"
	25	#include "include/types.h"
	26	#include "include/buffer_fwd.h"
	27	#include "include/lru.h"
	28	#include "include/elist.h"
	29	#include "include/filepath.h"
	30
	31	#include "MDSCacheObject.h"
	32	#include "SimpleLock.h"
	33	#include "LocalLock.h"
	34	#include "ScrubHeader.h"
	35
	36	class CInode;
	37	class CDir;
	38	class Locker;
	39	class Message;
	40	class CDentry;
	41	class LogSegment;
	42
	43	class Session;
	44
	45
	46
	47	// define an ordering
	48	bool operator<(const CDentry& l, const CDentry& r);
	49
	50	// dentry
	51	class CDentry : public MDSCacheObject, public LRUObject, public Counter<CDentry> {
	52	public:
181888fb	53	MEMPOOL_CLASS_HELPERS();
7c673cae FG	54	friend class CDir;
	55
	56	struct linkage_t {
94b18763 FG	57	CInode *inode = nullptr;
	58	inodeno_t remote_ino = 0;
	59	unsigned char remote_d_type = 0;
7c673cae	60
94b18763	61	linkage_t() {}
7c673cae FG	62
	63	// dentry type is primary \|\| remote \|\| null
	64	// inode ptr is required for primary, optional for remote, undefined for null
	65	bool is_primary() const { return remote_ino == 0 && inode != 0; }
	66	bool is_remote() const { return remote_ino > 0; }
	67	bool is_null() const { return remote_ino == 0 && inode == 0; }
	68
	69	CInode *get_inode() { return inode; }
	70	const CInode *get_inode() const { return inode; }
	71	inodeno_t get_remote_ino() const { return remote_ino; }
	72	unsigned char get_remote_d_type() const { return remote_d_type; }
	73	std::string get_remote_d_type_string() const;
	74
	75	void set_remote(inodeno_t ino, unsigned char d_type) {
	76	remote_ino = ino;
	77	remote_d_type = d_type;
	78	inode = 0;
	79	}
	80	void link_remote(CInode *in);
	81	};
	82
	83
	84	// -- state --
	85	static const int STATE_NEW = (1<<0);
	86	static const int STATE_FRAGMENTING = (1<<1);
	87	static const int STATE_PURGING = (1<<2);
	88	static const int STATE_BADREMOTEINO = (1<<3);
	89	static const int STATE_EVALUATINGSTRAY = (1<<4);
	90	static const int STATE_PURGINGPINNED = (1<<5);
31f18b77	91	static const int STATE_BOTTOMLRU = (1<<6);
7c673cae FG	92	// stray dentry needs notification of releasing reference
7c673cae FG	93	static const int STATE_STRAY = STATE_NOTIFYREF;
31f18b77	94	static const int MASK_STATE_IMPORT_KEPT = STATE_BOTTOMLRU;
7c673cae FG	95
	96	// -- pins --
	97	static const int PIN_INODEPIN = 1; // linked inode is pinned
	98	static const int PIN_FRAGMENTING = -2; // containing dir is refragmenting
	99	static const int PIN_PURGING = 3;
	100	static const int PIN_SCRUBPARENT = 4;
	101
	102	static const unsigned EXPORT_NONCE = 1;
	103
	104
94b18763	105	CDentry(boost::string_view n, __u32 h,
7c673cae	106	snapid_t f, snapid_t l) :
94b18763	107	hash(h),
7c673cae FG	108	first(f), last(l),
	109	item_dirty(this),
	110	lock(this, &lock_type),
	111	versionlock(this, &versionlock_type),
94b18763 FG	112	name(n)
	113	{}
	114	CDentry(boost::string_view n, __u32 h, inodeno_t ino, unsigned char dt,
7c673cae	115	snapid_t f, snapid_t l) :
94b18763	116	hash(h),
7c673cae FG	117	first(f), last(l),
	118	item_dirty(this),
	119	lock(this, &lock_type),
	120	versionlock(this, &versionlock_type),
94b18763 FG	121	name(n)
94b18763 FG	122	{
7c673cae FG	123	linkage.remote_ino = ino;
	124	linkage.remote_d_type = dt;
	125	}
	126
	127	const char *pin_name(int p) const override {
	128	switch (p) {
	129	case PIN_INODEPIN: return "inodepin";
	130	case PIN_FRAGMENTING: return "fragmenting";
	131	case PIN_PURGING: return "purging";
	132	case PIN_SCRUBPARENT: return "scrubparent";
	133	default: return generic_pin_name(p);
	134	}
	135	}
	136
	137	// -- wait --
	138	//static const int WAIT_LOCK_OFFSET = 8;
	139
	140	void add_waiter(uint64_t tag, MDSInternalContextBase *c) override;
	141
	142	bool is_lt(const MDSCacheObject *r) const override {
	143	return this < static_cast<const CDentry*>(r);
	144	}
	145
	146	dentry_key_t key() {
	147	return dentry_key_t(last, name.c_str(), hash);
	148	}
	149
	150	const CDir *get_dir() const { return dir; }
	151	CDir *get_dir() { return dir; }
94b18763	152	boost::string_view get_name() const { return boost::string_view(name); }
7c673cae FG	153
	154	__u32 get_hash() const { return hash; }
	155
	156	// linkage
	157	const linkage_t *get_linkage() const { return &linkage; }
	158	linkage_t *get_linkage() { return &linkage; }
	159
	160	linkage_t *_project_linkage() {
	161	projected.push_back(linkage_t());
	162	return &projected.back();
	163	}
	164	void push_projected_linkage();
	165	void push_projected_linkage(inodeno_t ino, char d_type) {
	166	linkage_t *p = _project_linkage();
	167	p->remote_ino = ino;
	168	p->remote_d_type = d_type;
	169	}
	170	void push_projected_linkage(CInode *inode);
	171	linkage_t *pop_projected_linkage();
	172
	173	bool is_projected() const { return !projected.empty(); }
	174
	175	linkage_t *get_projected_linkage() {
	176	if (!projected.empty())
	177	return &projected.back();
	178	return &linkage;
	179	}
	180
	181	const linkage_t *get_projected_linkage() const {
	182	if (!projected.empty())
	183	return &projected.back();
	184	return &linkage;
	185	}
	186
	187	CInode *get_projected_inode() {
	188	return get_projected_linkage()->inode;
	189	}
	190
	191	bool use_projected(client_t client, const MutationRef& mut) const {
	192	return lock.can_read_projected(client) \|\|
	193	lock.get_xlock_by() == mut;
	194	}
	195	linkage_t *get_linkage(client_t client, const MutationRef& mut) {
	196	return use_projected(client, mut) ? get_projected_linkage() : get_linkage();
	197	}
	198
	199	// ref counts: pin ourselves in the LRU when we're pinned.
	200	void first_get() override {
	201	lru_pin();
	202	}
	203	void last_put() override {
	204	lru_unpin();
	205	}
	206	void _put() override;
	207
	208	// auth pins
91327a77	209	bool can_auth_pin(int *err_ret=nullptr) const override;
7c673cae FG	210	void auth_pin(void *by) override;
	211	void auth_unpin(void *by) override;
	212	void adjust_nested_auth_pins(int adjustment, int diradj, void *by);
	213	bool is_frozen() const override;
	214	bool is_freezing() const override;
	215	int get_num_dir_auth_pins() const;
	216
	217	// remote links
	218	void link_remote(linkage_t dnl, CInode in);
	219	void unlink_remote(linkage_t *dnl);
	220
	221	// copy cons
	222	CDentry(const CDentry& m);
	223	const CDentry& operator= (const CDentry& right);
	224
	225	// misc
	226	void make_path_string(std::string& s, bool projected=false) const;
	227	void make_path(filepath& fp, bool projected=false) const;
	228
	229	// -- version --
	230	version_t get_version() const { return version; }
	231	void set_version(version_t v) { projected_version = version = v; }
	232	version_t get_projected_version() const { return projected_version; }
	233	void set_projected_version(version_t v) { projected_version = v; }
	234
	235	mds_authority_t authority() const override;
	236
	237	version_t pre_dirty(version_t min=0);
	238	void _mark_dirty(LogSegment *ls);
	239	void mark_dirty(version_t projected_dirv, LogSegment *ls);
	240	void mark_clean();
	241
	242	void mark_new();
	243	bool is_new() const { return state_test(STATE_NEW); }
	244	void clear_new() { state_clear(STATE_NEW); }
	245
	246	// -- replication
b32b8144	247	void encode_replica(mds_rank_t mds, bufferlist& bl, bool need_recover) {
7c673cae FG	248	if (!is_replicated())
	249	lock.replicate_relax();
	250
	251	__u32 nonce = add_replica(mds);
	252	::encode(nonce, bl);
	253	::encode(first, bl);
	254	::encode(linkage.remote_ino, bl);
	255	::encode(linkage.remote_d_type, bl);
b32b8144 FG	256	lock.encode_state_for_replica(bl);
b32b8144 FG	257	::encode(need_recover, bl);
7c673cae FG	258	}
	259	void decode_replica(bufferlist::iterator& p, bool is_new);
	260
	261	// -- exporting
	262	// note: this assumes the dentry already exists.
	263	// i.e., the name is already extracted... so we just need the other state.
	264	void encode_export(bufferlist& bl) {
	265	::encode(first, bl);
	266	::encode(state, bl);
	267	::encode(version, bl);
	268	::encode(projected_version, bl);
	269	::encode(lock, bl);
181888fb	270	::encode(get_replicas(), bl);
7c673cae FG	271	get(PIN_TEMPEXPORTING);
	272	}
	273	void finish_export() {
	274	// twiddle
	275	clear_replica_map();
	276	replica_nonce = EXPORT_NONCE;
	277	state_clear(CDentry::STATE_AUTH);
	278	if (is_dirty())
	279	mark_clean();
	280	put(PIN_TEMPEXPORTING);
	281	}
	282	void abort_export() {
	283	put(PIN_TEMPEXPORTING);
	284	}
	285	void decode_import(bufferlist::iterator& blp, LogSegment *ls) {
	286	::decode(first, blp);
	287	__u32 nstate;
	288	::decode(nstate, blp);
	289	::decode(version, blp);
	290	::decode(projected_version, blp);
	291	::decode(lock, blp);
181888fb	292	::decode(get_replicas(), blp);
7c673cae FG	293
7c673cae FG	294	// twiddle
31f18b77	295	state &= MASK_STATE_IMPORT_KEPT;
7c673cae FG	296	state_set(CDentry::STATE_AUTH);
	297	if (nstate & STATE_DIRTY)
	298	_mark_dirty(ls);
181888fb	299	if (is_replicated())
7c673cae FG	300	get(PIN_REPLICATED);
	301	replica_nonce = 0;
	302	}
	303
	304	// -- locking --
	305	SimpleLock* get_lock(int type) override {
	306	assert(type == CEPH_LOCK_DN);
	307	return &lock;
	308	}
	309	void set_object_info(MDSCacheObjectInfo &info) override;
	310	void encode_lock_state(int type, bufferlist& bl) override;
	311	void decode_lock_state(int type, bufferlist& bl) override;
	312
	313	// ---------------------------------------------
	314	// replicas (on clients)
	315
	316	bool is_any_leases() const {
	317	return !client_lease_map.empty();
	318	}
	319	const ClientLease *get_client_lease(client_t c) const {
	320	if (client_lease_map.count(c))
	321	return client_lease_map.find(c)->second;
	322	return 0;
	323	}
	324	ClientLease *get_client_lease(client_t c) {
	325	if (client_lease_map.count(c))
	326	return client_lease_map.find(c)->second;
	327	return 0;
	328	}
	329	bool have_client_lease(client_t c) const {
	330	const ClientLease *l = get_client_lease(c);
	331	if (l)
	332	return true;
	333	else
	334	return false;
	335	}
	336
	337	ClientLease add_client_lease(client_t c, Session session);
	338	void remove_client_lease(ClientLease r, Locker locker); // returns remaining mask (if any), and kicks locker eval_gathers
	339	void remove_client_leases(Locker *locker);
	340
	341	ostream& print_db_line_prefix(ostream& out) override;
	342	void print(ostream& out) override;
	343	void dump(Formatter *f) const;
	344
	345
7c673cae FG	346	__u32 hash;
	347	snapid_t first, last;
	348
b32b8144	349	elist<CDentry*>::item item_dirty, item_dir_dirty;
7c673cae FG	350	elist<CDentry*>::item item_stray;
	351
	352	// lock
	353	static LockType lock_type;
	354	static LockType versionlock_type;
	355
94b18763 FG	356	SimpleLock lock; // FIXME referenced containers not in mempool
94b18763 FG	357	LocalLock versionlock; // FIXME referenced containers not in mempool
7c673cae	358
94b18763	359	mempool::mds_co::map<client_t,ClientLease*> client_lease_map;
7c673cae FG	360
	361
	362	protected:
	363	friend class Migrator;
	364	friend class Locker;
	365	friend class MDCache;
	366	friend class StrayManager;
	367	friend class CInode;
	368	friend class C_MDC_XlockRequest;
	369
94b18763	370	CDir *dir = nullptr; // containing dirfrag
7c673cae	371	linkage_t linkage;
94b18763 FG	372	mempool::mds_co::list<linkage_t> projected;
	373
	374	version_t version = 0; // dir version when last touched.
	375	version_t projected_version = 0; // what it will be when i unlock/commit.
7c673cae	376
94b18763 FG	377	private:
94b18763 FG	378	mempool::mds_co::string name;
7c673cae FG	379	};
	380
	381	ostream& operator<<(ostream& out, const CDentry& dn);
	382
	383
	384	#endif