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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#ifndef CEPH_CLS_QUEUE_TYPES_H
#define CEPH_CLS_QUEUE_TYPES_H
#include <errno.h>
#include "include/types.h"
//Size of head leaving out urgent data
#define QUEUE_HEAD_SIZE_1K 1024
#define QUEUE_START_OFFSET_1K QUEUE_HEAD_SIZE_1K
constexpr unsigned int QUEUE_HEAD_START = 0xDEAD;
constexpr unsigned int QUEUE_ENTRY_START = 0xBEEF;
constexpr unsigned int QUEUE_ENTRY_OVERHEAD = sizeof(uint16_t) + sizeof(uint64_t);
struct cls_queue_entry
{
ceph::buffer::list data;
std::string marker;
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(data, bl);
encode(marker, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(data, bl);
decode(marker, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_queue_entry)
struct cls_queue_marker
{
uint64_t offset{0};
uint64_t gen{0};
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(gen, bl);
encode(offset, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(gen, bl);
decode(offset, bl);
DECODE_FINISH(bl);
}
std::string to_str() {
return std::to_string(gen) + '/' + std::to_string(offset);
}
int from_str(const char* str) {
errno = 0;
char* end = nullptr;
gen = ::strtoull(str, &end, 10);
if (errno) {
return errno;
}
if (str == end || *end != '/') { // expects delimiter
return -EINVAL;
}
str = end + 1;
offset = ::strtoull(str, &end, 10);
if (errno) {
return errno;
}
if (str == end || *end != 0) { // expects null terminator
return -EINVAL;
}
return 0;
}
};
WRITE_CLASS_ENCODER(cls_queue_marker)
struct cls_queue_head
{
uint64_t max_head_size = QUEUE_HEAD_SIZE_1K;
cls_queue_marker front{QUEUE_START_OFFSET_1K, 0};
cls_queue_marker tail{QUEUE_START_OFFSET_1K, 0};
uint64_t queue_size{0}; // size of queue requested by user, with head size added to it
uint64_t max_urgent_data_size{0};
ceph::buffer::list bl_urgent_data; // special data known to application using queue
void encode(ceph::buffer::list& bl) const {
ENCODE_START(1, 1, bl);
encode(max_head_size, bl);
encode(front, bl);
encode(tail, bl);
encode(queue_size, bl);
encode(max_urgent_data_size, bl);
encode(bl_urgent_data, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
DECODE_START(1, bl);
decode(max_head_size, bl);
decode(front, bl);
decode(tail, bl);
decode(queue_size, bl);
decode(max_urgent_data_size, bl);
decode(bl_urgent_data, bl);
DECODE_FINISH(bl);
}
};
WRITE_CLASS_ENCODER(cls_queue_head)
#endif
|
