source: xssim/trunk/src/test/rewolucja/scheduling/GridResourceDiscovery.java @ 210

package test.rewolucja.scheduling;

import eduni.simjava.Sim_event;
import eduni.simjava.Sim_type_p;
import gridsim.GridSimTags;
import gridsim.IO_data;
import gridsim.gssim.GssimTags;

import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import schedframe.exceptions.CandidateHostsNotFoundException;
import schedframe.resources.ResourceDescription;
import schedframe.resources.ResourceProvider;
import schedframe.scheduling.AbstractResourceRequirements;
import schedframe.scheduling.SecurityContextInterface;
import schedframe.scheduling.plugin.grid.ModuleType;
import schedframe.scheduling.plugin.grid.ResourceDiscovery;
import test.rewolucja.resources.ResourceCharacteristics;
import test.rewolucja.resources.ResourceStatus;
import test.rewolucja.resources.ResourceType;
import test.rewolucja.resources.exception.ResourceException;
import test.rewolucja.resources.logical.base.LogicalResource;
import test.rewolucja.resources.manager.interfaces.ResourceManagerInterface;
import test.rewolucja.resources.physical.base.ComputingResource;

public class  GridResourceDiscovery implements ResourceManagerInterface, ResourceDiscovery {

        protected LogicalResource brokerResource;
        
        public GridResourceDiscovery(LogicalResource broker){
                this.brokerResource = broker;
        }
        
        public List<String> getAdministrationDomains(SecurityContextInterface secContext) {
                throw new RuntimeException("Not implemented.");
        }

        public List<ResourceProvider> getProviders(SecurityContextInterface secContext) {
                throw new RuntimeException("Not implemented.");
        }

        public List<ResourceProvider> getProviders(String admDomain, SecurityContextInterface secContext) {
                throw new RuntimeException("Not implemented.");
        }

        public ResourceDescription getResources(
                        AbstractResourceRequirements<?> reqDesc, SecurityContextInterface secContext) {
                throw new RuntimeException("Not implemented.");
        }

        public List<ResourceProvider> getProviders(
                        AbstractResourceRequirements<?> reqDesc, SecurityContextInterface secContext) {
                throw new RuntimeException("Not implemented.");
        }
        
        public List<ResourceProvider> getProviders(
                        AbstractResourceRequirements<?> reqDesc, List<String> candidateHosts, 
                        SecurityContextInterface secContext) throws CandidateHostsNotFoundException {
                throw new RuntimeException("Not implemented");
        }
        
        public List<ResourceDescription> getResources(SecurityContextInterface secContext) {
                List <LogicalResource> resourceList = brokerResource.getChildren();
                for(int i = 0; i < resourceList.size(); i++){
                        int resourceId = resourceList.get(i).get_id();
                        brokerResource.send(resourceId, GridSimTags.SCHEDULE_NOW, GssimTags.QUERY_RESOURCE_DESC, null);
                }
                
                //filter only the query response messages
                Sim_type_p pred = new Sim_type_p(GssimTags.QUERY_RESOURCE_DESC_RESULT);
                Sim_event ev = new Sim_event();
                
                List<ResourceDescription> result = new ArrayList<ResourceDescription>(resourceList.size());
                for (int i = 0; i < resourceList.size(); ++i) {
                        brokerResource.sim_get_next(pred , ev);
                        IO_data ioData  = (IO_data) ev.get_data();
                        ResourceDescription resDesc = (ResourceDescription) ioData.getData();
                        result.add(resDesc);
                } 
                
                return result;
        }
        
        public void dispose() {
        }

        public ModuleType getType() {
                return ModuleType.RESOURCE_DISCOVERY;
        }

        public void init(Properties properties) {
        }


        public List<ResourceDescription> getResources() {

                for(int i = 0; i < brokerResource.getChildren().size(); i++){
                        int resourceId = brokerResource.getChildren().get(i).get_id();
                        brokerResource.send(resourceId, GridSimTags.SCHEDULE_NOW, GssimTags.QUERY_RESOURCE_DESC, null);
                }
                
                //filter only the query response messages
                Sim_type_p pred = new Sim_type_p(GssimTags.QUERY_RESOURCE_DESC_RESULT);
                Sim_event ev = new Sim_event();
                
                List<ResourceDescription> result = new ArrayList<ResourceDescription>(brokerResource.getChildren().size());
                for (int i = 0; i < brokerResource.getChildren().size(); ++i) {
                        brokerResource.sim_get_next(pred , ev);
                        IO_data ioData  = (IO_data) ev.get_data();
                        ResourceDescription resDesc = (ResourceDescription) ioData.getData();
                        result.add(resDesc);
                } 
                
                return result;
        }
        
        @Override
        public List<LogicalResource> getResourceProviders() {
                return brokerResource.getChildren();
        }


        @Override
        public boolean areResourcesAchievable(ResourceType type) {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }

        @Override
        public List<? extends ComputingResource> getResourcesOfType(ResourceType type) throws ResourceException {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }

        @Override
        public ComputingResource getResourceByName(String resourceName) {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }

        @Override
        public List<? extends ComputingResource> getResourcesOfTypeWithStatus(ResourceType type, ResourceStatus status)
                        throws ResourceException {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }

        @Override
        public ResourceCharacteristics getResourceCharacteristic() {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }

        @Override
        public List<ComputingResource> filterResources(Properties properties) {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }


        @Override
        public String getResourceProvider(String providerName) {
                throw new RuntimeException("Not available at Grid level. Please use getResourceProviders() method instead to explore available resource providers");
        }
}