From: Miloš Mulač Date: Wed, 5 Dec 2007 15:53:52 +0000 (+0000) Subject: simplify event storing for internally generated events (CollectionState) X-Git-Tag: glite-yaim-lb_R_4_0_1_2~9 X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=df878f91a3dcdb3aede0a5799880354d0f2e28aa;p=jra1mw.git simplify event storing for internally generated events (CollectionState) - no UserTag event nor ChangeACL --- diff --git a/org.glite.lb.server/src/db_store.c b/org.glite.lb.server/src/db_store.c index 3b8c1db..ae24f97 100644 --- a/org.glite.lb.server/src/db_store.c +++ b/org.glite.lb.server/src/db_store.c @@ -156,6 +156,7 @@ err: } +/* Called only when CollectionStateEvent generated */ int db_parent_store(edg_wll_Context ctx, edg_wll_Event *ev, intJobStat *is) { @@ -168,6 +169,7 @@ db_parent_store(edg_wll_Context ctx, edg_wll_Event *ev, intJobStat *is) edg_wll_ResetError(ctx); memset(&newstat,0,sizeof newstat); + /* Locked from load_parent_intJobStat() */ #ifdef LB_PERF if (sink_mode == GLITE_LB_SINK_STORE) { @@ -179,17 +181,6 @@ db_parent_store(edg_wll_Context ctx, edg_wll_Event *ev, intJobStat *is) #endif - /* XXX: if event type is user tag, convert the tag name to lowercase! - * (not sure whether to convert a value too is reasonable - * or keep it 'case sensitive') - */ - if ( ev->any.type == EDG_WLL_EVENT_USERTAG ) - { - int i; - for ( i = 0; ev->userTag.name[i] != '\0'; i++ ) - ev->userTag.name[i] = tolower(ev->userTag.name[i]); - } - assert(ev->any.user); if(use_db) { @@ -197,21 +188,14 @@ db_parent_store(edg_wll_Context ctx, edg_wll_Event *ev, intJobStat *is) goto err; } - if ( ev->any.type == EDG_WLL_EVENT_CHANGEACL ) - err = edg_wll_UpdateACL(ctx, ev->any.jobId, - ev->changeACL.user_id, ev->changeACL.user_id_type, - ev->changeACL.permission, ev->changeACL.permission_type, - ev->changeACL.operation); - else { #ifdef LB_PERF - if(sink_mode == GLITE_LB_SINK_STATE) { + if(sink_mode == GLITE_LB_SINK_STATE) { glite_wll_perftest_consumeEvent(ev); goto err; - } + } #endif - err = edg_wll_StepIntStateParent(ctx,ev->any.jobId, ev, seq, is, ctx->isProxy? NULL: &newstat); - } + err = edg_wll_StepIntStateParent(ctx,ev->any.jobId, ev, seq, is, ctx->isProxy? NULL: &newstat); if (err) goto err;