Changeset 49 for trunk/test
- Timestamp:
- 12/08/11 08:36:40 (13 years ago)
- Location:
- trunk/test
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/test/Makefile
r12 r49 1 1 example : example.c 2 gcc example.c -o example -ldrmaa - ldrmaa_base2 gcc example.c -o example -ldrmaa -L/opt/drmaa/torque/lib -I/opt/drmaa/torque/include 3 3 -
trunk/test/example.c
r12 r49 38 38 39 39 #define SEND_MAIL 0 40 #define WITH_BULK 040 #define WITH_BULK 1 41 41 #define EXPORT_ENVS 0 42 42 #define DEBUG 1 43 #define N_JOBS 143 #define N_JOBS 8 44 44 45 45 #define ERR_LEN DRMAA_ERROR_STRING_BUFFER … … 107 107 printf( "constructing %d\n", i ); 108 108 sprintf( arg, "%d", i ); 109 sprintf( job_path, " ./test_job" );109 sprintf( job_path, "/bin/sleep" ); 110 110 argv[0] = job_path; 111 argv[1] = arg;111 argv[1] = "5"; 112 112 argv[2] = NULL; 113 113 for( j = 0; j < 3; j++ ) … … 127 127 #endif 128 128 } 129 129 #if ! WITH_BULK 130 130 for( i = 0; i < N_JOBS; i++ ) 131 131 { … … 145 145 } 146 146 147 # if WITH_BULK148 { 149 char *argv[] = { " ./job", "bulk", "$drmaa_incr_ph$", NULL };147 #else 148 { 149 char *argv[] = { "/bin/sleep", "5", "$drmaa_incr_ph$", NULL }; 150 150 char *fds[] = { "b.$drmaa_incr_ph$.stdin", "b.$drmaa_incr_ph$.stdout", 151 151 "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 ); 155 155 if( rc ) drmaa_error("drmaa_run_bulk_jobs"); 156 156 … … 197 197 #endif 198 198 const char *scalar_attrs[] = { 199 DRMAA_WD , NULL,200 199 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",206 200 NULL , NULL 207 201 }; … … 222 216 int rc; 223 217 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"; 230 219 231 220 printf( "allocaing template\n" );
Note: See TracChangeset
for help on using the changeset viewer.