[ceph.git] / ceph / src / mds / Migrator.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.
 * 
 * Handles the import and export of  mds authorities and actual cache data.
 * See src/doc/exports.txt for a description.
 */

#ifndef CEPH_MDS_MIGRATOR_H
#define CEPH_MDS_MIGRATOR_H

#include "include/types.h"

#include <map>
#include <list>
#include <set>
using std::map;
using std::list;
using std::set;


class MDSRank;
class CDir;
class CInode;
class CDentry;

class MExportDirDiscover;
class MExportDirDiscoverAck;
class MExportDirCancel;
class MExportDirPrep;
class MExportDirPrepAck;
class MExportDir;
class MExportDirAck;
class MExportDirNotify;
class MExportDirNotifyAck;
class MExportDirFinish;

class MExportCaps;
class MExportCapsAck;
class MGatherCaps;

class EImportStart;

class Migrator {
public:
  // export stages.  used to clean up intelligently if there's a failure.
  const static int EXPORT_CANCELLED	= 0;  // cancelled
  const static int EXPORT_CANCELLING	= 1;  // waiting for cancel notifyacks
  const static int EXPORT_LOCKING	= 2;  // acquiring locks
  const static int EXPORT_DISCOVERING	= 3;  // dest is disovering export dir
  const static int EXPORT_FREEZING	= 4;  // we're freezing the dir tree
  const static int EXPORT_PREPPING	= 5;  // sending dest spanning tree to export bounds
  const static int EXPORT_WARNING	= 6;  // warning bystanders of dir_auth_pending
  const static int EXPORT_EXPORTING	= 7;  // sent actual export, waiting for ack
  const static int EXPORT_LOGGINGFINISH	= 8;  // logging EExportFinish
  const static int EXPORT_NOTIFYING	= 9;  // waiting for notifyacks
  static const char *get_export_statename(int s) {
    switch (s) {
    case EXPORT_CANCELLING: return "cancelling";
    case EXPORT_LOCKING: return "locking";
    case EXPORT_DISCOVERING: return "discovering";
    case EXPORT_FREEZING: return "freezing";
    case EXPORT_PREPPING: return "prepping";
    case EXPORT_WARNING: return "warning";
    case EXPORT_EXPORTING: return "exporting";
    case EXPORT_LOGGINGFINISH: return "loggingfinish";
    case EXPORT_NOTIFYING: return "notifying";
    default: ceph_abort(); return 0;
    }
  }

  // -- imports --
  const static int IMPORT_DISCOVERING   = 1; // waiting for prep
  const static int IMPORT_DISCOVERED    = 2; // waiting for prep
  const static int IMPORT_PREPPING      = 3; // opening dirs on bounds
  const static int IMPORT_PREPPED       = 4; // opened bounds, waiting for import
  const static int IMPORT_LOGGINGSTART  = 5; // got import, logging EImportStart
  const static int IMPORT_ACKING        = 6; // logged EImportStart, sent ack, waiting for finish
  const static int IMPORT_FINISHING     = 7; // sent cap imports, waiting for finish
  const static int IMPORT_ABORTING      = 8; // notifying bystanders of an abort before unfreezing
  static const char *get_import_statename(int s) {
    switch (s) {
    case IMPORT_DISCOVERING: return "discovering";
    case IMPORT_DISCOVERED: return "discovered";
    case IMPORT_PREPPING: return "prepping";
    case IMPORT_PREPPED: return "prepped";
    case IMPORT_LOGGINGSTART: return "loggingstart";
    case IMPORT_ACKING: return "acking";
    case IMPORT_FINISHING: return "finishing";
    case IMPORT_ABORTING: return "aborting";
    default: ceph_abort(); return 0;
    }
  }

  // -- cons --
  Migrator(MDSRank *m, MDCache *c) : mds(m), cache(c) {}


protected:
  // export fun
  struct export_state_t {
    int state;
    mds_rank_t peer;
    uint64_t tid;
    set<mds_rank_t> warning_ack_waiting;
    set<mds_rank_t> notify_ack_waiting;
    map<inodeno_t,map<client_t,Capability::Import> > peer_imported;
    set<CDir*> residual_dirs;

