Changeset 1378 for DCWoRMS/branches


Ignore:
Timestamp:
06/06/14 10:48:49 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/test
Files:
18 edited

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming/FCFSBF_RandomPluginPausing.java

    r1376 r1378  
    11package test.pausing_resuming; 
    2  
    3 import dcworms.schedframe.scheduling.ExecTask; 
    4 import dcworms.schedframe.scheduling.Executable; 
    5 import example.localplugin.BaseLocalSchedulingPlugin; 
    6 import gridsim.Gridlet; 
    7 import gridsim.dcworms.DCWormsTags; 
    82 
    93import java.util.ArrayList; 
    … …  
    115import java.util.List; 
    126import java.util.Map; 
    13 import java.util.Properties; 
    14  
    15 import org.joda.time.DateTime; 
    167 
    178import schedframe.events.scheduling.SchedulingEvent; 
    18 import schedframe.exceptions.ResourceException; 
    199import schedframe.resources.ResourceStatus; 
    20 import schedframe.resources.StandardResourceType; 
    21 import schedframe.resources.computing.Node; 
    2210import schedframe.resources.computing.ComputingResource; 
    2311import schedframe.resources.computing.Processor; 
    24 import schedframe.resources.computing.profiles.energy.EnergyEventType; 
    25 import schedframe.resources.units.Memory; 
    26 import schedframe.resources.units.PEUnit; 
    2712import schedframe.resources.units.ProcessingElements; 
    2813import schedframe.resources.units.ResourceUnit; 
    … …  
    3520import schedframe.scheduling.plan.impl.SchedulingPlan; 
    3621import schedframe.scheduling.plugin.grid.ModuleList; 
    37 import schedframe.scheduling.plugin.local.ResourceAllocation; 
    3822import schedframe.scheduling.queue.TaskQueue; 
    3923import schedframe.scheduling.queue.TaskQueueList; 
    4024import schedframe.scheduling.tasks.TaskInterface; 
    41 import simulator.DataCenterWorkloadSimulator; 
     25import dcworms.schedframe.scheduling.ExecTask; 
     26import example.localplugin.BaseLocalSchedulingPlugin; 
     27import gridsim.dcworms.DCWormsTags; 
    4228 
    4329public class FCFSBF_RandomPluginPausing extends BaseLocalSchedulingPlugin { 
    … …  
    6753                                                addToSchedulingPlan(plan, task, choosenResources); 
    6854                                        } else { 
    69                                                 if(jobRegistry.getRunningTasks().size() > 0) { 
    70                                                         for(ExecTask exec: jobRegistry.getRunningTasks()){ 
    71                                                                 jobRegistry.pauseTask(exec.getJobId(), exec.getId()); 
    72                                                         } 
    73                                                 }  
     55                                                ExecTask taskToPause = getTaskWithLowestPriority(jobRegistry.getRunningTasks()); 
     56                                                if(getTaskPriority(task) > getTaskPriority(taskToPause)){ 
     57                                                        jobRegistry.pauseTask(taskToPause.getJobId(), taskToPause.getId()); 
     58                                                } 
    7459                                        } 
    7560                                } 
    … …  
    154139                return null; 
    155140        } 
    156  
     141         
     142         
     143        private int getTaskPriority(TaskInterface<?> task){ 
     144                int priority; 
     145                 
     146                try { 
     147                        double cpuRequest = task.getCpuCntRequest(); 
     148                        priority = (-1) * Double.valueOf(cpuRequest).intValue(); 
     149                } catch (NoSuchFieldException e) { 
     150                        priority = Integer.MIN_VALUE; 
     151                } 
     152                 
     153                return priority; 
     154        } 
     155         
     156        private ExecTask getTaskWithLowestPriority(List<ExecTask> tasks){ 
     157                ExecTask lowestPriorityTask = null; 
     158                int lowestPriority = Integer.MAX_VALUE; 
     159                for(ExecTask execTask: tasks){ 
     160                        int taskPriority = getTaskPriority(execTask); 
     161                        if(taskPriority < lowestPriority){ 
     162                                lowestPriority = getTaskPriority(execTask); 
     163                                lowestPriorityTask = execTask; 
     164                        } 
     165                } 
     166                 
     167                return lowestPriorityTask; 
     168        } 
    157169 
    158170 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming/resources1.xml

    r1376 r1378  
    66        <resources> 
    77                <computingResource class="DataCenter" name="compRes"> 
    8                         <!-- Defined data center contains only 6 processors --> 
    9                         <computingResource class="Processor" count="1"/> 
     8                        <!-- Defined data center contains only 4 processors --> 
     9                        <computingResource class="Processor" count="4"/> 
    1010                </computingResource> 
    1111                <scheduler class="Cluster" name="cluster"> 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming/workload.swf

    r1375 r1378  
    1313;PUSpeed: 1 
    1414; 
    15  
    16  
    17                 1                       0                       -1              7200    1               -1              -1              1               -1              -1              -1              -1              -1              1               1               1               -1              -1 
    18                 2                       3600                    -1              7200    1               -1              -1              1               -1              -1              -1              -1              -1              1               1               1               -1              -1 
     15                0               0               -1              7200            4               -1              -1              4               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1 
     16                1               360             -1              7200            2               -1              -1              2               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1 
     17                2               1200            -1              7200            1               -1              -1              1               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1 
     18                3               3600            -1              7200            1               -1              -1              1               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1 
     19                4               5400            -1              7200            1               -1              -1              1               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming_result/Stats_Simulation_1_Jobs.txt

    r1375 r1378  
    11jobID;meanTaskCompletionTime;meanTaskExecutionTime;meanTaskStartTime;meanTaskFlowTime;meanTaskWaitingTime;meanTaskGQ_WaitingTime;lateness;tardiness;makespan; 
    2 1;14,400;7,200;0;14,400;0;0;0;0;14,400; 
    3 2;10,800;7,200;0;7,200;0;0;0;0;10,800; 
     20;19,440;7,200;0;19,440;0;0;0;0;19,440; 
     31;10,560;7,200;0;10,200;0;0;0;0;10,560; 
     42;8,400;7,200;0;7,200;0;0;0;0;8,400; 
     53;10,800;7,200;0;7,200;0;0;0;0;10,800; 
     64;12,600;7,200;0;7,200;0;0;0;0;12,600; 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming_result/Stats_Simulation_1_ResourceOccupancy.txt

    r1375 r1378  
    11utlization;compRes;1225666800000;1; 
     2utlization;compRes;1225667160000;0.5; 
     3utlization;compRes;1225668000000;0.75; 
    24utlization;compRes;1225670400000;1; 
    3 utlization;compRes;1225677600000;1; 
    4 utlization;compRes;1225681200000;0; 
     5utlization;compRes;1225672200000;0.75; 
     6utlization;compRes;1225675200000;1; 
     7utlization;compRes;1225677360000;0.5; 
     8utlization;compRes;1225677600000;0.25; 
     9utlization;compRes;1225679400000;1; 
     10utlization;compRes;1225686240000;0; 
     11mean: 0.8333333333333333 
     12utlization;compRes/Processor_1;1225666800000;1; 
     13utlization;compRes/Processor_1;1225667160000;1; 
     14utlization;compRes/Processor_1;1225672200000;1; 
     15utlization;compRes/Processor_1;1225679400000;1; 
     16utlization;compRes/Processor_1;1225686240000;0; 
    517mean: 1.0 
    6 utlization;compRes/Processor_1;1225666800000;1; 
    7 utlization;compRes/Processor_1;1225670400000;1; 
    8 utlization;compRes/Processor_1;1225677600000;1; 
    9 utlization;compRes/Processor_1;1225681200000;0; 
    10 mean: 1.0 
     18utlization;compRes/Processor_2;1225666800000;1; 
     19utlization;compRes/Processor_2;1225667160000;1; 
     20utlization;compRes/Processor_2;1225672200000;0; 
     21utlization;compRes/Processor_2;1225675200000;1; 
     22utlization;compRes/Processor_2;1225677360000;0; 
     23utlization;compRes/Processor_2;1225679400000;1; 
     24utlization;compRes/Processor_2;1225686240000;0; 
     25mean: 0.7407407407407407 
     26utlization;compRes/Processor_3;1225666800000;1; 
     27utlization;compRes/Processor_3;1225667160000;0; 
     28utlization;compRes/Processor_3;1225668000000;1; 
     29utlization;compRes/Processor_3;1225675200000;1; 
     30utlization;compRes/Processor_3;1225677360000;0; 
     31utlization;compRes/Processor_3;1225679400000;1; 
     32utlization;compRes/Processor_3;1225686240000;0; 
     33mean: 0.8518518518518519 
     34utlization;compRes/Processor_4;1225666800000;1; 
     35utlization;compRes/Processor_4;1225667160000;0; 
     36utlization;compRes/Processor_4;1225670400000;1; 
     37utlization;compRes/Processor_4;1225677600000;0; 
     38utlization;compRes/Processor_4;1225679400000;1; 
     39utlization;compRes/Processor_4;1225686240000;0; 
     40mean: 0.7407407407407407 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming_result/Stats_Simulation_1_ResourceUtilization.txt

    r1375 r1378  
    11utlization;compRes;1225666800000;1; 
    2 utlization;compRes;1225681200000;0; 
     2utlization;compRes;1225667160000;0.5; 
     3utlization;compRes;1225668000000;0.75; 
     4utlization;compRes;1225670400000;1; 
     5utlization;compRes;1225672200000;0.75; 
     6utlization;compRes;1225675200000;1; 
     7utlization;compRes;1225677360000;0.5; 
     8utlization;compRes;1225677600000;0.25; 
     9utlization;compRes;1225679400000;1; 
     10utlization;compRes;1225686240000;0; 
     11mean: 0.8333333333333333 
     12utlization;compRes/Processor_1;1225666800000;1; 
     13utlization;compRes/Processor_1;1225686240000;0; 
    314mean: 1.0 
    4 utlization;compRes/Processor_1;1225666800000;1; 
    5 utlization;compRes/Processor_1;1225681200000;0; 
    6 mean: 1.0 
     15utlization;compRes/Processor_2;1225666800000;1; 
     16utlization;compRes/Processor_2;1225672200000;0; 
     17utlization;compRes/Processor_2;1225675200000;1; 
     18utlization;compRes/Processor_2;1225677360000;0; 
     19utlization;compRes/Processor_2;1225679400000;1; 
     20utlization;compRes/Processor_2;1225686240000;0; 
     21mean: 0.7407407407407407 
     22utlization;compRes/Processor_3;1225666800000;1; 
     23utlization;compRes/Processor_3;1225667160000;0; 
     24utlization;compRes/Processor_3;1225668000000;1; 
     25utlization;compRes/Processor_3;1225677360000;0; 
     26utlization;compRes/Processor_3;1225679400000;1; 
     27utlization;compRes/Processor_3;1225686240000;0; 
     28mean: 0.8518518518518519 
     29utlization;compRes/Processor_4;1225666800000;1; 
     30utlization;compRes/Processor_4;1225667160000;0; 
     31utlization;compRes/Processor_4;1225670400000;1; 
     32utlization;compRes/Processor_4;1225677600000;0; 
     33utlization;compRes/Processor_4;1225679400000;1; 
     34utlization;compRes/Processor_4;1225686240000;0; 
     35mean: 0.7407407407407407 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming_result/Stats_Simulation_1_Simulation.txt

    r1375 r1378  
    22Delayed tasks;0;0;0;0;0;0;1; 
    33Failed requests (tasks);0;0;0;0;0;0;1; 
    4 Makespan;14,400;0;0;14,400;14,400;14,400;1; 
    5 Resources queue length;0.25;0;0;0.25;0.25;0.25;1; 
    6 Resources total load;1;0;0;1;1;1;1; 
     4Makespan;19,440;0;0;19,440;19,440;19,440;1; 
     5Resources queue length;0.432;0;0;0.432;0.432;0.432;1; 
     6Resources total load;0.833;0;0;0.833;0.833;0.833;1; 
    77Energy usage;?;?;?;?;?;?;0; 
    8 Task completion time;12,600;1,800;3,240,000;10,800;14,400;25,200;2; 
    9 Task execution time;7,200;0;0;7,200;7,200;14,400;2; 
    10 Task start time;0;0;0;0;0;0;2; 
    11 Task flow time;10,800;3,600;12,960,000;7,200;14,400;21,600;2; 
    12 Task waiting time;0;0;0;0;0;0;2; 
    13 Task lateness;0;0;0;0;0;0;2; 
    14 Task tardiness;0;0;0;0;0;0;2; 
     8Task completion time;12,360;3,782.571;14,307,840;8,400;19,440;61,800;5; 
     9Task execution time;7,200;0;0;7,200;7,200;36,000;5; 
     10Task start time;0;0;0;0;0;0;5; 
     11Task flow time;10,248;4,740.592;22,473,216;7,200;19,440;51,240;5; 
     12Task waiting time;0;0;0;0;0;0;5; 
     13Task lateness;0;0;0;0;0;0;5; 
     14Task tardiness;0;0;0;0;0;0;5; 

  • DCWoRMS/branches/coolemall/src/test/pausing_resuming_result/Stats_Simulation_1_Tasks.txt

    r1375 r1378  
    11JobID;TaskID;UserDN;SchedName;CpuCnt;ExecStartDate;ExecFinishDate;ExecEndDate;GB_SubDate;LB_SubDate;CompletionTime;ExecStartTime;ExecutionTime;ReadyTime;StartTime;FlowTime;WaitingTime;GQ_WaitingTime;Lateness;Tardiness;ReservStartDate;ReservFinishDate;HostNames;ProcessorName;Energy;AppName; 
    2 1;1;-1;cluster;1;1225666800;1225681200;1225681200;1225666800;1225666800;14400;0;7200;0;0;14400;0;0;0;0;0;0;[];[compRes/Processor_1];0;null; 
    3 2;2;-1;cluster;1;1225670400;1225677600;1225677600;1225670400;1225670400;10800;3600;7200;3600;0;7200;0;0;0;0;0;0;[];[compRes/Processor_1];0;null; 
     20;0;-1;cluster;4;1225666800;1225686240;1225686240;1225666800;1225666800;19440;0;7200;0;0;19440;0;0;0;0;0;0;[];[compRes/Processor_1, compRes/Processor_2, compRes/Processor_3, compRes/Processor_4];0;null; 
     31;1;-1;cluster;2;1225667160;1225677360;1225677360;1225667160;1225667160;10560;360;7200;360;0;10200;0;0;0;0;0;0;[];[compRes/Processor_1, compRes/Processor_2, compRes/Processor_3];0;null; 
     42;2;-1;cluster;1;1225668000;1225675200;1225675200;1225668000;1225668000;8400;1200;7200;1200;0;7200;0;0;0;0;0;0;[];[compRes/Processor_3];0;null; 
     53;3;-1;cluster;1;1225670400;1225677600;1225677600;1225670400;1225670400;10800;3600;7200;3600;0;7200;0;0;0;0;0;0;[];[compRes/Processor_4];0;null; 
     64;4;-1;cluster;1;1225672200;1225679400;1225679400;1225672200;1225672200;12600;5400;7200;5400;0;7200;0;0;0;0;0;0;[];[compRes/Processor_1];0;null; 
Note: See TracChangeset for help on using the changeset viewer.