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.
20 #include "osdc/Filer.h"
22 #include "include/types.h"
24 #include "common/config.h"
25 #include "common/errno.h"
26 #include "common/Finisher.h"
28 #include "include/assert.h"
31 #define dout_context g_ceph_context
32 #define dout_subsys ceph_subsys_mds
34 #define dout_prefix *_dout << "mds." << rank << "." << table_name << ": "
37 class MDSTableIOContext : public MDSIOContextBase
41 MDSRank *get_mds() override {return ida->mds;}
43 explicit MDSTableIOContext(MDSTable *ida_) : ida(ida_) {
49 class C_IO_MT_Save : public MDSTableIOContext {
52 C_IO_MT_Save(MDSTable *i, version_t v) : MDSTableIOContext(i), version(v) {}
53 void finish(int r) override {
54 ida->save_2(r, version);
58 void MDSTable::save(MDSInternalContextBase *onfinish, version_t v)
60 if (v > 0 && v <= committing_version) {
61 dout(10) << "save v " << version << " - already saving "
62 << committing_version << " >= needed " << v << dendl;
63 waitfor_save[v].push_back(onfinish);
67 dout(10) << "save v " << version << dendl;
71 ::encode(version, bl);
74 committing_version = version;
77 waitfor_save[version].push_back(onfinish);
81 object_t oid = get_object_name();
82 object_locator_t oloc(mds->mdsmap->get_metadata_pool());
83 mds->objecter->write_full(oid, oloc,
85 bl, ceph::real_clock::now(), 0,
86 new C_OnFinisher(new C_IO_MT_Save(this, version),
90 void MDSTable::save_2(int r, version_t v)
93 dout(1) << "save error " << r << " v " << v << dendl;
94 mds->clog->error() << "failed to store table " << table_name << " object,"
96 mds->handle_write_error(r);
100 dout(10) << "save_2 v " << v << dendl;
101 committed_version = v;
103 list<MDSInternalContextBase*> ls;
104 while (!waitfor_save.empty()) {
105 if (waitfor_save.begin()->first > v) break;
106 ls.splice(ls.end(), waitfor_save.begin()->second);
107 waitfor_save.erase(waitfor_save.begin());
109 finish_contexts(g_ceph_context, ls,0);
113 void MDSTable::reset()
116 state = STATE_ACTIVE;
121 // -----------------------
123 class C_IO_MT_Load : public MDSTableIOContext {
127 C_IO_MT_Load(MDSTable *i, Context *o) : MDSTableIOContext(i), onfinish(o) {}
128 void finish(int r) override {
129 ida->load_2(r, bl, onfinish);
133 object_t MDSTable::get_object_name() const
137 snprintf(n, sizeof(n), "mds%d_%s", int(mds->get_nodeid()), table_name);
139 snprintf(n, sizeof(n), "mds_%s", table_name);
143 void MDSTable::load(MDSInternalContextBase *onfinish)
145 dout(10) << "load" << dendl;
148 state = STATE_OPENING;
150 C_IO_MT_Load *c = new C_IO_MT_Load(this, onfinish);
151 object_t oid = get_object_name();
152 object_locator_t oloc(mds->mdsmap->get_metadata_pool());
153 mds->objecter->read_full(oid, oloc, CEPH_NOSNAP, &c->bl, 0,
154 new C_OnFinisher(c, mds->finisher));
157 void MDSTable::load_2(int r, bufferlist& bl, Context *onfinish)
159 assert(is_opening());
160 state = STATE_ACTIVE;
161 if (r == -EBLACKLISTED) {
166 derr << "load_2 could not read table: " << r << dendl;
167 mds->clog->error() << "error reading table object '" << get_object_name()
168 << "' " << r << " (" << cpp_strerror(r) << ")";
170 assert(r >= 0); // Should be unreachable because damaged() calls respawn()
173 dout(10) << "load_2 got " << bl.length() << " bytes" << dendl;
174 bufferlist::iterator p = bl.begin();
177 ::decode(version, p);
178 projected_version = committed_version = version;
179 dout(10) << "load_2 loaded v" << version << dendl;
181 } catch (buffer::error &e) {
182 mds->clog->error() << "error decoding table object '" << get_object_name()
183 << "': " << e.what();
185 assert(r >= 0); // Should be unreachable because damaged() calls respawn()
189 onfinish->complete(0);