Lines Matching refs:streams
19 #include "courgette/streams.h"
282 // differential compression of the individual streams, which can provide
283 // invaluable insights. The default, of course, is to include all the streams.
309 CheckBool EncodedProgram::WriteTo(SinkStreamSet* streams) {
313 // of the streams used. The code can be configured with all kStreamXXX
323 if (!streams->stream(kStreamMisc)->WriteVarint32(
333 streams->stream(kStreamAbs32Addresses));
338 streams->stream(kStreamRel32Addresses));
342 success &= WriteVector(origins_, streams->stream(kStreamOriginAddresses));
346 success &= streams->stream(kStreamOps)->Reserve(ops_.size() + 5);
347 success &= WriteVector(ops_, streams->stream(kStreamOps));
351 success &= WriteVector(copy_counts_, streams->stream(kStreamCopyCounts));
354 success &= WriteVectorU8(copy_bytes_, streams->stream(kStreamBytes));
357 success &= WriteVector(abs32_ix_, streams->stream(kStreamAbs32Indexes));
360 success &= WriteVector(rel32_ix_, streams->stream(kStreamRel32Indexes));
365 bool EncodedProgram::ReadFrom(SourceStreamSet* streams) {
368 if (!streams->stream(kStreamMisc)->ReadVarint32(&temp))
372 if (!ReadU32Delta(&abs32_rva_, streams->stream(kStreamAbs32Addresses)))
374 if (!ReadU32Delta(&rel32_rva_, streams->stream(kStreamRel32Addresses)))
376 if (!ReadVector(&origins_, streams->stream(kStreamOriginAddresses)))
378 if (!ReadVector(&ops_, streams->stream(kStreamOps)))
380 if (!ReadVector(©_counts_, streams->stream(kStreamCopyCounts)))
382 if (!ReadVectorU8(©_bytes_, streams->stream(kStreamBytes)))
384 if (!ReadVector(&abs32_ix_, streams->stream(kStreamAbs32Indexes)))
386 if (!ReadVector(&rel32_ix_, streams->stream(kStreamRel32Indexes)))
389 // Check that streams have been completely consumed.
391 if (streams->stream(i)->Remaining() > 0)
780 Status ReadEncodedProgram(SourceStreamSet* streams, EncodedProgram** output) {
782 if (encoded->ReadFrom(streams)) {
