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

Legend:

Unmodified
Added
Removed

  • 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) { 
Note: See TracChangeset for help on using the changeset viewer.