source: DCWoRMS/branches/coolemall/src/schedframe/resources/devices/DeviceAirflowInterface.java @ 1423

package schedframe.resources.devices;

import java.util.List;

import org.joda.time.DateTimeUtils;

import schedframe.Parameters;
import schedframe.resources.computing.profiles.energy.ResourceEvent;
import schedframe.resources.computing.profiles.energy.ResourceEventType;
import schedframe.resources.computing.profiles.energy.airthroughput.AirflowValue;
import schedframe.resources.computing.profiles.energy.airthroughput.AirflowProfile;
import schedframe.resources.computing.profiles.energy.airthroughput.AirflowState;
import schedframe.resources.computing.profiles.energy.airthroughput.AirflowStateName;
import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName;
import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirflowInterface;

public class DeviceAirflowInterface implements AirflowInterface{

        protected AirflowStateName currentAirflowState;
        protected AirflowProfile airflowProfile;
        protected PhysicalResource resource;
        
        public DeviceAirflowInterface(PhysicalResource resource, AirflowProfile airflowProfile){
                this.resource = resource;
                this.airflowProfile = airflowProfile;
                this.currentAirflowState = StandardAirflowStateName.ON;
        }
        
        public AirflowStateName getAirflowState() {
                return currentAirflowState;
        }

        public boolean setAirflowState(AirflowStateName state) {
                if(supportAirflowState(state)){
                        currentAirflowState = state;
                        
                        //TO DO - notifications should be called for all resources starting form the lowest layer
                        resource.handleEvent(new ResourceEvent(ResourceEventType.AIRFLOW_STATE_CHANGED, resource.getFullName()));
                        resource.handleEvent(new ResourceEvent(ResourceEventType.POWER_STATE_CHANGED, resource.getFullName()));
                        return true;
                }
                return false;
        }

        public boolean supportAirflowState(AirflowStateName state) {
                for(AirflowState airflowState: airflowProfile.getAirflowStates()){
                        if(airflowState.getName().getLabel().equals(state.getLabel())){
                                return true;
                        }
                }
                return false;
        }

        public List<AirflowState> getSupportedAirflowStates(){
                return airflowProfile.getAirflowStates();
        }

        public double getAirflow(AirflowStateName state) throws NoSuchFieldException {
                double airflow = 0;
                if(supportAirflowState(state)){
                        for(AirflowState airflowState: airflowProfile.getAirflowStates()){
                                if(airflowState.getName().getLabel().equals(state.getLabel())){
                                        airflow = airflowState.getValue();
                                        break;
                                }
                        }
                }
                return airflow;
        }

        public double getPowerConsumption(AirflowStateName state) throws NoSuchFieldException {
                double powerConsumption = 0;
                if(supportAirflowState(state)){
                        for(AirflowState airflowState: airflowProfile.getAirflowStates()){
                                if(airflowState.getName().getLabel().equals(state.getLabel())){
                                        powerConsumption = airflowState.getPowerUsage();
                                        break;
                                }
                        }
                }
                return powerConsumption;
        }
        
        public AirflowValue getRecentAirflow() {
                AirflowValue airflow = null;
                int lastIdx = getAirflowHistory().size() - 1;
                if(lastIdx >= 0)
                        airflow = getAirflowHistory().get(lastIdx);
                else {  
                        try {
                                airflow = new AirflowValue(DateTimeUtils.currentTimeMillis(), getAirflow(currentAirflowState));
                        } catch (NoSuchFieldException e) {
                        }
                }
                return airflow;
        }
        
        public List<AirflowValue> getAirflowHistory(){
                return airflowProfile.getAirflowHistory();
        }
        
        public Parameters getParameters() {
                return airflowProfile.getParameters();
        }

}