| 100 | } |
| 101 | |
| 102 | Status Init() { |
| 103 | DCHECK(!initialized_); |
| 104 | memset(&stream_, 0, sizeof(stream_)); |
| 105 | int ret; |
| 106 | ret = BZ2_bzDecompressInit(&stream_, 0, 0); |
| 107 | if (ret != BZ_OK) { |
| 108 | return BZ2Error("bz2 decompressor init failed: ", ret); |
| 109 | } |
| 110 | initialized_ = true; |
| 111 | finished_ = false; |
| 112 | return Status::OK(); |
| 113 | } |
| 114 | |
| 115 | Status Reset() override { |
| 116 | if (initialized_) { |