From 469a236dd4e42bdbff716545915f8aef347e2862 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Michal=20Voc=C5=AF?= Date: Tue, 28 Aug 2012 09:29:44 +0000 Subject: [PATCH] update location of job --- org.glite.lb.state-machine/src/process_event_pbs.c | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/org.glite.lb.state-machine/src/process_event_pbs.c b/org.glite.lb.state-machine/src/process_event_pbs.c index ab8a81c..d91c24f 100644 --- a/org.glite.lb.state-machine/src/process_event_pbs.c +++ b/org.glite.lb.state-machine/src/process_event_pbs.c @@ -200,6 +200,12 @@ int processEvent_PBS(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, c /* update job location */ switch(e->PBSTransfer.destination) { case EDG_WLL_SOURCE_PBS_SERVER: + rep(js->pub.location, e->PBSTransfer.dest_instance); + break; + + case EDG_WLL_SOURCE_PBS_MOM: + case EDG_WLL_SOURCE_PBS_SMOM: + rep(js->pub.ce_node, e->PBSTransfer.dest_instance); break; default: /* where is it going? */ @@ -219,12 +225,14 @@ int processEvent_PBS(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, c case EDG_WLL_SOURCE_PBS_SERVER: /* accepted by server means job is submitted */ js->pub.state = EDG_WLL_JOB_SUBMITTED; + rep(js->pub.location, e->any.src_instance); break; case EDG_WLL_SOURCE_PBS_SMOM: case EDG_WLL_SOURCE_PBS_MOM: /* accepted by MOM: job is going to run */ js->pub.state = EDG_WLL_JOB_SCHEDULED; + rep(js->pub.ce_node, e->any.src_instance); break; default: -- 1.8.2.3