Homec4science
Diffusion Multi-level Scheduling in Large Scale High Performance Computers (master) Browse

mls/bls-als/gridsim-simgrid/code/two-levels_simulator/unibas/multilevel/HoldResumeEntity.java
102bf7abcc5amaster

Last Change
Raw File

HoldResumeEntity.java
View Options

/*********************************************************************************
* Copyright (c) 2017 *
* Ahmed Eleliemy <ahmed.eleliemy@unibas.ch> *
* University of Basel, Switzerland *
* All rights reserved. *
* *
* This program is free software; you can redistribute it and/or modify it *
* under the terms of the license (GNU LGPL) which comes with this package. *
*********************************************************************************/
package unibas.multilevel;
import java.util.ArrayList;
import eduni.simjava.Sim_event;
import gridsim.GridSim;
import gridsim.GridSimTags;
import gridsim.Gridlet;
import gridsim.ResGridlet;
import xklusac.environment.ResourceInfo;
/**
* @author eleliemy
*
*/
public class HoldResumeEntity extends GridSim
{
// private instance of communication manager
private static CommunicationManager bacommunicator;
// used to indicate the ammount of message this object needs to wait before releasing the simulation
private static int waitForResult=0;
//constructor
public HoldResumeEntity(String name) throws Exception
{
super(name);
HoldResumeEntity.clearwait();
}
/**
* This function is used to set the communicator manager
* @param comm The communication manager instance
* */
public static void setCommunicator(CommunicationManager comm)
{
bacommunicator=comm;
}
/**
* This function is used to reset number of the messages that have to be delivered to the
* HoldResume entity
* */
private static void clearwait()
{
waitForResult=0;
}
/**
* This function is used to increment number of the messages that have to be delivered to the
* HoldResume entity
* */
public static void incrementWaitingList()
{
waitForResult++;
}
/**
* This function is used to decrement number of the messages that have to be delivered to the
* HoldResume entity
* */
public static void decrementWaitingList()
{
waitForResult--;
}
/**
* This function run until GridSimTags.END_OF_SIMULATION event is sent from the scheduler entity
* */
@Override
public void body()
{
super.gridSimHold(10.0);
while (true)
{
Sim_event ev = new Sim_event();
sim_get_next(ev);
if(ev.get_tag()==MLSTags.WaitToInject)
{
//System.out.println("waiting event");
while(waitForResult>0)
{
try
{
sleep(1);
}
catch (InterruptedException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//System.out.println("inject now waiting event");
}
else if(ev.get_tag()==MLSTags.SetJobEND)
{
@SuppressWarnings("unchecked")
ArrayList<Object> data=(ArrayList<Object>)ev.get_data();
ResGridlet rgl=(ResGridlet)data.get(0);
ResourceInfo ri=(ResourceInfo)data.get(1);
Double ExecustionTimeinMS=(Double)data.get(2);
Double WallTimeinMS=(Double)data.get(3);
rgl.getGridlet().setGridletFinishedSoFar(rgl.getGridletLength());
bacommunicator.gridletFinish(ExecustionTimeinMS, WallTimeinMS, ri.resource, rgl);
try
{
rgl.getGridlet().setGridletStatus(Gridlet.SUCCESS);
}
catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
send(GridSim.getEntityId("Alea_3.0_scheduler"), GridSimTags.SCHEDULE_NOW, GridSimTags.GRIDLET_RETURN,
rgl.getGridlet());
// System.out.println("Actuall return "+ super.clock()+" "+rgl.getGridlet().getGridletID());
}
else if(ev.get_tag()==GridSimTags.END_OF_SIMULATION)
{
System.out.println("injector dies in peace :D");
return;
}
}
}
}
c4science · Help