Searched refs:received_messages_ (Results 1 – 2 of 2) sorted by relevance
92 return MessageSpan(received_messages_.begin(), received_messages_.size()); in received_messages()112 if (received_messages_.full()) { in ReadAllEntries()115 received_messages_.emplace_back(); in ReadAllEntries()116 received_messages_.back() << std::string_view( in ReadAllEntries()120 } while (total_drop_count_ + received_messages_.size() < in ReadAllEntries()130 Vector<StringBuffer<kEntryBufferSize>, kMaxMessageCount> received_messages_; member in pw::multisink::LogPopReaderThread151 if (received_messages_.full()) { in ReadAllEntries()155 received_messages_.emplace_back(); in ReadAllEntries()156 received_messages_.back() << std::string_view( in ReadAllEntries()161 } while (total_drop_count_ + received_messages_.size() < in ReadAllEntries()
68 received_messages_.emplace_back(std::move(message));154 if (received_messages_.empty()) { in ConsumeReceivedMessage()157 DcSctpMessage ret = std::move(received_messages_.front()); in ConsumeReceivedMessage()158 received_messages_.pop_front(); in ConsumeReceivedMessage()175 std::deque<DcSctpMessage> received_messages_; variable