---

model/jobs/SMalleableJob.h

Go to the documentation of this file.

/* #start# ***********************************************************

           Scheduling Simulator
        Lehrstuhl f"ur Effiziente Algorithmen
           Technische Universit"at M"unchen

 File    : $Id: SMalleableJob.h,v 1.7 2003/03/21 15:47:05 taeubig Exp $

 Purpose : 

 RCS-Log:
 $Log: SMalleableJob.h,v $
 Revision 1.7  2003/03/21 15:47:05  taeubig
 merge with source from Bertolt

 Revision 1.6  2003/01/24 10:05:02  hall
 brdCast stuff

 Revision 1.5  2003/01/08 18:57:13  meierb
 added randomized release times

 Revision 1.2  2002/12/16 23:32:09  meierb
 *** empty log message ***

 Revision 1.1.1.1  2002/12/02 22:26:19  meierb
 my_schedule

 Revision 1.3  2002/11/10 18:19:42  taeubig
 Added std:: to cerr

 Revision 1.2  2002/11/09 20:50:14  taeubig
 <iostream> inclusion, added std::
 corrected relative path for header includes

 Revision 1.1  2002/08/29 12:59:59  taeubig
 Added the sources

 Revision 1.1  2000/05/29 19:51:25  taeubig
 Moved job type related files into subdirectory jobs

 Revision 1.8  2000/05/09 13:33:11  taeubig
 Defined fitsInto()  (replaces isSmaller())

 Revision 1.7  2000/04/18 00:17:30  taeubig
 Minor changes for setting the current topology and
 getting the processing time (have to discuss that later..)

 Revision 1.6  2000/02/23 18:06:55  taeubig
 Changed reference into pointer in setCurrentTopology()

 Revision 1.5  2000/01/30 03:06:19  taeubig
 Updated topologies.

 Revision 1.4  2000/01/08 19:36:23  taeubig
 Cleaned SMalleableJob* files

 Revision 1.3  1999/12/01 07:55:31  schickin
 temporary bug fixes (project didn't compile!)

 Revision 1.2  1999/12/01 03:59:55  taeubig
 SParallelJob is now superclass of SMalleableJob.
 Minor changes for requested topology.

 Revision 1.1  1999/11/10 03:06:00  taeubig
 Malleable jobs (parallelizable jobs),
 they may be scheduled on fewer machines than requested
 at the cost of increasing the processing time


 * #end# ************************************************************* */

#ifndef SMALLEABLEJOB_H
#define SMALLEABLEJOB_H

// system header files
#include <iostream>

// project header files
#include "SJob.h"
#include "SMalleableJobMod.h"
#include "SParallelJob.h"
#include "../topos/STopology.h"

// -----------------------------------------------------------------------
class SMalleableJob : public virtual SParallelJob {
  TYPEINFO0(SMalleableJob, "malleable");
  friend class SMalleableJobMod;
public:
  SMalleableJob(SProbabilityDist* dist) : SParallelJob(dist), _mod(*this), _pMaxTop(NULL), _pMinTop(NULL) {};
  SMalleableJob(double proctime) : SParallelJob(proctime), _mod(*this), _pMaxTop(NULL), _pMinTop(NULL) {};
  virtual ~SMalleableJob() {};

  virtual const STopology* getMaxTop() const { return _pMaxTop; };
  virtual const STopology* getMinTop() const { return _pMinTop; };

  virtual void process(SMachines& machines, double duration);

  SJobMod& getModifier() { return _mod; };

  // Why don't we overwrite setTopology() ???
  void setCurrentTopology(STopology* top) {
    assert(top != NULL);
    if ((_pMaxTop != NULL) && !top->fitsInto(_pMaxTop))
      // errorMsg("Error", "Topology is too big");
      std::cerr << "Error! Topology is too big" << std::endl;
    if ((_pMinTop != NULL) && !_pMinTop->fitsInto(top))
      // errorMsg("Error", "Topology is too small");
      std::cerr << "Error! Topology is too small" << std::endl;
    _mod.setTopology(top);
  }

  virtual double getProcTime();
  virtual double getProcTimeOnTopology(const STopology& rTopo);

private:
  SMalleableJobMod _mod;
  STopology *_pMaxTop;
  STopology *_pMinTop;
};
// -----------------------------------------------------------------------
std::ostream& operator<<(std::ostream& out, SMalleableJob &job);  
// -----------------------------------------------------------------------

#endif //SMALLEABLEJOB_H

---