- Timestamp:
- 10/11/12 16:31:09 (13 years ago)
- Location:
- DCWoRMS/trunk/src
- Files:
-
- 6 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/trunk/src/example/localplugin/FCFSClusterLocalPlugin.java
r505 r509 153 153 } 154 154 155 public String getName() {156 return getClass().getName();157 }158 159 155 } -
DCWoRMS/trunk/src/example/localplugin/FCFS_BFLocalPlugin.java
r493 r509 22 22 case START_TASK_EXECUTION: 23 23 case TASK_FINISHED: 24 //case TIMER:25 24 26 25 // our tasks are placed only in first queue (see BaseLocalPlugin.placeJobsInQueues() method) -
DCWoRMS/trunk/src/schedframe/scheduling/Scheduler.java
r494 r509 180 180 } 181 181 } 182 183 /*public boolean processOtherEvent(Sim_event ev) { 184 return false; 185 }*/ 186 182 187 183 protected void processWorkloadUnitReturn(Sim_event ev) { 188 184 WorkloadUnit job = (WorkloadUnit) ev.get_data(); … … 214 210 this.send(this.get_id(), delay, tag, data); 215 211 } 216 217 /*protected void send(int dest, int tag, int transaction, Object obj){218 IO_data data = new Transaction_IO_data(transaction, obj, 8, dest);219 super.send(dest, GridSimTags.SCHEDULE_NOW, tag, data);220 }*/221 212 222 213 public Sim_port getOutputPort() { -
DCWoRMS/trunk/src/simulator/reader/ResourceReader.java
r506 r509 69 69 UnknownParameter { 70 70 71 //File file = new File("src/test/rewolucja/schemas/example/coolemall/example4.xml");72 71 File file = new File(resDescFileName); 73 //File file = new File("example/tomekp/experiment1/tomExp3.xml");74 /*long s =System.currentTimeMillis();75 System.out.println("start: ");76 List<Processor> list = new ArrayList<Processor>();77 for(int i =0;i<3000000;i++){78 schemas.ComputingResource compResDef = new schemas.ComputingResource();79 compResDef.setName("a"+i);80 compResDef.setClazz("Processor");81 CompResourceDescription resDesc = new CompResourceDescription(compResDef);82 Processor proc = new Processor(resDesc);83 list.add(proc);84 }85 long e = System.currentTimeMillis();86 System.out.println("end: ");87 System.out.println(e-s);*/88 72 Environment env = Environment.unmarshal(new FileReader(file)); 89 73 … … 183 167 184 168 List<ComputingResource> mainCompResourceList = new ArrayList<ComputingResource>(); 185 186 169 Deque<ComputingResourceDescription> toExamine = new ArrayDeque<ComputingResourceDescription>(); 187 170 Deque<ComputingResource> resStructure = new ArrayDeque<ComputingResource>(); … … 268 251 ManagedResources managedResources = new ManagedResources(mainCompResourceList, new HashMap<ResourceUnitName, List<ResourceUnit>>()); 269 252 mainScheduler = ResourceFactory.createScheduler(StandardResourceType.GS, "grid", schedulingPlugin , execTimeEstimationPlugin, queues, managedResources); 270 /*ManagementSystem ms = new GridBroker("grid", 271 globalSchedulingPluginName, execTimeEstimationPlugin); 272 mainScheduler = new Scheduler(ms, mainCompResourceList);*/ 253 273 254 for(Scheduler lr: mainSchedulers){ 274 255 mainScheduler.addChild(lr); -
DCWoRMS/trunk/src/test/ariel/CPUFreqScalingExecTimeEstimationPlugin.java
r506 r509 30 30 speed = peUnit.getSpeed(); 31 31 32 33 34 32 int cnt = peUnit.getUsedAmount(); 35 33 -
DCWoRMS/trunk/src/test/ariel/experiment1.properties
r506 r509 4 4 resdesc=src/test/ariel/resources.xml 5 5 6 7 6 # and swf file, which name is declared by readscenario.workloadfilename parameter. 8 7 # Swf file must be placed in readscenario.inputfolder directory. 9 8 readscenario.workloadfilename=src/test/ariel/workload.swf 10 11 # Choose if files with task processing history should be created.12 printhistory=true13 9 14 10 # Choose directory where all result files should be placed. … … 17 13 18 14 creatediagrams.gantt=true 19 creatediagrams.utilization=false20 creatediagrams.energyusage=false21 15 22 creatediagrams. tasks=false23 creatediagrams.taskswaitingtime=false 16 creatediagrams.respowerusage=Processor 17
Note: See TracChangeset
for help on using the changeset viewer.