Method End

cpp/src/arrow/util/compression_bz2.cc:208–221

  }

  Result<EndResult> End(int64_t output_len, uint8_t* output) override {
    stream_.next_in = nullptr;
    stream_.avail_in = 0;
    stream_.next_out = reinterpret_cast<char*>(output);
    stream_.avail_out = static_cast<unsigned int>(std::min(output_len, kSizeLimit));
    int ret;

    ret = BZ2_bzCompress(&stream_, BZ_FINISH);
    if (ret == BZ_STREAM_END || ret == BZ_FINISH_OK) {
      return EndResult{output_len - stream_.avail_out, (ret == BZ_FINISH_OK)};
    } else {
      return BZ2Error("bz2 compress failed: ", ret);
    }
  }

 protected:
  bz_stream stream_;