33 std::unique_ptr<folly::IOBuf> compress(
const folly::IOBuf* in,
38 bool hasError() {
return status_ != Z_OK && status_ != Z_STREAM_END; }
40 bool finished() {
return status_ == Z_STREAM_END; }
44 int level_{Z_DEFAULT_COMPRESSION};
—— Concurrent Priority Queue Implementation ——
void init(int *argc, char ***argv, bool removeFlags)
DECLARE_int64(zlib_compressor_buffer_growth)