Ignore:
Timestamp:
07/15/14 16:26:31 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/schedframe/events
Files:
2 added
2 deleted
10 edited
1 moved

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/schedframe/events/Event.java

    r477 r1415  
    11package schedframe.events; 
    22 
    3 import schedframe.events.scheduling.EventReason; 
    43 
    54public interface Event { 
    … …  
    98        public String getSource(); 
    109         
    11         public int getTag(); 
    12          
    1310        public Object getData(); 
    1411         

  • DCWoRMS/branches/coolemall/src/schedframe/events/EventCommand.java

    r1316 r1415  
    11package schedframe.events; 
     2 
     3import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    24 
    35 
    … …  
    57public interface EventCommand { 
    68         
    7         public void execute(Event event); 
     9        public void execute(ResourceEvent event); 
    810} 

  • DCWoRMS/branches/coolemall/src/schedframe/events/EventHandler.java

    r477 r1415  
    22 
    33import schedframe.events.scheduling.SchedulingEvent; 
     4import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    45 
    56public interface EventHandler { 
    67         
    7         public void handleResourceEvent(Event event); 
     8        public void handleResourceEvent(ResourceEvent event); 
    89         
    910        public void handleSchedulingEvent(SchedulingEvent event); 

  • DCWoRMS/branches/coolemall/src/schedframe/events/EventReason.java

    r477 r1415  
    1 package schedframe.events.scheduling; 
     1package schedframe.events; 
    22 
    33public enum EventReason { 
     4         
    45        //Reasons that caused given events 
    56        UNKNOWN, 
    … …  
    1213         
    1314        //TASK_CANCELED 
    14         RESERVATION_EXCEEDED, 
    1515        RESOURCES_EXCEEDED, 
    1616         

  • DCWoRMS/branches/coolemall/src/schedframe/events/EventType.java

    r477 r1415  
    55        public String getName(); 
    66         
    7         public int getTag(); 
    8          
    97} 

  • DCWoRMS/branches/coolemall/src/schedframe/events/ResourceEventCommand.java

    r1316 r1415  
    11package schedframe.events; 
    22 
     3import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    34import schedframe.resources.devices.PhysicalResource; 
    45 
    … …  
    1112        } 
    1213 
    13         public void execute(Event event) { 
     14        public void execute(ResourceEvent event) { 
    1415                resource.getEventHandler().handleResourceEvent(event); 
    1516        } 

  • DCWoRMS/branches/coolemall/src/schedframe/events/scheduling/ResourceStateChangedEvent.java

    r1316 r1415  
    11package schedframe.events.scheduling; 
    22 
    3 import schedframe.events.EventType; 
     3import schedframe.resources.computing.profiles.energy.ResourceEventType; 
    44 
    5 public class ResourceStateChangedEvent  extends SchedulingEvent { 
     5public class ResourceStateChangedEvent extends SchedulingEvent { 
    66 
    7         protected String resourceName; 
    8         protected EventType eventType; 
     7        protected ResourceEventType eventType; 
    98         
    10         public ResourceStateChangedEvent(String resourceName, EventType eventType) { 
     9        public ResourceStateChangedEvent(ResourceEventType eventType) { 
    1110                super(SchedulingEventType.RESOURCE_STATE_CHANGED); 
    12                 this.resourceName = resourceName; 
    1311                this.eventType = eventType; 
    1412        } 
    1513 
    16         public String getResourceName() { 
    17                 return resourceName; 
    18         } 
    1914 
    20         public EventType getEventType() { 
     15        public ResourceEventType getResourceEventType() { 
    2116                return eventType; 
    2217        } 

  • DCWoRMS/branches/coolemall/src/schedframe/events/scheduling/SchedulingEvent.java

    r1316 r1415  
    22 
    33import schedframe.events.Event; 
     4import schedframe.events.EventReason; 
    45import schedframe.events.EventType; 
    56 
    … …  
    2526                        schedEventType = (SchedulingEventType)type; 
    2627                } catch(Exception e){ 
    27                         schedEventType = SchedulingEventType.RESOURCE_STATE_CHANGED; 
     28                        schedEventType = null; 
    2829                } 
    2930                return schedEventType; 
    … …  
    4243        } 
    4344 
    44         public int getTag() { 
    45                 return type.getTag(); 
    46         } 
    47  
    4845        public Object getData() { 
    4946                return null; 

  • DCWoRMS/branches/coolemall/src/schedframe/events/scheduling/SchedulingEventCommand.java

    r1316 r1415  
    11package schedframe.events.scheduling; 
    22 
    3 import schedframe.events.Event; 
    43import schedframe.events.EventCommand; 
    54import schedframe.resources.computing.ComputingResource; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66 
    77public class SchedulingEventCommand implements EventCommand { 
    … …  
    1313        } 
    1414         
    15         public void execute(Event event) { 
    16                 SchedulingEvent ev = new ResourceStateChangedEvent(compResource.getFullName(), event.getType()); 
     15        public void execute(ResourceEvent event) { 
     16                SchedulingEvent ev = new ResourceStateChangedEvent(event.getType()); 
    1717                ev.setSource(compResource.getFullName()); 
    1818                compResource.getEventHandler().handleSchedulingEvent(ev); 

  • DCWoRMS/branches/coolemall/src/schedframe/events/scheduling/SchedulingEventType.java

    r1360 r1415  
    66 
    77        // task related 
    8         TASK_FINISHED(1), 
    9         TASK_FAILED(2), 
    10         TASK_CANCELED(4), 
    11         TASK_ARRIVED(8), 
    12         TASK_PAUSED(16), 
    13         TASK_RESUMED(32), 
    14         TASK_MOVED(64), 
    15         START_TASK_EXECUTION(128), 
    16         TASK_REQUESTED_TIME_EXPIRED(256), 
     8        TASK_FINISHED, 
     9        TASK_FAILED, 
     10        TASK_CANCELED, 
     11        TASK_ARRIVED, 
     12        TASK_PAUSED, 
     13        TASK_RESUMED, 
     14        TASK_MOVED, 
     15        TASK_EXECUTION_CHANGED, 
     16        START_TASK_EXECUTION, 
     17        TASK_REQUESTED_TIME_EXPIRED, 
    1718 
    1819        //job related 
    19         JOB_ARRIVED(512), 
    20         JOB_FINISHED(1024), 
    21         JOB_FAILED(2048), 
    22         JOB_CANCELED(4096), 
     20        JOB_ARRIVED, 
     21        JOB_FINISHED, 
     22        JOB_FAILED, 
     23        JOB_CANCELED, 
    2324 
    2425        //time related 
    25         TIMER(8192), 
     26        TIMER, 
     27                 
     28        //resource related 
     29        RESOURCE_FAILED, 
     30        //provider related (relevant to grid scheduling) 
     31        PROVIDER_FAILED, 
     32 
     33        RESOURCE_STATE_CHANGED, 
    2634         
    27         //reservation related 
    28         RESERVATION_ACTIVE(16384), 
    29         RESERVATION_FINISHED(32768), 
    30         RESERVATION_FAILED(65536), 
    31         RESERVATION_EXPIRED(131072), 
    32          
    33         //resource related 
    34         RESOURCE_FAILED(262144), 
    35         //provider related (relevant to grid scheduling) 
    36         PROVIDER_FAILED(524288), 
     35        POWER_LIMIT_EXCEEDED; 
    3736 
    38         RESOURCE_STATE_CHANGED(1048576), 
    39          
    40         POWER_LIMIT_EXCEEDED(2097152) 
    41         ; 
    42          
    43         protected int tag; 
    44          
    45         private SchedulingEventType(int tag){ 
    46                 this.tag = tag; 
    47         } 
    48          
    49         public int getTag(){ 
    50                 return this.tag; 
    51         } 
    5237         
    5338        public String getName(){ 

  • DCWoRMS/branches/coolemall/src/schedframe/events/scheduling/TaskCanceledEvent.java

    r477 r1415  
    22 
    33import java.util.List; 
     4 
     5import schedframe.events.EventReason; 
    46 
    57 
Note: See TracChangeset for help on using the changeset viewer.