From: Michal Voců <michal@ruk.cuni.cz>
Date: Tue, 28 Aug 2012 09:29:44 +0000 (+0000)
Subject: update location of job
X-Git-Tag: glite-lb-common_R_8_2_4_1~9
X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=469a236dd4e42bdbff716545915f8aef347e2862;p=jra1mw.git

update location of job
---

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: