Changeset 1385 for DCWoRMS/branches


Ignore:
Timestamp:
06/18/14 14:06:49 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/schedframe/scheduling
Files:
4 edited

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/tasks/AbstractJobRegistry.java

    r1374 r1385  
    2020 
    2121 
    22 public abstract class AbstractJobRegistry /*extends ConcurrentHashMap<String, Job>*/ implements JobRegistry, Cloneable{ 
     22public abstract class AbstractJobRegistry /*extends ConcurrentHashMap<String, Job>*/ implements JobRegistry{ 
    2323         
    2424         
    … …  
    135135                        data[1] = new String(taskId); 
    136136                        data[2] = choosenResources; 
    137                         DataCenterWorkloadSimulator.getEventManager().sendToAllSchedulers(0, DCWormsTags.TASK_MOVE, data); 
     137                        DataCenterWorkloadSimulator.getEventManager().sendToAllSchedulers(0, DCWormsTags.TASK_MIGRATE, data); 
    138138                        return true;     
    139139                } 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/global/GlobalManagementSystem.java

    r1362 r1385  
    6363                                TimerEvent event = new  TimerEvent(); 
    6464                                SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event,  
    65                                                 queues,  getJobRegistry(), getResourceManager(), moduleList); 
     65                                                queues,  jobRegistry, getResourceManager(), moduleList); 
    6666                                executeSchedulingPlan(decision); 
    6767                        } 
    … …  
    9999                schedulingPlugin.placeTasksInQueues(readyTasks, queues, getResourceManager(), moduleList); 
    100100                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule( 
    101                                 new TaskArrivedEvent(), queues, getJobRegistry(),  getResourceManager(), moduleList); 
     101                                new TaskArrivedEvent(), queues, jobRegistry,  getResourceManager(), moduleList); 
    102102                if (decision != null) 
    103103                        executeSchedulingPlan(decision); 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/global/GridBroker.java

    r481 r1385  
    4848        } 
    4949         
    50  
    5150} 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

    r1379 r1385  
    100100                                SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TIMER); 
    101101                                SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event,  
    102                                                 queues,  getJobRegistry(), getResourceManager(), moduleList); 
     102                                                queues, jobRegistry, getResourceManager(), moduleList); 
    103103                                executeSchedulingPlan(decision); 
    104104                        } 
    … …  
    113113                                        SchedulingEvent event = new StartTaskExecutionEvent(execTask.getJobId(), execTask.getId()); 
    114114                                        SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event, 
    115                                                         queues,  getJobRegistry(), getResourceManager(), moduleList); 
     115                                                        queues, jobRegistry, getResourceManager(), moduleList); 
    116116                                        executeSchedulingPlan(decision); 
    117117                                } 
    … …  
    130130                                        SchedulingEvent event = new TaskFinishedEvent(execTask.getJobId(), execTask.getId()); 
    131131                                        SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event, 
    132                                                         queues, getJobRegistry(), getResourceManager(), moduleList); 
     132                                                        queues, jobRegistry, getResourceManager(), moduleList); 
    133133                                        executeSchedulingPlan(decision); 
    134134                                } 
    … …  
    157157                                SchedulingEvent event = new TaskRequestedTimeExpiredEvent(execTask.getJobId(), execTask.getId()); 
    158158                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event, 
    159                                                 queues, getJobRegistry(), getResourceManager(), moduleList); 
     159                                                queues, jobRegistry, getResourceManager(), moduleList); 
    160160                                executeSchedulingPlan(decision); 
    161161                        } 
    … …  
    169169                                SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TASK_PAUSED); 
    170170                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event, 
    171                                                 queues, getJobRegistry(), getResourceManager(), moduleList); 
     171                                                queues, jobRegistry, getResourceManager(), moduleList); 
    172172                                executeSchedulingPlan(decision); 
    173173                        } 
    … …  
    182182                                SchedulingEvent event = new StartTaskExecutionEvent(ids[0], ids[1]); 
    183183                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event, 
    184                                                 queues, getJobRegistry(), getResourceManager(), moduleList); 
     184                                                queues, jobRegistry, getResourceManager(), moduleList); 
    185185                                executeSchedulingPlan(decision); 
    186186                        } 
    187187                } 
    188188                break; 
    189                          
     189                 
     190                case DCWormsTags.TASK_MIGRATE:{ 
     191                        Object[] data = (Object[]) ev.get_data(); 
     192                        execTask = jobRegistry.getTask((String)data[0], (String)data[1]); 
     193                        double migrationTime = execTimeEstimationPlugin.estimateMigrationTime(new StartTaskExecutionEvent((String)data[0], (String)data[1]), execTask, execTask.getAllocatedResources().getLast().getResourceUnits(), (Map<ResourceUnitName, ResourceUnit>)data[2]); 
     194                        scheduler.sendInternal(migrationTime, DCWormsTags.TASK_MOVE, data); 
     195                } 
     196                break; 
     197                 
    190198                case DCWormsTags.TASK_MOVE:{ 
    191199                        Object[] data = (Object[]) ev.get_data(); 
    … …  
    195203                                SchedulingEvent event = new StartTaskExecutionEvent((String)data[0], (String)data[1]); 
    196204                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event, 
    197                                                 queues, getJobRegistry(), getResourceManager(), moduleList); 
     205                                                queues, jobRegistry, getResourceManager(), moduleList); 
    198206                                executeSchedulingPlan(decision); 
    199207                        } 
    … …  
    221229                                event.setSource(source); 
    222230                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event, 
    223                                                 queues,  getJobRegistry(), getResourceManager(), moduleList); 
     231                                                queues, jobRegistry, getResourceManager(), moduleList); 
    224232                                executeSchedulingPlan(decision); 
    225233                        } 
    … …  
    291299                        SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TASK_FINISHED); 
    292300                        SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event, 
    293                                         queues, getJobRegistry(), getResourceManager(), moduleList); 
     301                                        queues, jobRegistry, getResourceManager(), moduleList); 
    294302                        executeSchedulingPlan(decision); 
    295303                } 
Note: See TracChangeset for help on using the changeset viewer.