+++ /dev/null
-package example.symphony;\r
-\r
-import java.util.Collection;\r
-import java.util.Collections;\r
-import java.util.HashSet;\r
-import java.util.LinkedList;\r
-import java.util.logging.Level;\r
-import java.util.logging.Logger;\r
-\r
-import example.symphony.SymphonyProtocol.BootstrapStatus;\r
-import peersim.config.Configuration;\r
-import peersim.core.Control;\r
-import peersim.core.Network;\r
-import peersim.core.Node;\r
-\r
-/**\r
- *\r
- * @author Andrea Esposito <and1989@gmail.com>\r
- */\r
-public class RingRouteTest implements Control, Handler {\r
-\r
- private static final String PAR_SYMPHONY = "symphony";\r
- private static final String PAR_STARTNODE = "startnode";\r
- private final int symphonyID;\r
- private final int indexStartNode;\r
- private Node start;\r
- private boolean finished;\r
- private boolean flagTimeout;\r
- private HashSet<Node> antiLoopSet;\r
-\r
- public RingRouteTest(String prefix) {\r
- symphonyID = Configuration.getPid(prefix + "." + PAR_SYMPHONY);\r
- indexStartNode = Configuration.getInt(prefix + "." + PAR_STARTNODE, 0);\r
-\r
- finished = true;\r
- flagTimeout = false;\r
- antiLoopSet = new HashSet<Node>();\r
- }\r
-\r
- public boolean execute() {\r
-\r
- if (!finished && flagTimeout) {\r
-\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.WARNING, "Sent msg but no aswer. Timeout. Ring Route Test terminated for Timeout.");\r
-\r
- finished = true;\r
- flagTimeout = false;\r
- }\r
-\r
- if (finished) {\r
-\r
- flagTimeout = true;\r
- antiLoopSet.clear();\r
-\r
- int indexRealStartNode = indexStartNode;\r
- Node realStartNode = Network.get(indexStartNode);\r
- SymphonyProtocol symphony = (SymphonyProtocol) realStartNode.getProtocol(symphonyID);\r
-\r
- while (!symphony.isBootstrapped() || !realStartNode.isUp()) {\r
- indexRealStartNode = (indexRealStartNode + 1) % Network.size();\r
- realStartNode = Network.get(indexRealStartNode);\r
- symphony = (SymphonyProtocol) realStartNode.getProtocol(symphonyID);\r
-\r
- if (indexRealStartNode == indexStartNode) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.WARNING, "No ONLINE nodes. The ring is vanished. Ring Route Terminated.");\r
- finished = true;\r
- flagTimeout = false;\r
- return false;\r
- }\r
- }\r
-\r
- start = realStartNode;\r
- finished = false;\r
-\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.INFO, "RingRoute started.");\r
-\r
- doRoute(start, true);\r
- }\r
-\r
- return false;\r
- }\r
-\r
- public void handle(SymphonyProtocol symphony, Tuple<Node, Double> tuple) {\r
-\r
- if (tuple == null) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.SEVERE, "FAIL RING ROUTING");\r
- finished = true;\r
- return;\r
- }\r
-\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.FINER, symphony.getIdentifier() + " source find the manager of " + tuple.y + " and it is " + ((SymphonyProtocol) tuple.x.getProtocol(symphonyID)).getIdentifier());\r
-\r
- doRoute(tuple.x, false);\r
- }\r
-\r
- private void doRoute(Node node, boolean firstTime) {\r
-\r
- SymphonyProtocol symphonyStartNode = (SymphonyProtocol) start.getProtocol(symphonyID);\r
-\r
- if (!symphonyStartNode.isBootstrapped()) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.INFO, "The node i started from left. Ring Route Terminated.");\r
- finished = true;\r
- return;\r
- }\r
-\r
- if (!firstTime && node.equals(start)) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.INFO, "RingRoute Terminated");\r
- finished = true;\r
- return;\r
- }\r
-\r
- if (antiLoopSet.contains(node)) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.INFO, "Not able to reach the node that i started from. Ring Route Terminated.");\r
- finished = true;\r
- return;\r
- } else {\r
- antiLoopSet.add(node);\r
- }\r
-\r
- SymphonyProtocol symphony = (SymphonyProtocol) node.getProtocol(symphonyID);\r
- AdapterSymphonyNodeComparator adapterSymphonyNodeComparator = new AdapterSymphonyNodeComparator(new SymphonyNodeComparator(symphonyID, node));\r
-\r
- Collection<Tuple<Node, BootstrapStatus>> collection = (Collection<Tuple<Node, BootstrapStatus>>) symphony.leftShortRangeLinks.clone();\r
- LinkedList<Tuple<Node, BootstrapStatus>> list = new LinkedList<Tuple<Node, BootstrapStatus>>(collection);\r
- Collections.sort(list, adapterSymphonyNodeComparator);\r
-\r
- Node targetNode = null;\r
- for (Tuple<Node, BootstrapStatus> tuple : list) {\r
- if (tuple.y == BootstrapStatus.ONLINE) {\r
- targetNode = tuple.x;\r
- break;\r
- }\r
- }\r
-\r
- if (targetNode == null || !targetNode.isUp()) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.WARNING, "Terminated Ring Route but not done completely");\r
- finished = true;\r
- return;\r
- }\r
-\r
- SymphonyProtocol symphonyTarget = (SymphonyProtocol) targetNode.getProtocol(symphonyID);\r
- try {\r
- symphony.route(node, symphonyTarget.getIdentifier(), this);\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.FINEST, "Ring from: " + symphony.getIdentifier() + " to " + symphonyTarget.getIdentifier());\r
- } catch (RoutingException ex) {\r
- Logger.getLogger(RingRouteTest.class.getName()).log(Level.WARNING, "Finito AnelloRoute MA NON FATTO TUTTO");\r
- finished = true;\r
- }\r
- }\r
-}\r
