mahimahi/delay_queue.cc at pythonservers · talalahmad/mahimahi

Repository navigation

/* -*-mode:c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */

#include <limits>

#include "delay_queue.hh"

#include "timestamp.hh"

using namespace std;

void DelayQueue::read_packet( const string & contents )

{

packet_queue_.emplace( timestamp() + delay_ms_, contents );

}

void DelayQueue::write_packets( FileDescriptor & fd )

{

while ( (!packet_queue_.empty())

&& (packet_queue_.front().first <= timestamp()) ) {

fd.write( packet_queue_.front().second );

packet_queue_.pop();

}

unsigned int DelayQueue::wait_time( void ) const

{

if ( packet_queue_.empty() ) {

return numeric_limits<uint16_t>::max();

}

const auto now = timestamp();

if ( packet_queue_.front().first <= now ) {

return 0;

} else {

return packet_queue_.front().first - now;

}