Changeset 1131 for DCWoRMS/branches


Ignore:
Timestamp:
07/15/13 16:46:11 (12 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/simulator
Files:
10 edited

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/simulator/utils/XsltTransformations.java

    r490 r1131  
    162162                int end = 0; 
    163163                 
    164                 begin = xmlJob.indexOf("appId=") + 7; 
     164                begin = xmlJob.indexOf("id=") + 4; 
    165165                end = xmlJob.indexOf("\"", begin); 
    166166                String jobId = xmlJob.substring(begin, end); 
    … …  
    178178                        end += 7; 
    179179                        String task = xmlJob.substring(begin, end); 
    180                         tb = task.indexOf("taskId=") + 8; 
     180                        tb = task.indexOf("id=") + 4; 
    181181                        te = task.indexOf("\"", tb); 
    182182                        taskId = task.substring(tb, te); 

  • DCWoRMS/branches/coolemall/src/simulator/workload/WorkloadLoader.java

    r1082 r1131  
    11package simulator.workload; 
    22 
    3 import org.qcg.broker.schemas.jobdesc.QcgJob; 
    43import org.qcg.broker.schemas.jobdesc.Task; 
    54 
    … …  
    4847        private static Log log = LogFactory.getLog(WorkloadLoader.class); 
    4948         
    50         protected XMLJobReader<QcgJob> xmlJobReader; 
    51         protected WAReader<QcgJob> waReader; 
     49        protected XMLJobReader<org.qcg.broker.schemas.jobdesc.Job> xmlJobReader; 
     50        protected WAReader<org.qcg.broker.schemas.jobdesc.Job> waReader; 
    5251        protected WAParser localWAParser; 
    5352        protected int generatedJobsCnt; 
    … …  
    6261        protected Map<String, JobDescription> jobProfilesMap; 
    6362 
    64         public WorkloadLoader(XMLJobReader<QcgJob> xmlReader, WAReader<QcgJob> swfReader){ 
     63        public WorkloadLoader(XMLJobReader<org.qcg.broker.schemas.jobdesc.Job> xmlReader, WAReader<org.qcg.broker.schemas.jobdesc.Job> swfReader){ 
    6564                if(swfReader == null){ 
    6665                        throw new RuntimeException("Swf reader is required to build proper tasks."); 
    … …  
    9493                if(jobDescription.size() == 0){ 
    9594                        if(log.isWarnEnabled()) 
    96                                 log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getAppId()+". This job contains no tasks."); 
     95                                log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getId()+". This job contains no tasks."); 
    9796                        return null; 
    9897                } 
    … …  
    195194                                else if (prevJobCnt == generatedJobsCnt){ 
    196195                                        Task taskPattern = job.getDescription().getTask(0); 
    197                                         this.jobProfilesMap.put(taskPattern.getTaskId(), job); 
     196                                        this.jobProfilesMap.put(taskPattern.getId(), job); 
    198197                                } 
    199198                        } 
    … …  
    290289                if(jobDescription.size() == 0){ 
    291290                        if(log.isWarnEnabled()) 
    292                                 log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getAppId()+". This job contains no tasks."); 
     291                                log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getId()+". This job contains no tasks."); 
    293292                        return null; 
    294293                } 

  • DCWoRMS/branches/coolemall/src/simulator/workload/generator/impl/QcgJobGenerator.java

    r835 r1131  
    4242import org.qcg.broker.schemas.jobdesc.ParameterValueType; 
    4343import org.qcg.broker.schemas.jobdesc.PreferencesType; 
    44 import org.qcg.broker.schemas.jobdesc.QcgJob; 
    4544import org.qcg.broker.schemas.jobdesc.RangeType; 
    4645import org.qcg.broker.schemas.jobdesc.RequirementsType; 
    … …  
    110109                        log.info("Generate xml suplement - start"); 
    111110                 
    112                 WAReader<QcgJob> swfReader = AbstractWAReader.getInstace(waFileName); 
     111                WAReader<org.qcg.broker.schemas.jobdesc.Job> swfReader = AbstractWAReader.getInstace(waFileName); 
    113112                WAParser swfParser = AbstractWAParser.getInstance(waFileName); 
    114                 QcgJob qcgJob = null; 
     113                org.qcg.broker.schemas.jobdesc.Job qcgJob = null; 
    115114                Task task = null; 
    116115                Writer writer = null; 
    … …  
    149148                                for(int i = 0; i < qcgJob.getTaskCount(); i++){ 
    150149                                        task = qcgJob.getTask(i); 
    151                                         this.randomNumbersWrapper.setCurrentJobId(qcgJob.getAppId()); 
    152                                         this.randomNumbersWrapper.setCurrentTaskId(task.getTaskId()); 
     150                                        this.randomNumbersWrapper.setCurrentJobId(qcgJob.getId()); 
     151                                        this.randomNumbersWrapper.setCurrentTaskId(task.getId()); 
    153152                                        RequirementsType hardConstraints = createResourceRequirements(workload, task.getRequirements()); 
    154153                                        if(hardConstraints != null) { 
    … …  
    158157                                         
    159158                                        long submitTime = 0; 
    160                                         String sTab[] = swfParser.readTask(qcgJob.getAppId(), task.getTaskId()); 
     159                                        String sTab[] = swfParser.readTask(qcgJob.getId(), task.getId()); 
    161160                                        if(sTab != null) 
    162161                                                submitTime = startTime + Long.parseLong(sTab[SWFFields.DATA_SUBMIT_TIME]) * 1000; 
    … …  
    173172                                                                                        File.separator +  
    174173                                                                                        QcgJobFileNameFilter.FILE_NAME_PREFIX +  
    175                                                                                         qcgJob.getAppId() +  
     174                                                                                        qcgJob.getId() +  
    176175                                                                                        ".xml"); 
    177176                                         
    … …  
    206205                File outputDirectory = prepareWorkloadDirectory(outputDirectoryName, overwriteExistingFiles); 
    207206 
    208                 SWFJobWriter<QcgJob> swfJobWriter = new QcgSWFJobWriter(outputDirectoryName, outputWorkloadFileName); 
     207                SWFJobWriter<org.qcg.broker.schemas.jobdesc.Job> swfJobWriter = new QcgSWFJobWriter(outputDirectoryName, outputWorkloadFileName); 
    209208                swfJobWriter.writeFieldDescriptionHeader(); 
    210209                 
    … …  
    253252                 
    254253                while (proceedConditionsAreFulfilled()) { 
    255                         QcgJob QcgJob = new QcgJob(); 
     254                        org.qcg.broker.schemas.jobdesc.Job qcgJob = new org.qcg.broker.schemas.jobdesc.Job(); 
    256255                         
    257256                        String jobID = Integer.toString(generatedJobCount); 
    258                         QcgJob.setAppId(jobID); 
     257                        qcgJob.setId(jobID); 
    259258                         
    260259                        //initially - a standard value 
    … …  
    286285                        for (int taskNum = 0; taskNum < taskCountToBeGenerated; taskNum++) { 
    287286                                Task task = new Task(); 
    288                                 QcgJob.addTask(task); 
    289                                  
    290                                 task.setTaskId(String.valueOf(taskNum)); 
     287                                qcgJob.addTask(task); 
     288                                 
     289                                task.setId(String.valueOf(taskNum)); 
    291290                                 
    292291                                // create section execution 
    … …  
    304303                                        try { 
    305304                                                long l_taskLength = (long) getRandomValueFor(taskLength, parameterRandomNumbers); 
    306                                                 swfJobWriter.addTaskLength(task.getTaskId(), l_taskLength); 
     305                                                swfJobWriter.addTaskLength(task.getId(), l_taskLength); 
    307306                                        } catch (IllegalAccessException e) { 
    308307                                                e.printStackTrace(); 
    … …  
    345344 
    346345                        FileWriter taskWriter = new FileWriter(taskFile); 
    347                         GSSimXML.marshal(QcgJob, taskWriter); 
     346                        GSSimXML.marshal(qcgJob, taskWriter); 
    348347                        taskWriter.flush(); 
    349348                        taskWriter.close(); 
    … …  
    351350                        //swfJobWriter.setJobSubmitTime(simulationVirtualTime); 
    352351                        swfJobWriter.setJobSubmitTime((simulationVirtualTime - simulationStartTime)/1000); 
    353                         swfJobWriter.write(QcgJob); 
     352                        swfJobWriter.write(qcgJob); 
    354353                         
    355354                        generatedJobCount++; 

  • DCWoRMS/branches/coolemall/src/simulator/workload/reader/archive/AbstractWAReader.java

    r477 r1131  
    7171        public static AbstractWAReader 
    7272                        <org.qcg.broker.schemas.jobdesc.Task,  
    73                         org.qcg.broker.schemas.jobdesc.QcgJob> getInstace(String fileName){ 
     73                        org.qcg.broker.schemas.jobdesc.Job> getInstace(String fileName){ 
    7474                 
    7575                String name = fileName.trim().toLowerCase(); 

  • DCWoRMS/branches/coolemall/src/simulator/workload/reader/archive/QcgWAJobReader.java

    r883 r1131  
    1515 
    1616import simulator.workload.reader.archive.swf.SWFFields; 
    17 import org.qcg.broker.schemas.jobdesc.QcgJob; 
    1817import org.qcg.broker.schemas.jobdesc.ResourceConsumptionProfileType; 
    1918import org.qcg.broker.schemas.jobdesc.Task; 
    … …  
    2726 */ 
    2827 
    29 public abstract class QcgWAJobReader extends AbstractWAReader<Task, QcgJob> { 
     28public abstract class QcgWAJobReader extends AbstractWAReader<Task, org.qcg.broker.schemas.jobdesc.Job> { 
    3029 
    3130        protected String currntJobID; 
    … …  
    5857        } 
    5958         
    60         public QcgJob read() throws IOException { 
     59        public org.qcg.broker.schemas.jobdesc.Job read() throws IOException { 
    6160                Task task = null; 
    6261                 
    … …  
    6968                 
    7069                 
    71                 QcgJob job = new QcgJob(); 
     70                org.qcg.broker.schemas.jobdesc.Job job = new org.qcg.broker.schemas.jobdesc.Job(); 
    7271                String appID = this.waParser.getIDMapping(currntJobID)[0]; 
    73                 job.setAppId(appID); 
     72                job.setId(appID); 
    7473                 
    7574                 
    … …  
    8887         
    8988        public String readRaw() throws IOException{ 
    90                 QcgJob job = null; 
     89                org.qcg.broker.schemas.jobdesc.Job job = null; 
    9190                 
    9291                if((job = read()) == null) 
    … …  
    113112                 
    114113                StringReader reader = new StringReader(swfJobDesc); 
    115                 QcgJob job = null; 
     114                org.qcg.broker.schemas.jobdesc.Job job = null; 
    116115                try { 
    117                         job = (QcgJob)unmarshaller.unmarshal(reader); 
     116                        job = (org.qcg.broker.schemas.jobdesc.Job)unmarshaller.unmarshal(reader); 
    118117                } catch (MarshalException e) { 
    119118                        // TODO Auto-generated catch block 

  • DCWoRMS/branches/coolemall/src/simulator/workload/reader/archive/gwf/QcgGWFJobReader.java

    r477 r1131  
    104104                                        currntJobID = data[GWFFields.DATA_FIELDS[i]]; 
    105105                                        String tab[] = this.waParser.getIDMapping(currntJobID); 
    106                                         task.setTaskId(tab[1]); 
     106                                        task.setId(tab[1]); 
    107107                                        break; 
    108108                                         

  • DCWoRMS/branches/coolemall/src/simulator/workload/reader/archive/swf/QcgSWFJobReader.java

    r883 r1131  
    1111import org.qcg.broker.schemas.jobdesc.ParameterTypeChoice; 
    1212import org.qcg.broker.schemas.jobdesc.ParameterTypeChoiceItem; 
     13import org.qcg.broker.schemas.jobdesc.ParentType; 
    1314import org.qcg.broker.schemas.jobdesc.ResourceRequirementsType; 
    1415import org.qcg.broker.schemas.jobdesc.Value; 
    1516import org.qcg.broker.schemas.jobdesc.RequirementsType; 
     17import org.qcg.broker.schemas.jobdesc.Workflow; 
    1618import org.qcg.broker.schemas.jobdesc.types.ComputingParameterName; 
    1719import org.qcg.broker.schemas.jobdesc.Task; 
     20import org.qcg.broker.schemas.jobdesc.types.TaskStatesName; 
    1821 
    1922import java.io.IOException; 
    … …  
    115118                                        currntJobID = data[SWFFields.DATA_FIELDS[i]]; 
    116119                                        String tab[] = this.waParser.getIDMapping(currntJobID); 
    117                                         task.setTaskId(tab[1]); 
     120                                        task.setId(tab[1]); 
    118121                                        break; 
    119122                                         
    … …  
    239242                                         
    240243                                case SWFFields.DATA_PRECEDING_JOB_NUMBER: 
     244                                        /*Workflow workflow = new Workflow(); 
     245                                        ParentType parent = new ParentType(); 
     246                                        parent.setTriggerState(TaskStatesName.FINISHED); 
     247                                        workflow.addParent(parent); 
     248                                        task.setWorkflow(workflow);*/ 
    241249                                        break; 
    242250                                         

  • DCWoRMS/branches/coolemall/src/simulator/workload/reader/xmlJob/QcgXmlJobReader.java

    r477 r1131  
    1212 
    1313 
    14 import org.qcg.broker.schemas.jobdesc.QcgJob; 
    1514 
    1615/** 
    … …  
    2019 */ 
    2120 
    22 public class QcgXmlJobReader implements XMLJobReader<QcgJob> { 
     21public class QcgXmlJobReader implements XMLJobReader<org.qcg.broker.schemas.jobdesc.Job> { 
    2322 
    2423        protected static Unmarshaller unmarshaller; 
    … …  
    6564        } 
    6665 
    67         public QcgJob read() throws IOException { 
     66        public org.qcg.broker.schemas.jobdesc.Job read() throws IOException { 
    6867 
    6968                String s = readRaw(); 
    7069                StringReader reader = new StringReader(s); 
    71                 QcgJob job = null; 
     70                org.qcg.broker.schemas.jobdesc.Job job = null; 
    7271                 
    7372                try { 
    7473                 
    75                         job = (QcgJob) unmarshaller.unmarshal(reader); 
     74                        job = (org.qcg.broker.schemas.jobdesc.Job) unmarshaller.unmarshal(reader); 
    7675                 
    7776                } catch (MarshalException e) { 

  • DCWoRMS/branches/coolemall/src/simulator/workload/writer/swf/QcgSWFJobWriter.java

    r883 r1131  
    1010import org.qcg.broker.schemas.exception.NoSuchParamException; 
    1111import org.qcg.broker.schemas.jobdesc.ExecutionTimeType; 
    12 import org.qcg.broker.schemas.jobdesc.QcgJob; 
    1312import org.qcg.broker.schemas.jobdesc.Task; 
    1413import org.qcg.broker.schemas.jobdesc.wrapper.TaskRequirements; 
    … …  
    2019 * 
    2120 */ 
    22 public class QcgSWFJobWriter extends AbstractSWFJobWriter<QcgJob>{ 
     21public class QcgSWFJobWriter extends AbstractSWFJobWriter<org.qcg.broker.schemas.jobdesc.Job>{ 
    2322 
    2423        protected int intTaskId; 
    … …  
    3332        } 
    3433         
    35         public boolean write(QcgJob job) throws IOException { 
     34        public boolean write(org.qcg.broker.schemas.jobdesc.Job job) throws IOException { 
    3635                long taskLength; 
    3736                String idMapping; 
    … …  
    4645                        if(this.useTaskMapping){ 
    4746                                taskId = String.valueOf(intTaskId); 
    48                                 idMapping = taskId+":"+job.getAppId()+":"+task.getTaskId(); 
     47                                idMapping = taskId+":"+job.getId()+":"+task.getId(); 
    4948                                intTaskId++; 
    5049                                this.taskMapping.add(idMapping); 
    5150                        } else { 
    52                                 taskId = task.getTaskId(); 
     51                                taskId = task.getId(); 
    5352                        } 
    5453                         
    5554                        // prepare task length value 
    56                         if(tasksLength.containsKey(task.getTaskId())){ 
    57                                 taskLength = tasksLength.get(task.getTaskId()); 
     55                        if(tasksLength.containsKey(task.getId())){ 
     56                                taskLength = tasksLength.get(task.getId()); 
    5857                        } else { 
    5958                                taskLength = 0; 

  • DCWoRMS/branches/coolemall/src/simulator/workload/writer/xmlJob/QcgXmlJobWriter.java

    r477 r1131  
    1212import simulator.workload.fileFilters.QcgJobFileNameFilter; 
    1313 
    14 import org.qcg.broker.schemas.jobdesc.QcgJob; 
    1514 
    1615/** 
    … …  
    2019 */ 
    2120 
    22 public class QcgXmlJobWriter implements XMLJobWriter<QcgJob>{ 
     21public class QcgXmlJobWriter implements XMLJobWriter<org.qcg.broker.schemas.jobdesc.Job>{ 
    2322 
    2423        private Log log = LogFactory.getLog(QcgXmlJobWriter.class); 
    … …  
    3736        } 
    3837         
    39         public boolean write(QcgJob job) throws IOException{ 
    40                 String fileName = QcgJobFileNameFilter.FILE_NAME_PREFIX+"_"+job.getAppId()+".xml"; 
     38        public boolean write(org.qcg.broker.schemas.jobdesc.Job job) throws IOException{ 
     39                String fileName = QcgJobFileNameFilter.FILE_NAME_PREFIX+"_"+job.getId()+".xml"; 
    4140                 
    4241                File file = new File(directory, fileName); 
Note: See TracChangeset for help on using the changeset viewer.