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 | } |