ircproxy  The Ultimate Cyborg

---

Queue.cc

Go to the documentation of this file.

// ircproxy -- An IRC bouncer.
//
//! @file Queue.cc
//! @brief This file contains the implementation of class Queue.
//
// Copyright (C) 2007 by
//
// Carlo Wood, Run on IRC <carlo@alinoe.com>
// RSA-1024 0x624ACAD5 1997-01-26                    Sign & Encrypt
// Fingerprint16 = 32 EC A7 B6 AC DB 65 A6  F6 F6 55 DD 1C DC FF 61
//
// This file may be distributed under the terms of the Q Public License
// version 1.0 as appearing in the file LICENSE.QPL included in the
// packaging of this file.

#ifndef USE_PCH
#include "sys.h"
#include <sys/time.h>
#endif

#include <cmath>
#include "Queue.h"
#include "Identity.h"
#include "keys.h"

timeval operator-(timeval const& a, timeval const& b)
{
  timeval result;
  timersub(&a, &b, &result);
  return result;
}

void Queue::flush(void)
{
  DoutEntering(dc::debug, "Queue::flush() with M_free_messages = " << M_free_messages);
  timeval elapsed_time = timer_event_server_ct::instance().get_now() - M_time;
  float elapsed_seconds = elapsed_time.tv_sec + elapsed_time.tv_usec * 0.000001;
  // Calculate the number of free messages that we can send in a burst now.
  M_free_messages += elapsed_seconds * M_messages_per_second;
  if (M_free_messages > M_max_free_messages)
    M_free_messages = M_max_free_messages;
  while (!M_priority_queue.empty())
  {
    MessageOut const& msg(M_priority_queue.top());
    // We are still not hidden! Don't send any message yet.
    // However, allow to send WHO/WHOIS/WHOWAS and other safe queries.
    if (M_server_connection.state() < real_nick_sent && !msg.is_safe())
      M_free_messages = 0;
    if (M_free_messages < 1)    // FIXME: A more complex algorithm is needed.
      break;
    // Send this message to the server.
    msg.write_to(M_server_connection.server_session());
    M_free_messages -= 1;
    M_priority_queue.pop();
  }
  // Store the time at which M_free_messages was last updated.
  M_time = timer_event_server_ct::instance().get_now();
  // If there are still messages in the queue, set a timer to process them.
  if (!M_priority_queue.empty())
  {
    // Use 1.001 instead of 1 to avoid calling the function a micro second too soon due to rounding errors.
    float needed_seconds = (1.001 - M_free_messages) /  M_messages_per_second;
    timeval delay;
    delay.tv_sec = floorf(needed_seconds);
    delay.tv_usec = floorf((needed_seconds - delay.tv_sec) * 1000000);
    timerRequest(delay, *this, &Queue::send_next_message);
  }
}

void Queue::send_next_message(timer_event_type_ct const& LIBCW_UNUSED_UNLESS_DEBUG(expired_at))
{
  DoutEntering(dc::debug, "Queue::send_next_message(" << expired_at.get_expire_time() << ")");
  // For now, just call flush.
  flush();
}

---