Changeset 480


Ignore:
Timestamp:
10/02/12 14:53:44 (13 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/trunk/src
Files:
12 edited

Legend:

Unmodified
Added
Removed

  • DCWoRMS/trunk/src/gssim/schedframe/scheduling/Executable.java

    r477 r480  
    8888        } 
    8989 
    90         public String getUserDn() { 
    91                 return task.getUserDn(); 
     90        public String getUserDN() { 
     91                return task.getUserDN(); 
    9292        } 
    9393 

  • DCWoRMS/trunk/src/schedframe/scheduling/manager/tasks/AbstractJobRegistry.java

    r477 r480  
    3939        } 
    4040 
    41         public Job get(String jobId){ 
     41        public Job getJob(String jobId){ 
    4242                return jobs.get(jobId); 
    4343        } 

  • DCWoRMS/trunk/src/schedframe/scheduling/policy/AbstractManagementSystem.java

    r478 r480  
    169169                if(scheduler.getParent() == null) 
    170170                { 
    171                         Job job = jobRegistry.get(exec.getJobId()); 
     171                        Job job = jobRegistry.getJob(exec.getJobId()); 
    172172 
    173173                        if(job.isFinished()){ 

  • DCWoRMS/trunk/src/schedframe/scheduling/policy/global/GlobalManagementSystem.java

    r478 r480  
    149149                 
    150150                try { 
    151                         Job job = jobRegistry.get(exec.getJobId()); 
     151                        Job job = jobRegistry.getJob(exec.getJobId()); 
    152152                        /*Task task = job.getTask(exec.getTaskId()); 
    153153                        if(exec.getProcessesId() == null){ 
    … …  
    229229                                // not scheduled again are returned to the user. 
    230230                                if(taskDecision.getStatus() == AllocationStatus.REJECTED){ 
    231                                         Job job = jobRegistry.get(jobID); 
     231                                        Job job = jobRegistry.getJob(jobID); 
    232232                                        scheduler.send(job.getSenderId(), GridSimTags.SCHEDULE_NOW, GridSimTags.GRIDLET_RETURN, job); 
    233233                                        continue; 

  • DCWoRMS/trunk/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

    r478 r480  
    168168                                executeSchedulingPlan(decision); 
    169169                        } 
    170                         Job job = jobRegistry.get(task.getJobId()); 
     170                        Job job = jobRegistry.getJob(task.getJobId()); 
    171171                        if(!job.isFinished()){ 
    172172                                getWorkloadUnitHandler().handleJob(job); 
    … …  
    404404                 
    405405                Executable executable = (Executable) subTask.getGridlet(); 
    406                 Job job = jobRegistry.get(executable.getJobId()); 
     406                Job job = jobRegistry.getJob(executable.getJobId()); 
    407407 
    408408                Task task = null; 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/Job.java

    r477 r480  
    1818import schedframe.scheduling.WorkloadUnitHandler; 
    1919import schedframe.scheduling.manager.tasks.JobRegistryImpl; 
    20 import schedframe.scheduling.policy.AbstractManagementSystem; 
    2120 
    2221 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/Processes.java

    r478 r480  
    11package schedframe.scheduling.tasks; 
    2  
    3 import java.util.List; 
    42 
    53import org.qcg.broker.schemas.resreqs.ComputingResourceBaseTypeItem; 
    … …  
    196194        } 
    197195 
    198  
    199         @Override 
    200196        public int getStatus() { 
     197                return this.status; 
     198        } 
     199 
     200        @Override 
     201        public int getUserID() { 
    201202                // TODO Auto-generated method stub 
    202203                return 0; 
    203204        } 
    204205 
    205         @Override 
    206         public int getUserID() { 
    207                 // TODO Auto-generated method stub 
    208                 return 0; 
    209         } 
    210  
    211206 
    212207 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/SubmittedTask.java

    r477 r480  
    114114        } 
    115115 
    116         public String getUserDn() { 
    117                 return task.getUserDn(); 
     116        public String getUserDN() { 
     117                return task.getUserDN(); 
    118118        } 
    119119 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/Task.java

    r477 r480  
    3737 * 
    3838 */ 
    39 public class Task /*extends AbstractTask*/ implements TaskInterface<org.qcg.broker.schemas.resreqs.Task> { 
     39public class Task implements TaskInterface<org.qcg.broker.schemas.resreqs.Task> { 
    4040         
    4141        protected static Unmarshaller unmarshaller; 
    … …  
    7171        private int senderId; 
    7272        private long workloadLogWaitTime; 
    73         //String resPathHistory; 
    74          
     73 
    7574        public Task(org.qcg.broker.schemas.resreqs.Task task){ 
    7675                this.task = task; 
    … …  
    268267        } 
    269268 
    270         public String getUserDn() { 
     269        public String getUserDN() { 
    271270                return this.task.getUserDN(); 
    272271        } 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/TaskInterface.java

    r478 r480  
    3434         * submitted this task.  
    3535         */ 
    36         public abstract String getUserDn(); 
     36        public abstract String getUserDN(); 
    3737         
    3838        /** 
    … …  
    108108        public List<AbstractProcesses> getProcesses(AbstractProcessesGroup processGroup); 
    109109         
    110         public void setStatus(int status) throws Exception; 
     110        //public void setStatus(int status) throws Exception; 
    111111         
    112112        public double getCpuCntRequest() throws NoSuchFieldException; 
    … …  
    115115         
    116116        public long getWorkloadLogWaitTime(); 
    117          
    118         //public void addToResPath(String resName); 
    119          
    120         //public String getResPath(); 
     117 
    121118                 
    122119} 

  • DCWoRMS/trunk/src/schedframe/scheduling/tasks/WorkloadUnit.java

    r478 r480  
    11package schedframe.scheduling.tasks; 
    22 
    3 import schedframe.DescriptionContainer; 
    43import schedframe.scheduling.WorkloadUnitHandler; 
    54import schedframe.scheduling.manager.tasks.JobRegistryImpl; 

  • DCWoRMS/trunk/src/simulator/stats/implementation/TaskStats.java

    r477 r480  
    4545 
    4646        public String getUserDN() { 
    47                 return this.task.getUserDn(); 
     47                return this.task.getUserDN(); 
    4848        } 
    4949 
Note: See TracChangeset for help on using the changeset viewer.