Changeset 1131 for DCWoRMS/branches/coolemall/src/simulator/workload/writer/swf

Timestamp:

07/15/13 16:46:11 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/simulator/workload/writer/swf/QcgSWFJobWriter.java (modified) (4 diffs)

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

@@ -10 +10 @@
 import org.qcg.broker.schemas.exception.NoSuchParamException;
 import org.qcg.broker.schemas.jobdesc.ExecutionTimeType;
-import org.qcg.broker.schemas.jobdesc.QcgJob;
 import org.qcg.broker.schemas.jobdesc.Task;
 import org.qcg.broker.schemas.jobdesc.wrapper.TaskRequirements;
@@ -20 +19 @@
  *
  */
-public class QcgSWFJobWriter extends AbstractSWFJobWriter<QcgJob>{
+public class QcgSWFJobWriter extends AbstractSWFJobWriter<org.qcg.broker.schemas.jobdesc.Job>{
 
         protected int intTaskId;
@@ -33 +32 @@
         }
         
-        public boolean write(QcgJob job) throws IOException {
+        public boolean write(org.qcg.broker.schemas.jobdesc.Job job) throws IOException {
                 long taskLength;
                 String idMapping;
@@ -46 +45 @@
                         if(this.useTaskMapping){
                                 taskId = String.valueOf(intTaskId);
-                                idMapping = taskId+":"+job.getAppId()+":"+task.getTaskId();
+                                idMapping = taskId+":"+job.getId()+":"+task.getId();
                                 intTaskId++;
                                 this.taskMapping.add(idMapping);
                         } else {
-                                taskId = task.getTaskId();
+                                taskId = task.getId();
                         }
                         
                         // prepare task length value
-                        if(tasksLength.containsKey(task.getTaskId())){
-                                taskLength = tasksLength.get(task.getTaskId());
+                        if(tasksLength.containsKey(task.getId())){
+                                taskLength = tasksLength.get(task.getId());
                         } else {
                                 taskLength = 0;