diff options
Diffstat (limited to 'plugins/org.eclipse.etrice.abstractexec.behavior/src/org/eclipse/etrice/abstractexec/behavior/ActiveRules.java')
| -rw-r--r-- | plugins/org.eclipse.etrice.abstractexec.behavior/src/org/eclipse/etrice/abstractexec/behavior/ActiveRules.java | 152 |
1 files changed, 152 insertions, 0 deletions
diff --git a/plugins/org.eclipse.etrice.abstractexec.behavior/src/org/eclipse/etrice/abstractexec/behavior/ActiveRules.java b/plugins/org.eclipse.etrice.abstractexec.behavior/src/org/eclipse/etrice/abstractexec/behavior/ActiveRules.java new file mode 100644 index 000000000..72366bc69 --- /dev/null +++ b/plugins/org.eclipse.etrice.abstractexec.behavior/src/org/eclipse/etrice/abstractexec/behavior/ActiveRules.java @@ -0,0 +1,152 @@ +/*******************************************************************************
+ * This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * CONTRIBUTORS:
+ * Rohit Agrawal (initial contribution)
+ *
+ *******************************************************************************/
+
+package org.eclipse.etrice.abstractexec.behavior;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
+
+import org.eclipse.emf.common.util.BasicEList;
+import org.eclipse.emf.common.util.EList;
+import org.eclipse.etrice.core.room.*;
+
+public class ActiveRules {
+ private HashMap<InterfaceItem, EList<SemanticsRule>> rules ;
+
+ public ActiveRules()
+ {
+ rules= new HashMap<InterfaceItem, EList<SemanticsRule>>();
+ }
+ public ActiveRules(HashMap<InterfaceItem,EList<SemanticsRule>> r)
+ {
+ rules = r;
+ }
+ //checks for currently active rules against a message list and modifies the
+ //rules which can be merged with the destination node
+ //also returns a boolean to determine if anything was changed so as to determine the
+ //condition for adding to the queue
+ public boolean checkRules(List<MessageFromIf> msgList )
+ {
+ System.out.println("Entering checkRules");
+ System.out.println("Msgs contained in list : ");
+ for(MessageFromIf msg : msgList)
+ {
+ System.out.println("Msgs : " + msg.getMessage().getName());
+ }
+ boolean changed = false; //to determine if there was any change in rule
+ //keeps a record of the ports contained in the msgList
+ Set<InterfaceItem> portList = new HashSet<InterfaceItem>();
+ HashMap<InterfaceItem, EList<SemanticsRule>> ruleChange = new HashMap<InterfaceItem, EList<SemanticsRule>>();
+ for(MessageFromIf msg : msgList)
+ {
+ InterfaceItem port = msg.getFrom();
+ portList.add(port);
+ EList<SemanticsRule> followUps = this.getFollowingRules(msg);
+
+ if(followUps.size()>0)
+ {
+ System.out.println("Founded follow up rules for msg : " + msg.getMessage().getName());
+ changed = true;
+ ruleChange.put(port, followUps);
+ }
+ else
+ {
+ System.out.println("Didn't find any follow up for : " + msg.getMessage().getName());
+ }
+
+ }
+ //check also if there is a port in the ActiveRules port set which doesn't send any message
+ //in the action code
+ //since the active rules of that port would need to be merged without change
+ for(InterfaceItem ports : this.rules.keySet())
+ {
+ if(!portList.contains(ports))
+ {
+ changed = true;
+ ruleChange.put(ports, this.rules.get(ports));
+ }
+ }
+
+ this.rules = ruleChange;
+ System.out.println("Exiting checkRules");
+ return changed;
+
+ }
+
+ //merges the rules with the destination active rules
+ public void merge(ActiveRules ar)
+ {
+ for(InterfaceItem port : this.rules.keySet())
+ {
+ this.rules.get(port).addAll(ar.rules.get(port));
+ }
+ }
+ public ActiveRules createCopy()
+ {
+ HashMap<InterfaceItem, EList<SemanticsRule>> newRules= new HashMap<InterfaceItem, EList<SemanticsRule>>();
+ for(InterfaceItem port : this.rules.keySet())
+ {
+ EList<SemanticsRule> list = new BasicEList<SemanticsRule>(this.rules.get(port));
+ newRules.put(port, list);
+ }
+ return new ActiveRules(newRules);
+ }
+ //advances the pointer to the follow up messages if a message is found matching the rule
+ private EList<SemanticsRule> getFollowingRules(MessageFromIf msg)
+ {
+ System.out.println("Entering getFollowingRules");
+
+ EList<SemanticsRule> follow = new BasicEList<SemanticsRule>();
+ List<SemanticsRule> toRemove = new ArrayList<SemanticsRule>();
+
+ if(this.rules.containsKey(msg.getFrom()))
+ {
+ for(SemanticsRule rule : this.rules.get(msg.getFrom()))
+ {
+ if(rule.getMsg()== msg.getMessage())
+ {
+ follow.addAll(rule.getFollowUps());
+ //added for removal so it can be replaced the followUp rules
+ toRemove.add(rule);
+ }
+ else
+ {
+ //add the rule for removing since it is violated by the current msg
+ toRemove.add(rule);
+ }
+ }
+ }
+ //remove the discarded rules now
+ for(SemanticsRule rule : toRemove)
+ {
+ this.rules.get(msg.getFrom()).remove(rule);
+ }
+ //this basically just adds the advanced rules back to the ruleSet
+ this.rules.get(msg.getFrom()).addAll(follow);
+ System.out.println("Exiting getFollowingRules");
+ return follow;
+ }
+ public void print()
+ {
+ for(InterfaceItem port : rules.keySet())
+ {
+ System.out.print("Port : " + port.getName() + " : rules : " );
+ for(SemanticsRule rule : rules.get(port))
+ {
+ System.out.println(rule.getMsg().getName());
+ }
+ }
+ }
+}
|