Searched refs:reader (Results 1 - 25 of 48) sorted by relevance

12

/system/update_engine/payload_consumer/
H A Dextent_reader_unittest.cc81 DirectExtentReader reader; local
82 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize));
83 EXPECT_TRUE(reader.Seek(0));
85 EXPECT_TRUE(reader.Read(blob1.data(), blob1.size()));
93 DirectExtentReader reader; local
94 EXPECT_TRUE(reader.Init(fd_, {extents.begin(), extents.end()}, kBlockSize));
95 EXPECT_TRUE(reader.Seek(0));
97 EXPECT_TRUE(reader.Read(blob.data(), 0));
98 EXPECT_FALSE(reader.Read(blob.data(), 1));
102 DirectExtentReader reader; local
112 DirectExtentReader reader; local
121 DirectExtentReader reader; local
128 DirectExtentReader reader; local
136 DirectExtentReader reader; local
149 DirectExtentReader reader; local
[all...]
H A Dfile_descriptor_utils.cc50 DirectExtentReader reader; local
51 TEST_AND_RETURN_FALSE(reader.Init(source, src_extents, block_size));
56 TEST_AND_RETURN_FALSE(reader.Read(buf.data(), read_blocks * block_size));
/system/core/logd/
H A DLogListener.h35 LogReader* reader; member in class:LogListener
38 LogListener(LogBufferInterface* buf, LogReader* reader /* nullable */);
H A DFlushCommand.h38 // for opening a reader
39 explicit FlushCommand(LogReader& reader, bool nonBlock, unsigned long tail, argument
42 : mReader(reader),
52 explicit FlushCommand(LogReader& reader, log_mask_t logMask) argument
53 : mReader(reader),
H A DLogAudit.h30 LogReader* reader; member in class:LogAudit
37 LogAudit(LogBuffer* buf, LogReader* reader, int fdDmesg);
H A DLogKlog.h28 LogReader* reader; member in class:LogKlog
42 LogKlog(LogBuffer* buf, LogReader* reader, int fdWrite, int fdRead,
H A DLogListener.cpp35 LogListener::LogListener(LogBufferInterface* buf, LogReader* reader) argument
36 : SocketListener(getLogSocket(), false), logbuf(buf), reader(reader) {
140 if (res > 0 && reader != nullptr) {
141 reader->notifyNewLog(static_cast<log_mask_t>(1 << logId));
H A DCommandListener.h31 CommandListener(LogBuffer* buf, LogReader* reader, LogListener* swl);
43 ShutdownCmd(LogReader* reader, LogListener* swl);
H A DLogTimes.cpp30 LogTimeEntry::LogTimeEntry(LogReader& reader, SocketClient* client, argument
38 mReader(reader),
89 LogReader& reader = me->mReader; local
90 LastLogTimes& times = reader.logbuf().mTimes;
103 reader.release(client);
117 prctl(PR_SET_NAME, "logd.reader.per");
/system/nvram/messages/
H A Dmessage_codec.cpp90 ProtoReader* reader,
94 return decoder.Decode(reader);
97 bool MessageDecoderBase::Decode(ProtoReader* reader) { argument
98 NestedInputStreamBuffer nested_stream_buffer(reader->stream_buffer(),
99 reader->field_size());
104 bool MessageDecoderBase::DecodeData(ProtoReader* reader) { argument
105 while (!reader->Done()) {
106 if (!reader->ReadWireTag()) {
109 const FieldDescriptor* desc = FindDescriptor(reader);
111 if (!desc->decode_function(object_, reader)) {
89 Decode(void* object, ProtoReader* reader, const FieldDescriptor* descriptors, size_t num_descriptors) argument
[all...]
/system/nvram/messages/include/nvram/messages/
H A Dmessage_codec.h40 // A function to encode a protobuf struct field from |reader|. The decoded
42 using DecodeFunction = bool(void* object, ProtoReader* reader);
112 ProtoReader* reader,
118 bool Decode(ProtoReader* reader);
120 // Decode a protobuf message from reader. This just reads the sequence of
123 bool DecodeData(ProtoReader* reader);
129 const FieldDescriptor* FindDescriptor(ProtoReader* reader) const;
H A Dproto.hpp109 // * |static bool Decode(Type& object, ProtoReader* reader)| decodes a field
110 // from |reader| and places recovered data in |object|.
142 NVRAM_NOINLINE bool DecodeField(Type& value, ProtoReader* reader) { argument
143 return Codec::Decode(value, reader);
157 static bool Decode(Blob& blob, ProtoReader* reader) { argument
158 return blob.Resize(reader->field_size()) &&
159 reader->ReadLengthDelimited(blob.data(), blob.size());
193 static bool Decode(Type& value, ProtoReader* reader) { argument
195 if (!reader->ReadVarint(&raw_value)) {
218 static bool Decode(Vector<ElementType>& vector, ProtoReader* reader) { argument
234 Decode(Optional<ValueType>& value, ProtoReader* reader) argument
325 Decode(TaggedUnionType& object, ProtoReader* reader) argument
344 DecodeMember(void* object, ProtoReader* reader) argument
412 Decode(StructType& object, ProtoReader* reader) argument
440 Decode(StructType& object, ProtoReader* reader) argument
[all...]
/system/extras/simpleperf/
H A Drecord_file_test.cpp82 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); local
83 ASSERT_TRUE(reader != nullptr);
84 std::vector<EventAttrWithId> attrs = reader->AttrSection();
90 std::vector<std::unique_ptr<Record>> records = reader->DataSection();
95 std::vector<BuildIdRecord> read_build_id_records = reader->ReadBuildIdFeature();
99 ASSERT_TRUE(reader->Close());
126 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); local
127 ASSERT_TRUE(reader != nullptr);
128 std::vector<std::unique_ptr<Record>> records = reader->DataSection();
134 ASSERT_TRUE(reader
151 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); local
180 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); local
[all...]
H A Dcmd_record_test.cpp70 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(record_file); local
71 ASSERT_TRUE(reader);
72 std::vector<EventAttrWithId> attrs = reader->AttrSection();
123 std::unique_ptr<RecordFileReader> reader = local
125 ASSERT_TRUE(reader != nullptr);
126 std::vector<std::unique_ptr<Record>> records = reader->DataSection();
146 std::unique_ptr<RecordFileReader> reader = local
148 ASSERT_TRUE(reader != nullptr);
149 const FileHeader& file_header = reader->FileHeader();
152 ASSERT_GT(reader
289 std::unique_ptr<RecordFileReader> reader = local
320 std::unique_ptr<RecordFileReader> reader = local
384 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local
482 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local
519 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local
537 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local
550 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local
[all...]
H A Dcmd_debug_unwind_test.cpp101 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmp_file.path); local
102 ASSERT_TRUE(reader);
103 const std::map<int, PerfFileFormat::SectionDesc>& features = reader->FeatureSectionDescriptors();
107 ASSERT_TRUE(reader->ReadMetaInfoFeature(&info_map));
H A Denvironment.cpp84 LineReader reader(fp);
86 if ((line = reader.ReadLine()) != nullptr) {
129 LineReader reader(fp);
131 while ((line = reader.ReadLine()) != nullptr) {
133 char name[reader.MaxLineSize()];
268 LineReader reader(fp);
270 while ((line = reader.ReadLine()) != nullptr) {
273 char type[reader.MaxLineSize()];
274 char execname[reader.MaxLineSize()];
/system/update_engine/
H A Dmain.cc60 base::DirReaderPosix reader(kLogsRoot.c_str());
61 if (!reader.IsValid()) {
67 while (reader.Next()) {
68 if (reader.name()[0] == '.')
75 if (sscanf(reader.name(),
79 old_logs.push_back(reader.name());
81 LOG(WARNING) << "Unrecognized log file " << reader.name();
/system/tpm/tpm_manager/client/
H A Dtpm_ownership_dbus_proxy_test.cc52 dbus::MessageReader reader(method_call);
54 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
94 dbus::MessageReader reader(method_call);
96 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
125 dbus::MessageReader reader(method_call);
127 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
H A Dtpm_nvram_dbus_proxy_test.cc54 dbus::MessageReader reader(method_call);
56 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
90 dbus::MessageReader reader(method_call);
92 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
123 dbus::MessageReader reader(method_call);
125 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
160 dbus::MessageReader reader(method_call);
162 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request));
196 dbus::MessageReader reader(method_call);
198 EXPECT_TRUE(reader
[all...]
/system/nvram/core/
H A Dpersistence.cpp69 ProtoReader reader(&stream);
70 if (!reader.ReadWireTag() || reader.field_number() != magic ||
71 reader.wire_type() != WireType::kLengthDelimited ||
72 !proto::detail::MessageDecoder<Object>::Decode(*object, &reader)) {
/system/tpm/attestation/server/
H A Ddbus_service_test.cc106 dbus::MessageReader reader(response.get());
108 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply));
130 dbus::MessageReader reader(response.get());
132 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply));
159 dbus::MessageReader reader(response.get());
161 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply));
190 dbus::MessageReader reader(response.get());
192 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply));
220 dbus::MessageReader reader(response.get());
222 EXPECT_TRUE(reader
[all...]
/system/tpm/attestation/client/
H A Ddbus_proxy_test.cc52 dbus::MessageReader reader(method_call);
54 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto));
99 dbus::MessageReader reader(method_call);
101 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto));
145 dbus::MessageReader reader(method_call);
147 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto));
181 dbus::MessageReader reader(method_call);
183 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto));
223 dbus::MessageReader reader(method_call);
225 EXPECT_TRUE(reader
[all...]
/system/timezone/zone_compactor/main/java/
H A DZoneCompactor.java78 BufferedReader reader = new BufferedReader(new FileReader(setupFile));
81 while ((s = reader.readLine()) != null) {
102 reader.close();
170 reader = new BufferedReader(new FileReader(zoneTabFile));
171 while ((s = reader.readLine()) != null) {
177 reader.close();
/system/timezone/distro/tools/src/main/com/android/timezone/distro/tools/
H A DCreateTimeZoneDistro.java125 try (Reader reader = new InputStreamReader(new FileInputStream(f))) {
126 p.load(reader);
/system/extras/perfprofd/
H A Dperf_data_converter.cc172 ::quipper::PerfReader reader; local
173 if (!reader.ReadFile(perf_file)) return nullptr;
175 ::quipper::PerfParser parser(&reader, options);
178 if (!reader.Serialize(perf_data)) return nullptr;

Completed in 307 milliseconds

12