Changeset 29 for trunk/pbs_drmaa/log_reader.h
- Timestamp:
- 10/17/11 01:49:55 (12 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/pbs_drmaa/log_reader.h
r21 r29 25 25 #endif 26 26 27 #include <stdio.h> 28 27 29 #include <drmaa_utils/job.h> 28 30 #include <drmaa_utils/session.h> … … 31 33 32 34 pbsdrmaa_log_reader_t * 33 pbsdrmaa_log_reader_new ( fsd_drmaa_session_t * session, fsd_job_t * job ); 34 35 pbsdrmaa_log_reader_t * 36 pbsdrmaa_log_reader_accounting_new ( fsd_drmaa_session_t * session, fsd_job_t * job ); 35 pbsdrmaa_log_reader_new ( fsd_drmaa_session_t * session); 37 36 38 37 void … … 41 40 struct pbsdrmaa_log_reader_s { 42 41 fsd_drmaa_session_t *volatile session ; 43 fsd_job_t *volatile job;44 42 45 bool (* 46 read_log) ( pbsdrmaa_log_reader_t * self ); 43 void (*read_log) ( pbsdrmaa_log_reader_t * self ); 47 44 48 void (* 49 select_file) ( pbsdrmaa_log_reader_t * self ); 45 void (*select_file) ( pbsdrmaa_log_reader_t * self ); 50 46 51 /* line - read line, buffer - keeps read but not returned lines, idx, end_idx and line_idx values needed to be kept outside the function */ 52 ssize_t (* 53 read_line) ( pbsdrmaa_log_reader_t * self, char * line, char * buffer, ssize_t size, int * idx, int * end_idx, int * line_idx ); 54 55 /* specifies if function should run */ 47 /* determines if function should run */ 56 48 bool run_flag; 57 49 … … 59 51 time_t t; 60 52 61 /* for job_on_missing - available log files */ 62 char ** log_files; 63 64 /* for job_on_missing - number of log files */ 65 int log_files_number; 66 67 /* log file descriptor */ 68 int volatile fd; 69 70 /* for job_on_missing - log file size when function was ran */ 71 off_t log_file_initial_size; 72 73 /* for job_on_missing - read lines size */ 74 off_t log_file_read_size; 53 /* log file handle */ 54 FILE *fhandle; 75 55 76 56 /* for wait_thread - day changed */ … … 79 59 /* for wait_thread - log file first open */ 80 60 bool volatile first_open; 81 82 char * name;83 61 }; 84 62
Note: See TracChangeset
for help on using the changeset viewer.