Home
last modified time | relevance | path

Searched refs:possible_entry (Results 1 – 2 of 2) sorted by relevance

/external/pigweed/pw_log_rpc/
Drpc_log_drain.cc153 Result<multisink::MultiSink::Drain::PeekedEntry> possible_entry = in EncodeOutgoingPacket() local
158 if (possible_entry.status().IsResourceExhausted()) { in EncodeOutgoingPacket()
164 if (possible_entry.status().IsOutOfRange()) { in EncodeOutgoingPacket()
172 PW_CHECK_OK(possible_entry.status()); in EncodeOutgoingPacket()
176 filter_->ShouldDropLog(possible_entry.value().entry())) { in EncodeOutgoingPacket()
181 PW_CHECK_OK(PopEntry(possible_entry.value())); in EncodeOutgoingPacket()
187 possible_entry.value().entry().size() + kLogEntriesEncodeFrameSize; in EncodeOutgoingPacket()
191 PW_CHECK_OK(PopEntry(possible_entry.value())); in EncodeOutgoingPacket()
202 bool log_entry_buffer_has_valid_entry = possible_entry.ok(); in EncodeOutgoingPacket()
238 if (possible_entry.ok() && !log_entry_buffer_has_valid_entry) { in EncodeOutgoingPacket()
[all …]
/external/pigweed/pw_multisink/
Dmultisink_threaded_test.cc104 const Result<ConstByteSpan> possible_entry = in ReadAllEntries() local
107 if (possible_entry.status().IsOutOfRange()) { in ReadAllEntries()
111 ASSERT_EQ(possible_entry.status(), OkStatus()); in ReadAllEntries()
117 reinterpret_cast<const char*>(possible_entry.value().data()), in ReadAllEntries()
118 possible_entry.value().size()); in ReadAllEntries()
143 const Result<MultiSink::Drain::PeekedEntry> possible_entry = in ReadAllEntries() local
146 if (possible_entry.status().IsOutOfRange()) { in ReadAllEntries()
150 ASSERT_EQ(possible_entry.status(), OkStatus()); in ReadAllEntries()
157 reinterpret_cast<const char*>(possible_entry.value().entry().data()), in ReadAllEntries()
158 possible_entry.value().entry().size()); in ReadAllEntries()
[all …]