From 65a1c4ab487ccb9d0fd2f0d4afd54d141c5129d6 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Milo=C5=A1=20Mula=C4=8D?= Date: Fri, 1 Dec 2006 08:49:32 +0000 Subject: [PATCH] accept old sequence numbers - compatibility at incomming to-be-stored events level - do not solve DB containing events with old s.numbers --- org.glite.lb.server/src/store.c.T | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/org.glite.lb.server/src/store.c.T b/org.glite.lb.server/src/store.c.T index 7574b02..0192a44 100644 --- a/org.glite.lb.server/src/store.c.T +++ b/org.glite.lb.server/src/store.c.T @@ -63,7 +63,8 @@ int edg_wll_StoreEvent(edg_wll_Context ctx,edg_wll_Event *e,int *seq) if ( ctx->event_load ) now_s = strdup(edg_wll_TimeToDB(e->any.arrived.tv_sec)); else - now_s = strdup(edg_wll_TimeToDB(time(NULL))); + now_s = strdup(edg_wll_TimeToDB(time(NULL))); + edg_wll_ResetError(ctx); switch (err = check_auth(ctx,e)) { case 0: break; @@ -82,6 +83,15 @@ int edg_wll_StoreEvent(edg_wll_Context ctx,edg_wll_Event *e,int *seq) userid = strdup(strmd5(e->any.user,NULL)); +/* if old seq. code arrives, add LBS part to it */ + if (!strstr(e->any.seqcode, "LBS")) { + char *new_seqcode; + + asprintf(&new_seqcode,"%s:LBS=000000",e->any.seqcode); + free(e->any.seqcode); + e->any.seqcode = new_seqcode; + } + /* make sure user record is there */ if ((err = store_user(ctx,userid,e->any.user))) goto clean; -- 1.8.2.3