source: xssim/trunk/src/test/rewolucja/scheduling/implementation/GridBroker.java @ 230

package test.rewolucja.scheduling.implementation;

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

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import schedframe.scheduling.plugin.estimation.ExecTimeEstimationPlugin;
import schedframe.scheduling.plugin.grid.ModuleListImpl;
import test.rewolucja.reservation.GridReservationManagerNew;
import test.rewolucja.resources.description.ExecResourceDescription;
import test.rewolucja.resources.logical.base.LogicalResource;
import test.rewolucja.resources.manager.factory.ResourceManagerFactory;
import test.rewolucja.scheduling.GridResourceDiscovery;

public class GridBroker extends GlobalManagementSystem { 

        
        private static Log log = LogFactory.getLog(GridBroker.class);

        protected Set<Integer> otherGridSchedulersIds;


        public GridBroker(String name, String schedulingPluginClassName, ExecTimeEstimationPlugin execTimeEstimationPlugin, ExecResourceDescription arc) throws Exception {
                super(name, "BROKER",  schedulingPluginClassName, execTimeEstimationPlugin, arc);
                
                //make use of plug-in interface
                
                Properties prop = new Properties();
                prop.put("plugin.name", name);
                prop.put("plugin.utils.timeoperations", "gssim.scheduling.plugin.local.GssimTimeOperations");
                schedulingPlugin.init(prop);
                otherGridSchedulersIds = new HashSet<Integer>();
                
                moduleList = new ModuleListImpl(2);
                //this.moduleList.add(new GridResourceDiscovery(this.getLogicalResource()));
                moduleList.add(new GridReservationManagerNew(this));
                
                if(log.isDebugEnabled())
                        log.debug(name + ": Creating a broker interface object");
        }

        public void init(LogicalResource logRes) {
                logicalResource = logRes;
                resourceManager = ResourceManagerFactory.createResourceManager(logicalResource);
                moduleList.add((GridResourceDiscovery)resourceManager);
        }

        public List<Integer> getMyGridResources() {
                List<Integer> providerIds = new ArrayList<Integer>();
                for(LogicalResource logRes : logicalResource.getChildren()){
                        providerIds.add(logRes.get_id());
                }
                return providerIds;
                //return GridSim.getGridResourceList();
        }

        public void addOtherGridSchedulerId(int id){
                otherGridSchedulersIds.add(id);
        }
        

}