Changeset 49 for trunk


Ignore:
Timestamp:
12/08/11 08:36:40 (8 years ago)
Author:
mmamonski
Message:

on site fixies

Location:
trunk
Files:
6 edited

Legend:

Unmodified
Added
Removed
  • trunk/pbs_drmaa/log_reader.c

    r48 r49  
    670670 
    671671        self->current_offset = ftello(self->fhandle); 
     672         
     673        fsd_log_debug(("Closing log  file (offset=%d)", self->current_offset));   
    672674 
    673675        fclose(self->fhandle); 
     
    679681pbsdrmaa_reopen_log( pbsdrmaa_log_reader_t * self ) 
    680682{ 
     683        fsd_log_debug(("Reopening log file: %s (offset=%d)", self->log_path, self->current_offset));   
     684 
    681685        if ((self->fhandle = fopen(self->log_path,"r")) == NULL) 
    682686         { 
  • trunk/pbs_drmaa/pbs_attrib.gperf

    r48 r49  
    102102submit_args, t(PBSDRMAA_ATTR_SUBMIT_ARGS) 
    103103mtime, t(PBSDRMAA_ATTR_MTIME) 
    104 pbsdrmaa.node_properties, t(PBSDRMAA_ATTR_NODE_PROPERTIES) 
    105 pbsdrmaa.custom_resources, t(PBSDRMAA_ATTR_CUSTOM_RESOURCES) 
     104Resource_List.node_properties, t(PBSDRMAA_ATTR_NODE_PROPERTIES) 
     105Resource_List.custom_resources, t(PBSDRMAA_ATTR_CUSTOM_RESOURCES) 
    106106%% 
    107107#undef t 
     
    215215        { "submit_args", PBSDRMAA_ATTR_SUBMIT_ARGS, false }, 
    216216        { "mtime", PBSDRMAA_ATTR_MTIME, false }, 
    217         { "pbsdrmaa.node_properties", PBSDRMAA_ATTR_NODE_PROPERTIES, false }, 
    218         { "pbsdrmaa.custom_resources", PBSDRMAA_ATTR_CUSTOM_RESOURCES, false }, 
     217        { "Resource_List.node_properties", PBSDRMAA_ATTR_NODE_PROPERTIES, false }, /* DRMAA extenstions */ 
     218        { "Resource_List.custom_resources", PBSDRMAA_ATTR_CUSTOM_RESOURCES, false }, 
    219219         
    220220}; 
  • trunk/pbs_drmaa/pbs_attrib.h

    r48 r49  
    108108        PBSDRMAA_ATTR_HOST, 
    109109        PBSDRMAA_ATTR_NODES, 
    110         PBSDRMAA_ATTR_SOFTWARE, 
    111110        PBSDRMAA_ATTR_PROCS, 
    112111        PBSDRMAA_ATTR_NCPUS, 
     112        PBSDRMAA_ATTR_SOFTWARE, 
    113113        PBSDRMAA_ATTR_MAIL_POINTS, 
    114114        PBSDRMAA_ATTR_OUTPUT_PATH, 
  • trunk/pbs_drmaa/submit.c

    r48 r49  
    182182                                char *final_value = NULL; 
    183183 
    184                                 if (!nodes_value) 
     184                                if (nodes_value) 
    185185                                 { 
    186186                                        final_value = fsd_asprintf("%s:%s",nodes_value, value); 
  • trunk/test/Makefile

    r12 r49  
    11example : example.c 
    2         gcc example.c -o example -ldrmaa -ldrmaa_base 
     2        gcc example.c -o example -ldrmaa -L/opt/drmaa/torque/lib  -I/opt/drmaa/torque/include 
    33       
  • trunk/test/example.c

    r12 r49  
    3838 
    3939#define SEND_MAIL     0 
    40 #define WITH_BULK     0 
     40#define WITH_BULK     1 
    4141#define EXPORT_ENVS   0 
    4242#define DEBUG         1 
    43 #define N_JOBS        1 
     43#define N_JOBS        8 
    4444 
    4545#define ERR_LEN      DRMAA_ERROR_STRING_BUFFER 
     
    107107                printf( "constructing %d\n", i ); 
    108108                sprintf( arg, "%d", i ); 
    109                 sprintf( job_path, "./test_job" ); 
     109                sprintf( job_path, "/bin/sleep" ); 
    110110                argv[0] = job_path; 
    111                 argv[1] = arg; 
     111                argv[1] = "5"; 
    112112                argv[2] = NULL; 
    113113                for( j = 0;  j < 3;  j++ ) 
     
    127127#endif 
    128128         } 
    129  
     129#if ! WITH_BULK 
    130130        for( i = 0;  i < N_JOBS;  i++ ) 
    131131         { 
     
    145145         } 
    146146 
    147 #if WITH_BULK 
    148          { 
    149                 char *argv[] = { "./job", "bulk", "$drmaa_incr_ph$", NULL }; 
     147#else 
     148         { 
     149                char *argv[] = { "/bin/sleep", "5", "$drmaa_incr_ph$", NULL }; 
    150150                char *fds[]  = { "b.$drmaa_incr_ph$.stdin", "b.$drmaa_incr_ph$.stdout", 
    151151                        "b.$drmaa_incr_ph$.stderr" }; 
    152                 bulk_job = construct_job( argv, fds, WD ); 
    153          } 
    154         rc = drmaa_run_bulk_jobs( &bulk_job_ids, bulk_job, 1, N_JOBS, 1, err_msg, ERR_LEN ); 
     152                bulk_job = construct_job( argv, fds, "." ); 
     153         } 
     154        rc = drmaa_run_bulk_jobs( &bulk_job_ids, bulk_job, 1, N_JOBS, 2, err_msg, ERR_LEN ); 
    155155        if( rc )  drmaa_error("drmaa_run_bulk_jobs"); 
    156156 
     
    197197#endif 
    198198        const char *scalar_attrs[] = { 
    199                 DRMAA_WD            , NULL, 
    200199                DRMAA_REMOTE_COMMAND, NULL, 
    201                 DRMAA_JOB_NAME      , NULL, 
    202                 DRMAA_INPUT_PATH    , NULL, 
    203                 DRMAA_OUTPUT_PATH   , NULL, 
    204                 DRMAA_ERROR_PATH    , NULL, 
    205                 DRMAA_NATIVE_SPECIFICATION, "-l host=eeyore,nodes=1 -W x=FLAGS:ADVRES:usecase.0", 
    206200                NULL                , NULL 
    207201        }; 
     
    222216        int rc; 
    223217 
    224         scalar_attrs[ 1] = cwd; 
    225         scalar_attrs[ 3] = argv[0]; 
    226         scalar_attrs[ 5] = "jobname"; 
    227         scalar_attrs[ 7] = fds[0]; 
    228         scalar_attrs[ 9] = fds[1]; 
    229         scalar_attrs[11] = fds[2]; 
     218        scalar_attrs[ 1] = "/bin/sleep"; 
    230219 
    231220        printf( "allocaing template\n" ); 
Note: See TracChangeset for help on using the changeset viewer.