From 1751c5f05ae791274c920fa35db87843eddaa0f2 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Jan=20Posp=C3=AD=C5=A1il?= Date: Sun, 15 Oct 2006 21:16:42 +0000 Subject: [PATCH] added edg_wll_RegisterJobProxyOld for testing/measuring (LB_PERF) purposes --- .../interface/producer.h.T | 12 +++++++++ org.glite.lb.client/src/producer.c | 29 ++++++++++++++++++++++ 2 files changed, 41 insertions(+) diff --git a/org.glite.lb.client-interface/interface/producer.h.T b/org.glite.lb.client-interface/interface/producer.h.T index f84d623..ee3b3d6 100644 --- a/org.glite.lb.client-interface/interface/producer.h.T +++ b/org.glite.lb.client-interface/interface/producer.h.T @@ -373,6 +373,18 @@ extern int edg_wll_RegisterJobProxy( ); #ifdef LB_PERF +/* original register to LBProxy */ +extern int edg_wll_RegisterJobProxyOld( + edg_wll_Context context, + const edg_wlc_JobId job, + enum edg_wll_RegJobJobtype type, + const char * jdl, + const char * ns, + int num_subjobs, + const char * seed, + edg_wlc_JobId ** subjobs +); + /* register only to LBProxy */ /* useful for performance measurements */ diff --git a/org.glite.lb.client/src/producer.c b/org.glite.lb.client/src/producer.c index 3d5dee4..818e9b1 100644 --- a/org.glite.lb.client/src/producer.c +++ b/org.glite.lb.client/src/producer.c @@ -1021,6 +1021,35 @@ edg_wll_registerjobproxy_end: #undef MY_SEED } +/** + *----------------------------------------------------------------------- + * Register one job with L&B Proxy service + * \note simple wrapper around edg_wll_RegisterJobMaster() + * this is original edg_wll_RegisterJobProxy + *----------------------------------------------------------------------- + */ +int edg_wll_RegisterJobProxyOld( + edg_wll_Context ctx, + const edg_wlc_JobId job, + enum edg_wll_RegJobJobtype type, + const char * jdl, + const char * ns, + int num_subjobs, + const char * seed, + edg_wlc_JobId ** subjobs) +{ +#define MY_SEED "edg_wll_RegisterJobProxyOld()" + /* first register with bkserver */ + int ret = edg_wll_RegisterJobMaster(ctx,LOGFLAG_DIRECT,job,type,jdl,ns,NULL,num_subjobs,seed ? seed : MY_SEED,subjobs); + if (ret) { + edg_wll_UpdateError(ctx,0,"edg_wll_RegisterJobProxyOld(): unable to register with bkserver"); + return edg_wll_Error(ctx,NULL,NULL); + } + /* and then with L&B Proxy */ + return edg_wll_RegisterJobMaster(ctx,LOGFLAG_PROXY,job,type,jdl,ns,NULL,num_subjobs,seed ? seed : MY_SEED,subjobs); +#undef MY_SEED +} + #else /* LB_PERF */ /** -- 1.8.2.3