/system/update_engine/payload_consumer/ |
H A D | extent_reader_unittest.cc | 81 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 D | file_descriptor_utils.cc | 50 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 D | LogListener.h | 35 LogReader* reader; member in class:LogListener 38 LogListener(LogBufferInterface* buf, LogReader* reader /* nullable */);
|
H A D | FlushCommand.h | 38 // 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 D | LogAudit.h | 30 LogReader* reader; member in class:LogAudit 37 LogAudit(LogBuffer* buf, LogReader* reader, int fdDmesg);
|
H A D | LogKlog.h | 28 LogReader* reader; member in class:LogKlog 42 LogKlog(LogBuffer* buf, LogReader* reader, int fdWrite, int fdRead,
|
H A D | LogListener.cpp | 35 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 D | CommandListener.h | 31 CommandListener(LogBuffer* buf, LogReader* reader, LogListener* swl); 43 ShutdownCmd(LogReader* reader, LogListener* swl);
|
H A D | LogTimes.cpp | 30 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 D | message_codec.cpp | 90 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 D | message_codec.h | 40 // 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 D | proto.hpp | 109 // * |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 D | record_file_test.cpp | 82 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 D | cmd_record_test.cpp | 70 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 D | cmd_debug_unwind_test.cpp | 101 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 D | environment.cpp | 84 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 D | main.cc | 60 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 D | tpm_ownership_dbus_proxy_test.cc | 52 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 D | tpm_nvram_dbus_proxy_test.cc | 54 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 D | persistence.cpp | 69 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 D | dbus_service_test.cc | 106 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 D | dbus_proxy_test.cc | 52 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 D | ZoneCompactor.java | 78 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 D | CreateTimeZoneDistro.java | 125 try (Reader reader = new InputStreamReader(new FileInputStream(f))) { 126 p.load(reader);
|
/system/extras/perfprofd/ |
H A D | perf_data_converter.cc | 172 ::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;
|