    MutationRef mut;
    // for freeze tree deadlock detection
    utime_t last_cum_auth_pins_change;
    int last_cum_auth_pins;
    int num_remote_waiters; // number of remote authpin waiters
    export_state_t() : state(0), peer(0), tid(0), mut(),
		       last_cum_auth_pins(0), num_remote_waiters(0) {}
  };

  map<CDir*, export_state_t>  export_state;

  list<pair<dirfrag_t,mds_rank_t> >  export_queue;

  // import fun
  struct import_state_t {
    int state;
    mds_rank_t peer;
    uint64_t tid;
    set<mds_rank_t> bystanders;
    list<dirfrag_t> bound_ls;
    list<ScatterLock*> updated_scatterlocks;
    map<client_t,entity_inst_t> client_map;
    map<CInode*, map<client_t,Capability::Export> > peer_exports;
    MutationRef mut;
    import_state_t() : state(0), peer(0), tid(0), mut() {}
  };

  map<dirfrag_t, import_state_t>  import_state;

  void handle_export_discover_ack(MExportDirDiscoverAck *m);
  void export_frozen(CDir *dir, uint64_t tid);
  void check_export_size(CDir *dir, export_state_t& stat, set<client_t> &client_set);
  void handle_export_prep_ack(MExportDirPrepAck *m);
  void export_sessions_flushed(CDir *dir, uint64_t tid);
  void export_go(CDir *dir);
  void export_go_synced(CDir *dir, uint64_t tid);
  void export_try_cancel(CDir *dir, bool notify_peer=true);
  void export_cancel_finish(CDir *dir);
  void export_reverse(CDir *dir, export_state_t& stat);
  void export_notify_abort(CDir *dir, export_state_t& stat, set<CDir*>& bounds);
  void handle_export_ack(MExportDirAck *m);
  void export_logged_finish(CDir *dir);
  void handle_export_notify_ack(MExportDirNotifyAck *m);
  void export_finish(CDir *dir);

  void handle_gather_caps(MGatherCaps *m);

  friend class C_MDC_ExportFreeze;
  friend class C_MDS_ExportFinishLogged;
  friend class C_M_ExportGo;
  friend class C_M_ExportSessionsFlushed;
  friend class MigratorContext;
  friend class MigratorLogContext;

  // importer
  void handle_export_discover(MExportDirDiscover *m);
  void handle_export_cancel(MExportDirCancel *m);
  void handle_export_prep(MExportDirPrep *m);
  void handle_export_dir(MExportDir *m);

  void import_reverse_discovering(dirfrag_t df);
  void import_reverse_discovered(dirfrag_t df, CInode *diri);
  void import_reverse_prepping(CDir *dir, import_state_t& stat);
  void import_remove_pins(CDir *dir, set<CDir*>& bounds);
  void import_reverse_unfreeze(CDir *dir);
  void import_reverse_final(CDir *dir);
  void import_notify_abort(CDir *dir, set<CDir*>& bounds);
  void import_notify_finish(CDir *dir, set<CDir*>& bounds);
  void import_logged_start(dirfrag_t df, CDir *dir, mds_rank_t from,
			   map<client_t,entity_inst_t> &imported_client_map,
			   map<client_t,uint64_t>& sseqmap);
  void handle_export_finish(MExportDirFinish *m);

  void handle_export_caps(MExportCaps *m);
  void logged_import_caps(CInode *in,
			  mds_rank_t from,
			  map<CInode*, map<client_t,Capability::Export> >& cap_imports,
			  map<client_t,entity_inst_t>& client_map,
			  map<client_t,uint64_t>& sseqmap);


  friend class C_MDS_ImportDirLoggedStart;
  friend class C_MDS_ImportDirLoggedFinish;
  friend class C_M_LoggedImportCaps;

  // bystander
  void handle_export_notify(MExportDirNotify *m);


public:

  void dispatch(Message*);

  void show_importing();
  void show_exporting();

  int get_num_exporting() const { return export_state.size(); }
  int get_export_queue_size() const { return export_queue.size(); }
  
