| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| package org.apache.ode.bpel.runtime; |
| |
| import java.util.HashSet; |
| import java.util.Set; |
| |
| import org.slf4j.Logger; |
| import org.slf4j.LoggerFactory; |
| import org.apache.ode.bpel.common.FaultException; |
| import org.apache.ode.bpel.explang.EvaluationException; |
| import org.apache.ode.bpel.obj.ORepeatUntil; |
| import org.apache.ode.bpel.obj.OScope; |
| import org.apache.ode.bpel.runtime.channels.FaultData; |
| import org.apache.ode.bpel.runtime.channels.ParentScope; |
| import org.apache.ode.bpel.runtime.channels.Termination; |
| import org.apache.ode.jacob.ReceiveProcess; |
| import org.apache.ode.jacob.Synch; |
| import org.w3c.dom.Element; |
| |
| import static org.apache.ode.jacob.ProcessUtil.compose; |
| |
| |
| public class REPEATUNTIL extends ACTIVITY { |
| private static final long serialVersionUID = 1L; |
| |
| private static final Logger __log = LoggerFactory.getLogger(WHILE.class); |
| |
| private Set<CompensationHandler> _compHandlers = new HashSet<CompensationHandler>(); |
| |
| public REPEATUNTIL(ActivityInfo self, ScopeFrame scopeFrame, LinkFrame linkFrame) { |
| super(self, scopeFrame, linkFrame); |
| } |
| |
| public void run() { |
| ActivityInfo child = new ActivityInfo(genMonotonic(), |
| getORepeatUntil().getActivity(), |
| newChannel(Termination.class), newChannel(ParentScope.class)); |
| instance(createChild(child, _scopeFrame, _linkFrame)); |
| instance(new WAITER(child)); |
| } |
| |
| /* (non-Javadoc) |
| * @see java.lang.Object#toString() |
| */ |
| public String toString() { |
| return "<T:Act:RepeatUntil:" + _self.o + ">"; |
| } |
| |
| protected Logger log() { |
| return __log; |
| } |
| |
| private ORepeatUntil getORepeatUntil() { |
| return (ORepeatUntil)_self.o; |
| } |
| |
| /** |
| * Evaluates the while condition. |
| * |
| * @return <code>true</code> if the while condition is satisfied, <code>false</code> otherwise. |
| * @throws FaultException in case of standard expression fault (e.g. selection failure) |
| */ |
| private boolean checkCondition() throws FaultException { |
| try { |
| return getBpelRuntimeContext().getExpLangRuntime().evaluateAsBoolean(getORepeatUntil().getUntilCondition(),getEvaluationContext()); |
| } catch (EvaluationException e) { |
| String msg = "Unexpected expression evaluation error checking repeatUntil condition."; |
| __log.error(msg, e); |
| throw new InvalidProcessException(msg,e); |
| } |
| } |
| |
| private class WAITER extends BpelJacobRunnable { |
| private static final long serialVersionUID = -7645042174027252066L; |
| private ActivityInfo _child; |
| private boolean _terminated; |
| |
| WAITER(ActivityInfo child) { |
| _child = child; |
| } |
| |
| public void run() { |
| object(false, compose(new ReceiveProcess() { |
| private static final long serialVersionUID = -5471984635653784051L; |
| }.setChannel(_self.self).setReceiver(new Termination() { |
| public void terminate() { |
| _terminated = true; |
| replication(_child.self).terminate(); |
| instance(WAITER.this); |
| } |
| })).or(new ReceiveProcess() { |
| private static final long serialVersionUID = 3907167240907524405L; |
| }.setChannel(_child.parent).setReceiver(new ParentScope() { |
| public void compensate(OScope scope, Synch ret) { |
| _self.parent.compensate(scope,ret); |
| instance(WAITER.this); |
| } |
| |
| public void completed(FaultData faultData, Set<CompensationHandler> compensations) { |
| _compHandlers.addAll(compensations); |
| if (_terminated || faultData != null) |
| _self.parent.completed(faultData, _compHandlers); |
| else { |
| |
| boolean condResult = false; |
| |
| try { |
| condResult = checkCondition(); |
| } catch (FaultException fe) { |
| __log.error("",fe); |
| _self.parent.completed(createFault(fe.getQName(), _self.o),_compHandlers); |
| return; |
| } |
| if (!condResult) |
| instance(REPEATUNTIL.this); |
| else |
| _self.parent.completed(null,_compHandlers); |
| } |
| } |
| |
| public void cancelled() { completed(null, CompensationHandler.emptySet()); } |
| public void failure(String reason, Element data) { completed(null, CompensationHandler.emptySet()); } |
| }))); |
| } |
| } |
| |
| } |