From 211e5b502a4ed9091665bb10c793eb95b3a7e226 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Franti=C5=A1ek=20Dvo=C5=99=C3=A1k?= Date: Wed, 27 Jan 2010 12:57:45 +0000 Subject: [PATCH] Notify after purging unknown jobs too. --- org.glite.lb.server/src/srv_purge.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/org.glite.lb.server/src/srv_purge.c b/org.glite.lb.server/src/srv_purge.c index 5bde3f7..dfffd53 100644 --- a/org.glite.lb.server/src/srv_purge.c +++ b/org.glite.lb.server/src/srv_purge.c @@ -763,10 +763,7 @@ int purge_one(edg_wll_Context ctx,edg_wll_JobStat *stat,int dump, int purge, int glite_common_log(LOG_CATEGORY_LB_SERVER_DB, LOG_PRIORITY_DEBUG, stmt); if (edg_wll_ExecSQL(ctx,stmt,NULL) < 0) goto rollback; free(stmt); stmt = NULL; - } - if ( purge ) - { trio_asprintf(&stmt,"delete from status_tags where jobid = '%|Ss'",dbjob); glite_common_log(LOG_CATEGORY_LB_SERVER_DB, LOG_PRIORITY_DEBUG, stmt); if (edg_wll_ExecSQL(ctx,stmt,NULL) < 0) goto rollback; @@ -867,8 +864,11 @@ int purge_one(edg_wll_Context ctx,edg_wll_JobStat *stat,int dump, int purge, int } glite_lbu_FreeStmt(&q); free(stmt); stmt = NULL; + } - /* notifications */ + if ( purge ) + { + // notifications memcpy(&new_stat, stat, sizeof new_stat); new_stat.state = EDG_WLL_JOB_PURGED; edg_wll_NotifMatch(ctx, stat, &new_stat); -- 1.8.2.3