| 656 | } |
| 657 | |
| 658 | void SnappyUncompress(ThreadState* thread) { |
| 659 | RandomGenerator gen; |
| 660 | Slice input = gen.Generate(Options().block_size); |
| 661 | std::string compressed; |
| 662 | bool ok = port::Snappy_Compress(input.data(), input.size(), &compressed); |
| 663 | int64_t bytes = 0; |
| 664 | char* uncompressed = new char[input.size()]; |
| 665 | while (ok && bytes < 1024 * 1048576) { // Compress 1G |
| 666 | ok = port::Snappy_Uncompress(compressed.data(), compressed.size(), |
| 667 | uncompressed); |
| 668 | bytes += input.size(); |
| 669 | thread->stats.FinishedSingleOp(); |
| 670 | } |
| 671 | delete[] uncompressed; |
| 672 | |
| 673 | if (!ok) { |
| 674 | thread->stats.AddMessage("(snappy failure)"); |
| 675 | } else { |
| 676 | thread->stats.AddBytes(bytes); |
| 677 | } |
| 678 | } |
| 679 | |
| 680 | void Open() { |
| 681 | assert(db_ == nullptr); |
nothing calls this directly
no test coverage detected