| 898 | } |
| 899 | |
| 900 | Status ReadablePBContainerFile::Open() { |
| 901 | DCHECK_EQ(FileState::NOT_INITIALIZED, state_); |
| 902 | RETURN_NOT_OK(ParsePBFileHeader(reader_.get(), &cached_file_size_, &offset_, &version_)); |
| 903 | ContainerSupHeaderPB sup_header; |
| 904 | RETURN_NOT_OK(ReadSupplementalHeader(reader_.get(), version_, &cached_file_size_, |
| 905 | &offset_, &sup_header)); |
| 906 | protos_.reset(sup_header.release_protos()); |
| 907 | pb_type_ = sup_header.pb_type(); |
| 908 | state_ = FileState::OPEN; |
| 909 | return Status::OK(); |
| 910 | } |
| 911 | |
| 912 | Status ReadablePBContainerFile::ReadNextPB(Message* msg) { |
| 913 | DCHECK_EQ(FileState::OPEN, state_); |