injector

Class Injector

java.lang.Object

org.simgrid.msg.Process

injector.Injector

All Implemented Interfaces:

java.lang.Runnable

public class Injector
extends org.simgrid.msg.Process

Field Summary

Fields inherited from class org.simgrid.msg.Process

startTime

Method Summary

Modifier and Type	Method and Description
static java.util.Deque<FaultEvent>	generateFaultQueue(XHost[] xhosts, long duration, int faultPeriod)
static java.util.Deque<LoadEvent>	generateLoadQueue(XVM[] vms, long duration, int injectionPeriod)
static java.util.Deque<FaultEvent>	generateSnoozeFaultQueue(XHost[] xhosts, long duration)
static java.util.Deque<VMSuspendResumeEvent>	generateVMFluctuationQueue(XVM[] xvms, long duration, int faultPeriod)
static boolean	isStillOff(XHost tmp, java.util.LinkedList<FaultEvent> queue, double currentTime, double crashDuration)
void	main(java.lang.String[] args)
void	main2(java.lang.String[] args)
static java.util.Deque<InjectorEvent>	mergeQueues(java.util.Deque<LoadEvent> loadQueue, java.util.Deque<FaultEvent> faultQueue, java.util.Deque<VMSuspendResumeEvent> vmEvents)

Methods inherited from class org.simgrid.msg.Process

create, exit, fromPID, getCount, getCurrentProcess, getHost, getName, getPID, getPPID, getProperty, isSuspended, kill, kill, killAll, migrate, restart, resume, run, setAutoRestart, setKillTime, sleep, sleep, start, suspend, waitFor, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

generateLoadQueue

public static java.util.Deque<LoadEvent> generateLoadQueue(XVM[] vms,
                                                           long duration,
                                                           int injectionPeriod)

Parameters:

vms, - Simgrid VMs that have been instanciated

duration - int, duration of the simulated time in second

injectionPeriod - int, frequency of event occurrence in seconds

Returns:

the queue of the VM changes

generateSnoozeFaultQueue

public static java.util.Deque<FaultEvent> generateSnoozeFaultQueue(XHost[] xhosts,
                                                                   long duration)

generateFaultQueue

public static java.util.Deque<FaultEvent> generateFaultQueue(XHost[] xhosts,
                                                             long duration,
                                                             int faultPeriod)

generateVMFluctuationQueue

public static java.util.Deque<VMSuspendResumeEvent> generateVMFluctuationQueue(XVM[] xvms,
                                                                               long duration,
                                                                               int faultPeriod)

isStillOff

public static boolean isStillOff(XHost tmp,
                                 java.util.LinkedList<FaultEvent> queue,
                                 double currentTime,
                                 double crashDuration)

mergeQueues

public static java.util.Deque<InjectorEvent> mergeQueues(java.util.Deque<LoadEvent> loadQueue,
                                                         java.util.Deque<FaultEvent> faultQueue,
                                                         java.util.Deque<VMSuspendResumeEvent> vmEvents)

main

public void main(java.lang.String[] args)
          throws org.simgrid.msg.MsgException

Specified by:

main in class org.simgrid.msg.Process

Throws:

org.simgrid.msg.MsgException

main2

public void main2(java.lang.String[] args)
           throws org.simgrid.msg.MsgException

Throws:

org.simgrid.msg.MsgException