from_gzip.hpp

Go to the documentation of this file.

#ifndef EMINEM_FROM_GZIP_HPP
#define EMINEM_FROM_GZIP_HPP
 
#include <memory>
#include <cstddef>
 
#include "Parser.hpp"
#include "byteme/PerByte.hpp"
#include "byteme/GzipFileReader.hpp"
#include "byteme/ZlibBufferReader.hpp"
#include "byteme/SomeFileReader.hpp"
#include "byteme/SomeBufferReader.hpp"
 
namespace eminem {
 
struct ParseGzipFileOptions {
    std::size_t buffer_size = 65536;
 
    int num_threads = 1;
 
    std::size_t block_size = 65536;
};
 
inline Parser<byteme::PerByteSerial<char> > parse_gzip_file(const char* path, const ParseGzipFileOptions& options) {
    ParserOptions popt;
    popt.num_threads = options.num_threads;
    popt.block_size = options.block_size;
 
    byteme::GzipFileReaderOptions gopt;
    gopt.buffer_size = options.buffer_size;
    auto reader = std::make_unique<byteme::GzipFileReader>(path, gopt);
    auto pb = std::make_unique<byteme::PerByteSerial<char> >(std::move(reader));
    return Parser<byteme::PerByteSerial<char> >(std::move(pb), popt);
}
 
struct ParseZlibBufferOptions {
    std::size_t buffer_size = 65536;
 
    int num_threads = 1;
 
    std::size_t block_size = 65536;
 
    int mode = 3;
};
 
inline Parser<byteme::PerByteSerial<char> > parse_zlib_buffer(const unsigned char* buffer, std::size_t len, const ParseZlibBufferOptions& options) {
    ParserOptions popt;
    popt.num_threads = options.num_threads;
    popt.block_size = options.block_size;
 
    byteme::ZlibBufferReaderOptions zopt;
    zopt.buffer_size = options.buffer_size;
    zopt.mode = options.mode;
    auto reader = std::make_unique<byteme::ZlibBufferReader>(buffer, len, zopt);
    auto pb = std::make_unique<byteme::PerByteSerial<char> >(std::move(reader));
    return Parser<byteme::PerByteSerial<char> >(std::move(pb), popt);
}
 
struct ParseSomeFileOptions {
    std::size_t buffer_size = 65536;
 
    int num_threads = 1;
 
    std::size_t block_size = 65536;
};
 
inline Parser<byteme::PerByteSerial<char> > parse_some_file(const char* path, const ParseSomeFileOptions& options) {
    ParserOptions popt;
    popt.num_threads = options.num_threads;
    popt.block_size = options.block_size;
 
    byteme::SomeFileReaderOptions sopt;
    sopt.buffer_size = options.buffer_size;
    auto reader = std::make_unique<byteme::SomeFileReader>(path, sopt);
    auto pb = std::make_unique<byteme::PerByteSerial<char> >(std::move(reader));
 
    return Parser<byteme::PerByteSerial<char> >(std::move(pb), popt);
}
 
struct ParseSomeBufferOptions {
    std::size_t buffer_size = 65536;
 
    int num_threads = 1;
 
    std::size_t block_size = 65536;
};
 
inline Parser<byteme::PerByteSerial<char> > parse_some_buffer(const unsigned char* buffer, std::size_t len, const ParseSomeBufferOptions& options) {
    ParserOptions popt;
    popt.num_threads = options.num_threads;
    popt.block_size = options.block_size;
 
    byteme::SomeBufferReaderOptions sopt;
    sopt.buffer_size = options.buffer_size;
    auto reader = std::make_unique<byteme::SomeBufferReader>(buffer, len, sopt);
    auto pb = std::make_unique<byteme::PerByteSerial<char> >(std::move(reader));
    return Parser<byteme::PerByteSerial<char> >(std::move(pb), popt);
}
 
}
 
#endif