1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include "include/types.h"
#include "cls_2pc_queue_types.h"
struct cls_2pc_queue_reserve_op {
uint64_t size;
uint32_t entries;
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(size, bl);
encode(entries, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(size, bl);
decode(entries, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_reserve_op)
struct cls_2pc_queue_reserve_ret {
cls_2pc_reservation::id_t id; // allocated reservation id
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(id, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(id, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_reserve_ret)
struct cls_2pc_queue_commit_op {
cls_2pc_reservation::id_t id; // reservation to commit
std::vector<ceph::buffer::list> bl_data_vec; // the data to enqueue
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(id, bl);
encode(bl_data_vec, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(id, bl);
decode(bl_data_vec, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_commit_op)
struct cls_2pc_queue_abort_op {
cls_2pc_reservation::id_t id; // reservation to abort
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(id, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(id, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_abort_op)
struct cls_2pc_queue_expire_op {
// any reservation older than this time should expire
ceph::coarse_real_time stale_time;
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(stale_time, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(stale_time, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_expire_op)
struct cls_2pc_queue_reservations_ret {
cls_2pc_reservations reservations; // reservation list (keyed by id)
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(reservations, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(reservations, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_reservations_ret)
struct cls_2pc_queue_remove_op {
std::string end_marker;
uint32_t entries_to_remove = 0;
cls_2pc_queue_remove_op() {}
void encode(ceph::buffer::list& bl) const {
ENCODE_START(2, 1, bl);
encode(end_marker, bl);
encode(entries_to_remove, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(2, bl);
decode(end_marker, bl);
if (struct_v > 1) {
decode(entries_to_remove, bl);
}
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_2pc_queue_remove_op)
|
