server.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:33:08 karl>
 */

#include "server.h"

Define_Module (Server);

void
Server::initialize()
{
  busy = 0;
  speed = par ("speed");

  // prepare the self-message:
  taskIsDone = new cMessage;
  taskIsDone->setKind (taskDone);
}

void
Server::finish()
{
  recordScalar ("utilization", AreaUnderUtilizationCurve / simTime());
}

void
Server::updateStatistics (int kind)
{
  simtime_t timeSinceLastEvent = simTime() - timeOfLastEvent;
  timeOfLastEvent = simTime();
  
  switch (kind)
    {
      case taskArrives:
	break;
      case taskDone:
	AreaUnderUtilizationCurve += timeSinceLastEvent;
	break;
      default:
	ev << "No statistics implemented for this kind of event" << endl;
	break;
    }
}


void
Server::handleMessage (cMessage *msg)
{
  double size;

  int type = msg->kind();
  cMessage *statusAnswer;
  
  switch (type)
    {
      case taskArrives:
	if (busy)
	  {
	    ev << "Server received a task when already busy - ignored!\n" ;
	  }
	else
	  {
	    busy = 1;
	    size = msg->par ("size");
	    scheduleAt (simTime() + size/speed, taskIsDone);
	  }
	delete msg;

	updateStatistics (taskArrives);
	
	break;

      case taskDone:
	if (!busy)
	  {
	    ev << "Server told itself a task is done when not busy - ignored!\n";
	  }
	else
	  {
	    cMessage *taskDoneToDispatcher = new cMessage ("Task done");

	    taskDoneToDispatcher->setKind (taskDone);
	    send (taskDoneToDispatcher, "toDispatcher");
	    
	    busy = 0;
	  }

	updateStatistics (taskDone);

	break;

      case checkStatus:
	statusAnswer = new cMessage ("Status report");
	statusAnswer->setKind (checkStatusResult);
	statusAnswer->addPar("busy") = busy;
	send (statusAnswer, "toDispatcher");
	delete msg;
	break;
	
      default:
	ev << "Server received an unknown message - ignored!\n";
	delete msg;
	break;
    }

}