Lines Matching refs:Packets
162 bool IsTimeSorted(const Packets& packets) {
163 PacketsConstIt last_it = packets.begin();
164 for (PacketsConstIt it = last_it; it != packets.end(); ++it) {
255 void RateCounterFilter::RunFor(int64_t /*time_ms*/, Packets* in_out) {
278 void LossFilter::RunFor(int64_t /*time_ms*/, Packets* in_out) {
302 void DelayFilter::RunFor(int64_t /*time_ms*/, Packets* in_out) {
326 void JitterFilter::RunFor(int64_t /*time_ms*/, Packets* in_out) {
350 void ReorderFilter::RunFor(int64_t /*time_ms*/, Packets* in_out) {
391 void ChokeFilter::RunFor(int64_t /*time_ms*/, Packets* in_out) {
483 void TraceBasedDeliveryFilter::RunFor(int64_t time_ms, Packets* in_out) {
489 // Drop any packets that have been queued for too long.
523 // When the trace wraps we allow two packets to be sent back-to-back.
569 void VideoSender::RunFor(int64_t time_ms, Packets* in_out) {
572 Packets new_packets;
578 // Generate new packets for this frame, all with the same timestamp,
580 // one packet, we will see a number of equally sized packets followed by
623 void PacedVideoSender::RunFor(int64_t time_ms, Packets* in_out) {
625 Packets generated_packets;
627 Packets::iterator it = generated_packets.begin();
628 // Run process periodically to allow the packets to be paced out.
656 void PacedVideoSender::QueuePackets(Packets* batch,
662 Packets::iterator it = queue_.begin();
668 Packets to_transfer;
683 for (Packets::iterator it = pacer_queue_.begin(); it != pacer_queue_.end();
