From 87a2b4b57e1164ae3ee851dfce638bc4bec5101a Mon Sep 17 00:00:00 2001 From: =?utf8?q?Milo=C5=A1=20Mula=C4=8D?= Date: Tue, 27 Mar 2007 12:05:21 +0000 Subject: [PATCH] enable repeated queries to LBProxy - default delay set to 0 --- org.glite.lb.client/examples/job_log.c | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/org.glite.lb.client/examples/job_log.c b/org.glite.lb.client/examples/job_log.c index 53667a3..605e6dd 100644 --- a/org.glite.lb.client/examples/job_log.c +++ b/org.glite.lb.client/examples/job_log.c @@ -46,7 +46,10 @@ int main(int argc,char **argv) char *errt,*errd, *sock = NULL; edg_wll_Event *events = NULL; edg_wlc_JobId job; - int i,opt,delay = 1,count = 0, ret = 0; + int i,opt,delay = 0,count = 0; + int (*jobLog)(edg_wll_Context, + edg_wlc_JobId, + edg_wll_Event **); if (argc < 2) help(argv[0]); @@ -74,12 +77,10 @@ int main(int argc,char **argv) #endif if (sock) { edg_wll_SetParam(ctx, EDG_WLL_PARAM_LBPROXY_SERVE_SOCK, sock); - ret = edg_wll_JobLogProxy(ctx,job,&events); } - else - ret = edg_wll_JobLog(ctx,job,&events); + jobLog = (sock) ? edg_wll_JobLogProxy : edg_wll_JobLog; - if (ret) + if ( jobLog(ctx,job,&events) ) { edg_wll_Error(ctx,&errt,&errd); fprintf(stderr,"%s: %s (%s)\n",argv[0],errt,errd); @@ -99,7 +100,7 @@ int main(int argc,char **argv) while (count--) { puts("Sleeping ..."); sleep(delay); - if (edg_wll_JobLog(ctx,job,&events)) { + if (jobLog(ctx,job,&events)) { edg_wll_Error(ctx,&errt,&errd); fprintf(stderr,"%s: %s (%s)\n",argv[0],errt,errd); free(errt); free(errd); errt = errd = NULL; -- 1.8.2.3