Control plane

.gitignore

@@ -8,3 +8,9 @@ lib/python*
 \.pydevproject
 
 \.project
+.idea/workspace.xml
+.idea/vcs.xml
+.idea/modules.xml
+.idea/misc.xml
+.idea/encodings.xml
+.idea/CSCI_466_Programming_Assignments.iml

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>CSCI_466_PAs</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.python.pydev.PyDevBuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.python.pydev.pythonNature</nature>
+	</natures>
+</projectDescription>

.pydevproject

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<?eclipse-pydev version="1.0"?><pydev_project>
+<pydev_pathproperty name="org.python.pydev.PROJECT_SOURCE_PATH">
+<path>/${PROJECT_DIR_NAME}</path>
+</pydev_pathproperty>
+<pydev_property name="org.python.pydev.PYTHON_PROJECT_VERSION">python 3.6</pydev_property>
+<pydev_property name="org.python.pydev.PYTHON_PROJECT_INTERPRETER">python37</pydev_property>
+</pydev_project>

.settings/org.eclipse.core.resources.prefs

@@ -0,0 +1,3 @@
+eclipse.preferences.version=1
+encoding/network.py=UTF-8
+encoding/network_1.py=UTF-8

link_2.py

@@ -0,0 +1,75 @@
+import queue
+import threading
+
+## An abstraction of a link between router interfaces
+class Link:
+
+    ## creates a link between two objects by looking up and linking node interfaces.
+    # @param node_1: node from which data will be transfered
+    # @param node_1_intf: number of the interface on that node
+    # @param node_2: node to which data will be transfered
+    # @param node_2_intf: number of the interface on that node
+    def __init__(self, node_1, node_1_intf, node_2, node_2_intf):
+        self.node_1 = node_1
+        self.node_1_intf = node_1_intf
+        self.node_2 = node_2
+        self.node_2_intf = node_2_intf
+        print('Created link %s' % self.__str__())
+
+    ## called when printing the object
+    def __str__(self):
+        return 'Link %s-%d - %s-%d' % (self.node_1, self.node_1_intf, self.node_2, self.node_2_intf)
+
+    ##transmit a packet between interfaces in each direction
+    def tx_pkt(self):
+        for (node_a, node_a_intf, node_b, node_b_intf) in \
+        [(self.node_1, self.node_1_intf, self.node_2, self.node_2_intf), 
+         (self.node_2, self.node_2_intf, self.node_1, self.node_1_intf)]: 
+            intf_a = node_a.intf_L[node_a_intf]
+            intf_b = node_b.intf_L[node_b_intf]
+            pkt_S = intf_a.get('out')
+            if pkt_S is None:
+                continue #continue if no packet to transfer
+            #otherwise transmit the packet
+            try:
+                intf_b.put(pkt_S, 'in')
+                print('%s: direction %s-%s -> %s-%s: transmitting packet "%s"' % \
+                    (self, node_a, node_a_intf, node_b, node_b_intf, pkt_S))
+            except queue.Full:
+                print('%s: direction %s-%s -> %s-%s: packet lost' % \
+                    (self, node_a, node_a_intf, node_b, node_b_intf))
+                pass
+
+
+## An abstraction of the link layer
+class LinkLayer:
+
+    def __init__(self):
+        ## list of links in the network
+        self.link_L = []
+        self.stop = False #for thread termination
+
+    ## called when printing the object
+    def __str__(self):
+        return 'Network'
+
+    ##add a Link to the network
+    def add_link(self, link):
+        self.link_L.append(link)
+
+    ##transfer a packet across all links
+    def transfer(self):
+        for link in self.link_L:
+            link.tx_pkt()
+
+    ## thread target for the network to keep transmitting data across links
+    def run(self):
+        print (threading.currentThread().getName() + ': Starting')
+        while True:
+            #transfer one packet on all the links
+            self.transfer()
+            #terminate
+            if self.stop:
+                print (threading.currentThread().getName() + ': Ending')
+                return
+

link_3.py

@@ -0,0 +1,75 @@
+import queue
+import threading
+
+## An abstraction of a link between router interfaces
+class Link:
+
+    ## creates a link between two objects by looking up and linking node interfaces.
+    # @param node_1: node from which data will be transfered
+    # @param node_1_intf: number of the interface on that node
+    # @param node_2: node to which data will be transfered
+    # @param node_2_intf: number of the interface on that node
+    def __init__(self, node_1, node_1_intf, node_2, node_2_intf):
+        self.node_1 = node_1
+        self.node_1_intf = node_1_intf
+        self.node_2 = node_2
+        self.node_2_intf = node_2_intf
+        print('Created link %s' % self.__str__())
+
+    ## called when printing the object
+    def __str__(self):
+        return 'Link %s-%d - %s-%d' % (self.node_1, self.node_1_intf, self.node_2, self.node_2_intf)
+
+    ##transmit a packet between interfaces in each direction
+    def tx_pkt(self):
+        for (node_a, node_a_intf, node_b, node_b_intf) in \
+        [(self.node_1, self.node_1_intf, self.node_2, self.node_2_intf), 
+         (self.node_2, self.node_2_intf, self.node_1, self.node_1_intf)]: 
+            intf_a = node_a.intf_L[node_a_intf]
+            intf_b = node_b.intf_L[node_b_intf]
+            pkt_S = intf_a.get('out')
+            if pkt_S is None:
+                continue #continue if no packet to transfer
+            #otherwise transmit the packet
+            try:
+                intf_b.put(pkt_S, 'in')
+                print('%s: direction %s-%s -> %s-%s: transmitting packet "%s"' % \
+                    (self, node_a, node_a_intf, node_b, node_b_intf, pkt_S))
+            except queue.Full:
+                print('%s: direction %s-%s -> %s-%s: packet lost' % \
+                    (self, node_a, node_a_intf, node_b, node_b_intf))
+                pass
+
+
+## An abstraction of the link layer
+class LinkLayer:
+
+    def __init__(self):
+        ## list of links in the network
+        self.link_L = []
+        self.stop = False #for thread termination
+
+    ## called when printing the object
+    def __str__(self):
+        return 'Network'
+
+    ##add a Link to the network
+    def add_link(self, link):
+        self.link_L.append(link)
+
+    ##transfer a packet across all links
+    def transfer(self):
+        for link in self.link_L:
+            link.tx_pkt()
+
+    ## thread target for the network to keep transmitting data across links
+    def run(self):
+        print (threading.currentThread().getName() + ': Starting')
+        while True:
+            #transfer one packet on all the links
+            self.transfer()
+            #terminate
+            if self.stop:
+                print (threading.currentThread().getName() + ': Ending')
+                return
+