Attachment #2649 for bug #2535

View | Details | Raw Unified | Return to bug 2535
Collapse All | Expand All





std::string g_me;
#define LOG(x)   std::cout << x << std::endl
    #define LOGME(x) LOG (g_me << x)
    #define DEB(x) if (g_debug) { LOGME (x); }

// Output field width
int g_fwidth = 6;

class Bench
{
public:
  Bench (const uint32_t population, const uint32_t total)
    : m_population (population),
      m_total (total),
      m_count (0)
  {
  }

  void SetRandomStream (Ptr<RandomVariableStream> stream)
  {
    m_rand = stream;
  }

  void SetPopulation (const uint32_t population)
  {
    m_population = population;
  }

  void SetTotal (const uint32_t total)
  {
    m_total = total;
  }

  void RunBench (void);
private:
  void Cb (void);

  Ptr<RandomVariableStream> m_rand;
  uint32_t m_population;
  uint32_t m_total;

};

void
Bench::RunBench (void)
{
  SystemWallClockMs time;
  double init, simu;

void
Bench::Cb (void)
{
  if (m_count >= m_total)
    {
      return;
    }

GetRandomStream (std::string filename)
{
  Ptr<RandomVariableStream> stream = 0;

  if (filename == "")
    {
      LOGME ("using default exponential distribution");

    }
  else
    {
      std::istream *input;

      if (filename == "-")
        {
          LOGME ("using event distribution from stdin");
          input = &std::cin;
        }
      else
        {
          LOGME ("using event distribution from " << filename);


      double value;
      std::vector<double> nsValues;

      while (!input->eof ())
        {
          if (*input >> value)
            {
              uint64_t ns = (uint64_t) (value * 1000000000);
              nsValues.push_back (ns);
            }
          else
            {
              input->clear ();
              std::string line;

      drv->SetValueArray (&nsValues[0], nsValues.size ());
      stream = drv;
    }

  return stream;
}


  uint32_t total = 1000000;
  uint32_t runs  =       1;
  std::string filename = "";

  CommandLine cmd;
  cmd.Usage ("Benchmark the simulator scheduler.\n"
             "\n"

  g_fwidth += 6;  // 5 extra chars in '2.000002e+07 ': . e+0 _

  ObjectFactory factory ("ns3::MapScheduler");
  if (schedCal)
    {
      factory.SetTypeId ("ns3::CalendarScheduler");
    }
  if (schedHeap)
    {
      factory.SetTypeId ("ns3::HeapScheduler");
    }
  if (schedList)
    {
      factory.SetTypeId ("ns3::ListScheduler");
    }
  Simulator::SetScheduler (factory);

  LOGME (std::setprecision (g_fwidth - 6));

  LOGME ("population: " << pop);
  LOGME ("total events: " << total);
  LOGME ("runs: " << runs);

  Bench *bench = new Bench (pop, total);
  bench->SetRandomStream (GetRandomStream (filename));


       std::left << std::setw (g_fwidth) << "Per (s/ev)" );
  LOG (std::setfill ('-') <<
       std::right << std::setw (g_fwidth) << " " <<
       std::right << std::setw (g_fwidth) << " " <<
       std::right << std::setw (g_fwidth) << " " <<
       std::right << std::setw (g_fwidth) << " " <<
       std::right << std::setw (g_fwidth) << " " <<
       std::right << std::setw (g_fwidth) << " " <<
       std::right << std::setw (g_fwidth) << " " <<
       std::setfill (' ')
       );

  // prime
  DEB ("priming");
  std::cout << std::left << std::setw (g_fwidth) << "(prime)";

  for (uint32_t i = 0; i < runs; i++)
    {
      std::cout << std::setw (g_fwidth) << i;

      bench->RunBench ();
    }

  LOG ("");
  return 0;

  Simulator::Destroy ();
  delete bench;

  return 0;
}

Return to bug 2535