From 90231f92de19f30564be6a00aed54ecd10a8353b Mon Sep 17 00:00:00 2001 From: =?utf8?q?Milo=C5=A1=20Mula=C4=8D?= Date: Wed, 9 Sep 2009 12:23:55 +0000 Subject: [PATCH] enhancements in state transitions --- org.glite.lb.state-machine/src/process_event_cream.c | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/org.glite.lb.state-machine/src/process_event_cream.c b/org.glite.lb.state-machine/src/process_event_cream.c index b4b83e4..631522d 100644 --- a/org.glite.lb.state-machine/src/process_event_cream.c +++ b/org.glite.lb.state-machine/src/process_event_cream.c @@ -56,6 +56,9 @@ int processEvent_Cream(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, js->pub.cream_state = EDG_WLL_STAT_REGISTERED; } if (USABLE_DATA(res)) { + rep_cond(js->pub.cream_owner, js->pub.owner); + rep_cond(js->pub.cream_jdl, e->regJob.jdl); + rep_cond(js->pub.cream_endpoint, e->regJob.ns); } break; case EDG_WLL_EVENT_CREAMSTART: @@ -105,6 +108,9 @@ int processEvent_Cream(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, if (USABLE(res)) { js->pub.state = EDG_WLL_JOB_RUNNING; js->pub.cream_state = EDG_WLL_STAT_RUNNING; + if (e->any.source == EDG_WLL_SOURCE_LRMS) { + js->pub.cream_jw_status = EDG_WLL_STAT_WRAPPER_RUNNING; + } } if (USABLE_DATA(res)) { js->pub.cream_node = e->CREAMRunning.node; @@ -114,6 +120,9 @@ int processEvent_Cream(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, if (USABLE(res)) { js->pub.state = EDG_WLL_JOB_RUNNING; js->pub.cream_state = EDG_WLL_STAT_REALLYRUNNING; + if (e->any.source == EDG_WLL_SOURCE_LRMS) { + js->pub.cream_jw_status = EDG_WLL_STAT_PAYLOAD_RUNNING; + } } if (USABLE_DATA(res)) { } @@ -122,6 +131,9 @@ int processEvent_Cream(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, if (USABLE(res)) { js->pub.state = EDG_WLL_JOB_DONE; js->pub.cream_state = (e->CREAMDone.status_code == EDG_WLL_DONE_OK) ? EDG_WLL_STAT_DONEOK : EDG_WLL_STAT_DONEFAILED; + if (e->any.source == EDG_WLL_SOURCE_LRMS) { + js->pub.cream_jw_status = EDG_WLL_STAT_DONE; + } } if (USABLE_DATA(res)) { js->pub.cream_done_code = e->CREAMDone.status_code; @@ -137,7 +149,7 @@ int processEvent_Cream(intJobStat *js, edg_wll_Event *e, int ev_seq, int strict, } } if (USABLE_DATA(res)) { - js->pub.cream_cancel_reason = e->CREAMCancel.reason; + js->pub.cream_reason = e->CREAMCancel.reason; } break; case EDG_WLL_EVENT_CREAMABORT: -- 1.8.2.3