clang -cc1 -triple x86_64-unknown-linux-gnu -fsyntax-only -disable-free -main-file-name iterator.cpp -mrelocation-model pic -pic-level 2 -mthread-model posix -mdisable-fp-elim -fmath-errno -masm-verbose -mconstructor-aliases -munwind-tables -fuse-init-array -target-cpu x86-64 -dwarf-column-info -debug-info-kind=limited -dwarf-version=4 -debugger-tuning=gdb -momit-leaf-frame-pointer -ffunction-sections -fdata-sections -resource-dir /home/alan/workspace/canalyze/llvm/sprinter/build/bin/resources -isystem /home/alan/workspace/canalyze/llvm/sprinter/build/bin/resources/include -isystem /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/extra/rapidjson/include -isystem /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/extra/lz4 -isystem /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/extra/libedit/libedit-20190324-3.1/src/editline -isystem /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/extra/zstd/lib -isystem /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/build/extra/zlib -isystem /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/extra/zlib -I /home/alan/workspace/canalyze/llvm/sprinter/build/bin/resources/include -D HAVE_CONFIG_H -D HAVE_TLSv13 -D LZ4_DISABLE_DEPRECATE_WARNINGS -D RAPIDJSON_NO_SIZETYPEDEFINE -D RAPIDJSON_SCHEMA_USE_INTERNALREGEX=0 -D RAPIDJSON_SCHEMA_USE_STDREGEX=1 -D _FILE_OFFSET_BITS=64 -D _GNU_SOURCE -D _USE_MATH_DEFINES -D __STDC_FORMAT_MACROS -D __STDC_LIMIT_MACROS -I /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/build -I /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/build/include -I /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server -I /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/include -I /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/libbinlogevents/include -D DBUG_OFF -D NDEBUG -internal-isystem /usr/bin/../lib/gcc/x86_64-linux-gnu/10/../../../../include/c++/10 -internal-isystem /usr/bin/../lib/gcc/x86_64-linux-gnu/10/../../../../include/x86_64-linux-gnu/c++/10 -internal-isystem /usr/bin/../lib/gcc/x86_64-linux-gnu/10/../../../../include/x86_64-linux-gnu/c++/10 -internal-isystem /usr/bin/../lib/gcc/x86_64-linux-gnu/10/../../../../include/c++/10/backward -internal-isystem /usr/local/include -internal-isystem /home/alan/workspace/canalyze/llvm/sprinter/build/bin/resources/include -internal-externc-isystem /usr/include/x86_64-linux-gnu -internal-externc-isystem /include -internal-externc-isystem /usr/include -O2 -Wall -Wextra -Wformat-security -Wvla -Wundef -Wmissing-format-attribute -Woverloaded-virtual -Wcast-qual -Wimplicit-fallthrough=2 -Wstringop-truncation -Wlogical-op -Wshadow=local -w -std=c++14 -fdeprecated-macro -fdebug-compilation-dir /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/build/libbinlogevents/src -ferror-limit 19 -fmessage-length 0 -ftls-model=initial-exec -fobjc-runtime=gcc -fcxx-exceptions -fexceptions -fdiagnostics-show-option -vectorize-loops -vectorize-slp -faddrsig -x c++ /home/alan/workspace/canalyze/llvm/llvm-git/build/smtptr-test/testcase/mysql-server/libbinlogevents/src/compression/iterator.cpp
1 | |
2 | |
3 | |
4 | |
5 | |
6 | |
7 | |
8 | |
9 | |
10 | |
11 | |
12 | |
13 | |
14 | |
15 | |
16 | |
17 | |
18 | |
19 | |
20 | |
21 | |
22 | |
23 | #include <byteorder.h> |
24 | #include <compression/factory.h> |
25 | #include <compression/iterator.h> |
26 | |
27 | namespace binary_log { |
28 | namespace transaction { |
29 | namespace compression { |
30 | |
31 | |
32 | Iterable_buffer::Iterable_buffer(const char *input_buffer, |
33 | size_t input_buffer_size) |
34 | : Iterable_buffer(input_buffer, input_buffer_size, input_buffer_size, |
35 | CompType::NONE) {} |
36 | |
37 | |
38 | Iterable_buffer::Iterable_buffer( |
39 | const char *input_buffer, size_t input_buffer_size, |
40 | size_t decompressed_buffer_size, |
41 | binary_log::transaction::compression::type comp_algo) |
42 | : m_compressed_buffer(input_buffer), |
43 | m_compressed_buffer_size(input_buffer_size), |
44 | m_decompressed_buffer_size(decompressed_buffer_size) { |
45 | if (comp_algo != CompType::NONE) { |
46 | auto res{false}; |
47 | auto left{0}; |
48 | m_decoder = Factory::build_decompressor(comp_algo); |
49 | auto ptr = (unsigned char *)malloc(m_decompressed_buffer_size); |
50 | m_decoder->set_buffer((unsigned char *)ptr, m_decompressed_buffer_size); |
51 | |
52 | |
53 | m_decoder->open(); |
54 | std::tie(left, res) = m_decoder->decompress( |
55 | (const unsigned char *)m_compressed_buffer, m_compressed_buffer_size); |
56 | m_decoder->close(); |
57 | |
58 | |
59 | if (res || left > 0) { |
60 | |
61 | free(const_cast<char *>(m_decompressed_buffer)); |
62 | m_decompressed_buffer = nullptr; |
63 | m_decompressed_buffer_size = 0; |
64 | |
65 | } else { |
66 | |
67 | std::tie(ptr, m_decompressed_buffer_size, std::ignore) = |
68 | m_decoder->get_buffer(); |
69 | m_decompressed_buffer = (const char *)ptr; |
70 | } |
71 | } else { |
72 | |
73 | m_decompressed_buffer = m_compressed_buffer; |
74 | m_decompressed_buffer_size = m_compressed_buffer_size; |
75 | |
76 | } |
77 | } |
78 | |
79 | Iterable_buffer::~Iterable_buffer() { |
80 | if (m_decompressed_buffer != m_compressed_buffer) { |
81 | auto ptr{const_cast<char *>(m_decompressed_buffer)}; |
82 | free(ptr); |
83 | m_decompressed_buffer = nullptr; |
84 | } |
85 | } |
86 | |
87 | Iterable_buffer::iterator::iterator(Iterable_buffer &parent) |
88 | : m_target{&parent} { |
89 | m_reader = std::make_unique<binary_log::Event_reader>( |
90 | m_target->m_decompressed_buffer, m_target->m_decompressed_buffer_size); |
91 | m_reader->go_to(0); |
92 | } |
93 | |
94 | Iterable_buffer::iterator::iterator(const iterator &rhs) { (*this) = rhs; } |
| 2 | | Calling copy assignment operator for 'iterator' | |
|
| 7 | | Returning from copy assignment operator for 'iterator' | |
|
95 | Iterable_buffer::iterator::iterator(iterator &&rhs) { (*this) = rhs; } |
96 | |
97 | Iterable_buffer::iterator::~iterator() {} |
98 | |
99 | Iterable_buffer::iterator &Iterable_buffer::iterator::operator=( |
100 | const Iterable_buffer::iterator &rhs) { |
101 | m_target = rhs.m_target; |
102 | if (rhs.m_reader != nullptr) { |
| 3 | | Calling 'operator!=<binary_log::Event_reader, std::default_delete<binary_log::Event_reader>>' | |
|
| 4 | | Pointer assignment: class std::unique_ptr<class binary_log::Event_reader, struct std::default_delete<class binary_log::Event_reader> > SymRegion{reg_$0<class binary_log::transaction::compression::Iterable_buffer::iterator * this>}->m_reader = nullptr | |
|
| 5 | | Returning from 'operator!=<binary_log::Event_reader, std::default_delete<binary_log::Event_reader>>' | |
|
| |
103 | m_reader = std::make_unique<binary_log::Event_reader>( |
104 | m_target->m_decompressed_buffer, m_target->m_decompressed_buffer_size); |
105 | m_reader->go_to(rhs.m_reader->position()); |
106 | } |
107 | return (*this); |
108 | } |
109 | |
110 | |
111 | Iterable_buffer::iterator &Iterable_buffer::iterator::operator=( |
112 | Iterable_buffer::iterator &&rhs) { |
113 | m_target = rhs.m_target; |
114 | m_reader.swap(rhs.m_reader); |
115 | |
116 | rhs.m_target = nullptr; |
117 | |
118 | return (*this); |
119 | } |
120 | |
121 | |
122 | Iterable_buffer::iterator &Iterable_buffer::iterator::operator++() { |
123 | |
124 | if (has_next_buffer()) { |
| 10 | | Calling 'iterator::has_next_buffer' | |
|
125 | auto ptr = m_reader->ptr(); |
126 | m_reader->forward(EVENT_LEN_OFFSET); |
127 | uint32_t event_len = m_reader->read_and_letoh<uint32_t>(); |
128 | m_reader->go_to((ptr - m_reader->buffer()) + event_len); |
129 | } |
130 | |
131 | |
132 | if (!has_next_buffer()) m_reader.reset(nullptr); |
133 | |
134 | return (*this); |
135 | } |
136 | |
137 | Iterable_buffer::iterator::reference Iterable_buffer::iterator::operator*() |
138 | const { |
139 | if (has_next_buffer()) return m_reader->ptr(); |
140 | return nullptr; |
141 | } |
142 | |
143 | Iterable_buffer::iterator Iterable_buffer::iterator::operator++(int) { |
144 | Iterable_buffer::iterator to_return = (*this); |
| 1 | Calling copy constructor for 'iterator' | |
|
| 8 | | Returning from copy constructor for 'iterator' | |
|
145 | ++(*this); |
| 9 | | Calling 'iterator::operator++' | |
|
146 | return to_return; |
147 | } |
148 | |
149 | |
150 | |
151 | Iterable_buffer::iterator::pointer Iterable_buffer::iterator::operator->() |
152 | const { |
153 | return this->operator*(); |
154 | } |
155 | |
156 | |
157 | bool Iterable_buffer::iterator::operator==( |
158 | Iterable_buffer::iterator rhs) const { |
159 | return m_reader == rhs.m_reader || |
160 | (m_reader != nullptr && rhs.m_reader != nullptr && |
161 | m_reader->position() == rhs.m_reader->position()); |
162 | } |
163 | |
164 | bool Iterable_buffer::iterator::operator!=( |
165 | Iterable_buffer::iterator rhs) const { |
166 | return !((*this) == rhs); |
167 | } |
168 | |
169 | bool Iterable_buffer::iterator::has_next_buffer() const { |
170 | if (m_reader->has_error() || |
| 11 | | Dereference an empty smart pointer by calling operator -> |
|
171 | !m_reader->can_read(LOG_EVENT_MINIMAL_HEADER_LEN)) |
172 | return false; |
173 | |
174 | return true; |
175 | } |
176 | |
177 | Iterable_buffer::iterator Iterable_buffer::begin() { |
178 | Iterable_buffer::iterator begin{*this}; |
179 | if (begin.has_next_buffer()) |
180 | return begin; |
181 | else |
182 | return Iterable_buffer::iterator{}; |
183 | } |
184 | |
185 | Iterable_buffer::iterator Iterable_buffer::end() { |
186 | return Iterable_buffer::iterator{}; |
187 | } |
188 | |
189 | } |
190 | } |
191 | } |