From 4823daf90d5f89b2218de7a48166eb537caf661c Mon Sep 17 00:00:00 2001 From: =?utf8?q?Ale=C5=A1=20K=C5=99enek?= Date: Fri, 23 Feb 2007 13:10:02 +0000 Subject: [PATCH] PBS job support --- org.glite.lb.client/examples/job_reg.c | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/org.glite.lb.client/examples/job_reg.c b/org.glite.lb.client/examples/job_reg.c index 2d86ec7..b9300eb 100644 --- a/org.glite.lb.client/examples/job_reg.c +++ b/org.glite.lb.client/examples/job_reg.c @@ -21,7 +21,7 @@ int main(int argc, char *argv[]) { char *src = NULL,*job = NULL,*server = NULL,*seq,*jdl = NULL, *seed = NULL; int lbproxy = 0; - int done = 0,num_subjobs = 0,reg_subjobs = 0,i, collection = 0; + int done = 0,num_subjobs = 0,reg_subjobs = 0,i, collection = 0, pbs=0; edg_wll_Context ctx; edg_wlc_JobId jobid,*subjobs; @@ -30,7 +30,7 @@ int main(int argc, char *argv[]) opterr = 0; do { - switch (getopt(argc,argv,"xs:j:m:n:SCl:e:")) { + switch (getopt(argc,argv,"xs:j:m:n:SCl:e:P")) { case 'x': lbproxy = 1; break; case 's': src = (char *) strdup(optarg); break; case 'j': job = (char *) strdup(optarg); break; @@ -38,6 +38,7 @@ int main(int argc, char *argv[]) case 'n': num_subjobs = atoi(optarg); break; case 'S': if (num_subjobs>0) { reg_subjobs = 1; break; } case 'C': if (num_subjobs>0) { collection = 1; break; } + case 'P': pbs = 1; break; case 'l': jdl = (char *) strdup(optarg); break; case 'e': seed = strdup(optarg); break; case '?': usage(argv[0]); exit(EINVAL); @@ -88,7 +89,11 @@ int main(int argc, char *argv[]) edg_wll_SetParam(ctx,EDG_WLL_PARAM_SOURCE,edg_wll_StringToSource(src)); if (lbproxy) { if (edg_wll_RegisterJobProxy(ctx,jobid, - num_subjobs?(collection?EDG_WLL_REGJOB_COLLECTION:EDG_WLL_REGJOB_DAG):EDG_WLL_REGJOB_SIMPLE, + pbs ? EDG_WLL_REGJOB_PBS + : (num_subjobs ? + (collection?EDG_WLL_REGJOB_COLLECTION:EDG_WLL_REGJOB_DAG) + :EDG_WLL_REGJOB_SIMPLE + ), jdl ? jdl : "blabla", "NNNSSSS", num_subjobs,seed,&subjobs)) { @@ -99,7 +104,11 @@ int main(int argc, char *argv[]) } } else { if (edg_wll_RegisterJobSync(ctx,jobid, - num_subjobs?(collection?EDG_WLL_REGJOB_COLLECTION:EDG_WLL_REGJOB_DAG):EDG_WLL_REGJOB_SIMPLE, + pbs ? EDG_WLL_REGJOB_PBS + : (num_subjobs ? + (collection?EDG_WLL_REGJOB_COLLECTION:EDG_WLL_REGJOB_DAG) + :EDG_WLL_REGJOB_SIMPLE + ), jdl ? jdl : "blabla", "NNNSSSS", num_subjobs,seed,&subjobs)) { -- 1.8.2.3