loadgen.cc

mmk排队论系统的omnet 源码

/*
 * Copyright (C) 2000, 2001  by Holger Karl
 * This file is for internal use only.
 *
 * Written by: Holger Karl <[e-mail]>
 *
 * Time-stamp: <01/05/21 14:32:08 karl>
 */

#include "omnetpp.h"

#include "loadgen.h"

Define_Module (LoadGen);

void
LoadGen::activity()
{
  int outgate_id = findGate ("loadout");
  
  
  for (int i=0; i<1000; i++)
    {
      double wait_time = par("interarrival_time");
      ev << "L: waiting for: " << wait_time << ", restart at " << wait_time + simTime() << "\n";

      wait (wait_time);

      // construct a message and send it:
      double loadsize = par("load_size");

      cMessage *msg = new cMessage ("Task arrives");

      msg->setTimestamp (simTime());
      msg->addPar ("size") = loadsize;
      msg->setKind (taskArrives);
      
      send (msg, outgate_id);
    }

  cMessage *terminate = new cMessage;
  terminate->addPar ("s") = -1.0;
  send (terminate, outgate_id);
  
}