  // -- status --
  int is_exporting(CDir *dir) const {
    map<CDir*, export_state_t>::const_iterator it = export_state.find(dir);
    if (it != export_state.end()) return it->second.state;
    return 0;
  }
  bool is_exporting() const { return !export_state.empty(); }
  int is_importing(dirfrag_t df) const {
    map<dirfrag_t, import_state_t>::const_iterator it = import_state.find(df);
    if (it != import_state.end()) return it->second.state;
    return 0;
  }
  bool is_importing() const { return !import_state.empty(); }

  bool is_ambiguous_import(dirfrag_t df) const {
    map<dirfrag_t, import_state_t>::const_iterator p = import_state.find(df);
    if (p == import_state.end())
      return false;
    if (p->second.state >= IMPORT_LOGGINGSTART &&
	p->second.state < IMPORT_ABORTING)
      return true;
    return false;
  }

  int get_import_state(dirfrag_t df) const {
    map<dirfrag_t, import_state_t>::const_iterator it = import_state.find(df);
    assert(it != import_state.end());
    return it->second.state;
  }
  int get_import_peer(dirfrag_t df) const {
    map<dirfrag_t, import_state_t>::const_iterator it = import_state.find(df);
    assert(it != import_state.end());
    return it->second.peer;
  }

  int get_export_state(CDir *dir) const {
    map<CDir*, export_state_t>::const_iterator it = export_state.find(dir);
    assert(it != export_state.end());
    return it->second.state;
  }
  // this returns true if we are export @dir,
  // and are not waiting for @who to be
  // be warned of ambiguous auth.
  // only returns meaningful results during EXPORT_WARNING state.
  bool export_has_warned(CDir *dir, mds_rank_t who) {
    map<CDir*, export_state_t>::iterator it = export_state.find(dir);
    assert(it != export_state.end());
    assert(it->second.state == EXPORT_WARNING);
    return (it->second.warning_ack_waiting.count(who) == 0);
  }

  bool export_has_notified(CDir *dir, mds_rank_t who) const {
    map<CDir*, export_state_t>::const_iterator it = export_state.find(dir);
    assert(it != export_state.end());
    assert(it->second.state == EXPORT_NOTIFYING);
    return (it->second.notify_ack_waiting.count(who) == 0);
  }

  void export_freeze_inc_num_waiters(CDir *dir) {
    map<CDir*, export_state_t>::iterator it = export_state.find(dir);
    assert(it != export_state.end());
    it->second.num_remote_waiters++;
  }
  void find_stale_export_freeze();

  // -- misc --
  void handle_mds_failure_or_stop(mds_rank_t who);

  void audit();

  // -- import/export --
  // exporter
  void dispatch_export_dir(MDRequestRef& mdr, int count);
  void export_dir(CDir *dir, mds_rank_t dest);
  void export_empty_import(CDir *dir);

  void export_dir_nicely(CDir *dir, mds_rank_t dest);
  void maybe_do_queued_export();
  void clear_export_queue() {
    export_queue.clear();
  }
  
  void get_export_lock_set(CDir *dir, set<SimpleLock*>& locks);
  void get_export_client_set(CInode *in, set<client_t> &client_set);

  void encode_export_inode(CInode *in, bufferlist& bl, 
			   map<client_t,entity_inst_t>& exported_client_map);
  void encode_export_inode_caps(CInode *in, bool auth_cap, bufferlist& bl,
				map<client_t,entity_inst_t>& exported_client_map);
  void finish_export_inode(CInode *in, utime_t now, mds_rank_t target,
			   map<client_t,Capability::Import>& peer_imported,
			   list<MDSInternalContextBase*>& finished);
  void finish_export_inode_caps(CInode *in, mds_rank_t target,
			        map<client_t,Capability::Import>& peer_imported);


  uint64_t encode_export_dir(bufferlist& exportbl,
			CDir *dir,
			map<client_t,entity_inst_t>& exported_client_map,
			utime_t now);
  void finish_export_dir(CDir *dir, utime_t now, mds_rank_t target,
			 map<inodeno_t,map<client_t,Capability::Import> >& peer_imported,
			 list<MDSInternalContextBase*>& finished, int *num_dentries);

