Changeset 749 for DCWoRMS


Ignore:
Timestamp:
01/04/13 15:40:15 (12 years ago)
Author:
wojtekp
Message:
 
File:
1 edited

Legend:

Unmodified
Added
Removed
  • DCWoRMS/trunk/src/simulator/workload/generator/impl/QcgJobGenerator.java

    r547 r749  
    112112                WAReader<QcgJob> swfReader = AbstractWAReader.getInstace(waFileName); 
    113113                WAParser swfParser = AbstractWAParser.getInstance(waFileName); 
    114                 QcgJob QcgJob = null; 
     114                QcgJob qcgJob = null; 
    115115                Task task = null; 
    116116                Writer writer = null; 
     
    145145                try { 
    146146                         
    147                         while((QcgJob = swfReader.read()) != null){ 
    148                                  
    149                                 for(int i = 0; i < QcgJob.getTaskCount(); i++){ 
    150                                         task = QcgJob.getTask(i); 
    151                                         this.randomNumbersWrapper.setCurrentJobId(QcgJob.getAppId()); 
     147                        while((qcgJob = swfReader.read()) != null){ 
     148                                 
     149                                for(int i = 0; i < qcgJob.getTaskCount(); i++){ 
     150                                        task = qcgJob.getTask(i); 
     151                                        this.randomNumbersWrapper.setCurrentJobId(qcgJob.getAppId()); 
    152152                                        this.randomNumbersWrapper.setCurrentTaskId(task.getTaskId()); 
    153153                                        RequirementsType hardConstraints = createResourceRequirements(workload, task.getRequirements()); 
     
    158158                                         
    159159                                        long submitTime = 0; 
    160                                         String sTab[] = swfParser.readTask(QcgJob.getAppId(), task.getTaskId()); 
     160                                        String sTab[] = swfParser.readTask(qcgJob.getAppId(), task.getTaskId()); 
    161161                                        if(sTab != null) 
    162162                                                submitTime = startTime + Long.parseLong(sTab[SWFFields.DATA_SUBMIT_TIME]) * 1000; 
     
    169169                                } 
    170170                                 
    171                                 if(QcgJob.getTaskCount() > 0){ 
     171                                if(qcgJob.getTaskCount() > 0){ 
    172172                                        writer = new FileWriter(outputDirectory.getPath() +  
    173173                                                                                        File.separator +  
    174174                                                                                        QcgJobFileNameFilter.FILE_NAME_PREFIX +  
    175                                                                                         QcgJob.getAppId() +  
     175                                                                                        qcgJob.getAppId() +  
    176176                                                                                        ".xml"); 
    177177                                         
    178                                         GSSimXML.marshal(QcgJob, writer); 
     178                                        GSSimXML.marshal(qcgJob, writer); 
    179179                                        writer.close(); 
    180180                                } 
Note: See TracChangeset for help on using the changeset viewer.