Changeset 749 for DCWoRMS/trunk
- Timestamp:
- 01/04/13 15:40:15 (12 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/trunk/src/simulator/workload/generator/impl/QcgJobGenerator.java
r547 r749 112 112 WAReader<QcgJob> swfReader = AbstractWAReader.getInstace(waFileName); 113 113 WAParser swfParser = AbstractWAParser.getInstance(waFileName); 114 QcgJob QcgJob = null;114 QcgJob qcgJob = null; 115 115 Task task = null; 116 116 Writer writer = null; … … 145 145 try { 146 146 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()); 152 152 this.randomNumbersWrapper.setCurrentTaskId(task.getTaskId()); 153 153 RequirementsType hardConstraints = createResourceRequirements(workload, task.getRequirements()); … … 158 158 159 159 long submitTime = 0; 160 String sTab[] = swfParser.readTask( QcgJob.getAppId(), task.getTaskId());160 String sTab[] = swfParser.readTask(qcgJob.getAppId(), task.getTaskId()); 161 161 if(sTab != null) 162 162 submitTime = startTime + Long.parseLong(sTab[SWFFields.DATA_SUBMIT_TIME]) * 1000; … … 169 169 } 170 170 171 if( QcgJob.getTaskCount() > 0){171 if(qcgJob.getTaskCount() > 0){ 172 172 writer = new FileWriter(outputDirectory.getPath() + 173 173 File.separator + 174 174 QcgJobFileNameFilter.FILE_NAME_PREFIX + 175 QcgJob.getAppId() +175 qcgJob.getAppId() + 176 176 ".xml"); 177 177 178 GSSimXML.marshal( QcgJob, writer);178 GSSimXML.marshal(qcgJob, writer); 179 179 writer.close(); 180 180 }
Note: See TracChangeset
for help on using the changeset viewer.