Lines Matching defs:sequence_number
278 << ": Message (seq: " << error_ack_message->sequence_number()
490 const uint32_t sequence_number = this->GetSequenceNumber();
493 sequence_number, is_dump_msg, message->Encode(sequence_number),
498 VLOG(5) << "NL Message " << pending_message.sequence_number << " to send ("
538 } else if (ContainsKey(message_handlers_, pending_message.sequence_number)) {
540 << pending_message.sequence_number;
549 message_handlers_[pending_message.sequence_number] =
557 VLOG(5) << "Sending NL message " << pending_message.sequence_number;
565 << pending_message.sequence_number;
580 const uint32_t sequence_number = packet.GetMessageSequence();
581 if (!ContainsKey(message_handlers_, sequence_number) &&
625 return pending_messages_.front().sequence_number;
629 if (!ContainsKey(message_handlers_, message.sequence_number())) {
632 message_handlers_.erase(message.sequence_number());
683 const uint32_t sequence_number = packet->GetMessageSequence();
688 VLOG(3) << "NL Message " << sequence_number << " <===";
692 VLOG(5) << "NL Message " << sequence_number << " Received ("
712 (message->sequence_number() == PendingDumpSequenceNumber()) &&
741 VLOG(3) << "Error/ACK response to message " << sequence_number;
743 CallErrorHandler(sequence_number, kErrorFromKernel, message.get());
745 if (ContainsKey(message_handlers_, sequence_number)) {
747 if (message_handlers_[sequence_number]->HandleAck()) {
749 message_handlers_.erase(sequence_number);
758 if (ContainsKey(message_handlers_, sequence_number)) {
762 message_handlers_[sequence_number]->HandleError(kDone, message.get());
763 } else if (!message_handlers_[sequence_number]->HandleMessage(*message)) {
764 LOG(ERROR) << "Couldn't call message handler for " << sequence_number;
767 message_handlers_[sequence_number]->HandleError(kUnexpectedResponseType,
775 message_handlers_.erase(sequence_number);
813 void NetlinkManager::CallErrorHandler(uint32_t sequence_number,
816 if (ContainsKey(message_handlers_, sequence_number)) {
818 message_handlers_[sequence_number]->HandleError(type, netlink_message);
819 message_handlers_.erase(sequence_number);
