Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 71) sorted by relevance

123

/system/update_engine/payload_consumer/
Dextent_reader_unittest.cc81 DirectExtentReader reader; in TEST_F() local
82 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
83 EXPECT_TRUE(reader.Seek(0)); in TEST_F()
85 EXPECT_TRUE(reader.Read(blob1.data(), blob1.size())); in TEST_F()
93 DirectExtentReader reader; in TEST_F() local
94 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize)); in TEST_F()
95 EXPECT_TRUE(reader.Seek(0)); in TEST_F()
97 EXPECT_TRUE(reader.Read(blob.data(), 0)); in TEST_F()
98 EXPECT_FALSE(reader.Read(blob.data(), 1)); in TEST_F()
102 DirectExtentReader reader; in TEST_F() local
[all …]
Dinstall_operation_executor.cc51 BsdiffExtentFile(std::unique_ptr<ExtentReader> reader, size_t size) in BsdiffExtentFile() argument
52 : BsdiffExtentFile(std::move(reader), nullptr, size) {} in BsdiffExtentFile()
92 BsdiffExtentFile(std::unique_ptr<ExtentReader> reader, in BsdiffExtentFile() argument
95 : reader_(std::move(reader)), in BsdiffExtentFile()
112 PuffinExtentStream(std::unique_ptr<ExtentReader> reader, uint64_t size) in PuffinExtentStream() argument
113 : PuffinExtentStream(std::move(reader), nullptr, size) {} in PuffinExtentStream()
160 PuffinExtentStream(std::unique_ptr<ExtentReader> reader, in PuffinExtentStream() argument
163 : reader_(std::move(reader)), in PuffinExtentStream()
292 auto reader = std::make_unique<DirectExtentReader>(); in ExecuteSourceBsdiffOperation() local
294 reader->Init(source_fd, operation.src_extents(), block_size_)); in ExecuteSourceBsdiffOperation()
[all …]
Dfile_descriptor_utils.cc53 DirectExtentReader reader; in CommonHashExtents() local
54 TEST_AND_RETURN_FALSE(reader.Init(source, src_extents, block_size)); in CommonHashExtents()
59 TEST_AND_RETURN_FALSE(reader.Read(buf.data(), read_blocks * block_size)); in CommonHashExtents()
/system/nvram/messages/
Dmessage_codec.cpp90 ProtoReader* reader, in Decode() argument
94 return decoder.Decode(reader); in Decode()
97 bool MessageDecoderBase::Decode(ProtoReader* reader) { in Decode() argument
98 NestedInputStreamBuffer nested_stream_buffer(reader->stream_buffer(), in Decode()
99 reader->field_size()); in Decode()
104 bool MessageDecoderBase::DecodeData(ProtoReader* reader) { in DecodeData() argument
105 while (!reader->Done()) { in DecodeData()
106 if (!reader->ReadWireTag()) { in DecodeData()
109 const FieldDescriptor* desc = FindDescriptor(reader); in DecodeData()
111 if (!desc->decode_function(object_, reader)) { in DecodeData()
[all …]
/system/core/fs_mgr/libsnapshot/
Dsnapshot_reader_test.cpp76 auto reader = writer->OpenReader(); in TestBlockReads() local
77 ASSERT_NE(reader, nullptr); in TestBlockReads()
87 ASSERT_EQ(reader->Seek(i * kBlockSize, SEEK_SET), i * kBlockSize); in TestBlockReads()
88 ASSERT_EQ(reader->Read(block.data(), block.size()), kBlockSize); in TestBlockReads()
97 ASSERT_EQ(reader->Seek(1 * kBlockSize, SEEK_SET), 1 * kBlockSize); in TestBlockReads()
98 ASSERT_EQ(reader->Read(data.data(), data.size()), kBlockSize); in TestBlockReads()
105 ASSERT_EQ(reader->Seek(3 * kBlockSize, SEEK_SET), 3 * kBlockSize); in TestBlockReads()
106 ASSERT_EQ(reader->Read(block.data(), block.size()), kBlockSize); in TestBlockReads()
109 ASSERT_EQ(reader->Seek(5 * kBlockSize, SEEK_SET), 5 * kBlockSize); in TestBlockReads()
110 ASSERT_EQ(reader->Read(block.data(), block.size()), kBlockSize); in TestBlockReads()
[all …]
Dcow_api_test.cpp82 CowReader reader; in TEST_F() local
85 ASSERT_TRUE(reader.Parse(cow_->fd)); in TEST_F()
86 ASSERT_TRUE(reader.GetHeader(&header)); in TEST_F()
87 ASSERT_TRUE(reader.GetFooter(&footer)); in TEST_F()
94 auto iter = reader.GetOpIter(); in TEST_F()
115 ASSERT_TRUE(reader.ReadData(*op, &sink)); in TEST_F()
160 CowReader reader; in TEST_F() local
163 ASSERT_TRUE(reader.Parse(cow_->fd)); in TEST_F()
164 ASSERT_TRUE(reader.GetHeader(&header)); in TEST_F()
165 ASSERT_TRUE(reader.GetFooter(&footer)); in TEST_F()
[all …]
Dinspect_cow.cpp84 static void ShowBad(CowReader& reader, const struct CowOperation& op) { in ShowBad() argument
88 if (!reader.GetRawBytes(op.source, buffer.get(), op.data_length, &count)) { in ShowBad()
109 CowReader reader; in Inspect() local
110 if (!reader.Parse(fd)) { in Inspect()
116 if (!reader.GetHeader(&header)) { in Inspect()
122 if (reader.GetFooter(&footer)) has_footer = true; in Inspect()
141 if (reader.VerifyMergeOps()) { in Inspect()
150 iter = reader.GetOpIter(); in Inspect()
152 iter = reader.GetRevMergeOpIter(opt.include_merged); in Inspect()
154 iter = reader.GetMergeOpIter(opt.include_merged); in Inspect()
[all …]
Dsnapshot_writer.cpp97 auto reader = std::make_unique<CompressedSnapshotReader>(); in OpenReader() local
98 if (!reader->SetCow(std::move(cow))) { in OpenReader()
103 reader->SetSourceDevice(*source_device_); in OpenReader()
108 reader->SetBlockDeviceSize(*cow_options.max_blocks * cow_options.block_size); in OpenReader()
111 return reader; in OpenReader()
/system/nvram/messages/include/nvram/messages/
Dproto.hpp142 NVRAM_NOINLINE bool DecodeField(Type& value, ProtoReader* reader) { in DecodeField() argument
143 return Codec::Decode(value, reader); in DecodeField()
157 static bool Decode(Blob& blob, ProtoReader* reader) { in Decode()
158 return blob.Resize(reader->field_size()) && in Decode()
159 reader->ReadLengthDelimited(blob.data(), blob.size()); in Decode()
193 static bool Decode(Type& value, ProtoReader* reader) { in Decode()
195 if (!reader->ReadVarint(&raw_value)) { in Decode()
218 static bool Decode(Vector<ElementType>& vector, ProtoReader* reader) { in Decode()
220 DecodeField<ElementCodec>(vector[vector.size() - 1], reader); in Decode()
234 static bool Decode(Optional<ValueType>& value, ProtoReader* reader) { in Decode()
[all …]
Dmessage_codec.h42 using DecodeFunction = bool(void* object, ProtoReader* reader);
112 ProtoReader* reader,
118 bool Decode(ProtoReader* reader);
123 bool DecodeData(ProtoReader* reader);
129 const FieldDescriptor* FindDescriptor(ProtoReader* reader) const;
/system/extras/simpleperf/
Dcmd_merge.cpp181 auto get_arch = [](std::unique_ptr<RecordFileReader>& reader) { in CheckFeatureSection() argument
182 return reader->ReadFeatureString(PerfFileFormat::FEAT_ARCH); in CheckFeatureSection()
184 auto get_kernel_version = [](std::unique_ptr<RecordFileReader>& reader) { in CheckFeatureSection() argument
185 return reader->ReadFeatureString(PerfFileFormat::FEAT_OSRELEASE); in CheckFeatureSection()
187 auto get_meta_info = [](std::unique_ptr<RecordFileReader>& reader, const char* key) { in CheckFeatureSection() argument
188 auto it = reader->GetMetaInfoFeature().find(key); in CheckFeatureSection()
189 return it == reader->GetMetaInfoFeature().end() ? "" : it->second; in CheckFeatureSection()
191 auto get_simpleperf_version = [&](std::unique_ptr<RecordFileReader>& reader) { in CheckFeatureSection() argument
192 return get_meta_info(reader, "simpleperf_version"); in CheckFeatureSection()
194 auto get_trace_offcpu = [&](std::unique_ptr<RecordFileReader>& reader) { in CheckFeatureSection() argument
[all …]
Dcmd_record_test.cpp99 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(record_file); in CheckEventType() local
100 ASSERT_TRUE(reader); in CheckEventType()
101 std::vector<EventAttrWithId> attrs = reader->AttrSection(); in CheckEventType()
152 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); in TEST() local
153 ASSERT_TRUE(reader != nullptr); in TEST()
154 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST()
172 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); in TEST() local
173 ASSERT_TRUE(reader != nullptr); in TEST()
174 const FileHeader& file_header = reader->FileHeader(); in TEST()
176 ASSERT_GT(reader->FeatureSectionDescriptors().size(), 0u); in TEST()
[all …]
Drecord_file_test.cpp87 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
88 ASSERT_TRUE(reader != nullptr); in TEST_F()
89 std::vector<EventAttrWithId> attrs = reader->AttrSection(); in TEST_F()
95 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST_F()
100 std::vector<BuildIdRecord> read_build_id_records = reader->ReadBuildIdFeature(); in TEST_F()
104 ASSERT_TRUE(reader->Close()); in TEST_F()
121 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
122 ASSERT_TRUE(reader != nullptr); in TEST_F()
123 std::vector<EventAttrWithId> attrs = reader->AttrSection(); in TEST_F()
150 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
[all …]
Dkallsyms.cpp44 LineReader reader(kKallsymsPath); in CanReadKernelSymbolAddresses() local
45 if (!reader.Ok()) { in CanReadKernelSymbolAddresses()
51 std::string* line = reader.ReadLine(); in CanReadKernelSymbolAddresses()
174 LineReader reader(kProcModulesPath); in GetLoadedModules() local
175 if (!reader.Ok()) { in GetLoadedModules()
182 while ((line = reader.ReadLine()) != nullptr) { in GetLoadedModules()
212 LineReader reader(kKallsymsPath); in GetKernelStartAddress() local
213 if (!reader.Ok()) { in GetKernelStartAddress()
217 while ((line = reader.ReadLine()) != nullptr) { in GetKernelStartAddress()
Dutils_test.cpp82 LineReader reader(tmpfile.path); in TEST() local
83 ASSERT_TRUE(reader.Ok()); in TEST()
84 std::string* line = reader.ReadLine(); in TEST()
87 line = reader.ReadLine(); in TEST()
90 ASSERT_TRUE(reader.ReadLine() == nullptr); in TEST()
Dcmd_api_test.cpp50 auto reader = RecordFileReader::CreateInstance(filename); in CheckPerfDataFile() local
51 ASSERT_TRUE(reader); in CheckPerfDataFile()
53 ASSERT_TRUE(reader->ReadDataSection([&](std::unique_ptr<Record> r) { in CheckPerfDataFile()
/system/logging/logd/
DSerializedLogChunk.cpp60 void SerializedLogChunk::AttachReader(SerializedFlushToState* reader) { in AttachReader() argument
61 readers_.emplace_back(reader); in AttachReader()
65 void SerializedLogChunk::DetachReader(SerializedFlushToState* reader) { in DetachReader() argument
66 auto it = std::find(readers_.begin(), readers_.end(), reader); in DetachReader()
75 for (auto& reader : readers) { in NotifyReadersOfPrune() local
76 reader->Prune(log_id); in NotifyReadersOfPrune()
DLogReaderList.cpp129 for (const auto& reader : running_reader_threads_) { in ReleaseThreadByName() local
130 if (reader->name() == cli_name) { in ReleaseThreadByName()
131 reader->Release(); in ReleaseThreadByName()
136 for (const auto& reader : pending_reader_threads_) { in ReleaseThreadByName() local
137 if (reader->name() == cli_name) { in ReleaseThreadByName()
138 reader->Release(); in ReleaseThreadByName()
DLogBufferTest.h149 auto reader = TestReaderThread(params, *this); in ReadLogMessagesNonBlockingThread() local
150 reader.WaitUntilReleased(); in ReadLogMessagesNonBlockingThread()
154 return reader.read_log_messages(); in ReadLogMessagesNonBlockingThread()
160 for (auto& reader : reader_list_.running_reader_threads()) { in ReleaseAndJoinReaders()
161 reader->Release(); in ReleaseAndJoinReaders()
DSimpleLogBuffer.cpp341 void SimpleLogBuffer::KickReader(LogReaderThread* reader, log_id_t id, unsigned long prune_rows) { in KickReader() argument
345 LOG(WARNING) << "Kicking blocked reader, " << reader->name() in KickReader()
347 reader->Release(); in KickReader()
348 } else if (reader->deadline().time_since_epoch().count() != 0) { in KickReader()
350 reader->TriggerReader(); in KickReader()
353 LOG(WARNING) << "Skipping " << prune_rows << " entries from slow reader, " << reader->name() in KickReader()
355 reader->TriggerSkip(id, prune_rows); in KickReader()
/system/nfc/src/rust/hal/
Drootcanal_hal.rs33 let (reader, writer) = TcpStream::connect("127.0.0.1:54323") in init()
38 let reader = BufReader::new(reader); in init() localVariable
39 tokio::spawn(dispatch_incoming(inner_hal.in_cmd_tx, inner_hal.in_data_tx, reader)); in init()
54 mut reader: R, in dispatch_incoming()
61 let len: usize = reader.read_u16().await?.into(); in dispatch_incoming()
63 reader.read_exact(&mut buffer).await?; in dispatch_incoming()
/system/update_engine/aosp/
Dlogging_android.cc57 base::DirReaderPosix reader(kLogsRoot.c_str()); in DeleteOldLogs() local
58 if (!reader.IsValid()) { in DeleteOldLogs()
64 while (reader.Next()) { in DeleteOldLogs()
65 if (reader.name()[0] == '.') in DeleteOldLogs()
72 if (sscanf(reader.name(), in DeleteOldLogs()
76 old_logs.push_back(reader.name()); in DeleteOldLogs()
78 LOG(WARNING) << "Unrecognized log file " << reader.name(); in DeleteOldLogs()
/system/nvram/core/
Dpersistence.cpp69 ProtoReader reader(&stream); in DecodeObject() local
70 if (!reader.ReadWireTag() || reader.field_number() != magic || in DecodeObject()
71 reader.wire_type() != WireType::kLengthDelimited || in DecodeObject()
72 !proto::detail::MessageDecoder<Object>::Decode(*object, &reader)) { in DecodeObject()
/system/core/fs_mgr/liblp/
Dreader.cpp167 static bool ReadMetadataHeader(Reader* reader, LpMetadata* metadata) { in ReadMetadataHeader() argument
172 if (!reader->ReadFully(&header, sizeof(LpMetadataHeaderV1_0))) { in ReadMetadataHeader()
201 if (!reader->ReadFully(offset, remaining_bytes)) { in ReadMetadataHeader()
247 Reader* reader) { in ParseMetadata() argument
252 if (!ReadMetadataHeader(reader, metadata.get())) { in ParseMetadata()
271 if (!reader->ReadFully(buffer.get(), header.tables_size)) { in ParseMetadata()
367 MemoryReader reader(buffer, size); in ParseMetadata() local
368 return ParseMetadata(geometry, &reader); in ParseMetadata()
372 FileReader reader(fd); in ParseMetadata() local
373 return ParseMetadata(geometry, &reader); in ParseMetadata()
/system/extras/libjsonpb/verify/
Dverify.cpp139 std::unique_ptr<Json::CharReader> reader(builder.newCharReader()); in AllFieldsAreKnown() local
141 if (!reader->parse(&*json.begin(), &*json.end(), &value, error)) { in AllFieldsAreKnown()
157 std::unique_ptr<Json::CharReader> reader(builder.newCharReader()); in EqReformattedJson() local
159 if (!reader->parse(&*json.begin(), &*json.end(), &old_json, error)) { in EqReformattedJson()
169 if (!reader->parse(&*new_json_string->begin(), &*new_json_string->end(), &new_json, error)) { in EqReformattedJson()

123