package org.argeo.slc.detached;
+import java.util.List;
+import java.util.Vector;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.argeo.slc.detached.admin.CloseSession;
+import org.argeo.slc.detached.admin.OpenSession;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
public class DetachedExecutionServerImpl implements DetachedExecutionServer {
+ private final static Log log = LogFactory
+ .getLog(DetachedExecutionServerImpl.class);
+
private final DetachedContextImpl detachedContext;
+ private final List sessions;
+
+ private int skipCount = 0;
private BundleContext bundleContext;
private DetachedDriver driver;
public DetachedExecutionServerImpl() {
detachedContext = new DetachedContextImpl();
+ sessions = new Vector();
}
- public DetachedStepAnswer executeStep(DetachedStepRequest request) {
+ public DetachedAnswer executeStep(DetachedRequest request) {
+ DetachedAnswer answer = null;
try {
DetachedStep step = null;
- // Find step
+ // Find action
ServiceReference[] refs = bundleContext.getAllServiceReferences(
StaticRefProvider.class.getName(), null);
+ Object obj = null;
for (int i = 0; i < refs.length; i++) {
StaticRefProvider provider = (StaticRefProvider) bundleContext
.getService(refs[i]);
- Object obj = provider.getStaticRef(request.getStepRef());
+ obj = provider.getStaticRef(request.getRef());
if (obj != null) {
- step = (DetachedStep) obj;
break;
}
}
- if (step == null)
- throw new DetachedException("Could not find step with ref "
- + request.getStepRef());
+ if (obj == null)
+ throw new DetachedException("Could not find action with ref "
+ + request.getRef());
+
+ // Execute actions
+ if (obj instanceof DetachedStep) {
+ if (getCurrentSession() == null)
+ throw new DetachedException("No open session.");
+
+ StringBuffer skippedLog = new StringBuffer();
+ boolean execute = true;
+ if (getPreviousSession() != null
+ && !getPreviousSession().isClosed()) {
+ if (getCurrentSession().getDoItAgainPolicy().equals(
+ DetachedSession.SKIP_UNTIL_ERROR)) {
+ // Skip execution of already successful steps
+ if (getPreviousSession().getAnswers().size() > skipCount) {
+ DetachedAnswer previousAnswer = (DetachedAnswer) getPreviousSession()
+ .getAnswers().get(skipCount);
+ DetachedRequest previousRequest = (DetachedRequest) getPreviousSession()
+ .getRequests().get(skipCount);
+ // Check paths
+ if (!previousRequest.getPath().equals(
+ request.getPath())) {
+ String msg = "New request is not consistent with previous path. previousPath="
+ + previousRequest.getPath()
+ + ", newPath="
+ + request.getPath()
+ + "\n";
+ skippedLog.append(msg);
+ log.warn(msg);
+ }
+
+ if (previousAnswer.getStatus() != DetachedAnswer.ERROR) {
+ execute = false;
+ }
+ } else {
+ // went further as skip count, doing nothing.
+ }
+ }
+ }
+
+ if (execute) {
+ step = (DetachedStep) obj;
+ answer = step.execute(detachedContext, request);
+ } else {
+ skippedLog.append("Skipped path " + request.getPath()
+ + " (skipCount=" + skipCount + ")");
+ answer = new DetachedAnswer(request);
+ answer.setStatus(DetachedAnswer.SKIPPED);
+ answer.setLog(skippedLog.toString());
+ }
+
+ } else if (obj instanceof DetachedAdminCommand) {
+ if (obj instanceof OpenSession) {
+ if (getCurrentSession() != null)
+ throw new DetachedException(
+ "There is already an open session #"
+ + getCurrentSession().getUuid());
+ sessions.add(((OpenSession) obj).execute(request,
+ bundleContext));
+ answer = new DetachedAnswer(request, "Session #"
+ + getCurrentSession().getUuid() + " open.");
+ } else if (obj instanceof CloseSession) {
+ if (getCurrentSession() == null)
+ throw new DetachedException(
+ "There is no open session to close");
+ answer = new DetachedAnswer(request, "Session #"
+ + getCurrentSession().getUuid() + " closed.");
+ answer.setStatus(DetachedAnswer.CLOSED_SESSION);
+ }
+ }
+
+ if (answer == null)
+ throw new DetachedException("Unknown action type "
+ + obj.getClass() + " for action with ref "
+ + request.getRef());
- return step.execute(detachedContext, request);
} catch (DetachedException e) {
- throw e;
+ answer = new DetachedAnswer(request);
+ answer.setStatus(DetachedAnswer.ERROR);
+ answer.setLog(e.getMessage());
} catch (Exception e) {
e.printStackTrace();
throw new DetachedException(
"Unexpected exception while executing request " + request,
e);
}
+ getCurrentSession().getRequests().add(request);
+ getCurrentSession().getAnswers().add(answer);
+ return answer;
+ }
+
+ protected final DetachedSession getCurrentSession() {
+ if (sessions.size() == 0) {
+ return null;
+ } else {
+ DetachedSession session = (DetachedSession) sessions.get(sessions
+ .size() - 1);
+ List answers = session.getAnswers();
+ if (answers.size() > 0) {
+ DetachedAnswer lastAnswer = (DetachedAnswer) answers
+ .get(answers.size() - 1);
+ if (lastAnswer.getStatus() == DetachedAnswer.ERROR
+ || lastAnswer.getStatus() == DetachedAnswer.CLOSED_SESSION)
+ return null;
+ }
+ return session;
+ }
+ }
+
+ protected final DetachedSession getPreviousSession() {
+ if (sessions.size() < 2)
+ return null;
+ else
+ return (DetachedSession) sessions.get(sessions.size() - 2);
}
public void init(BundleContext bundleContext) {
public void run() {
while (active) {
try {
- DetachedStepRequest request = driver.receiveRequest();
- executeStep(request);
+ DetachedRequest request = driver.receiveRequest();
+ DetachedAnswer answer = executeStep(request);
+ driver.sendAnswer(answer);
} catch (Exception e) {
if (e instanceof RuntimeException)
throw (RuntimeException) e;
projects / gpl / argeo-slc.git / blobdiff