Changeset 1131 for DCWoRMS/branches/coolemall/src/simulator/workload/WorkloadLoader.java

Timestamp:

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

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/simulator/workload/WorkloadLoader.java (modified) (6 diffs)

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

@@ -1 +1 @@
 package simulator.workload;
 
-import org.qcg.broker.schemas.jobdesc.QcgJob;
 import org.qcg.broker.schemas.jobdesc.Task;
 
@@ -48 +47 @@
         private static Log log = LogFactory.getLog(WorkloadLoader.class);
         
-        protected XMLJobReader<QcgJob> xmlJobReader;
-        protected WAReader<QcgJob> waReader;
+        protected XMLJobReader<org.qcg.broker.schemas.jobdesc.Job> xmlJobReader;
+        protected WAReader<org.qcg.broker.schemas.jobdesc.Job> waReader;
         protected WAParser localWAParser;
         protected int generatedJobsCnt;
@@ -62 +61 @@
         protected Map<String, JobDescription> jobProfilesMap;
 
-        public WorkloadLoader(XMLJobReader<QcgJob> xmlReader, WAReader<QcgJob> swfReader){
+        public WorkloadLoader(XMLJobReader<org.qcg.broker.schemas.jobdesc.Job> xmlReader, WAReader<org.qcg.broker.schemas.jobdesc.Job> swfReader){
                 if(swfReader == null){
                         throw new RuntimeException("Swf reader is required to build proper tasks.");
@@ -94 +93 @@
                 if(jobDescription.size() == 0){
                         if(log.isWarnEnabled())
-                                log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getAppId()+". This job contains no tasks.");
+                                log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getId()+". This job contains no tasks.");
                         return null;
                 }
@@ -195 +194 @@
                                 else if (prevJobCnt == generatedJobsCnt){
                                         Task taskPattern = job.getDescription().getTask(0);
-                                        this.jobProfilesMap.put(taskPattern.getTaskId(), job);
+                                        this.jobProfilesMap.put(taskPattern.getId(), job);
                                 }
                         }
@@ -290 +289 @@
                 if(jobDescription.size() == 0){
                         if(log.isWarnEnabled())
-                                log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getAppId()+". This job contains no tasks.");
+                                log.warn("Omitting tasks creation for job "+jobDescription.getDescription().getId()+". This job contains no tasks.");
                         return null;
                 }