/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.cpp | 29 FlushCommand::FlushCommand(LogReader& reader, bool nonBlock, unsigned long tail, argument 32 : mReader(reader), 42 // log reader socket. Here we manage and associated the reader
|
H A D | LogAudit.h | 30 LogReader* reader; member in class:LogAudit 42 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) { 136 if (res > 0 && reader != nullptr) { 137 reader->notifyNewLog();
|
H A D | LogTimes.cpp | 30 LogTimeEntry::LogTimeEntry(LogReader& reader, SocketClient* client, argument 39 mReader(reader), 90 LogReader& reader = me->mReader; local 91 LastLogTimes& times = reader.logbuf().mTimes; 104 reader.release(client); 118 prctl(PR_SET_NAME, "logd.reader.per");
|
H A D | CommandListener.cpp | 40 CommandListener::CommandListener(LogBuffer* buf, LogReader* /*reader*/, 56 CommandListener::ShutdownCmd::ShutdownCmd(LogReader* reader, LogListener* swl) argument 57 : LogCommand("shutdown"), mReader(*reader), mSwl(*swl) {
|
H A D | LogBufferElement.cpp | 231 log_time LogBufferElement::flushTo(SocketClient* reader, LogBuffer* parent, argument 262 log_time retval = reader->sendDatav(iovec, 1 + (entry.len != 0))
|
H A D | LogAudit.cpp | 43 LogAudit::LogAudit(LogBuffer* buf, LogReader* reader, int fdDmesg) argument 46 reader(reader), 369 reader->notifyNewLog();
|
H A D | main.cpp | 421 // transitory per-client threads are created for each reader. 481 // socket connection, and as a reader lock on a range of log 503 LogReader* reader = new LogReader(logBuf); local 504 if (reader->startListener()) { 512 LogListener* swl = new LogListener(logBuf, reader); 521 CommandListener* cl = new CommandListener(logBuf, reader, swl); 532 al = new LogAudit(logBuf, reader, 541 kl = new LogKlog(logBuf, reader, fdDmesg, fdPmesg, al != nullptr);
|
H A D | LogKlog.cpp | 205 LogKlog::LogKlog(LogBuffer* buf, LogReader* reader, int fdWrite, int fdRead, argument 209 reader(reader), 829 reader->notifyNewLog();
|
H A D | LogBuffer.cpp | 63 // In-place element fixup so no need to check reader-lock. Entries 99 // We may have been triggered by a SIGHUP. Release any sleeping reader 623 // the prune operation could not be completed because a reader is blocking 631 // If the selected reader is blocking our pruning progress, decide on 635 // A misbehaving or slow reader has its connection 639 // Allow a blocked WRAP timeout reader to 643 // tell slow reader to skip entries to catch up 654 // First there is a prep phase where we discover the reader region lock that 686 // lock is causing us to buffer too much in the logs to help the reader(s), 687 // and will tell the slowest reader threa 1096 flushTo(SocketClient* reader, const log_time& start, pid_t* lastTid, bool privileged, bool security, int (*filter)(const LogBufferElement* element, void* arg), void* arg) argument [all...] |
/system/update_engine/payload_generator/ |
H A D | inplace_generator.h | 64 Block() : reader(Vertex::kInvalidIndex), writer(Vertex::kInvalidIndex) {} 65 Vertex::Index reader; member in struct:chromeos_update_engine::InplaceGenerator::Block 176 // The |blocks| vector contains a reader and writer for each block on the 177 // filesystem that's being in-place updated. We populate the reader/writer 180 // in |blocks| and set the reader/writer field to the vertex passed. 190 // This method will also register the vertex as the reader or writer of the
|
/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 | 87 std::unique_ptr<RecordFileReader> reader = local 89 ASSERT_TRUE(reader != nullptr); 90 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); 110 std::unique_ptr<RecordFileReader> reader = local 112 ASSERT_TRUE(reader != nullptr); 113 const FileHeader& file_header = reader->FileHeader(); 116 ASSERT_GT(reader->FeatureSectionDescriptors().size(), 0u); 253 std::unique_ptr<RecordFileReader> reader = local 255 ASSERT_TRUE(reader != nullptr); 256 std::vector<std::unique_ptr<Record>> records = reader 284 std::unique_ptr<RecordFileReader> reader = local 348 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local 446 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local 476 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); local [all...] |
H A D | record_file_reader.cpp | 39 auto reader = std::unique_ptr<RecordFileReader>(new RecordFileReader(filename, fp)); local 40 if (!reader->ReadHeader() || !reader->ReadAttrSection() || 41 !reader->ReadFeatureSectionDescriptors()) { 44 return reader;
|
H A D | cmd_record.cpp | 935 std::unique_ptr<RecordFileReader> reader = local 937 if (reader == nullptr) { 945 bool result = reader->ReadDataSection(
|
/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 | 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/core/adb/ |
H A D | fdevent_test.cpp | 121 int reader = fd_pair2[0]; local 130 ASSERT_TRUE(ReadFdExactly(reader, &write_buffer[0], write_buffer.size())); 136 ASSERT_EQ(0, adb_close(reader));
|