version_t tid;
version_t version;
- ETableServer() : LogEvent(EVENT_TABLESERVER) { }
+ ETableServer() : LogEvent(EVENT_TABLESERVER), table(0), op(0),
+ reqid(0), bymds(0), tid(0), version(0) { }
ETableServer(int t, int o, uint64_t ri, int m, version_t ti, version_t v) :
LogEvent(EVENT_TABLESERVER),
table(t), op(o), reqid(ri), bymds(m), tid(ti), version(v) { }
- void encode(bufferlist& bl) const {
- ENCODE_START(3, 3, bl);
- ::encode(stamp, bl);
- ::encode(table, bl);
- ::encode(op, bl);
- ::encode(reqid, bl);
- ::encode(bymds, bl);
- ::encode(mutation, bl);
- ::encode(tid, bl);
- ::encode(version, bl);
- ENCODE_FINISH(bl);
- }
- void decode(bufferlist::iterator &bl) {
- DECODE_START_LEGACY_COMPAT_LEN(3, 3, 3, bl);
- if (struct_v >= 2)
- ::decode(stamp, bl);
- ::decode(table, bl);
- ::decode(op, bl);
- ::decode(reqid, bl);
- ::decode(bymds, bl);
- ::decode(mutation, bl);
- ::decode(tid, bl);
- ::decode(version, bl);
- DECODE_FINISH(bl);
- }
+ void encode(bufferlist& bl) const;
+ void decode(bufferlist::iterator& bl);
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ETableServer*>& ls);
void print(ostream& out) {
out << "ETableServer " << get_mdstable_name(table)
}
+// -----------------------
+// ETableServer
+
+void ETableServer::encode(bufferlist& bl) const
+{
+ ENCODE_START(3, 3, bl);
+ ::encode(stamp, bl);
+ ::encode(table, bl);
+ ::encode(op, bl);
+ ::encode(reqid, bl);
+ ::encode(bymds, bl);
+ ::encode(mutation, bl);
+ ::encode(tid, bl);
+ ::encode(version, bl);
+ ENCODE_FINISH(bl);
+}
+
+void ETableServer::decode(bufferlist::iterator &bl)
+{
+ DECODE_START_LEGACY_COMPAT_LEN(3, 3, 3, bl);
+ if (struct_v >= 2)
+ ::decode(stamp, bl);
+ ::decode(table, bl);
+ ::decode(op, bl);
+ ::decode(reqid, bl);
+ ::decode(bymds, bl);
+ ::decode(mutation, bl);
+ ::decode(tid, bl);
+ ::decode(version, bl);
+ DECODE_FINISH(bl);
+}
+
+void ETableServer::dump(Formatter *f) const
+{
+ f->dump_int("table id", table);
+ f->dump_int("op", op);
+ f->dump_int("request id", reqid);
+ f->dump_int("by mds", bymds);
+ f->dump_int("tid", tid);
+ f->dump_int("version", version);
+}
+
+void ETableServer::generate_test_instances(list<ETableServer*>& ls)
+{
+ ls.push_back(new ETableServer());
+}
void ETableServer::update_segment()