Method run

pdal/compression/DeflateCompression.cpp:82–120

private:
    void run(const char *buf, size_t bufsize, int mode)
    {
        auto handleError = [](int ret) -> void
        {
            switch (ret)
            {
            case Z_OK:
            case Z_STREAM_END:
                return;
            case Z_STREAM_ERROR:
                throw compression_error("Internal error.");
            case Z_DATA_ERROR:
                throw compression_error("Corrupted data.");
            case Z_MEM_ERROR:
                throw compression_error("Memory allocation failure.");
            default:
                std::cerr << "Compression error !\n";
                throw compression_error();
            }
        };

        if (buf)
        {
            m_strm.avail_in = bufsize;
            m_strm.next_in = reinterpret_cast<unsigned char *>(
                    const_cast<char *>(buf));
        }
        int ret = Z_OK;
        do
        {
            m_strm.avail_out = CHUNKSIZE;
            m_strm.next_out = m_tmpbuf;
            ret = ::deflate(&m_strm, mode);
            handleError(ret);
            size_t written = CHUNKSIZE - m_strm.avail_out;
            if (written)
                m_cb(reinterpret_cast<char *>(m_tmpbuf), written);
        } while (m_strm.avail_out == 0);
    }

private:
    BlockCb m_cb;