Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 55) 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 …]
Dfile_descriptor_utils.cc50 DirectExtentReader reader; in CommonHashExtents() local
51 TEST_AND_RETURN_FALSE(reader.Init(source, src_extents, block_size)); in CommonHashExtents()
56 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/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/
Drecord_file_test.cpp82 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
83 ASSERT_TRUE(reader != nullptr); in TEST_F()
84 std::vector<EventAttrWithId> attrs = reader->AttrSection(); in TEST_F()
90 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST_F()
95 std::vector<BuildIdRecord> read_build_id_records = reader->ReadBuildIdFeature(); in TEST_F()
99 ASSERT_TRUE(reader->Close()); in TEST_F()
116 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
117 ASSERT_TRUE(reader != nullptr); in TEST_F()
118 std::vector<EventAttrWithId> attrs = reader->AttrSection(); in TEST_F()
145 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
[all …]
Dcmd_record_test.cpp98 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(record_file); in CheckEventType() local
99 ASSERT_TRUE(reader); in CheckEventType()
100 std::vector<EventAttrWithId> attrs = reader->AttrSection(); in CheckEventType()
151 std::unique_ptr<RecordFileReader> reader = in TEST() local
153 ASSERT_TRUE(reader != nullptr); in TEST()
154 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST()
174 std::unique_ptr<RecordFileReader> reader = in TEST() local
176 ASSERT_TRUE(reader != nullptr); in TEST()
177 const FileHeader& file_header = reader->FileHeader(); in TEST()
180 ASSERT_GT(reader->FeatureSectionDescriptors().size(), 0u); in TEST()
[all …]
Dcmd_debug_unwind_test.cpp60 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmp_file.path); in TEST() local
61 ASSERT_TRUE(reader); in TEST()
62 const std::map<int, PerfFileFormat::SectionDesc>& features = reader->FeatureSectionDescriptors(); in TEST()
65 auto meta_info = reader->GetMetaInfoFeature(); 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()
DRecordReadThread_test.cpp77 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance( in TEST() local
79 ASSERT_TRUE(reader); in TEST()
80 RecordParser parser(*reader->AttrSection()[0].attr); in TEST()
110 ASSERT_TRUE(reader->ReadDataSection([&](std::unique_ptr<Record> record) { in TEST()
195 KernelRecordReader reader(&event_fd); in TEST() local
197 ASSERT_TRUE(reader.GetDataFromKernelBuffer()); in TEST()
199 ASSERT_TRUE(reader.MoveToNextRecord(parser)); in TEST()
200 ASSERT_EQ(reader.RecordHeader().type, records[i]->type()); in TEST()
201 ASSERT_EQ(reader.RecordHeader().size, records[i]->size()); in TEST()
202 ASSERT_EQ(reader.RecordTime(), records[i]->Timestamp()); in TEST()
[all …]
DRecordReadThread.cpp427 [&](const KernelRecordReader& reader) { in HandleRemoveEventFds() argument
428 return reader.GetEventFd() == event_fd; in HandleRemoveEventFds()
451 for (auto& reader : kernel_record_readers_) { in ReadRecordsFromKernelBuffer() local
452 if (reader.GetDataFromKernelBuffer()) { in ReadRecordsFromKernelBuffer()
453 readers.push_back(&reader); in ReadRecordsFromKernelBuffer()
469 for (auto& reader : readers) { in ReadRecordsFromKernelBuffer() local
470 reader->MoveToNextRecord(record_parser_); in ReadRecordsFromKernelBuffer()
581 for (auto& reader : kernel_record_readers_) { in ReadAuxDataFromKernelBuffer() local
582 EventFd* event_fd = reader.GetEventFd(); in ReadAuxDataFromKernelBuffer()
/system/bt/profile/sdp/common/test/
Ddata_element_reader_test.cc195 DataElementReader reader(packet->begin(), packet->end()); in TEST_P() local
196 auto read_value = reader.ReadNext(); in TEST_P()
201 ASSERT_EQ(reader.ReadNext(), DataElement(std::monostate())); in TEST_P()
220 DataElementReader reader(packet->begin(), packet->end()); in TEST() local
223 auto data_element = reader.ReadNext(); in TEST()
239 data_element = reader.ReadNext(); in TEST()
245 ASSERT_EQ(reader.ReadNext(), DataElement(std::monostate())); in TEST()
251 DataElementReader reader(packet->begin(), packet->end()); in TEST() local
253 ASSERT_EQ(reader.ReadNext(), DataElement(std::monostate())); in TEST()
259 DataElementReader reader(packet->begin(), packet->end()); in TEST() local
[all …]
/system/extras/libjsonpb/verify/
Dverify.cpp147 Json::Reader reader; in AllFieldsAreKnown() local
149 if (!reader.parse(json, value)) { in AllFieldsAreKnown()
150 *error = reader.getFormattedErrorMessages(); in AllFieldsAreKnown()
166 Json::Reader reader; in EqReformattedJson() local
168 if (!reader.parse(json, old_json)) { in EqReformattedJson()
169 *error = reader.getFormattedErrorMessages(); in EqReformattedJson()
179 if (!reader.parse(*new_json_string, new_json)) { in EqReformattedJson()
180 *error = reader.getFormattedErrorMessages(); in EqReformattedJson()
Dtest.cpp220 Json::Reader reader; in IsJsonEq() local
222 if (!reader.parse(l, lvalue)) in IsJsonEq()
224 << reader.getFormattedErrorMessages(); in IsJsonEq()
226 if (!reader.parse(r, rvalue)) in IsJsonEq()
228 << reader.getFormattedErrorMessages(); in IsJsonEq()
/system/update_engine/
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/tools/hidl/metadata/
Dparser.cpp30 Json::Reader reader; in main() local
33 if (!reader.parse(stream, root)) { in main()
35 << reader.getFormattedErrorMessages() << std::endl; in main()
/system/tools/aidl/metadata/
Dparser.cpp30 Json::Reader reader; in main() local
33 if (!reader.parse(stream, root)) { in main()
35 << reader.getFormattedErrorMessages() << std::endl; in main()
/system/core/logd/
DSimpleLogBuffer.cpp343 void SimpleLogBuffer::KickReader(LogReaderThread* reader, log_id_t id, unsigned long prune_rows) { in KickReader() argument
347 LOG(WARNING) << "Kicking blocked reader, " << reader->name() in KickReader()
349 reader->release_Locked(); in KickReader()
350 } else if (reader->deadline().time_since_epoch().count() != 0) { in KickReader()
352 reader->triggerReader_Locked(); in KickReader()
355 LOG(WARNING) << "Skipping " << prune_rows << " entries from slow reader, " << reader->name() in KickReader()
357 reader->triggerSkip_Locked(id, prune_rows); in KickReader()
DSerializedLogBuffer.cpp198 void SerializedLogBuffer::KickReader(LogReaderThread* reader, log_id_t id, size_t bytes_to_free) { in KickReader() argument
201 LOG(WARNING) << "Kicking blocked reader, " << reader->name() in KickReader()
203 reader->release_Locked(); in KickReader()
204 } else if (reader->deadline().time_since_epoch().count() != 0) { in KickReader()
206 reader->triggerReader_Locked(); in KickReader()
210 LOG(WARNING) << "Skipping " << prune_rows << " entries from slow reader, " << reader->name() in KickReader()
212 reader->triggerSkip_Locked(id, prune_rows); in KickReader()
DLogReader.cpp49 SocketLogWriter(LogReader* reader, SocketClient* client, bool privileged) in SocketLogWriter() argument
50 : LogWriter(client->getUid(), privileged), reader_(reader), client_(client) {} in SocketLogWriter()
234 for (const auto& reader : reader_list_->reader_threads()) { in DoSocketDelete() local
235 if (reader->name() == cli_name) { in DoSocketDelete()
236 reader->release_Locked(); in DoSocketDelete()
/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/media/audio_utils/include/audio_utils/
DFdToString.h51 mOutput = std::async(std::launch::async, reader, mPipeFd[0], mTimeoutTimeNs, mPrefix); in mPrefix()
93 static std::string reader(int fd, int64_t timeoutTimeNs, std::string prefix) { in reader() function
/system/timezone/input_tools/android/zone_compactor/main/java/
DZoneCompactor.java79 BufferedReader reader = new BufferedReader(new FileReader(setupFile)); in ZoneCompactor() local
82 while ((s = reader.readLine()) != null) { in ZoneCompactor()
104 reader.close(); in ZoneCompactor()
/system/core/adb/fastdeploy/deployagent/src/com/android/fastdeploy/
DDeployAgent.java158 BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream())); in getFilenameFromPackageName() local
163 while ((line = reader.readLine()) != null) { in getFilenameFromPackageName()
204 BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream())); in createInstallSession() local
208 while ((line = reader.readLine()) != null) { in createInstallSession()

123