diff options
10 files changed, 564 insertions, 647 deletions
diff --git a/sandbox/dougsleite/guardian-model/pom.xml b/sandbox/dougsleite/guardian-model/pom.xml index ac4d37db06..66f2bdbf32 100644 --- a/sandbox/dougsleite/guardian-model/pom.xml +++ b/sandbox/dougsleite/guardian-model/pom.xml @@ -88,10 +88,12 @@ <artifactId>axis2</artifactId> <version>1.2</version> <type>pom</type> - </dependency> - - - + </dependency> + <dependency> + <groupId>org.apache.tuscany.sca</groupId> + <artifactId>tuscany-policy-recoveryrules</artifactId> + <version>1.6-SNAPSHOT</version> + </dependency> </dependencies> <build> @@ -113,3 +115,4 @@ </build> </project> + diff --git a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/Constants.java b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/Constants.java new file mode 100644 index 0000000000..0396a65c08 --- /dev/null +++ b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/Constants.java @@ -0,0 +1,60 @@ +/* + * 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.tuscany.sca.guardian; + +import javax.xml.namespace.QName; + +public interface Constants { + + String RECOVERY_RULES = "recovery_rules"; + QName RECOVERY_RULES_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, RECOVERY_RULES); + + String RULE = "rule"; + QName RULE_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, RULE); + + String NAME = "name"; + QName NAME_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, NAME); + + String SIGNALED_EXCEPTION = "signaled_exception"; + QName SIGNALED_EXCEPTION_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, SIGNALED_EXCEPTION); + + String PARTICIPANT = "participant"; + QName PARTICIPANT_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, PARTICIPANT); + + String MATCH = "match"; + QName MATCH_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, MATCH); + + String THROW_EXCEPTION = "throw_exception"; + QName THROW_EXCEPTION_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, THROW_EXCEPTION); + + String CLASS = "class"; + QName CLASS_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, CLASS); + + String TARGET_CONTEXT = "target_context"; + QName TARGET_CONTEXT_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, TARGET_CONTEXT); + + String MIN_PARTICIPANT_JOINED = "min_participant_joined"; + QName MIN_PARTICIPANT_JOINED_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, MIN_PARTICIPANT_JOINED); + + String MAX_PARTICIPANT_JOINED = "max_participant_joined"; + QName MAX_PARTICIPANT_JOINED_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, MAX_PARTICIPANT_JOINED); + + String AFFECTED_PARTICIPANTS = "affected_participants"; + QName AFFECTED_PARTICIPANTS_QNAME = new QName(org.apache.tuscany.sca.assembly.xml.Constants.SCA10_NS, AFFECTED_PARTICIPANTS); +} diff --git a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroup.java b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroup.java index b0dbcac4a1..5119390a14 100644 --- a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroup.java +++ b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroup.java @@ -23,6 +23,9 @@ import org.osoa.sca.annotations.Remotable; //@Remotable public interface GuardianGroup extends GuardianPrimitives { + public static int NORMAL_PARTICIPANT_STATE = 0; + public static int SUSPENDED_PARTICIPANT_STATE = 1; + public void addGuardianMember(GuardianMember guardianMember); public boolean removeGuardianMember(GuardianMember guardianMember); diff --git a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroupImpl.java b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroupImpl.java index e21016b3f5..1168f7406c 100644 --- a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroupImpl.java +++ b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianGroupImpl.java @@ -20,7 +20,6 @@ package org.apache.tuscany.sca.guardian; import java.io.FileInputStream; import java.io.FileNotFoundException; -import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import java.util.logging.Level; @@ -39,12 +38,16 @@ public class GuardianGroupImpl implements GuardianGroup { private List<GuardianMember> guardianList; private ResettableReader reader; + private InnerGuardianGroupThread innerThread; + private List<GlobalExceptionInterface> concurrentExList; public GuardianGroupImpl() { guardianList = new LinkedList<GuardianMember>(); + concurrentExList = new LinkedList<GlobalExceptionInterface>(); + innerThread = new InnerGuardianGroupThread(); } - @Property(name = "recovery_rules", required = true) + @Property(name = "recovery_rules", required = false) public void setRecoveryRules(String recoveryRules) { try { FileInputStream fileInputStream = new FileInputStream(recoveryRules); @@ -71,52 +74,33 @@ public class GuardianGroupImpl implements GuardianGroup { throw new UnsupportedOperationException("Not supported yet."); } - public void gthrow(GlobalExceptionInterface ex, List<String> participantList) { + public synchronized void gthrow(GlobalExceptionInterface ex, List<String> participantList) { //1)Ivoked by a GuardianMember instance through the gthrow method //2)Notify all participants about the exception (FIFO atomic broadcast model) - it will cause the suspension of all participants // 2.1)Invoke the gthrow of the guardian members associated with the participants on participantList + concurrentExList.add(ex); + //Sends a message representing the exception to the other guardian members + SuspendException suspendEx = new SuspendException(); if (participantList == null) { for (GuardianMember g : guardianList) { - if (!g.getParticipantIdentifier().equals(ex.getSignalingParticipant())) { - //g.gthrow(ex, participantList); - g.gthrow(null, null); - } + g.gthrow(suspendEx, null); } } else { for (GuardianMember g : guardianList) { - if (participantList.contains(g.getCurrentContext())) { - //g.gthrow(ex, participantList); - g.gthrow(null, null); + if (participantList.contains(g.getParticipantIdentifier())) { + g.gthrow(suspendEx, null); + //g.gthrow(suspendEx,null); -> g is the signler } } } - //Check if the participants are blocked - List<Integer> flags = new ArrayList<Integer>(guardianList.size()); - for (int i = 0; i < guardianList.size(); i++) { - if (guardianList.get(i).getService().isBlocked()) { - flags.add(i, 1); - } else { - flags.add(i, 0); - } - } - - //Wait until all participants are blocked - while (flags.contains(0)) { - try { - Thread.sleep(5000); - } catch (InterruptedException ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); - } - } - - //3)Once ALL required participants are SUSPENDED (suspended point), invoke the defined Recovery Rules - for (GuardianMember g : guardianList) { - g.addException(new SuspendException()); - } +// //3)Once ALL required participants are SUSPENDED (suspended point), invoke the defined Recovery Rules +// for (GuardianMember g : guardianList) { +// g.addException(new SuspendException()); +// } // 3.1) recovery_rules < signaled exceptions + context information of all participant > target context + exception to raise //Simpleste Recovery Rule: broadcast the exception for all participants - FIXME: hardcoded @@ -125,494 +109,346 @@ public class GuardianGroupImpl implements GuardianGroup { // g.addException(ex); // } - applyRecoveryRules(ex); - -// //HARDCODED - SERVER-BACKUP EXAMPLE -// //Rule 1 -// if (ex instanceof JoinException) { -// if (guardianMembers.size() > 1) { -// -// PrimaryExistsException primaryExists = new PrimaryExistsException(); -// primaryExists.setTargetContext(new Context("MAIN")); -// -// BackupJoinedException backupJoined = new BackupJoinedException(); -// backupJoined.setTargetContext(new Context("PRIMARY")); -// -// for (GuardianMember g : guardianMembers) { -// //let p = JoinException.signaler -// if (g.getParticipantIdentifier().equals(ex.getSignalingParticipant())) { -// g.addException(primaryExists); -// System.out.println("adding PrimaryExistsException to " + g.getParticipantIdentifier()); -// } else { -// g.addException(backupJoined); -// System.out.println("adding BackupJoinedException to " + g.getParticipantIdentifier()); -// } -// } -// } -// } //Rule 2 -// else if (ex instanceof PrimaryFailedException) { -// -// PrimaryFailedException primaryFailedInit = new PrimaryFailedException(); -// primaryFailedInit.setTargetContext(Context.INIT_CONTEXT); -// -// PrimaryFailedException primaryFailedMain = new PrimaryFailedException(); -// primaryFailedMain.setTargetContext(new Context("MAIN")); -// -// for (GuardianMember g : guardianMembers) { -// if (g.getCurrentContext().getName().equals("PRIMARY")) { -// System.out.println("adding PrimaryFailedException to " + g.getParticipantIdentifier()); -// g.addException(primaryFailedInit); -// } else if (g.getCurrentContext().getName().equals("BACKUP")) { -// System.out.println("adding PrimaryFailedException to " + g.getParticipantIdentifier()); -// g.addException(primaryFailedMain); -// } -// } -// } //Rule 3 -// else if (ex instanceof BackupFailedException) { -// -// BackupFailedException backupFailedPrimary = new BackupFailedException(); -// backupFailedPrimary.setTargetContext(new Context("PRIMARY")); -// -// BackupFailedException backupFailedInit = new BackupFailedException(); -// backupFailedInit.setTargetContext(Context.INIT_CONTEXT); -// -// for (GuardianMember g : guardianMembers) { -// if (g.getCurrentContext().getName().equals("PRIMARY")) { -// System.out.println("adding BackupFailedException to " + g.getParticipantIdentifier()); -// g.addException(backupFailedPrimary); -// } else if (g.getCurrentContext().getName().equals("BACKUP")) { -// System.out.println("adding BackupFailedException to " + g.getParticipantIdentifier()); -// g.addException(backupFailedInit); -// } -// } -// -// } + if (!innerThread.isRunning) { + innerThread.setGlobalException(ex); + new Thread(innerThread).start(); + } + } + public boolean propagate(GlobalExceptionInterface ex) { + throw new UnsupportedOperationException("Not supported yet."); } - private void applyRecoveryRules(GlobalExceptionInterface ex) { - reader.reset(); - ruleTag(ex); + public void checkExceptionStatus() { + throw new UnsupportedOperationException("Not supported yet."); } - private void ruleTag(GlobalExceptionInterface ex) { - try { - while (reader.hasNext()) { - reader.next(); - //<rule name="" signaled_exception=""> - if (reader.isStartElement() && reader.getLocalName().equals("rule")) { - for (int i = 0; i < reader.getAttributeCount(); i++) { - //ex == signaled_exception - if (reader.getAttributeLocalName(i).equals("signaled_exception") && ex.getClass().getName().equals(reader.getAttributeValue(i))) { - participantExceptionTag(ex); - break; - } - } - } - } - } catch (XMLStreamException exc) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex); - } + public boolean removeGuardianMember(GuardianMember guardianMember) { + return this.guardianList.remove(guardianMember); } - private void participantExceptionTag(GlobalExceptionInterface ex) { - List<GuardianMember> gmList; - try { - while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("rule"))) { - reader.next(); - //<participant match="<REG_EXP> | SIGNALER"> - if (reader.isStartElement() && reader.getLocalName().equals("participant")) { - String participantMatch = reader.getAttributeValue(0).trim(); + private class InnerGuardianGroupThread implements Runnable { - gmList = getMatchingParticipants(participantMatch, ex); + private boolean isRunning; + private GlobalExceptionInterface ex = null; - if (!gmList.isEmpty()) { - throwExceptionTag(gmList, ex); - } - } - } - } catch (XMLStreamException exc) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, exc); + public InnerGuardianGroupThread() { + isRunning = false; } - } - private void throwExceptionTag(List<GuardianMember> gmList, GlobalExceptionInterface ex) { + public void setGlobalException(GlobalExceptionInterface ex) { + this.ex = ex; + } - String exceptionClassName; - String targetContextName; - Integer min_participant_joined; - Integer max_participant_joined; + public GlobalExceptionInterface getGlobalException() { + return ex; + } - try { + public void run() { + if (ex != null) { + isRunning = true; + applyRecoveryRules(ex); - while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("participant"))) { - reader.next(); - - //<throw_exception class="<Exception>" target_context="<Context>"/> - if (reader.isStartElement() && reader.getLocalName().equals("throw_exception")) { - - exceptionClassName = null; - targetContextName = null; - min_participant_joined = null; - max_participant_joined = null; - for (int j = 0; j < reader.getAttributeCount(); j++) { - if (reader.getAttributeLocalName(j).equals("class")) { - //class value - exceptionClassName = reader.getAttributeValue(j); - } else if (reader.getAttributeLocalName(j).equals("target_context")) { - //target_context value - targetContextName = reader.getAttributeValue(j); - } else if (reader.getAttributeLocalName(j).equals("min_participant_joined")) { - //min_participant_joined value - min_participant_joined = Integer.parseInt(reader.getAttributeValue(j)); - } else { - //max_participant_joined value - max_participant_joined = Integer.parseInt(reader.getAttributeValue(j)); - } + for (GuardianMember gm : guardianList) { + if (gm.getParticipantState() == SUSPENDED_PARTICIPANT_STATE) { + gm.setParticipantState(NORMAL_PARTICIPANT_STATE); } + } + } + isRunning = false; + } - //Test the min and max joined participants condition - if (min_participant_joined != null && max_participant_joined != null) { - if (!(guardianList.size() >= min_participant_joined && guardianList.size() < max_participant_joined)) { - break; - } - } else if (min_participant_joined != null) { - if (!(guardianList.size() >= min_participant_joined)) { - break; - } - } else if (max_participant_joined != null) { - if (!(guardianList.size() >= min_participant_joined)) { - break; - } - } + public boolean isRunning() { + return isRunning; + } - //<affected_participants> - String affectedParticipants = affectedParticipantsTag(); - int index = -1; - - //Verify if the parameter is an index - try { - index = Integer.parseInt(affectedParticipants); - } catch (NumberFormatException nexc) { - index = -1; - } + private void applyRecoveryRules(GlobalExceptionInterface ex) { + reader.reset(); + ruleTag(ex); + } - Class exceptionClass = Class.forName(exceptionClassName); - Context targetContext; - if (targetContextName.toUpperCase().equals(Context.CURRENT_CONTEXT.getName().toUpperCase())) { - targetContext = Context.CURRENT_CONTEXT; - } else if (targetContextName.toUpperCase().equals(Context.INIT_CONTEXT.getName().toUpperCase())) { - targetContext = Context.INIT_CONTEXT; - } else { - targetContext = new Context(targetContextName); - } - GlobalException newException = (GlobalException) exceptionClass.newInstance(); - - newException.setTargetContext(targetContext); - newException.setSignalingContext(ex.getSignalingContext()); - newException.setSignalingParticipant(ex.getSignalingParticipant()); - - //Add the exception to the participants matched - if (index != -1) { - gmList.get(index).addException(newException); - } else if (affectedParticipants != null && affectedParticipants.length() != 0) { - if (affectedParticipants.toUpperCase().equals("FIRST")) { - gmList.get(0).addException(newException); - } else if (affectedParticipants.toUpperCase().equals("LAST")) { - gmList.get(gmList.size() - 1).addException(newException); - } else if (affectedParticipants.toUpperCase().equals("ALL")) { - for (GuardianMember gm : gmList) { - gm.addException(newException); + private void ruleTag(GlobalExceptionInterface ex) { + try { + while (reader.hasNext()) { + reader.next(); + //<rule name="" signaled_exception=""> + if (reader.isStartElement() && reader.getLocalName().equals("rule")) { + for (int i = 0; i < reader.getAttributeCount(); i++) { + //ex == signaled_exception + if (reader.getAttributeLocalName(i).equals("signaled_exception") && ex.getClass().getName().equals(reader.getAttributeValue(i))) { + participantExceptionTag(ex); + break; } } - } else { - for (GuardianMember gm : gmList) { - gm.addException(newException); - } } } + } catch (XMLStreamException exc) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex); } - } catch (XMLStreamException ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); - } catch (InstantiationException ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); - } catch (IllegalAccessException ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); - } catch (ClassNotFoundException ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); } - } - private String affectedParticipantsTag() { - String affectedParticipants = null; - try { - while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("throw_exception"))) { - reader.next(); - //<affected_participants> - if (reader.isStartElement() && reader.getLocalName().equals("affected_participants")) { - affectedParticipants = reader.getElementText(); + private void participantExceptionTag(GlobalExceptionInterface ex) { + List<GuardianMember> gmList; + try { + while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("rule"))) { + reader.next(); + //<participant match="<REG_EXP> | SIGNALER"> + if (reader.isStartElement() && reader.getLocalName().equals("participant")) { + String participantMatch = reader.getAttributeValue(0).trim(); + + gmList = getMatchingParticipants(participantMatch, ex); + + if (!gmList.isEmpty()) { + throwExceptionTag(gmList, ex); + } + } } + } catch (XMLStreamException exc) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, exc); } - } catch (XMLStreamException ex) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex); } - return affectedParticipants; - } + private void throwExceptionTag(List<GuardianMember> gmList, GlobalExceptionInterface ex) { - private void applyRecoveryRulesOriginal(GlobalExceptionInterface ex) { + String exceptionClassName; + String targetContextName; + Integer min_participant_joined; + Integer max_participant_joined; - String exceptionClassName; - String targetContextName; - Integer min_participant_joined; - Integer max_participant_joined; + try { - List<GuardianMember> gmList; + while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("participant"))) { + reader.next(); + + //<throw_exception class="<Exception>" target_context="<Context>"/> + if (reader.isStartElement() && reader.getLocalName().equals("throw_exception")) { + + exceptionClassName = null; + targetContextName = null; + min_participant_joined = null; + max_participant_joined = null; + for (int j = 0; j < reader.getAttributeCount(); j++) { + if (reader.getAttributeLocalName(j).equals("class")) { + //class value + exceptionClassName = reader.getAttributeValue(j); + } else if (reader.getAttributeLocalName(j).equals("target_context")) { + //target_context value + targetContextName = reader.getAttributeValue(j); + } else if (reader.getAttributeLocalName(j).equals("min_participant_joined")) { + //min_participant_joined value + min_participant_joined = Integer.parseInt(reader.getAttributeValue(j)); + } else { + //max_participant_joined value + max_participant_joined = Integer.parseInt(reader.getAttributeValue(j)); + } + } - try { + //Test the min and max joined participants condition + if (min_participant_joined != null && max_participant_joined != null) { + if (!(guardianList.size() >= min_participant_joined && guardianList.size() < max_participant_joined)) { + break; + } + } else if (min_participant_joined != null) { + if (!(guardianList.size() >= min_participant_joined)) { + break; + } + } else if (max_participant_joined != null) { + if (!(guardianList.size() >= min_participant_joined)) { + break; + } + } - reader.reset(); + //<affected_participants> + String affectedParticipants = affectedParticipantsTag(); + int index = -1; - while (reader.hasNext()) { - reader.next(); - //<rule name="" signaled_exception=""> - if (reader.isStartElement() && reader.getLocalName().equals("rule")) { - for (int i = 0; i < reader.getAttributeCount(); i++) { - //ex == signaled_exception - if (reader.getAttributeLocalName(i).equals("signaled_exception") && - ex.getClass().getName().equals(reader.getAttributeValue(i))) { - - while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("rule"))) { - reader.next(); - - //<participant match="<REG_EXP> | SIGNALER"> - if (reader.isStartElement() && reader.getLocalName().equals("participant")) { - - String participant_match = reader.getAttributeValue(0).trim(); - - while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("participant"))) { - reader.next(); - - //<throw_exception class="<Exception>" target_context="<Context>"/> - if (reader.isStartElement() && reader.getLocalName().equals("throw_exception")) { - - exceptionClassName = null; - targetContextName = null; - min_participant_joined = null; - max_participant_joined = null; - - for (int j = 0; j < reader.getAttributeCount(); j++) { - if (reader.getAttributeLocalName(j).equals("class")) { - //class value - exceptionClassName = reader.getAttributeValue(j); - } else if (reader.getAttributeLocalName(j).equals("target_context")) { - //target_context value - targetContextName = reader.getAttributeValue(j); - } else if (reader.getAttributeLocalName(j).equals("min_participant_joined")) { - //min_participant_joined value - min_participant_joined = Integer.parseInt(reader.getAttributeValue(j)); - } else { - //max_participant_joined value - max_participant_joined = Integer.parseInt(reader.getAttributeValue(j)); - } - } - - //Test the min and max joined participants condition - if (min_participant_joined != null && max_participant_joined != null) { - if (!(guardianList.size() >= min_participant_joined && guardianList.size() < max_participant_joined)) { - break; - } - } else if (min_participant_joined != null) { - if (!(guardianList.size() >= min_participant_joined)) { - break; - } - } else if (max_participant_joined != null) { - if (!(guardianList.size() >= min_participant_joined)) { - break; - } - } - - //match value - gmList = getMatchingParticipants(participant_match, ex); - - String affectedParticipants = null; - int index = -1; - while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("throw_exception"))) { - reader.next(); - - //<affected_participants> - if (reader.isStartElement() && reader.getLocalName().equals("affected_participants")) { - affectedParticipants = reader.getElementText(); - - //Verify if the parameter is an index - try { - index = Integer.parseInt(affectedParticipants); - } catch (NumberFormatException nexc) { - index = -1; - } - } - } - - Class exceptionClass = Class.forName(exceptionClassName); - - Context targetContext; - if (targetContextName.toUpperCase().equals(Context.CURRENT_CONTEXT.getName().toUpperCase())) { - targetContext = Context.CURRENT_CONTEXT; - } else if (targetContextName.toUpperCase().equals(Context.INIT_CONTEXT.getName().toUpperCase())) { - targetContext = Context.INIT_CONTEXT; - } else { - targetContext = new Context(targetContextName); - } - - GlobalException newException = (GlobalException) exceptionClass.newInstance(); - newException.setTargetContext(targetContext); - - //Add the exception to the participants matched - if (index != -1) { - gmList.get(index).addException(newException); - } else if (affectedParticipants != null && affectedParticipants.length() != 0) { - if (affectedParticipants.toUpperCase().equals("FIRST")) { - gmList.get(0).addException(newException); - - } else if (affectedParticipants.toUpperCase().equals("LAST")) { - gmList.get(gmList.size() - 1).addException(newException); - } else if (affectedParticipants.toUpperCase().equals("ALL")) { - for (GuardianMember gm : gmList) { - gm.addException(newException); - } - } - } else { - for (GuardianMember gm : gmList) { - gm.addException(newException); - } - } - } - } + //Verify if the parameter is an index + try { + index = Integer.parseInt(affectedParticipants); + } catch (NumberFormatException nexc) { + index = -1; + } + + Class exceptionClass = Class.forName(exceptionClassName); + Context targetContext; + if (targetContextName.toUpperCase().equals(Context.CURRENT_CONTEXT.getName().toUpperCase())) { + targetContext = Context.CURRENT_CONTEXT; + } else if (targetContextName.toUpperCase().equals(Context.INIT_CONTEXT.getName().toUpperCase())) { + targetContext = Context.INIT_CONTEXT; + } else { + targetContext = new Context(targetContextName); + } + GlobalException newException = (GlobalException) exceptionClass.newInstance(); + + newException.setTargetContext(targetContext); + newException.setSignalingContext(ex.getSignalingContext()); + newException.setSignalingParticipant(ex.getSignalingParticipant()); + +// //Time window of 10 seconds +// try { +// Thread.sleep(10000); +// } catch (InterruptedException ex1) { +// Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); +// } +// //Check concurrent exception existence +// if (concurrentExList.size() != 1) { +// applyConcurrentRecoveryRules(concurrentExList); +// } + + //Add the exception to the participants matched + if (index != -1) { + gmList.get(index).addException(newException); + } else if (affectedParticipants != null && affectedParticipants.length() != 0) { + if (affectedParticipants.toUpperCase().equals("FIRST")) { + gmList.get(0).addException(newException); + } else if (affectedParticipants.toUpperCase().equals("LAST")) { + gmList.get(gmList.size() - 1).addException(newException); + } else if (affectedParticipants.toUpperCase().equals("ALL")) { + for (GuardianMember gm : gmList) { + gm.addException(newException); } } - break; + } else { + for (GuardianMember gm : gmList) { + gm.addException(newException); + } } } } + } catch (XMLStreamException ex1) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); + } catch (InstantiationException ex1) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); + } catch (IllegalAccessException ex1) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); + } catch (ClassNotFoundException ex1) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); } - } catch (XMLStreamException ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); - } catch (Exception ex1) { - Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex1); } - } - - private List<GuardianMember> getMatchingParticipants(String regularExpression, GlobalExceptionInterface signaledException) { - List<GuardianMember> matchingParticipants = new LinkedList(); - if (regularExpression.toUpperCase().equals("SIGNALER")) { - for (GuardianMember gm : guardianList) { - if (gm.getParticipantIdentifier().equals(signaledException.getSignalingParticipant())) { - matchingParticipants.add(gm); - break; + private String affectedParticipantsTag() { + String affectedParticipants = null; + try { + while (reader.hasNext() && !(reader.isEndElement() && reader.getLocalName().equals("throw_exception"))) { + reader.next(); + //<affected_participants> + if (reader.isStartElement() && reader.getLocalName().equals("affected_participants")) { + affectedParticipants = reader.getElementText(); + } } + } catch (XMLStreamException ex) { + Logger.getLogger(GuardianGroupImpl.class.getName()).log(Level.SEVERE, null, ex); } - } else if (regularExpression.toUpperCase().equals("!SIGNALER")) { - for (GuardianMember gm : guardianList) { - if (!gm.getParticipantIdentifier().equals(signaledException.getSignalingParticipant())) { - matchingParticipants.add(gm); + + return affectedParticipants; + } + + private void applyConcurrentRecoveryRules(List<GlobalExceptionInterface> exceptionList) { + System.out.println("CONCURRENT RECOVERY RULES!"); + System.out.println("exceptions: "+exceptionList); + exceptionList.clear(); + } + + private List<GuardianMember> getMatchingParticipants(String regularExpression, GlobalExceptionInterface signaledException) { + List<GuardianMember> matchingParticipants = new LinkedList(); + + if (regularExpression.toUpperCase().equals("SIGNALER")) { + for (GuardianMember gm : guardianList) { + if (gm.getParticipantIdentifier().equals(signaledException.getSignalingParticipant())) { + matchingParticipants.add(gm); + break; + } + } + } else if (regularExpression.toUpperCase().equals("!SIGNALER")) { + for (GuardianMember gm : guardianList) { + if (!gm.getParticipantIdentifier().equals(signaledException.getSignalingParticipant())) { + matchingParticipants.add(gm); + } } - } - } else { - //Create an java regular expression - String re = createJavaRegularExpression(regularExpression); + } else { + //Create an java regular expression + String re = createJavaRegularExpression(regularExpression); - for (GuardianMember gm : guardianList) { - if (gm.getParticipantIdentifier().matches(re)) { - matchingParticipants.add(gm); + for (GuardianMember gm : guardianList) { + if (gm.getParticipantIdentifier().matches(re)) { + matchingParticipants.add(gm); + } } } - } - return matchingParticipants; - } + return matchingParticipants; + } - /* Valid expressions: *, <Context>.*, <Context>, *.<Context>, *.<Context>.*, - * *.<Context>.*.<Context>.*, <REG_EXP> || <REG_EXP> - * - * Invalid expressions: *.*, **, - * - * Not supported yet: !<Context>, !<Context> || <Context>, !(<Context> || <Context>) - */ - private String createJavaRegularExpression(String regularExpression) throws InvalidRegularExpression { - StringBuffer re = new StringBuffer(); + /* Valid expressions: *, <Context>.*, <Context>, *.<Context>, *.<Context>.*, + * *.<Context>.*.<Context>.*, <REG_EXP> || <REG_EXP> + * + * Invalid expressions: *.*, **, + * + * Not supported yet: !<Context>, !<Context> || <Context>, !(<Context> || <Context>) + */ + private String createJavaRegularExpression(String regularExpression) throws InvalidRegularExpression { + StringBuffer re = new StringBuffer(); - String[] splitedByBar = regularExpression.split("\\|\\|"); - String[] splitedByPeriod; + String[] splitedByBar = regularExpression.split("\\|\\|"); + String[] splitedByPeriod; - for (int i = 0; i < splitedByBar.length; i++) { + for (int i = 0; i < splitedByBar.length; i++) { - splitedByPeriod = splitedByBar[i].split("\\."); + splitedByPeriod = splitedByBar[i].split("\\."); - if (i > 0) { - re.append("|"); - } + if (i > 0) { + re.append("|"); + } - re.append("^"); - for (int j = 0; j < splitedByPeriod.length; j++) { + re.append("^"); + for (int j = 0; j < splitedByPeriod.length; j++) { - //* - if (splitedByPeriod[j].equals("*")) { + //* + if (splitedByPeriod[j].equals("*")) { - //Validate the regular expression - if (j + 1 != splitedByPeriod.length && splitedByPeriod[j + 1].equals("*")) { - throw new InvalidRegularExpression(); - } + //Validate the regular expression + if (j + 1 != splitedByPeriod.length && splitedByPeriod[j + 1].equals("*")) { + throw new InvalidRegularExpression(); + } - //* - if (splitedByPeriod.length == 1) { - re.append("(\\w+)"); - } //*.<CONTEXT> - - if (j == 0 && splitedByPeriod.length != 1) { - re.append("(\\w+\\"); - re.append(".)*"); - } //<CONTEXT>.* + //* + if (splitedByPeriod.length == 1) { + re.append("(\\w+)"); + } //*.<CONTEXT> + + if (j == 0 && splitedByPeriod.length != 1) { + re.append("(\\w+\\"); + re.append(".)*"); + } //<CONTEXT>.* + else { + re.append("(\\"); + re.append(".\\w+)*"); + } + } //<CONTEXT> else { - re.append("(\\"); - re.append(".\\w+)*"); - } - } //<CONTEXT> - else { // //Validate the regular expression // if (splitedByPeriod[j].matches("^(\\*)*$")) { // throw new RuntimeException("Invalid name for a context"); // } - //<CONTEXT> || <CONTEXT>.<CONTEXT>.<CONTEXT> || *.<CONTEXT> - if (splitedByPeriod.length == 1) { - re.append("(\\w+\\"); - re.append(".)*"); - } + //<CONTEXT> || <CONTEXT>.<CONTEXT>.<CONTEXT> || *.<CONTEXT> + if (splitedByPeriod.length == 1) { + re.append("(\\w+\\"); + re.append(".)*"); + } - if (j == 0 || j - 1 == 0) { - re.append("(" + splitedByPeriod[j] + ")"); - } else { - re.append("(\\." + splitedByPeriod[j] + ")"); + if (j == 0 || j - 1 == 0) { + re.append("(" + splitedByPeriod[j] + ")"); + } else { + re.append("(\\." + splitedByPeriod[j] + ")"); + } } } + re.append("$"); } - re.append("$"); + return re.toString(); } - return re.toString(); - } - - public boolean propagate(GlobalExceptionInterface ex) { - throw new UnsupportedOperationException("Not supported yet."); - } - - public void checkExceptionStatus() { - throw new UnsupportedOperationException("Not supported yet."); - } - - public boolean removeGuardianMember(GuardianMember guardianMember) { - return this.guardianList.remove(guardianMember); } } diff --git a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMember.java b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMember.java index 460a89ce2d..48dad22bff 100644 --- a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMember.java +++ b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMember.java @@ -33,4 +33,8 @@ public interface GuardianMember extends GuardianPrimitives { public String getParticipantIdentifier(); public void setUniqueParticipantID(int id); + + public int getParticipantState(); + + public void setParticipantState(int state); } diff --git a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberAdapter.java b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberAdapter.java index 8c0fd92b6e..b6cbfe8ec6 100644 --- a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberAdapter.java +++ b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberAdapter.java @@ -1,27 +1,25 @@ /* - * Copyright 2009 douglas. - * - * Licensed 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. - * under the License. + * 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.tuscany.sca.guardian; import javax.xml.bind.annotation.adapters.XmlAdapter; -/** - * - * @author douglas - */ public class GuardianMemberAdapter extends XmlAdapter<GuardianMemberImpl, GuardianMember> { @Override diff --git a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberImpl.java b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberImpl.java index 682a6d8e1b..ec6ecb609c 100644 --- a/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberImpl.java +++ b/sandbox/dougsleite/guardian-model/src/main/java/org/apache/tuscany/sca/guardian/GuardianMemberImpl.java @@ -34,6 +34,7 @@ import org.osoa.sca.annotations.Service; @Scope("COMPOSITE") public class GuardianMemberImpl implements GuardianMember { + private int participantState; private Stack<Context> contextList; private BlockingInterface service; private Queue<GlobalException> exceptionQueue; @@ -45,6 +46,7 @@ public class GuardianMemberImpl implements GuardianMember { contextList = new Stack<Context>(); contextList.add(Context.INIT_CONTEXT); exceptionQueue = new LinkedList<GlobalException>(); + participantState = GuardianGroup.NORMAL_PARTICIPANT_STATE; } @Init @@ -78,7 +80,10 @@ public class GuardianMemberImpl implements GuardianMember { contextList.push(context); if (contextList.size() == 2) { - gthrow(new JoinException(), null); + JoinException ex = new JoinException(); + ex.setSignalingContext(context); + ex.setSignalingParticipant(getParticipantIdentifier()); + gthrow(ex, null); } } @@ -93,30 +98,31 @@ public class GuardianMemberImpl implements GuardianMember { //If participantList is null then signal to ALL participants public void gthrow(GlobalExceptionInterface ex, List<String> participantList) { //1)Block the participant until raise an exception - if (!service.isBlocked()) { - service.block(); - if (ex != null) { - //Set the exception's parameters - ex.setSignalingContext(getCurrentContext()); - ex.setSignalingParticipant(getParticipantIdentifier()); + if (!(ex instanceof SuspendException)) { + //Set the exception's parameters + ex.setSignalingContext(getCurrentContext()); + ex.setSignalingParticipant(getParticipantIdentifier()); - guardianGroup.gthrow(ex, participantList); - } + guardianGroup.gthrow(ex, participantList); + } else { + /*if (service instanceof BlockingInterface && !service.isBlocked()) { + service.block(); + }*/ + participantState = GuardianGroup.SUSPENDED_PARTICIPANT_STATE; } - - //*Is here the best place to receive such kind of msg? - // - //2B)When receive exception_msg from GuardianGroup do - // if participant is not suspended then suspend it - // if participant supports interrupts then - // interrupt it, add SuspendException in the exception_queue, and invoke checkExceptionStatus - // else invoke checkExceptionStatus periodically - // - //4)Once ALL required participants are SUSPENDED (suspended point), invoke the defined Recovery Rules - // 4.1) recovery_rules < signaled exceptions + context_list of all participant > target context + exception to raise - // 4.2) raise the resolved exception in each participant -> it goes to the exception_queue + //*Is here the best place to receive such kind of msg? + // + //2B)When receive exception_msg from GuardianGroup do + // if participant is not suspended then suspend it + // if participant supports interrupts then + // interrupt it, add SuspendException in the exception_queue, and invoke checkExceptionStatus + // else invoke checkExceptionStatus periodically + // + //4)Once ALL required participants are SUSPENDED (suspended point), invoke the defined Recovery Rules + // 4.1) recovery_rules < signaled exceptions + context_list of all participant > target context + exception to raise + // 4.2) raise the resolved exception in each participant -> it goes to the exception_queue } @@ -131,62 +137,34 @@ public class GuardianMemberImpl implements GuardianMember { // else if first element on the exception_queue is SuspendException then // the method blocks until the next exception is received. The method raises the first non-SuspendException in the queue + //Blocks until the state be diferent the SUSPENDED_STATE + while (participantState == GuardianGroup.SUSPENDED_PARTICIPANT_STATE) { + try { + Thread.sleep(5000); + } catch (InterruptedException ex) { + Logger.getLogger(GuardianMemberImpl.class.getName()).log(Level.SEVERE, null, ex); + } + } + GlobalException exc; if ((exc = exceptionQueue.peek()) == null) { System.out.println(getParticipantIdentifier() + "#No exception on exception queue"); return; - } else { - while ((exc = exceptionQueue.peek()) instanceof SuspendException) { - try { - Thread.sleep(5000); - } catch (InterruptedException ex) { - Logger.getLogger(GuardianMemberImpl.class.getName()).log(Level.SEVERE, null, ex); - } - exceptionQueue.poll(); - } + } - service.unblock(); - -// if (exc != null) { -// System.out.println("\n" + getParticipantIdentifier() + "#"); -// System.out.println("Exc: " + exc); -// System.out.println("TargetContext: " + exc.getTargetContext().getName()); -// System.out.println("Signaling Participant: " + exc.getSignalingParticipant()); -// System.out.println("Current Context: " + getCurrentContext().getName()); -// System.out.println("Equals: " + exc.getTargetContext().equals(getCurrentContext()) + "\n"); -// } - - //Check if ex.targetContext() matches the participant id - //Eg. ex.targetContext(): Main and participant id: Init.Main.Backup -> should thrown the exception - //Test if the exception should be thrown in the target context - if (exc != null) { - for (Context c : contextList) { - if (exc.getTargetContext().equals(c) && (c.equals(Context.INIT_CONTEXT) || c.getExceptionList().contains(exc.getClass()))) { - System.out.println(getParticipantIdentifier() + "#Returning an exception"); - exceptionQueue.poll(); - throw exc; - } - } + //Check if ex.targetContext() matches the participant id + //Eg. ex.targetContext(): Main and participant id: Init.Main.Backup -> should thrown the exception + //Test if the exception should be thrown in the target context + for (Context c : contextList) { + if (exc.getTargetContext().equals(c) && (c.equals(Context.INIT_CONTEXT) || c.getExceptionList().contains(exc.getClass()))) { + System.out.println(getParticipantIdentifier() + "#Returning an exception"); + exceptionQueue.poll(); + throw exc; } -// String[] contexts = getParticipantIdentifier().split("\\."); -// if (exc != null) { -// for (int i = contexts.length - 1; i > 0; i--) { -// if (exc.getTargetContext().equals(new Context(contexts[i]))) { -// -// //Test if the exception should be thrown in the target context -// -// -// System.out.println(getParticipantIdentifier() + "#Returning an exception"); -// exceptionQueue.poll(); -// throw exc; -// } -// } -// } - - return; } + return; } public String getParticipantIdentifier() { @@ -207,4 +185,12 @@ public class GuardianMemberImpl implements GuardianMember { public void removeService() { this.service = null; } + + public int getParticipantState() { + return participantState; + } + + public void setParticipantState(int state) { + this.participantState = state; + } } diff --git a/sandbox/dougsleite/guardian-model/src/main/resources/definitions.xml b/sandbox/dougsleite/guardian-model/src/main/resources/definitions.xml new file mode 100644 index 0000000000..c08d08cdfa --- /dev/null +++ b/sandbox/dougsleite/guardian-model/src/main/resources/definitions.xml @@ -0,0 +1,66 @@ +<?xml version="1.0" encoding="ASCII"?> +<!-- + * 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. +--> +<sca:definitions xmlns="http://www.osoa.org/xmlns/sca/1.0" + targetNamespace="http://primarybackup" + xmlns:sca="http://www.osoa.org/xmlns/sca/1.0" + > + + <sca:policySet name="recoveryRulesPolicy" + provides="recoveryRules" + appliesTo="sca:implementation.java"> + + <recovery_rules> + + <rule name="Rule1" signaled_exception="org.apache.tuscany.sca.guardian.JoinException"> + + <participant match="SIGNALER"> + <throw_exception class="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.PrimaryExistsException" target_context="MAIN" min_participant_joined="2"/> + </participant> + + <participant match="!SIGNALER"> + <throw_exception class="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.BackupJoinedException" target_context="PRIMARY" min_participant_joined="2"/> + </participant> + </rule> + + <rule name="Rule2" signaled_exception="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.PrimaryFailedException"> + + <participant match="*.PRIMARY"> + <throw_exception class="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.PrimaryFailedException" target_context="INIT_CONTEXT"/> + </participant> + + <participant match="*.BACKUP"> + <throw_exception class="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.PrimaryFailedException" target_context="MAIN"/> + </participant> + </rule> + + <rule name="Rule3" signaled_exception="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.BackupFailedException"> + + <participant match="*.PRIMARY"> + <throw_exception class="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.BackupFailedException" target_context="PRIMARY"/> + </participant> + + <participant match="*.BACKUP"> + <throw_exception class="org.apache.tuscany.sca.guardian.itests.primaryBackup.common.BackupFailedException" target_context="INIT_CONTEXT"/> + </participant> + </rule> + + </recovery_rules> + </sca:policySet> +</sca:definitions>
\ No newline at end of file diff --git a/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/common/NodeImpl.java b/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/common/NodeImpl.java index 5ff80e3472..00880352b8 100644 --- a/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/common/NodeImpl.java +++ b/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/common/NodeImpl.java @@ -32,7 +32,8 @@ import org.osoa.sca.annotations.Destroy; import org.osoa.sca.annotations.OneWay; @Scope("COMPOSITE") -public class NodeImpl implements Node, TestInterface { +//public class NodeImpl implements Node, TestInterface { +public class NodeImpl implements Node { private static int PRIMARY = 0; private static int BACKUP = 1; @@ -49,6 +50,7 @@ public class NodeImpl implements Node, TestInterface { public List<Node> nodeList; private boolean forcePSFException; private boolean forceAUFException; + private int upcount; public NodeImpl() { @@ -91,6 +93,9 @@ public class NodeImpl implements Node, TestInterface { role = PRIMARY; while (true) { + + //blockingCheck(); + try { System.out.println(pID + "#Main context: "); sleep(pID + "#Sleeping at main context...", 4000); @@ -142,37 +147,17 @@ public class NodeImpl implements Node, TestInterface { } } - public String getID() { - return gm.getParticipantIdentifier(); - } - - private void sleep(String msg, int millis) { - try { - System.out.println(msg); - Thread.sleep(millis); - } catch (InterruptedException ex) { - Logger.getLogger(NodeImpl.class.getName()).log(Level.SEVERE, null, ex); - } - } - - private boolean isThereBackupAvailable() { - for (Node n : nodeList) { - if (!n.isBlocked()) { - return true; - } - } - return false; - } - private void primaryService() { boolean backupAvailable = isThereBackupAvailable(); - System.out.println("Backup available?: " + backupAvailable); - int upcount = 1; + + upcount = 1; while (true) { gm.enableContext(primaryContext); + //blockingCheck(); + try { System.out.println(pID + "#Primary context: "); sleep(pID + "#Sleeping at primary context...", 4000); @@ -187,15 +172,14 @@ public class NodeImpl implements Node, TestInterface { } if (backupAvailable) { - for (Node n : nodeList) { - if (!n.isBlocked()) { - n.sendUpdate("Update " + upcount); - } + + if (!updateBackups()) { + backupAvailable = isThereBackupAvailable(); } - upcount++; + } else { System.out.println(pID + "#No backup available to send updates!"); - backupAvailable = isThereBackupAvailable(); + //backupAvailable = isThereBackupAvailable(); } //send the reply to the client System.out.println(pID + "#Sending the reply to the client..."); @@ -216,11 +200,29 @@ public class NodeImpl implements Node, TestInterface { } } + private boolean updateBackups() { + boolean flag = false; + + for (Node n : nodeList) { + if (!n.isBlocked()) { + n.sendUpdate("Update " + upcount); + flag = true; + } + } + if (flag) { + upcount++; + } + + return flag; + } + private void backupService() { while (true) { gm.enableContext(backupContext); + //blockingCheck(); + try { System.out.println(pID + "#Backup context: "); sleep(pID + "#Sleeping at backup service", 4000); @@ -241,31 +243,53 @@ public class NodeImpl implements Node, TestInterface { } } - //FIXME - It is not working asynchronously - //@OneWay + public String getID() { + return gm.getParticipantIdentifier(); + } + + private void sleep(String msg, int millis) { + try { + System.out.println(msg); + Thread.sleep(millis); + } catch (InterruptedException ex) { + Logger.getLogger(NodeImpl.class.getName()).log(Level.SEVERE, null, ex); + } + } + + private boolean isThereBackupAvailable() { + for (Node n : nodeList) { + if (!n.isBlocked()) { + return true; + } + } + return false; + } + public void block() { - System.out.println(pID + "#Participant blocked!"); isBlocked = true; - -// while (isBlocked) { -// try { -// Thread.sleep(5000); -// } catch (InterruptedException ex) { -// Logger.getLogger(ComponentImpl.class.getName()).log(Level.SEVERE, null, ex); -// } -// } } public boolean isBlocked() { return isBlocked; } - //@OneWay public void unblock() { - System.out.println(pID + "#Participant unblocked!"); isBlocked = false; } + private void blockingCheck() { + System.out.println(pID + "#Participant blocked!"); + while (isBlocked) { + System.out.println("isBlocked: " + isBlocked); + try { + Thread.sleep(5000); + } catch (InterruptedException ex) { + Logger.getLogger(NodeImpl.class.getName()).log(Level.SEVERE, null, ex); + } + } + System.out.println(pID + "#Participant unblocked!"); + } + public void sendUpdate(String update) { System.out.println(pID + "#Receiving updates from primary: " + update); updates.offer(update); diff --git a/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/simple/Launch3.java b/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/simple/Launch3.java deleted file mode 100644 index 780a8df464..0000000000 --- a/sandbox/dougsleite/guardian-model/src/test/java/org/apache/tuscany/sca/guardian/itests/primaryBackup/simple/Launch3.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Copyright 2009 douglas. - * - * Licensed 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. - * under the License. - */ -package org.apache.tuscany.sca.guardian.itests.primaryBackup.simple; - -import java.io.IOException; -import org.apache.tuscany.sca.guardian.GuardianGroup; -import org.apache.tuscany.sca.guardian.GuardianMember; -import org.apache.tuscany.sca.guardian.GuardianMemberImpl; -import org.apache.tuscany.sca.host.embedded.SCADomain; - -/** - * - * @author douglas - */ -public class Launch3 { - - public static void main(String... args) throws IOException { - SCADomain scaDomain = SCADomain.newInstance("primarybackup-ws.composite"); - - System.out.println("Testing..."); - GuardianGroup c = scaDomain.getService(GuardianGroup.class, "GuardianGroupComponent"); - - GuardianMember gm = new GuardianMemberImpl(); - c.addGuardianMember(gm); - //c.enableContext(Context.INIT_CONTEXT); - - System.in.read(); - -// System.out.println("Starting participat1..."); -// Node c = scaDomain.getService(Node.class, "Participant1"); -// c.execute(); -// -// System.in.read(); -// -// System.out.println("Starting participant2..."); -// Node c2 = scaDomain.getService(Node.class, "Participant2"); -// c2.execute(); -// -// System.in.read(); -// -// System.out.println("Forcing exception ocurrence at participant1..."); -// TestInterface t = scaDomain.getService(TestInterface.class, "Participant1"); -// t.forcePrimaryServiceFailureException(); -// -// System.in.read(); - - scaDomain.close(); - } -} |