| 309 | } |
| 310 | |
| 311 | void test_compress(CompressorRef compressor, size_t size) |
| 312 | { |
| 313 | char* data = (char*) malloc(size); |
| 314 | for (size_t t = 0; t < size; t++) { |
| 315 | data[t] = (t & 0xff) | (t >> 8); |
| 316 | } |
| 317 | bufferlist in; |
| 318 | in.append(data, size); |
| 319 | for (size_t t = 0; t < 10000; t++) { |
| 320 | bufferlist out; |
| 321 | std::optional<int32_t> compressor_message; |
| 322 | int res = compressor->compress(in, out, compressor_message); |
| 323 | EXPECT_EQ(res, 0); |
| 324 | } |
| 325 | free(data); |
| 326 | } |
| 327 | |
| 328 | void test_decompress(CompressorRef compressor, size_t size) |
| 329 | { |