BandwidthMonitor.inl

Go to the documentation of this file.

/* -*- C++ -*- */
#ifndef _BANDWIDTH_MONITOR_INL_
#define _BANDWIDTH_MONITOR_INL_

#include "BandwidthMonitor.h"
#include "madara/utility/Utility.h"

inline time_t
madara::transport::BandwidthMonitor::update_utilization (void)
{
  MADARA_GUARD_TYPE guard (mutex_);
  
  time_t cur_time = time (NULL);
  time_t earliest_time = cur_time - window_;
  
  BandwidthMessages::iterator begin = messages_.begin ();
  BandwidthMessages::iterator end = begin;

  for (end = begin; end != messages_.end (); ++end)
  {
    if (end->first < earliest_time)
    {
      utilization_ -= end->second;
    }
    else
      break;
  }

  if (end != begin)
    messages_.erase (begin, end);

  return cur_time;
}

#endif // _BANDWIDTH_MONITOR_INL_