1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 * Ceph - scalable distributed file system
6 * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
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.
15 #ifndef CEPH_LOGSEGMENT_H
16 #define CEPH_LOGSEGMENT_H
18 #include "include/elist.h"
19 #include "include/interval_set.h"
20 #include "include/Context.h"
25 #include "MDSContext.h"
27 #include "include/unordered_set.h"
28 using ceph::unordered_set;
36 typedef uint64_t log_segment_seq_t;
40 const log_segment_seq_t seq;
45 elist<CDir*> dirty_dirfrags, new_dirfrags;
46 elist<CInode*> dirty_inodes;
47 elist<CDentry*> dirty_dentries;
49 elist<CInode*> open_files;
50 elist<CInode*> dirty_parent_inodes;
51 elist<CInode*> dirty_dirfrag_dir;
52 elist<CInode*> dirty_dirfrag_nest;
53 elist<CInode*> dirty_dirfrag_dirfragtree;
55 elist<MDSlaveUpdate*> slave_updates;
57 set<CInode*> truncating_inodes;
59 map<int, ceph::unordered_set<version_t> > pending_commit_tids; // mdstable
60 set<metareqid_t> uncommitted_masters;
61 set<dirfrag_t> uncommitted_fragments;
64 map<int, ceph_tid_t> last_client_tids;
66 // potentially dirty sessions
67 std::set<entity_name_t> touched_sessions;
71 version_t sessionmapv;
72 map<int,version_t> tablev;
75 void try_to_expire(MDSRank *mds, MDSGatherBuilder &gather_bld, int op_prio);
77 std::list<MDSInternalContextBase*> expiry_waiters;
79 void wait_for_expiry(MDSInternalContextBase *c)
82 expiry_waiters.push_back(c);
86 LogSegment(uint64_t _seq, loff_t off=-1) :
87 seq(_seq), offset(off), end(off), num_events(0),
88 dirty_dirfrags(member_offset(CDir, item_dirty)),
89 new_dirfrags(member_offset(CDir, item_new)),
90 dirty_inodes(member_offset(CInode, item_dirty)),
91 dirty_dentries(member_offset(CDentry, item_dirty)),
92 open_files(member_offset(CInode, item_open_file)),
93 dirty_parent_inodes(member_offset(CInode, item_dirty_parent)),
94 dirty_dirfrag_dir(member_offset(CInode, item_dirty_dirfrag_dir)),
95 dirty_dirfrag_nest(member_offset(CInode, item_dirty_dirfrag_nest)),
96 dirty_dirfrag_dirfragtree(member_offset(CInode, item_dirty_dirfrag_dirfragtree)),
97 slave_updates(0), // passed to begin() manually
98 inotablev(0), sessionmapv(0)