Searched defs:reader (Results 1 - 20 of 20) sorted by relevance

/system/core/logd/
H A DLogListener.h35 LogReader* reader; member in class:LogListener
38 LogListener(LogBufferInterface* buf, LogReader* reader /* nullable */);
H A DFlushCommand.cpp29 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 DLogAudit.h30 LogReader* reader; member in class:LogAudit
42 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) {
136 if (res > 0 && reader != nullptr) {
137 reader->notifyNewLog();
H A DLogTimes.cpp30 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 DCommandListener.cpp40 CommandListener::CommandListener(LogBuffer* buf, LogReader* /*reader*/,
56 CommandListener::ShutdownCmd::ShutdownCmd(LogReader* reader, LogListener* swl) argument
57 : LogCommand("shutdown"), mReader(*reader), mSwl(*swl) {
H A DLogBufferElement.cpp231 log_time LogBufferElement::flushTo(SocketClient* reader, LogBuffer* parent, argument
262 log_time retval = reader->sendDatav(iovec, 1 + (entry.len != 0))
H A DLogAudit.cpp43 LogAudit::LogAudit(LogBuffer* buf, LogReader* reader, int fdDmesg) argument
46 reader(reader),
369 reader->notifyNewLog();
H A Dmain.cpp421 // 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 DLogKlog.cpp205 LogKlog::LogKlog(LogBuffer* buf, LogReader* reader, int fdWrite, int fdRead, argument
209 reader(reader),
829 reader->notifyNewLog();
H A DLogBuffer.cpp63 // 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 Dinplace_generator.h64 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 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.cpp87 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 Drecord_file_reader.cpp39 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 Dcmd_record.cpp935 std::unique_ptr<RecordFileReader> reader = local
937 if (reader == nullptr) {
945 bool result = reader->ReadDataSection(
/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 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/core/adb/
H A Dfdevent_test.cpp121 int reader = fd_pair2[0]; local
130 ASSERT_TRUE(ReadFdExactly(reader, &write_buffer[0], write_buffer.size()));
136 ASSERT_EQ(0, adb_close(reader));

Completed in 185 milliseconds