1 #ifndef OSMIUM_IO_GZIP_COMPRESSION_HPP 2 #define OSMIUM_IO_GZIP_COMPRESSION_HPP 71 gzip_error_code(error_code),
72 system_errno(error_code == Z_ERRNO ? errno : 0) {
81 OSMIUM_NORETURN inline void throw_gzip_error(gzFile gzfile,
const char* msg,
int zlib_error = 0) {
82 std::string error(
"gzip error: ");
85 int errnum = zlib_error;
87 error += std::to_string(zlib_error);
89 error += ::gzerror(gzfile, &errnum);
106 m_gzfile(::gzdopen(fd,
"w")) {
108 detail::throw_gzip_error(m_gzfile,
"write initialization failed");
120 void write(
const std::string& data)
final {
122 int nwrite = ::gzwrite(m_gzfile, data.data(), static_cast_with_assert<unsigned int>(data.size()));
124 detail::throw_gzip_error(m_gzfile,
"write failed");
131 int result = ::gzclose(m_gzfile);
133 if (result != Z_OK) {
134 detail::throw_gzip_error(m_gzfile,
"write close failed", result);
137 osmium::io::detail::reliable_fsync(m_fd);
139 osmium::io::detail::reliable_close(m_fd);
153 m_gzfile(::gzdopen(fd,
"r")) {
155 detail::throw_gzip_error(m_gzfile,
"read initialization failed");
169 int nread = ::gzread(m_gzfile, const_cast<char*>(buffer.data()), static_cast_with_assert<unsigned int>(buffer.size()));
171 detail::throw_gzip_error(m_gzfile,
"read failed");
173 buffer.resize(static_cast<std::string::size_type>(nread));
179 int result = ::gzclose(m_gzfile);
181 if (result != Z_OK) {
182 detail::throw_gzip_error(m_gzfile,
"read close failed", result);
201 m_zstream.next_in =
reinterpret_cast<unsigned char*
>(
const_cast<char*
>(buffer));
202 m_zstream.avail_in = static_cast_with_assert<unsigned int>(size);
203 int result = inflateInit2(&m_zstream, MAX_WBITS | 32);
204 if (result != Z_OK) {
205 std::string message(
"gzip error: decompression init failed: ");
207 message.append(m_zstream.msg);
225 const size_t buffer_size = 10240;
226 output.append(buffer_size,
'\0');
227 m_zstream.next_out =
reinterpret_cast<unsigned char*
>(
const_cast<char*
>(output.data()));
228 m_zstream.avail_out = buffer_size;
229 int result = inflate(&m_zstream, Z_SYNC_FLUSH);
231 if (result != Z_OK) {
236 if (result != Z_OK && result != Z_STREAM_END) {
237 std::string message(
"gzip error: inflate failed: ");
239 message.append(m_zstream.msg);
244 output.resize(static_cast<unsigned long>(m_zstream.next_out - reinterpret_cast<const unsigned char*>(output.data())));
251 inflateEnd(&m_zstream);
267 inline bool get_registered_gzip_compression() noexcept {
268 return registered_gzip_compression;
277 #endif // OSMIUM_IO_GZIP_COMPRESSION_HPP gzFile m_gzfile
Definition: gzip_compression.hpp:99
Definition: gzip_compression.hpp:189
gzip_error(const std::string &what, int error_code)
Definition: gzip_compression.hpp:69
gzFile m_gzfile
Definition: gzip_compression.hpp:147
#define OSMIUM_NORETURN
Definition: compatibility.hpp:41
Definition: gzip_compression.hpp:96
z_stream m_zstream
Definition: gzip_compression.hpp:193
static CompressionFactory & instance()
Definition: compression.hpp:151
static constexpr unsigned int input_buffer_size
Definition: compression.hpp:91
GzipCompressor(int fd, fsync sync)
Definition: gzip_compression.hpp:103
size_t m_buffer_size
Definition: gzip_compression.hpp:192
Definition: gzip_compression.hpp:145
~GzipDecompressor() noexcept final
Definition: gzip_compression.hpp:159
Definition: compression.hpp:87
int m_fd
Definition: gzip_compression.hpp:98
GzipBufferDecompressor(const char *buffer, size_t size)
Definition: gzip_compression.hpp:197
Namespace for everything in the Osmium library.
Definition: assembler.hpp:59
const char * m_buffer
Definition: gzip_compression.hpp:191
void close() final
Definition: gzip_compression.hpp:250
fsync
Definition: writer_options.hpp:51
void close() final
Definition: gzip_compression.hpp:129
int system_errno
Definition: gzip_compression.hpp:67
Definition: gzip_compression.hpp:64
std::string read() final
Definition: gzip_compression.hpp:167
int gzip_error_code
Definition: gzip_compression.hpp:66
GzipDecompressor(int fd)
Definition: gzip_compression.hpp:151
Definition: compression.hpp:62
void write(const std::string &data) final
Definition: gzip_compression.hpp:120
~GzipCompressor() noexcept final
Definition: gzip_compression.hpp:112
~GzipBufferDecompressor() noexcept final
Definition: gzip_compression.hpp:213
bool register_compression(osmium::io::file_compression compression, create_compressor_type create_compressor, create_decompressor_type_fd create_decompressor_fd, create_decompressor_type_buffer create_decompressor_buffer)
Definition: compression.hpp:156
std::string read() final
Definition: gzip_compression.hpp:221
void close() final
Definition: gzip_compression.hpp:177