Lines Matching refs:streams
19 #include "courgette/streams.h"
280 // differential compression of the individual streams, which can provide
281 // invaluable insights. The default, of course, is to include all the streams.
307 CheckBool EncodedProgram::WriteTo(SinkStreamSet* streams) {
311 // of the streams used. The code can be configured with all kStreamXXX
321 if (!streams->stream(kStreamMisc)->WriteVarint32(
331 streams->stream(kStreamAbs32Addresses));
336 streams->stream(kStreamRel32Addresses));
340 success &= WriteVector(origins_, streams->stream(kStreamOriginAddresses));
344 success &= streams->stream(kStreamOps)->Reserve(ops_.size() + 5);
345 success &= WriteVector(ops_, streams->stream(kStreamOps));
349 success &= WriteVector(copy_counts_, streams->stream(kStreamCopyCounts));
352 success &= WriteVectorU8(copy_bytes_, streams->stream(kStreamBytes));
355 success &= WriteVector(abs32_ix_, streams->stream(kStreamAbs32Indexes));
358 success &= WriteVector(rel32_ix_, streams->stream(kStreamRel32Indexes));
363 bool EncodedProgram::ReadFrom(SourceStreamSet* streams) {
366 if (!streams->stream(kStreamMisc)->ReadVarint32(&temp))
370 if (!ReadU32Delta(&abs32_rva_, streams->stream(kStreamAbs32Addresses)))
372 if (!ReadU32Delta(&rel32_rva_, streams->stream(kStreamRel32Addresses)))
374 if (!ReadVector(&origins_, streams->stream(kStreamOriginAddresses)))
376 if (!ReadVector(&ops_, streams->stream(kStreamOps)))
378 if (!ReadVector(©_counts_, streams->stream(kStreamCopyCounts)))
380 if (!ReadVectorU8(©_bytes_, streams->stream(kStreamBytes)))
382 if (!ReadVector(&abs32_ix_, streams->stream(kStreamAbs32Indexes)))
384 if (!ReadVector(&rel32_ix_, streams->stream(kStreamRel32Indexes)))
387 // Check that streams have been completely consumed.
389 if (streams->stream(i)->Remaining() > 0)
768 Status ReadEncodedProgram(SourceStreamSet* streams, EncodedProgram** output) {
770 if (encoded->ReadFrom(streams)) {
