in opticalUtils.py:

General logic fixes for emulating multi-domain networks

Change-Id: I58e487e0b663a6b64e99d93d6fa5cea6afe86aac

@@ -58,7 +58,7 @@ import os
 from time import sleep
 from time import sleep
 import urllib2
 import urllib2
 
 
-from mininet.node import Switch, RemoteController
+from mininet.node import Switch, OVSSwitch, RemoteController
 from mininet.topo import Topo
 from mininet.topo import Topo
 from mininet.util import quietRun
 from mininet.util import quietRun
 from mininet.net import Mininet
 from mininet.net import Mininet
@@ -357,7 +357,13 @@ class LINCSwitch(OpticalSwitch):
 
 
     @staticmethod
     @staticmethod
     def bootOE(net):
     def bootOE(net):
-        "Start the LINC optical emulator within a mininet instance"
+        """
+        Start the LINC optical emulator within a mininet instance
+
+        This involves 1. converting the information stored in Linc* to configs
+        for both LINC and the network config system, 2. starting Linc, 3. connecting
+        cross-connects, and finally pushing the network configs to ONOS.
+        """
         LINCSwitch.opticalJSON = {}
         LINCSwitch.opticalJSON = {}
         linkConfig = []
         linkConfig = []
         devices = []
         devices = []
@@ -367,7 +373,7 @@ class LINCSwitch(OpticalSwitch):
         for switch in net.switches:
         for switch in net.switches:
             if isinstance(switch, OpticalSwitch):
             if isinstance(switch, OpticalSwitch):
                 devices.append(switch.json())
                 devices.append(switch.json())
-            else:
+            elif isinstance(switch, OVSSwitch):
                 devices.append(LINCSwitch.switchJSON(switch))
                 devices.append(LINCSwitch.switchJSON(switch))
         LINCSwitch.opticalJSON[ 'devices' ] = devices
         LINCSwitch.opticalJSON[ 'devices' ] = devices
 
 
@@ -450,17 +456,20 @@ class LINCSwitch(OpticalSwitch):
         opener = urllib2.build_opener(handler)
         opener = urllib2.build_opener(handler)
         opener.open(url)
         opener.open(url)
         urllib2.install_opener(opener)
         urllib2.install_opener(opener)
+        # focus on just checking the state of devices we're interested in
+        devlist =  map( lambda x: x['uri'], devices )
         while True:
         while True:
             response = json.load(urllib2.urlopen(url))
             response = json.load(urllib2.urlopen(url))
             devs = response.get('devices')
             devs = response.get('devices')
 
 
-            # Wait for all devices to be registered
-            if (len(devices) != len(devs)):
+            # Wait for all devices to be registered. There is a chance that this is only a subgraph.
+            if (len(devices) > len(devs)):
                 continue
                 continue
 
 
             # Wait for all devices to available
             # Wait for all devices to available
             available = True
             available = True
             for d in devs:
             for d in devs:
+                if d['id'] in devlist:
                     available &= d['available']
                     available &= d['available']
             if available:
             if available:
                 break
                 break
@@ -615,9 +624,11 @@ class LINCSwitch(OpticalSwitch):
             if isinstance(link, LINCLink):
             if isinstance(link, LINCLink):
                 if link.annotations[ 'optical.type' ] == 'cross-connect':
                 if link.annotations[ 'optical.type' ] == 'cross-connect':
                     tapCount += 1
                     tapCount += 1
-
         while True:
         while True:
-            if str(tapCount) == quietRun('ip addr | grep tap | wc -l', shell=True).strip('\n'):
+            # tapCount can be less than the actual number of taps if the optical network
+            # is a subgraph of a larger multidomain network.
+            tapNum = int(quietRun('ip addr | grep tap | wc -l', shell=True).strip('\n'))
+            if tapCount <= tapNum:
                 return True
                 return True
             if timeout:
             if timeout:
                 if time >= TIMEOUT:
                 if time >= TIMEOUT: