Home
last modified time | relevance | path

Searched refs:sequence (Results 1 – 25 of 71) sorted by relevance

123

/system/logging/logd/
DSerializedFlushToStateTest.cpp41 auto sequence_to_log_id = [&](uint64_t sequence) -> int { in TestReport() argument
43 if (std::find(sequences.begin(), sequences.end(), sequence) != sequences.end()) { in TestReport()
54 for (uint64_t sequence : missing_expected) { in TestReport() local
55 int log_id = sequence_to_log_id(sequence); in TestReport()
56 missing_sequences[log_id].emplace_back(sequence); in TestReport()
63 for (uint64_t sequence : extra_read) { in TestReport() local
64 int log_id = sequence_to_log_id(sequence); in TestReport()
65 extra_sequences[log_id].emplace_back(sequence); in TestReport()
88 for (uint64_t sequence = 0; sequence < max_sequence; ++sequence) { in TestAllReading() local
90 auto state = SerializedFlushToState{sequence, mask, log_chunks_}; in TestAllReading()
[all …]
DSerializedLogBufferTest.cpp68 uint64_t sequence; member
82 chunk.Log(entry.sequence, entry.realtime, entry.uid, entry.pid, entry.tid, entry.msg.data(), in CreateChunk()
150 .sequence = 1, in TEST()
194 .sequence = 1, in TEST()
200 .sequence = 2, in TEST()
225 .sequence = 1, in TEST()
231 .sequence = 2, in TEST()
259 .sequence = 1, in TEST()
268 .sequence = 2, in TEST()
277 .sequence = 3, in TEST()
[all …]
Dlibaudit.cpp98 static uint32_t sequence = 0; in audit_send() local
99 if (sequence == std::numeric_limits<uint32_t>::max()) { in audit_send()
100 sequence = 1; in audit_send()
102 sequence++; in audit_send()
104 req.nlh.nlmsg_seq = sequence; in audit_send()
120 rc = (rc == 0) ? (int)sequence : rc; in audit_send()
DLogReader.cpp170 uint64_t sequence = 1; in onDataAvailable() local
174 uint64_t last = sequence; in onDataAvailable()
175 auto log_find_start = [pid, start, &sequence, &start_time_set, &last]( in onDataAvailable()
182 sequence = element_sequence; in onDataAvailable()
187 sequence = last; in onDataAvailable()
196 auto flush_to_state = log_buffer_->CreateFlushToState(sequence, logMask); in onDataAvailable()
203 sequence = log_buffer_->sequence(); in onDataAvailable()
220 logMask, pid, start, sequence, deadline); in onDataAvailable()
DSerializedLogBuffer.cpp31 size_t max_size, uint64_t sequence, log_time realtime, in LogToLogBuffer() argument
44 return log_buffer.back().Log(sequence, realtime, uid, pid, tid, msg, len); in LogToLogBuffer()
84 LogToLogBuffer(new_logs, max_size, entry.sequence(), entry.realtime(), entry.uid(), in ClearLogsByUid()
151 auto sequence = sequence_.fetch_add(1, std::memory_order_relaxed); in Log() local
154 auto entry = LogToLogBuffer(logs_[log_id], max_size_[log_id], sequence, realtime, uid, pid, tid, in Log()
253 const std::function<FilterResult(log_id_t log_id, pid_t pid, uint64_t sequence, in FlushTo() argument
262 if (entry->sequence() < state.start()) { in FlushTo()
265 state.set_start(entry->sequence()); in FlushTo()
272 auto ret = filter(log_id, entry->pid(), entry->sequence(), entry->realtime()); in FlushTo()
DSerializedLogChunk.cpp84 SerializedLogEntry* SerializedLogChunk::Log(uint64_t sequence, log_time realtime, uid_t uid, in Log() argument
87 auto* entry = new (new_log_address) SerializedLogEntry(uid, pid, tid, sequence, realtime, len); in Log()
90 highest_sequence_number_ = sequence; in Log()
DSimpleLogBuffer.cpp99 auto sequence = sequence_.fetch_add(1, std::memory_order_relaxed); in Log() local
100 LogInternal(LogBufferElement(log_id, realtime, uid, pid, tid, sequence, msg, len)); in Log()
137 const std::function<FilterResult(log_id_t log_id, pid_t pid, uint64_t sequence, in FlushTo() argument
151 if (it->sequence() == state.start()) { in FlushTo()
153 } else if (it->sequence() < state.start()) { in FlushTo()
163 state.set_start(element.sequence()); in FlushTo()
175 filter(element.log_id(), element.pid(), element.sequence(), element.realtime()); in FlushTo()
304 if (oldest && oldest->start() <= element.sequence()) { in Prune()
DSerializedLogEntry.h36 SerializedLogEntry(uid_t uid, pid_t pid, pid_t tid, uint64_t sequence, log_time realtime, in SerializedLogEntry() argument
41 sequence_(sequence), in SerializedLogEntry()
85 uint64_t sequence() const { return sequence_; } in sequence() function
DLogReaderThread.cpp71 [this](log_id_t log_id, pid_t pid, uint64_t sequence, in ThreadFunction()
73 return FilterFirstPass(log_id, pid, sequence, realtime); in ThreadFunction()
78 [this](log_id_t log_id, pid_t pid, uint64_t sequence, log_time realtime) REQUIRES( in ThreadFunction()
79 logd_lock) { return FilterSecondPass(log_id, pid, sequence, realtime); }); in ThreadFunction()
DLogReaderThread.h42 LogMask log_mask, pid_t pid, log_time start_time, uint64_t sequence,
71 FilterResult FilterFirstPass(log_id_t log_id, pid_t pid, uint64_t sequence, log_time realtime)
73 FilterResult FilterSecondPass(log_id_t log_id, pid_t pid, uint64_t sequence, log_time realtime)
DLogBufferTest.h100 FlushMessagesResult FlushMessages(uint64_t sequence = 1, LogMask log_mask = kLogMaskAll) {
105 auto flush_to_state = log_buffer_->CreateFlushToState(sequence, log_mask);
116 uint64_t sequence = 1; member
128 params.sequence, params.deadline)); in TestReaderThread()
DLogBufferElement.h38 uint64_t sequence, const char* msg, uint16_t len);
56 uint64_t sequence() const { return sequence_; } in sequence() function
DSerializedFlushToState.cpp59 if (entry->sequence() >= start()) { in CreateLogPosition()
133 if (log_positions_[i]->log_entry()->sequence() < min_sequence) { in PopNextUnreadLog()
136 min_sequence = entry->sequence(); in PopNextUnreadLog()
/system/tools/xsdc/tests/resources/simple_complex_content/
Dsimple_complex_content.xsd4 <xs:sequence>
10 </xs:sequence>
16 <xs:sequence>
19 </xs:sequence>
26 <xs:sequence>
30 </xs:sequence>
48 <xs:sequence>
53 </xs:sequence>
58 <xs:sequence>
65 </xs:sequence>
/system/tools/xsdc/tests/resources/nested_type/
Dnested_type.xsd4 <xs:sequence>
9 <xs:sequence>
15 <xs:sequence>
18 </xs:sequence>
29 </xs:sequence>
33 </xs:sequence>
/system/update_engine/payload_generator/
Dmerge_sequence_generator.cc61 std::vector<CowMergeOperation>* sequence) { in SplitSelfOverlapping() argument
64 sequence->emplace_back(CreateCowMergeOperation(src_extent, dst_extent)); in SplitSelfOverlapping()
72 sequence->emplace_back(CreateCowMergeOperation( in SplitSelfOverlapping()
80 std::vector<CowMergeOperation> sequence; in Create() local
107 SplitSelfOverlapping(src_extent, dst_extent, &sequence); in Create()
109 sequence.emplace_back(CreateCowMergeOperation(src_extent, dst_extent)); in Create()
122 std::sort(sequence.begin(), sequence.end()); in Create()
124 new MergeSequenceGenerator(sequence)); in Create()
179 std::vector<CowMergeOperation>* sequence) const { in Generate()
180 sequence->clear(); in Generate()
[all …]
Dmerge_sequence_generator.h54 static bool ValidateSequence(const std::vector<CowMergeOperation>& sequence);
58 bool Generate(std::vector<CowMergeOperation>* sequence) const;
75 std::vector<CowMergeOperation>* sequence);
Dmerge_sequence_generator_unittest.cc47 std::vector<CowMergeOperation> sequence; in GenerateSequence() local
48 ASSERT_TRUE(generator.Generate(&sequence)); in GenerateSequence()
49 ASSERT_EQ(expected, sequence); in GenerateSequence()
212 std::vector<CowMergeOperation> sequence; in ValidateSplitSequence() local
213 SplitSelfOverlapping(src_extent, dst_extent, &sequence); in ValidateSplitSequence()
223 for (const auto& merge_op : sequence) { in ValidateSplitSequence()
/system/tools/xsdc/tests/resources/predefined_types/
Dpredefined_types.xsd3 <xs:sequence>
15 </xs:sequence>
18 <xs:sequence>
28 </xs:sequence>
31 <xs:sequence>
46 </xs:sequence>
49 <xs:sequence>
60 </xs:sequence>
63 <xs:sequence>
99 </xs:sequence>
[all …]
/system/tools/xsdc/
DREADME.md17 <xs:sequence>
19 </xs:sequence>
29 <xs:sequence>
31 </xs:sequence>
54 <xs:sequence>
56 </xs:sequence>
66 <xs:sequence>
70 </xs:sequence>
167 "xsd:sequence": [
/system/tools/xsdc/tests/resources/group/
Daddress.xsd3 <xs:sequence>
6 </xs:sequence>
Dgroup.xsd4 <xs:sequence>
6 </xs:sequence>
/system/tools/xsdc/tests/resources/reference/
Dreference.xsd6 <xs:sequence>
8 </xs:sequence>
/system/tools/xsdc/tests/resources/attr_group_simple/
Dattr_group_simple.xsd15 <xs:sequence>
17 </xs:sequence>
/system/vold/
DCheckpoint.cpp419 uint32_t sequence; member
572 if (index == 0 && ls.sequence != 0) { in restoreSector()
634 LOG(INFO) << action << " " << original_ls.sequence << " log sectors"; in cp_restoreCheckpoint()
636 for (int sequence = original_ls.sequence; sequence >= 0 && status.isOk(); sequence--) { in cp_restoreCheckpoint() local
654 if ((int)ls.sequence != sequence) { in cp_restoreCheckpoint()
655 status = error(EINVAL, "Expecting log sector " + std::to_string(sequence) + in cp_restoreCheckpoint()
656 " but got " + std::to_string(ls.sequence)); in cp_restoreCheckpoint()
660 LOG(INFO) << action << " from log sector " << ls.sequence; in cp_restoreCheckpoint()

123