Searched refs:incoming_queue_ (Results 1 – 2 of 2) sorted by relevance
81 std::queue<packet::PacketView<packet::kLittleEndian>> incoming_queue_; member91 auto packet = incoming_queue_.front(); in on_data_ready()92 incoming_queue_.pop(); in on_data_ready()93 if (incoming_queue_.empty() && enqueue_registered_->exchange(false)) { in on_data_ready()137 if (incoming_queue_.size() > kMaxQueuedPacketsPerConnection) { in on_incoming_packet()143 incoming_queue_.push(recombination_stage_); in on_incoming_packet()
236 IOVector incoming_queue_; member