From de3c4d4c036fa55ec08918c812468b89dceb3328 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Milo=C5=A1=20Mula=C4=8D?= Date: Thu, 28 Feb 2008 17:15:55 +0000 Subject: [PATCH] merge two transactions into one bigger --- org.glite.lb.server/src/db_store.c | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/org.glite.lb.server/src/db_store.c b/org.glite.lb.server/src/db_store.c index d450188..ed8f042 100644 --- a/org.glite.lb.server/src/db_store.c +++ b/org.glite.lb.server/src/db_store.c @@ -92,15 +92,6 @@ db_store(edg_wll_Context ctx, char *event) if (edg_wll_PurgeServerProxy(ctx, ev->any.jobId)) goto rollback; } -commit: -rollback:; - } while (edg_wll_TransNeedRetry(ctx)); - - if (edg_wll_Error(ctx, NULL, NULL)) goto err; - - - do { - if (edg_wll_Transaction(ctx)) goto err; if (ev->any.type == EDG_WLL_EVENT_REGJOB && (ev->regJob.jobtype == EDG_WLL_REGJOB_DAG || @@ -108,9 +99,10 @@ rollback:; ev->regJob.jobtype == EDG_WLL_REGJOB_COLLECTION) && ev->regJob.nsubjobs > 0) - if (register_subjobs_embryonic(ctx,&ev->regJob)) goto rollback2; + if (register_subjobs_embryonic(ctx,&ev->regJob)) goto rollback; -rollback2:; +commit: +rollback:; } while (edg_wll_TransNeedRetry(ctx)); if (edg_wll_Error(ctx, NULL, NULL)) goto err; -- 1.8.2.3