| 326 | } |
| 327 | |
| 328 | void test_decompress(CompressorRef compressor, size_t size) |
| 329 | { |
| 330 | char* data = (char*) malloc(size); |
| 331 | for (size_t t = 0; t < size; t++) { |
| 332 | data[t] = (t & 0xff) | (t >> 8); |
| 333 | } |
| 334 | bufferlist in, out; |
| 335 | in.append(data, size); |
| 336 | std::optional<int32_t> compressor_message; |
| 337 | int res = compressor->compress(in, out, compressor_message); |
| 338 | EXPECT_EQ(res, 0); |
| 339 | for (size_t t = 0; t < 10000; t++) { |
| 340 | bufferlist out_dec; |
| 341 | int res = compressor->decompress(out, out_dec, compressor_message); |
| 342 | EXPECT_EQ(res, 0); |
| 343 | } |
| 344 | free(data); |
| 345 | } |
| 346 | |
| 347 | TEST_P(CompressorTest, compress_1024) |
| 348 | { |
no test coverage detected