Lines Matching refs:slot
123 PendingFrameSlot* const slot = get_slot_for(frame.frame_id); in EnqueueFrame() local
124 OSP_DCHECK(!slot->frame); in EnqueueFrame()
125 slot->frame = crypto_.Encrypt(frame); in EnqueueFrame()
126 const int packet_count = rtp_packetizer_.ComputeNumberOfPackets(*slot->frame); in EnqueueFrame()
128 slot->frame.reset(); in EnqueueFrame()
131 slot->send_flags.Resize(packet_count, YetAnotherBitVector::SET); in EnqueueFrame()
132 slot->packet_sent_times.assign(packet_count, SenderPacketRouter::kNever); in EnqueueFrame()
136 last_enqueued_frame_id_ = slot->frame->frame_id; in EnqueueFrame()
139 if (slot->frame->dependency == EncodedFrame::KEY_FRAME) { in EnqueueFrame()
140 last_enqueued_key_frame_id_ = slot->frame->frame_id; in EnqueueFrame()
144 if (slot->frame->new_playout_delay > milliseconds::zero()) { in EnqueueFrame()
145 target_playout_delay_ = slot->frame->new_playout_delay; in EnqueueFrame()
146 playout_delay_change_at_frame_id_ = slot->frame->frame_id; in EnqueueFrame()
150 pending_sender_report_.reference_time = slot->frame->reference_time; in EnqueueFrame()
151 pending_sender_report_.rtp_timestamp = slot->frame->rtp_timestamp; in EnqueueFrame()
236 *chosen.slot->frame, chosen.packet_id, buffer); in GetRtpPacketForImmediateSend()
237 chosen.slot->send_flags.Clear(chosen.packet_id); in GetRtpPacketForImmediateSend()
238 chosen.slot->packet_sent_times[chosen.packet_id] = send_time; in GetRtpPacketForImmediateSend()
404 PendingFrameSlot* slot = nullptr; in OnReceiverIsMissingPackets() local
408 slot = candidate_slot; in OnReceiverIsMissingPackets()
417 if (!slot) { in OnReceiverIsMissingPackets()
429 if (slot->packet_sent_times[packet_id] <= too_recent_a_send_time) { in OnReceiverIsMissingPackets()
430 slot->send_flags.Set(packet_id); in OnReceiverIsMissingPackets()
434 const FramePacketId range_end = slot->packet_sent_times.size(); in OnReceiverIsMissingPackets()
463 PendingFrameSlot* const slot = get_slot_for(frame_id); in ChooseNextRtpPacketNeedingSend() local
464 if (!slot->is_active_for_frame(frame_id)) { in ChooseNextRtpPacketNeedingSend()
467 const FramePacketId packet_id = slot->send_flags.FindFirstSet(); in ChooseNextRtpPacketNeedingSend()
468 if (packet_id < slot->send_flags.size()) { in ChooseNextRtpPacketNeedingSend()
469 return {slot, packet_id}; in ChooseNextRtpPacketNeedingSend()
489 chosen.slot = get_slot_for(last_enqueued_frame_id_); in ChooseKickstartPacket()
492 OSP_DCHECK(chosen.slot->is_active_for_frame(last_enqueued_frame_id_)); in ChooseKickstartPacket()
493 chosen.packet_id = chosen.slot->send_flags.size() - 1; in ChooseKickstartPacket()
496 chosen.slot->packet_sent_times[chosen.packet_id]; in ChooseKickstartPacket()
523 PendingFrameSlot* const slot = get_slot_for(frame_id); in CancelPendingFrame() local
524 if (!slot->is_active_for_frame(frame_id)) { in CancelPendingFrame()
529 slot->frame->data.size(), rtcp_packet_arrival_time_, round_trip_time_); in CancelPendingFrame()
531 slot->frame.reset(); in CancelPendingFrame()