Lines Matching refs:stream_

24     (void)memset_s(&stream_, sizeof(bz_stream), 0, sizeof(bz_stream));

25     int32_t ret = BZ2_bzCompressInit(&stream_, BLOCK_SIZE_BEST, 0, 0);

39     int32_t ret = BZ2_bzCompressEnd(&stream_);

50     stream_.next_in = reinterpret_cast<char*>(srcData.buffer);

51     stream_.avail_in = srcData.length;

54     stream_.avail_out = buffer_.size() - offset_ - dataSize_;

55     stream_.next_out = next;

58         ret = BZ2_bzCompress(&stream_, BZ_RUN);

59         if (stream_.avail_out == 0) {

60             dataSize_ += stream_.next_out - next;

63             stream_.avail_out = IGMDIFF_LIMIT_UNIT;

65             stream_.next_out = next;

67         if (stream_.avail_in == 0) {

75     if (stream_.avail_in != 0) {

79     dataSize_ += stream_.next_out - next;

87     stream_.next_in = nullptr;

88     stream_.avail_in = 0;

89     stream_.avail_out = buffer_.size() - offset_ - dataSize_;

91     stream_.next_out = next;

94         ret = BZ2_bzCompress(&stream_, BZ_FINISH);

95         if (stream_.avail_out == 0) {

96             dataSize_ += stream_.next_out - next;

98             stream_.avail_out = buffer_.size() - offset_ - dataSize_;

100             stream_.next_out = next;

107     dataSize_ += stream_.next_out - next;

121     stream_.next_in = reinterpret_cast<char*>(srcData.buffer);

122     stream_.avail_in = srcData.length;

124     stream_.avail_out = buffer_.size();

125     stream_.next_out = reinterpret_cast<char*>(buffer_.data());

128         ret = BZ2_bzCompress(&stream_, BZ_RUN);

129         if (stream_.avail_out == 0) {

131             dataSize_ += stream_.next_out - reinterpret_cast<char*>(buffer_.data());

132             stream_.avail_out = buffer_.size();

133             stream_.next_out = reinterpret_cast<char*>(buffer_.data());

135         if (stream_.avail_in == 0) {

143     if (stream_.avail_in != 0) {

147     if (stream_.avail_out != buffer_.size()) {

148         outStream_.write(buffer_.data(), stream_.next_out - reinterpret_cast<char*>(buffer_.data()));

150     dataSize_ += stream_.next_out - reinterpret_cast<char*>(buffer_.data());

157     stream_.next_in = nullptr;

158     stream_.avail_in = 0;

159     stream_.avail_out = buffer_.size();

160     stream_.next_out = reinterpret_cast<char*>(buffer_.data());

163         ret = BZ2_bzCompress(&stream_, BZ_FINISH);

164         if (stream_.avail_out == 0) {

165             outStream_.write(buffer_.data(), stream_.next_out - reinterpret_cast<char*>(buffer_.data()));

166             dataSize_ += stream_.next_out - reinterpret_cast<char*>(buffer_.data());

167             stream_.avail_out = buffer_.size();

168             stream_.next_out = reinterpret_cast<char*>(buffer_.data());

175     if (stream_.avail_out != buffer_.size()) {

176         outStream_.write(buffer_.data(), stream_.next_out - reinterpret_cast<char*>(buffer_.data()));

178     dataSize_ += stream_.next_out - reinterpret_cast<char*>(buffer_.data());

196     (void)memset_s(&stream_, sizeof(bz_stream), 0, sizeof(bz_stream));

197     int32_t ret = BZ2_bzDecompressInit(&stream_, 0, 0);

202     stream_.avail_in = static_cast<unsigned int>(dataLength_);

203     stream_.next_in  = reinterpret_cast<char*>(buffer_.buffer + offset_);

215     ret = BZ2_bzDecompressEnd(&stream_);

232     stream_.next_out = reinterpret_cast<char*>(info.buffer);

233     stream_.avail_out = info.length;

235         ret = BZ2_bzDecompress(&stream_);

237             readLen = info.length - stream_.avail_out;

244         if (stream_.avail_out == 0) {

248         if (stream_.avail_in == 0) {