Searched refs:incoming_queue_ (Results 1 – 1 of 1) sorted by relevance
57 std::queue<packet::PacketView<kLittleEndian>> incoming_queue_; member67 auto packet = incoming_queue_.front(); in on_le_incoming_data_ready()68 incoming_queue_.pop(); in on_le_incoming_data_ready()69 if (incoming_queue_.empty() && enqueue_registered_->exchange(false)) { in on_le_incoming_data_ready()116 if (incoming_queue_.size() > kMaxQueuedPacketsPerConnection) { in on_incoming_packet()121 incoming_queue_.push(payload); in on_incoming_packet()