]>
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) 2012 Inktank, Inc. | |
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 | #ifndef CEPH_MMONSYNC_H | |
14 | #define CEPH_MMONSYNC_H | |
15 | ||
16 | #include "msg/Message.h" | |
17 | ||
18 | class MMonSync : public Message | |
19 | { | |
20 | static const int HEAD_VERSION = 2; | |
21 | static const int COMPAT_VERSION = 2; | |
22 | ||
23 | public: | |
24 | /** | |
25 | * Operation types | |
26 | */ | |
27 | enum { | |
28 | OP_GET_COOKIE_FULL = 1, // -> start a session (full scan) | |
29 | OP_GET_COOKIE_RECENT = 2, // -> start a session (only recent paxos events) | |
30 | OP_COOKIE = 3, // <- pass the iterator cookie, or | |
31 | OP_GET_CHUNK = 4, // -> get some keys | |
32 | OP_CHUNK = 5, // <- return some keys | |
33 | OP_LAST_CHUNK = 6, // <- return the last set of keys | |
34 | OP_NO_COOKIE = 8, // <- sorry, no cookie | |
35 | }; | |
36 | ||
37 | /** | |
38 | * Obtain a string corresponding to the operation type @p op | |
39 | * | |
40 | * @param op Operation type | |
41 | * @returns A string | |
42 | */ | |
43 | static const char *get_opname(int op) { | |
44 | switch (op) { | |
45 | case OP_GET_COOKIE_FULL: return "get_cookie_full"; | |
46 | case OP_GET_COOKIE_RECENT: return "get_cookie_recent"; | |
47 | case OP_COOKIE: return "cookie"; | |
48 | case OP_GET_CHUNK: return "get_chunk"; | |
49 | case OP_CHUNK: return "chunk"; | |
50 | case OP_LAST_CHUNK: return "last_chunk"; | |
51 | case OP_NO_COOKIE: return "no_cookie"; | |
52 | default: assert(0 == "unknown op type"); return NULL; | |
53 | } | |
54 | } | |
55 | ||
56 | uint32_t op; | |
57 | uint64_t cookie; | |
58 | version_t last_committed; | |
59 | pair<string,string> last_key; | |
60 | bufferlist chunk_bl; | |
61 | entity_inst_t reply_to; | |
62 | ||
63 | MMonSync() | |
64 | : Message(MSG_MON_SYNC, HEAD_VERSION, COMPAT_VERSION) | |
65 | { } | |
66 | ||
67 | MMonSync(uint32_t op, uint64_t c = 0) | |
68 | : Message(MSG_MON_SYNC, HEAD_VERSION, COMPAT_VERSION), | |
69 | op(op), | |
70 | cookie(c), | |
71 | last_committed(0) | |
72 | { } | |
73 | ||
74 | const char *get_type_name() const override { return "mon_sync"; } | |
75 | ||
76 | void print(ostream& out) const override { | |
77 | out << "mon_sync(" << get_opname(op); | |
78 | if (cookie) | |
79 | out << " cookie " << cookie; | |
80 | if (last_committed > 0) | |
81 | out << " lc " << last_committed; | |
82 | if (chunk_bl.length()) | |
83 | out << " bl " << chunk_bl.length() << " bytes"; | |
84 | if (!last_key.first.empty() || !last_key.second.empty()) | |
85 | out << " last_key " << last_key.first << "," << last_key.second; | |
86 | out << ")"; | |
87 | } | |
88 | ||
89 | void encode_payload(uint64_t features) override { | |
90 | ::encode(op, payload); | |
91 | ::encode(cookie, payload); | |
92 | ::encode(last_committed, payload); | |
93 | ::encode(last_key.first, payload); | |
94 | ::encode(last_key.second, payload); | |
95 | ::encode(chunk_bl, payload); | |
96 | ::encode(reply_to, payload, features); | |
97 | } | |
98 | ||
99 | void decode_payload() override { | |
100 | bufferlist::iterator p = payload.begin(); | |
101 | ::decode(op, p); | |
102 | ::decode(cookie, p); | |
103 | ::decode(last_committed, p); | |
104 | ::decode(last_key.first, p); | |
105 | ::decode(last_key.second, p); | |
106 | ::decode(chunk_bl, p); | |
107 | ::decode(reply_to, p); | |
108 | } | |
109 | }; | |
110 | ||
111 | #endif /* CEPH_MMONSYNC_H */ |