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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "journal/Entry.h"
#include "gtest/gtest.h"
class TestEntry : public ::testing::Test {
};
TEST_F(TestEntry, DefaultConstructor) {
journal::Entry entry;
ASSERT_EQ(0U, entry.get_entry_tid());
ASSERT_EQ(0U, entry.get_tag_tid());
bufferlist data(entry.get_data());
bufferlist expected_data;
ASSERT_TRUE(data.contents_equal(expected_data));
}
TEST_F(TestEntry, Constructor) {
bufferlist data;
data.append("data");
journal::Entry entry(234, 123, data);
data.clear();
data = entry.get_data();
bufferlist expected_data;
expected_data.append("data");
ASSERT_EQ(123U, entry.get_entry_tid());
ASSERT_EQ(234U, entry.get_tag_tid());
ASSERT_TRUE(data.contents_equal(expected_data));
}
TEST_F(TestEntry, IsReadable) {
bufferlist data;
data.append("data");
journal::Entry entry(234, 123, data);
bufferlist full_bl;
encode(entry, full_bl);
uint32_t bytes_needed;
for (size_t i = 0; i < full_bl.length() - 1; ++i) {
bufferlist partial_bl;
if (i > 0) {
partial_bl.substr_of(full_bl, 0, i);
}
ASSERT_FALSE(journal::Entry::is_readable(partial_bl.begin(),
&bytes_needed));
ASSERT_GT(bytes_needed, 0U);
}
ASSERT_TRUE(journal::Entry::is_readable(full_bl.begin(), &bytes_needed));
ASSERT_EQ(0U, bytes_needed);
}
TEST_F(TestEntry, IsReadableBadPreamble) {
bufferlist data;
data.append("data");
journal::Entry entry(234, 123, data);
uint64_t stray_bytes = 0x1122334455667788;
bufferlist full_bl;
encode(stray_bytes, full_bl);
encode(entry, full_bl);
uint32_t bytes_needed;
bufferlist::iterator it = full_bl.begin();
ASSERT_FALSE(journal::Entry::is_readable(it, &bytes_needed));
ASSERT_EQ(0U, bytes_needed);
it.advance(sizeof(stray_bytes));
ASSERT_TRUE(journal::Entry::is_readable(it, &bytes_needed));
ASSERT_EQ(0U, bytes_needed);
}
TEST_F(TestEntry, IsReadableBadCRC) {
bufferlist data;
data.append("data");
journal::Entry entry(234, 123, data);
bufferlist full_bl;
encode(entry, full_bl);
bufferlist bad_bl;
bad_bl.substr_of(full_bl, 0, full_bl.length() - 4);
encode(full_bl.crc32c(1), bad_bl);
uint32_t bytes_needed;
ASSERT_FALSE(journal::Entry::is_readable(bad_bl.begin(), &bytes_needed));
ASSERT_EQ(0U, bytes_needed);
}
|
