Changeset 30 for trunk


Ignore:
Timestamp:
10/17/11 02:10:44 (8 years ago)
Author:
mmamonski
Message:

log reader cont...

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/pbs_drmaa/log_reader.c

    r29 r30  
    217217                                                fsd_log_debug(("WT - Date changed. Closing log file")); 
    218218                                                self->date_changed = true; 
     219                                                fsd_free(line); 
     220                                                break; 
    219221                                         } 
    220222 
     
    232234                                                                event_type = pbsdrmaa_event_0010; 
    233235                                                        else 
     236                                                         { 
     237                                                                fsd_free(line); 
    234238                                                                break; /*we are interested only in the above log messages */ 
     239                                                         } 
    235240                                                 } 
    236241                                                else if ( field_id == PBSDRMAA_FLD_ID_SRC) 
     
    241246                                                 { 
    242247                                                        if (strncmp(field_token, "Job", 3) != 0) 
     248                                                         { 
     249                                                                fsd_free(line); 
    243250                                                                break; /* we are interested only in job events */ 
     251                                                         } 
    244252                                                 } 
    245253                                                else if (field_id == PBSDRMAA_FLD_ID_OBJ_ID) 
     
    258266                                                                 { 
    259267                                                                        fsd_log_debug(("WT - Unknown job: %s", event_jobid)); /* Not a DRMAA job */ 
     268                                                                        fsd_free(line); 
    260269                                                                        break; 
    261270                                                                 } 
     
    278287                                                                char *p_queue = NULL; 
    279288 
     289                                                                fsd_log_info(("WT - Detected queued of job %s", job->job_id)); 
     290 
    280291                                                                if ((p_queue = strstr(msg,"queue =")) == NULL) 
    281292                                                                        fsd_exc_raise_fmt(FSD_ERRNO_INTERNAL_ERROR,"No queue attribute found in log line = %s", line); 
    282293 
    283                                                         /* != Job deleted and Job to be deleted*/ 
    284 #ifdef PBS_PROFESSIONAL 
    285                                                         if      (field[4] != 't' && field[10] != 'd') 
    286                                                          { 
    287 #else 
    288                                                         if (field[4] != 'd') 
    289                                                          { 
    290 #endif 
    291                                                                 struct_state.value = fsd_asprintf("%c",field[n]); 
     294                                                                attribs = pbsdrmaa_add_attr(attribs, PBSDRMAA_JOB_STATE, "Q"); 
     295                                                                attribs = pbsdrmaa_add_attr(attribs, PBSDRMAA_QUEUE, p_queue + 7); 
     296                                                         } 
     297                                                        else if (event_type == pbsdrmaa_event_0008 && strncmp(msg, "Job Run", 7) == 0) 
     298                                                        { 
     299                                                                /* 
     300                                                                 * Running 
     301                                                                 * Torque: 10/11/2011 14:48:23;0008;PBS_Server;Job;15545337.batch.grid.cyf-kr.edu.pl;Job Run at request of root@batch.grid.cyf-kr.edu.pl 
     302                                                                 * PBS Pro: 10/11/2011 14:43:31;0008;Server@nova;Job;2127218.nova;Job Run at request of Scheduler@nova.wcss.wroc.pl on exec_vnode (wn698:ncpus=3:mem=2048000kb)+(wn700:ncpus=3:mem=2048000kb) 
     303                                                                 */ 
     304                                                                char timestamp_unix[64]; 
     305 
     306                                                                fsd_log_info(("WT - Detected start of job %s", job->job_id)); 
     307 
    292308                                                                (void)pbsdrmaa_parse_log_timestamp(event_timestamp, timestamp_unix, sizeof(timestamp_unix)); 
    293309 
     
    322338                                                                char timestamp_unix[64]; 
    323339 
     340                                                                fsd_log_info(("WT - Detected deletion of job %s", job->job_id)); 
     341 
    324342                                                                (void)pbsdrmaa_parse_log_timestamp(event_timestamp, timestamp_unix, sizeof(timestamp_unix)); 
    325343 
     
    333351                                                                else 
    334352                                                                 { 
     353                                                                        job->release( job ); 
     354                                                                        fsd_free(line); 
    335355                                                                        break; /* job was started, ignore, wait for Exit_status message */ 
    336356                                                                 } 
     
    392412                                                        else 
    393413                                                        { 
     414                                                                job->release( job ); 
     415                                                                fsd_free(line); 
    394416                                                                break; /* ignore other job events*/ 
    395417                                                        } 
     
    435457 
    436458                                 } /* end of while getline loop */ 
     459 
    437460 
    438461                                 { /* poll on log file */ 
Note: See TracChangeset for help on using the changeset viewer.