  void clear_export_proxy_pins(CDir *dir);

  void export_caps(CInode *in);

  void decode_import_inode(CDentry *dn, bufferlist::iterator& blp,
			   mds_rank_t oldauth, LogSegment *ls,
			   map<CInode*, map<client_t,Capability::Export> >& cap_imports,
			   list<ScatterLock*>& updated_scatterlocks);
  void decode_import_inode_caps(CInode *in, bool auth_cap, bufferlist::iterator &blp,
				map<CInode*, map<client_t,Capability::Export> >& cap_imports);
  void finish_import_inode_caps(CInode *in, mds_rank_t from, bool auth_cap,
				map<client_t,Capability::Export> &export_map,
				map<client_t,Capability::Import> &import_map);
  int decode_import_dir(bufferlist::iterator& blp,
			mds_rank_t oldauth,
			CDir *import_root,
			EImportStart *le, 
			LogSegment *ls,
			map<CInode*, map<client_t,Capability::Export> >& cap_imports,
			list<ScatterLock*>& updated_scatterlocks, utime_t now);

  void import_reverse(CDir *dir);

  void import_finish(CDir *dir, bool notify, bool last=true);

private:
  MDSRank *mds;
  MDCache *cache;
};

#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	* Handles the import and export of mds authorities and actual cache data.
	14	* See src/doc/exports.txt for a description.
	15	*/
	16
	17	#ifndef CEPH_MDS_MIGRATOR_H
	18	#define CEPH_MDS_MIGRATOR_H
	19
	20	#include "include/types.h"
	21
	22	#include <map>
	23	#include <list>
	24	#include <set>
	25	using std::map;
	26	using std::list;
	27	using std::set;
	28
	29
	30	class MDSRank;
	31	class CDir;
	32	class CInode;
	33	class CDentry;
	34
	35	class MExportDirDiscover;
	36	class MExportDirDiscoverAck;
	37	class MExportDirCancel;
	38	class MExportDirPrep;
	39	class MExportDirPrepAck;
	40	class MExportDir;
	41	class MExportDirAck;
	42	class MExportDirNotify;
	43	class MExportDirNotifyAck;
	44	class MExportDirFinish;
	45
	46	class MExportCaps;
	47	class MExportCapsAck;
	48	class MGatherCaps;
	49
	50	class EImportStart;
	51
	52	class Migrator {
	53	public:
	54	// export stages. used to clean up intelligently if there's a failure.
	55	const static int EXPORT_CANCELLED = 0; // cancelled
	56	const static int EXPORT_CANCELLING = 1; // waiting for cancel notifyacks
	57	const static int EXPORT_LOCKING = 2; // acquiring locks
	58	const static int EXPORT_DISCOVERING = 3; // dest is disovering export dir
	59	const static int EXPORT_FREEZING = 4; // we're freezing the dir tree
	60	const static int EXPORT_PREPPING = 5; // sending dest spanning tree to export bounds
	61	const static int EXPORT_WARNING = 6; // warning bystanders of dir_auth_pending
	62	const static int EXPORT_EXPORTING = 7; // sent actual export, waiting for ack
	63	const static int EXPORT_LOGGINGFINISH = 8; // logging EExportFinish
	64	const static int EXPORT_NOTIFYING = 9; // waiting for notifyacks
65	static const char *get_export_statename(int s) {
66	switch (s) {
67	case EXPORT_CANCELLING: return "cancelling";
68	case EXPORT_LOCKING: return "locking";
69	case EXPORT_DISCOVERING: return "discovering";
70	case EXPORT_FREEZING: return "freezing";
71	case EXPORT_PREPPING: return "prepping";
72	case EXPORT_WARNING: return "warning";
73	case EXPORT_EXPORTING: return "exporting";
74	case EXPORT_LOGGINGFINISH: return "loggingfinish";
75	case EXPORT_NOTIFYING: return "notifying";
76	default: ceph_abort(); return 0;
77	}
78	}
79
80	// -- imports --
81	const static int IMPORT_DISCOVERING = 1; // waiting for prep
82	const static int IMPORT_DISCOVERED = 2; // waiting for prep
83	const static int IMPORT_PREPPING = 3; // opening dirs on bounds
84	const static int IMPORT_PREPPED = 4; // opened bounds, waiting for import
85	const static int IMPORT_LOGGINGSTART = 5; // got import, logging EImportStart
86	const static int IMPORT_ACKING = 6; // logged EImportStart, sent ack, waiting for finish
87	const static int IMPORT_FINISHING = 7; // sent cap imports, waiting for finish
88	const static int IMPORT_ABORTING = 8; // notifying bystanders of an abort before unfreezing
89	static const char *get_import_statename(int s) {
90	switch (s) {
91	case IMPORT_DISCOVERING: return "discovering";
92	case IMPORT_DISCOVERED: return "discovered";
93	case IMPORT_PREPPING: return "prepping";
94	case IMPORT_PREPPED: return "prepped";
95	case IMPORT_LOGGINGSTART: return "loggingstart";
96	case IMPORT_ACKING: return "acking";
97	case IMPORT_FINISHING: return "finishing";
98	case IMPORT_ABORTING: return "aborting";
99	default: ceph_abort(); return 0;
100	}
101	}
102
103	// -- cons --
104	Migrator(MDSRank m, MDCache c) : mds(m), cache(c) {}
105
106
107
108	protected:
109	// export fun
110	struct export_state_t {
111	int state;
112	mds_rank_t peer;
113	uint64_t tid;
114	set<mds_rank_t> warning_ack_waiting;
115	set<mds_rank_t> notify_ack_waiting;
116	map<inodeno_t,map<client_t,Capability::Import> > peer_imported;
b32b8144 FG	117	set<CDir*> residual_dirs;
b32b8144 FG	118
7c673cae FG	119	MutationRef mut;
	120	// for freeze tree deadlock detection
	121	utime_t last_cum_auth_pins_change;
	122	int last_cum_auth_pins;
	123	int num_remote_waiters; // number of remote authpin waiters
	124	export_state_t() : state(0), peer(0), tid(0), mut(),
	125	last_cum_auth_pins(0), num_remote_waiters(0) {}
	126	};
	127
	128	map<CDir*, export_state_t> export_state;
	129
	130	list<pair<dirfrag_t,mds_rank_t> > export_queue;
	131
	132	// import fun
	133	struct import_state_t {
	134	int state;
	135	mds_rank_t peer;
	136	uint64_t tid;
	137	set<mds_rank_t> bystanders;
	138	list<dirfrag_t> bound_ls;
	139	list<ScatterLock*> updated_scatterlocks;
	140	map<client_t,entity_inst_t> client_map;
	141	map<CInode*, map<client_t,Capability::Export> > peer_exports;
	142	MutationRef mut;
	143	import_state_t() : state(0), peer(0), tid(0), mut() {}
	144	};
	145
	146	map<dirfrag_t, import_state_t> import_state;
	147
	148	void handle_export_discover_ack(MExportDirDiscoverAck *m);
	149	void export_frozen(CDir *dir, uint64_t tid);
b32b8144	150	void check_export_size(CDir *dir, export_state_t& stat, set<client_t> &client_set);
7c673cae FG	151	void handle_export_prep_ack(MExportDirPrepAck *m);
	152	void export_sessions_flushed(CDir *dir, uint64_t tid);
	153	void export_go(CDir *dir);
	154	void export_go_synced(CDir *dir, uint64_t tid);
	155	void export_try_cancel(CDir *dir, bool notify_peer=true);
	156	void export_cancel_finish(CDir *dir);
b32b8144 FG	157	void export_reverse(CDir *dir, export_state_t& stat);
b32b8144 FG	158	void export_notify_abort(CDir dir, export_state_t& stat, set<CDir>& bounds);
7c673cae FG	159	void handle_export_ack(MExportDirAck *m);
	160	void export_logged_finish(CDir *dir);
	161	void handle_export_notify_ack(MExportDirNotifyAck *m);
	162	void export_finish(CDir *dir);
	163
	164	void handle_gather_caps(MGatherCaps *m);
	165
	166	friend class C_MDC_ExportFreeze;
	167	friend class C_MDS_ExportFinishLogged;
	168	friend class C_M_ExportGo;
	169	friend class C_M_ExportSessionsFlushed;
	170	friend class MigratorContext;
	171	friend class MigratorLogContext;
	172
	173	// importer
	174	void handle_export_discover(MExportDirDiscover *m);
	175	void handle_export_cancel(MExportDirCancel *m);
	176	void handle_export_prep(MExportDirPrep *m);
	177	void handle_export_dir(MExportDir *m);
	178
	179	void import_reverse_discovering(dirfrag_t df);
	180	void import_reverse_discovered(dirfrag_t df, CInode *diri);
b32b8144	181	void import_reverse_prepping(CDir *dir, import_state_t& stat);
7c673cae FG	182	void import_remove_pins(CDir dir, set<CDir>& bounds);
	183	void import_reverse_unfreeze(CDir *dir);
	184	void import_reverse_final(CDir *dir);
	185	void import_notify_abort(CDir dir, set<CDir>& bounds);
	186	void import_notify_finish(CDir dir, set<CDir>& bounds);
	187	void import_logged_start(dirfrag_t df, CDir *dir, mds_rank_t from,
	188	map<client_t,entity_inst_t> &imported_client_map,
	189	map<client_t,uint64_t>& sseqmap);
	190	void handle_export_finish(MExportDirFinish *m);
	191
	192	void handle_export_caps(MExportCaps *m);
	193	void logged_import_caps(CInode *in,
	194	mds_rank_t from,
	195	map<CInode*, map<client_t,Capability::Export> >& cap_imports,
	196	map<client_t,entity_inst_t>& client_map,
	197	map<client_t,uint64_t>& sseqmap);
	198
	199
	200	friend class C_MDS_ImportDirLoggedStart;
	201	friend class C_MDS_ImportDirLoggedFinish;
	202	friend class C_M_LoggedImportCaps;
	203
	204	// bystander
	205	void handle_export_notify(MExportDirNotify *m);
	206
	207
	208	public:
	209
	210	void dispatch(Message*);
	211
	212	void show_importing();
	213	void show_exporting();
	214
	215	int get_num_exporting() const { return export_state.size(); }
	216	int get_export_queue_size() const { return export_queue.size(); }
	217
	218	// -- status --
	219	int is_exporting(CDir *dir) const {
	220	map<CDir*, export_state_t>::const_iterator it = export_state.find(dir);
	221	if (it != export_state.end()) return it->second.state;
	222	return 0;
	223	}
	224	bool is_exporting() const { return !export_state.empty(); }
	225	int is_importing(dirfrag_t df) const {
	226	map<dirfrag_t, import_state_t>::const_iterator it = import_state.find(df);
	227	if (it != import_state.end()) return it->second.state;
	228	return 0;
	229	}
	230	bool is_importing() const { return !import_state.empty(); }
	231
	232	bool is_ambiguous_import(dirfrag_t df) const {
	233	map<dirfrag_t, import_state_t>::const_iterator p = import_state.find(df);
	234	if (p == import_state.end())
	235	return false;
	236	if (p->second.state >= IMPORT_LOGGINGSTART &&
	237	p->second.state < IMPORT_ABORTING)
	238	return true;
	239	return false;
	240	}
	241
	242	int get_import_state(dirfrag_t df) const {
	243	map<dirfrag_t, import_state_t>::const_iterator it = import_state.find(df);
	244	assert(it != import_state.end());
	245	return it->second.state;
246	}
247	int get_import_peer(dirfrag_t df) const {
248	map<dirfrag_t, import_state_t>::const_iterator it = import_state.find(df);
249	assert(it != import_state.end());
250	return it->second.peer;
251	}
252
253	int get_export_state(CDir *dir) const {
254	map<CDir*, export_state_t>::const_iterator it = export_state.find(dir);
255	assert(it != export_state.end());
256	return it->second.state;
257	}
258	// this returns true if we are export @dir,
259	// and are not waiting for @who to be
260	// be warned of ambiguous auth.
261	// only returns meaningful results during EXPORT_WARNING state.
262	bool export_has_warned(CDir *dir, mds_rank_t who) {
263	map<CDir*, export_state_t>::iterator it = export_state.find(dir);
264	assert(it != export_state.end());
265	assert(it->second.state == EXPORT_WARNING);
266	return (it->second.warning_ack_waiting.count(who) == 0);
267	}
268
269	bool export_has_notified(CDir *dir, mds_rank_t who) const {
270	map<CDir*, export_state_t>::const_iterator it = export_state.find(dir);
271	assert(it != export_state.end());
272	assert(it->second.state == EXPORT_NOTIFYING);
273	return (it->second.notify_ack_waiting.count(who) == 0);
274	}
275
276	void export_freeze_inc_num_waiters(CDir *dir) {
277	map<CDir*, export_state_t>::iterator it = export_state.find(dir);
278	assert(it != export_state.end());
279	it->second.num_remote_waiters++;
280	}
281	void find_stale_export_freeze();
282
283	// -- misc --
284	void handle_mds_failure_or_stop(mds_rank_t who);
285
286	void audit();
287
288	// -- import/export --
289	// exporter
290	void dispatch_export_dir(MDRequestRef& mdr, int count);
291	void export_dir(CDir *dir, mds_rank_t dest);
292	void export_empty_import(CDir *dir);
293
294	void export_dir_nicely(CDir *dir, mds_rank_t dest);
295	void maybe_do_queued_export();
296	void clear_export_queue() {
297	export_queue.clear();
298	}
299
300	void get_export_lock_set(CDir dir, set<SimpleLock>& locks);
7c673cae FG	301	void get_export_client_set(CInode *in, set<client_t> &client_set);
	302
	303	void encode_export_inode(CInode *in, bufferlist& bl,
	304	map<client_t,entity_inst_t>& exported_client_map);
	305	void encode_export_inode_caps(CInode *in, bool auth_cap, bufferlist& bl,
	306	map<client_t,entity_inst_t>& exported_client_map);
	307	void finish_export_inode(CInode *in, utime_t now, mds_rank_t target,
	308	map<client_t,Capability::Import>& peer_imported,
	309	list<MDSInternalContextBase*>& finished);
	310	void finish_export_inode_caps(CInode *in, mds_rank_t target,
	311	map<client_t,Capability::Import>& peer_imported);
	312
	313
	314	uint64_t encode_export_dir(bufferlist& exportbl,
	315	CDir *dir,
	316	map<client_t,entity_inst_t>& exported_client_map,
	317	utime_t now);
	318	void finish_export_dir(CDir *dir, utime_t now, mds_rank_t target,
	319	map<inodeno_t,map<client_t,Capability::Import> >& peer_imported,
	320	list<MDSInternalContextBase>& finished, int num_dentries);
	321
	322	void clear_export_proxy_pins(CDir *dir);
	323
	324	void export_caps(CInode *in);
	325
	326	void decode_import_inode(CDentry *dn, bufferlist::iterator& blp,
	327	mds_rank_t oldauth, LogSegment *ls,
	328	map<CInode*, map<client_t,Capability::Export> >& cap_imports,
	329	list<ScatterLock*>& updated_scatterlocks);
	330	void decode_import_inode_caps(CInode *in, bool auth_cap, bufferlist::iterator &blp,
	331	map<CInode*, map<client_t,Capability::Export> >& cap_imports);
	332	void finish_import_inode_caps(CInode *in, mds_rank_t from, bool auth_cap,
	333	map<client_t,Capability::Export> &export_map,
	334	map<client_t,Capability::Import> &import_map);
	335	int decode_import_dir(bufferlist::iterator& blp,
	336	mds_rank_t oldauth,
	337	CDir *import_root,
	338	EImportStart *le,
	339	LogSegment *ls,
	340	map<CInode*, map<client_t,Capability::Export> >& cap_imports,
	341	list<ScatterLock*>& updated_scatterlocks, utime_t now);
	342
	343	void import_reverse(CDir *dir);
	344
	345	void import_finish(CDir *dir, bool notify, bool last=true);
	346
	347	private:
	348	MDSRank *mds;
	349	MDCache *cache;
	350	};
	351
	352	#endif