1 package at.ac.tuwien.lsdc;
4 import java.io.IOException;
5 import java.util.Collections;
6 import java.util.LinkedList;
8 import org.slf4j.Logger;
9 import org.slf4j.LoggerFactory;
11 import at.ac.tuwien.lsdc.sched.AbstractScheduler;
12 import at.ac.tuwien.lsdc.sched.SchedulerA;
13 import at.ac.tuwien.lsdc.sched.SchedulerB;
14 import at.ac.tuwien.lsdc.sched.SchedulerC;
15 import at.ac.tuwien.lsdc.types.Application;
16 import at.ac.tuwien.lsdc.types.ScenarioData;
17 import at.ac.tuwien.lsdc.types.ScenarioType;
18 import at.ac.tuwien.lsdc.types.SchedulerType;
19 import at.ac.tuwien.lsdc.util.CSVLogger;
20 import at.ac.tuwien.lsdc.util.CSVParser;
23 * Read config (command line properties) and start Scheduler-Simulation.
25 public class SchedSimulator {
27 private static final String USAGE = "SchedSimulator needs exactly 7 parameters: scenario, scheduler, numPMS, numCloudPartners, inputFile, generalLogPath, schedulerLogPath";
29 private static final Logger log = LoggerFactory
30 .getLogger(SchedSimulator.class);
32 private static ScenarioType scenario;
33 private static SchedulerType schedulerType;
34 private static int numPMs;
35 private static int numCloudPartners;
36 private static File inputFile;
37 private static File generalLog;
38 private static File schedulerLog;
40 public static void main(String[] args) throws Exception {
41 if (args.length == 7) {
42 parseCommandLineArgs(args);
43 } else if (args.length == 1) {
44 String[] newArgs = args[0].split(" ");
45 if (newArgs.length == 7) {
46 parseCommandLineArgs(newArgs);
55 LinkedList<Application> apps = CSVParser.parseFile(inputFile);
56 Collections.sort(apps);
57 AbstractScheduler scheduler;
58 switch (schedulerType) {
60 scheduler = new SchedulerA(schedulerLog, schedulerType, scenario, numPMs, numCloudPartners);
62 scheduler = new SchedulerB(schedulerLog, schedulerType, scenario, numPMs, numCloudPartners);
64 scheduler = new SchedulerC(schedulerLog, schedulerType, scenario, numPMs, numCloudPartners);
66 ScenarioData data = scheduler.initAndStart(apps);
67 CSVLogger logger = new CSVLogger(generalLog);
68 logger.logScenarioData(data);
73 * Commandline arguments parsed (mandatory):
76 * - number of available PMs
77 * - number of cloud partners
78 * - scenario input file with applications
79 * - general output file for all schedulers
80 * - specific output file for this scheduler/scenario combination
81 * @param args the command line arguments to parse
83 private static void parseCommandLineArgs(String[] args) {
84 String scenarioStr = args[0];
85 String schedulerTypeStr = args[1];
86 String numPMsStr = args[2];
87 String numCloudPartnersStr = args[3];
88 String inputFileStr = args[4];
89 String generalLogStr = args[5];
90 String schedulerLogStr = args[6];
93 scenario = ScenarioType.valueOf(scenarioStr);
94 schedulerType = SchedulerType.valueOf(schedulerTypeStr);
95 numPMs = Integer.parseInt(numPMsStr);
96 numCloudPartners = Integer.parseInt(numCloudPartnersStr);
97 inputFile = new File(inputFileStr);
99 if (!inputFile.canRead())
100 throw new IOException("Can not read input file");
101 generalLog = new File(generalLogStr);
102 boolean generalLogOK = false;
103 if ( generalLog.canWrite() ) {
106 else if (!generalLog.exists()) {
107 generalLog.createNewFile();
111 throw new IOException("Can not write to general log file");
113 boolean schedulerLogOK = false;
114 schedulerLog = new File(schedulerLogStr);
115 if (schedulerLog.exists()) {
116 schedulerLogOK = schedulerLog.canWrite();
117 schedulerLog.delete();
118 schedulerLog.createNewFile();
120 schedulerLog.createNewFile();
121 schedulerLogOK = true;
124 throw new IOException("Can not write to scheduler log file "
126 } catch (Exception e) {