Ignore:
Timestamp:
10/01/12 10:05:16 (13 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/trunk/src/schedframe/scheduling
Files:
14 edited

Legend:

Unmodified
Added
Removed

  • DCWoRMS/trunk/src/schedframe/scheduling/Scheduler.java

    r477 r478  
    195195         
    196196        protected void processGSSIMJobReturn(Sim_event ev) { 
    197                 WorkloadUnit<?> job = (WorkloadUnit<?>) ev.get_data(); 
     197                WorkloadUnit job = (WorkloadUnit) ev.get_data(); 
    198198                managementSystem.notifyReturnedWorkloadUnit(job); 
    199199        } 
    200200 
    201201        protected void processGSSIMJobSubmit(Sim_event ev, boolean ack) { 
    202                 WorkloadUnit<?> job = (WorkloadUnit<?>) ev.get_data(); 
     202                WorkloadUnit job = (WorkloadUnit) ev.get_data(); 
    203203                managementSystem.notifySubmittedWorkloadUnit(job, ack); 
    204204        } 

  • DCWoRMS/trunk/src/schedframe/scheduling/WorkloadUnitList.java

    r477 r478  
    66 
    77 
    8 public interface WorkloadUnitList extends List<WorkloadUnit<?>>{ 
     8public interface WorkloadUnitList extends List<WorkloadUnit>{ 
    99 
    1010} 

  • DCWoRMS/trunk/src/schedframe/scheduling/WorkloadUnitListImpl.java

    r477 r478  
    66 
    77 
    8 public class WorkloadUnitListImpl extends ArrayList<WorkloadUnit<?>> implements WorkloadUnitList { 
     8public class WorkloadUnitListImpl extends ArrayList<WorkloadUnit> implements WorkloadUnitList { 
    99 
    1010        private static final long serialVersionUID = -3824600938144742457L; 

  • DCWoRMS/trunk/src/schedframe/scheduling/plan/ScheduledTaskInterface.java

    r477 r478  
    192192        public ArrayList<AllocationInterface> getAllocations(); 
    193193         
    194         public WorkloadUnit<?> getTask(); 
     194        public WorkloadUnit getTask(); 
    195195 
    196196} 

  • DCWoRMS/trunk/src/schedframe/scheduling/plan/impl/ScheduledTask.java

    r477 r478  
    178178         
    179179 
    180         protected WorkloadUnit<?> task; 
     180        protected WorkloadUnit task; 
    181181        protected ArrayList<AllocationInterface> allocationList; 
    182182 
    183         public ScheduledTask(WorkloadUnit<?> task){ 
     183        public ScheduledTask(WorkloadUnit task){ 
    184184                this(); 
    185185                this.task = task; 
    … …  
    190190        } 
    191191         
    192         public WorkloadUnit<?> getTask(){ 
     192        public WorkloadUnit getTask(){ 
    193193                return this.task; 
    194194        } 

  • DCWoRMS/trunk/src/schedframe/scheduling/policy/AbstractManagementSystem.java

    r477 r478  
    111111        } 
    112112 
    113         public abstract void notifySubmittedWorkloadUnit(WorkloadUnit<?> wu, boolean ack); 
    114  
    115         public abstract void notifyCanceledWorkloadUnit(WorkloadUnit<?> wu); 
    116  
    117         public abstract void notifyReturnedWorkloadUnit(WorkloadUnit<?> wu); 
     113        public abstract void notifySubmittedWorkloadUnit(WorkloadUnit wu, boolean ack); 
     114 
     115        public abstract void notifyCanceledWorkloadUnit(WorkloadUnit wu); 
     116 
     117        public abstract void notifyReturnedWorkloadUnit(WorkloadUnit wu); 
    118118 
    119119        protected abstract void executeSchedulingPlan(SchedulingPlanInterface decision); 
    … …  
    122122 
    123123        //POPRAWIC  (ale co? bo teraz chyba jest ok) 
    124         protected void submitWorkloadUnit(WorkloadUnit<?> wu, AllocationInterface allocation) { 
     124        protected void submitWorkloadUnit(WorkloadUnit wu, AllocationInterface allocation) { 
    125125                String providerName = allocation.getProviderName(); 
    126126                if (providerName == null) { 
    … …  
    164164        } 
    165165 
    166         protected boolean sendFinishedWorkloadUnit(WorkloadUnit<?> wu) { 
     166        protected boolean sendFinishedWorkloadUnit(WorkloadUnit wu) { 
    167167                 
    168168                Executable exec = (Executable) wu; 
    … …  
    220220        } 
    221221         
    222         protected boolean removeFromQueue(WorkloadUnit<?> wu) { 
     222        protected boolean removeFromQueue(WorkloadUnit wu) { 
    223223                for(TaskQueue queue : queues){ 
    224224                        if(queue.contains(wu)){ 

  • DCWoRMS/trunk/src/schedframe/scheduling/policy/global/GlobalManagementSystem.java

    r477 r478  
    8181        } 
    8282         
    83         public void notifySubmittedWorkloadUnit(WorkloadUnit<?> wu, boolean ack) { 
     83        public void notifySubmittedWorkloadUnit(WorkloadUnit wu, boolean ack) { 
    8484                if (!pluginSupportsEvent(GridSimTags.GRIDLET_SUBMIT)) { 
    8585                        log.error("Plugin " + schedulingPlugin.getClass() 
    … …  
    106106        } 
    107107         
    108         private void registerWorkloadUnit(WorkloadUnit<?> wu){ 
     108        private void registerWorkloadUnit(WorkloadUnit wu){ 
    109109                if(!wu.isRegistered()){ 
    110110                        wu.register(jobRegistry); 
    … …  
    139139        } 
    140140         
    141         public void notifyReturnedWorkloadUnit(WorkloadUnit<?> wu) { 
     141        public void notifyReturnedWorkloadUnit(WorkloadUnit wu) { 
    142142                Executable exec = (Executable) wu; 
    143143 
    … …  
    189189        } 
    190190 
    191         public void notifyCanceledWorkloadUnit(WorkloadUnit<?> wu){; 
     191        public void notifyCanceledWorkloadUnit(WorkloadUnit wu){; 
    192192 
    193193                Executable task = (Executable) wu; 
    … …  
    251251        } 
    252252 
    253         protected void submitWorkloadUnit(WorkloadUnit<?> job, AllocationInterface allocation) { 
     253        protected void submitWorkloadUnit(WorkloadUnit job, AllocationInterface allocation) { 
    254254 
    255255                String providerName = allocation.getProviderName(); 

  • DCWoRMS/trunk/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

    r477 r478  
    192192         
    193193 
    194         public void notifyReturnedWorkloadUnit(WorkloadUnit<?> wu) { 
     194        public void notifyReturnedWorkloadUnit(WorkloadUnit wu) { 
    195195                if (pluginSupportsEvent(WormsTags.TASK_EXECUTION_FINISHED)) { 
    196196                        SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TASK_FINISHED); 
    … …  
    204204        } 
    205205 
    206         public void notifyCanceledWorkloadUnit(WorkloadUnit<?> job) { 
     206        public void notifyCanceledWorkloadUnit(WorkloadUnit job) { 
    207207 
    208208                if (!pluginSupportsEvent(GridSimTags.GRIDLET_CANCEL)) 
    … …  
    247247                                ArrayList<AllocationInterface> allocations = taskDecision.getAllocations(); 
    248248 
    249                                 WorkloadUnit<?> task = taskDecision.getTask(); 
     249                                WorkloadUnit task = taskDecision.getTask(); 
    250250                                for (int j = 0; j < allocations.size(); j++) { 
    251251 
    … …  
    633633 
    634634         
    635         public void notifySubmittedWorkloadUnit(WorkloadUnit<?> job, boolean ack) { 
     635        public void notifySubmittedWorkloadUnit(WorkloadUnit job, boolean ack) { 
    636636                updateProcessingProgress(); 
    637637                registerWorkloadUnit(job); 
    638638        } 
    639639 
    640         private void registerWorkloadUnit(WorkloadUnit<?> wu){ 
     640        private void registerWorkloadUnit(WorkloadUnit wu){ 
    641641                if(!wu.isRegistered()){ 
    642642                        wu.register(jobRegistry); 
    … …  
    660660                        } 
    661661 
    662                         for(WorkloadUnit<?> e:readyTasks){       
     662                        for(WorkloadUnit e:readyTasks){  
    663663                                registerWorkloadUnit(e); 
    664664                        } 

  • DCWoRMS/trunk/src/schedframe/scheduling/queue/TaskQueue.java

    r477 r478  
    88import schedframe.scheduling.tasks.WorkloadUnit; 
    99 
    10 public class TaskQueue extends AbstractStatsSupportingQueue<WorkloadUnit<?>> implements Queue<WorkloadUnit<?>>{ 
     10public class TaskQueue extends AbstractStatsSupportingQueue<WorkloadUnit> implements Queue<WorkloadUnit>{ 
    1111 
    1212 
    … …  
    2525        } 
    2626         
    27         public boolean add(WorkloadUnit<?> wu){ 
     27        public boolean add(WorkloadUnit wu){ 
    2828                try { 
    2929                        wu.setStatus(Gridlet.QUEUED); 
    … …  
    3535        } 
    3636         
    37         public void add(int pos, WorkloadUnit<?> wu){ 
     37        public void add(int pos, WorkloadUnit wu){ 
    3838                try { 
    3939                        wu.setStatus(Gridlet.QUEUED); 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/AbstractProcesses.java

    r477 r478  
    33import schedframe.scheduling.tasks.requirements.ResourceParameterName; 
    44 
    5 public abstract class AbstractProcesses<T> implements WorkloadUnit<T>{ 
     5public abstract class AbstractProcesses implements WorkloadUnit{ 
    66         
    77         

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/JobInterface.java

    r477 r478  
    22 
    33import java.util.List; 
     4 
     5import schedframe.DescriptionContainer; 
    46 
    57 
    … …  
    911 * 
    1012 */ 
    11 public interface JobInterface<T> extends WorkloadUnit<T> { 
     13public interface JobInterface<T> extends WorkloadUnit, DescriptionContainer<T> { 
    1214 
    1315        /** 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/Processes.java

    r477 r478  
    196196        } 
    197197 
    198         public org.qcg.broker.schemas.resreqs.Processes getDescription(){ 
    199                 return this.pr; 
    200         } 
    201198 
    202199        @Override 
    … …  
    212209        } 
    213210 
    214         @Override 
    215         public String getDocument() throws Exception { 
    216                 // TODO Auto-generated method stub 
    217                 return null; 
    218         } 
     211 
    219212 
    220213        @Override 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/TaskInterface.java

    r477 r478  
    66import org.joda.time.ReadableDuration; 
    77 
     8import schedframe.DescriptionContainer; 
    89import schedframe.scheduling.tasks.requirements.ResourceParameterName; 
    910 
    … …  
    1415 * 
    1516 */ 
    16 public interface TaskInterface<T> extends WorkloadUnit<T> { 
     17public interface TaskInterface<T> extends WorkloadUnit, DescriptionContainer<T> { 
    1718         
    1819        /** 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/WorkloadUnit.java

    r477 r478  
    55import schedframe.scheduling.manager.tasks.JobRegistryImpl; 
    66 
    7 public interface WorkloadUnit<T> extends DescriptionContainer<T> { 
     7public interface WorkloadUnit { 
    88 
    99        public String getId(); 
Note: See TracChangeset for help on using the changeset viewer.