mpm: udp xport: Bind SID addr 0 and 1 to respective SFP ports

Reviewed-by: Trung Tran <trung.tran@ettus.com>

1 files changed, 11 insertions, 2 deletions

diff --git a/mpm/python/usrp_mpm/xports/xportmgr_udp.py b/mpm/python/usrp_mpm/xports/xportmgr_udp.py
index 9ae76a610..9e1c1d40a 100644
--- a/mpm/python/usrp_mpm/xports/xportmgr_udp.py
+++ b/mpm/python/usrp_mpm/xports/xportmgr_udp.py
@@ -28,6 +28,10 @@ class XportMgrUDP(object):
     #     },
     # }
     iface_config = {}
+    # The control addresses are typically addresses bound to the controlling
+    # UHD session. When the requested source address is below or equal to this
+    # number, we override requested SID source addresses based on other logic.
+    max_ctrl_addr = 1
 
     def __init__(self, log):
         assert len(self.iface_config)
@@ -170,6 +174,11 @@ class XportMgrUDP(object):
         """
         Return UDP xport info
         """
+        def fixup_sid(sid, iface_name):
+            " Modify the source SID (e.g. the UHD SID) "
+            if sid.src_addr <= self.max_ctrl_addr:
+                sid.src_addr = self.iface_config[iface_name]['ctrl_src_addr']
+            return sid
         assert xport_type in ('CTRL', 'ASYNC_MSG', 'TX_DATA', 'RX_DATA')
         allocation_getter = lambda iface: {
             'CTRL': 0,
@@ -182,11 +191,11 @@ class XportMgrUDP(object):
                 'type': 'UDP',
                 'ipv4': str(iface_info['ip_addr']),
                 'port': str(self.chdr_port),
-                'send_sid': str(sid),
+                'send_sid': str(fixup_sid(sid, iface_name)),
                 'allocation': str(allocation_getter(iface_name)),
                 'xport_type': xport_type,
             }
-            for _, iface_info in iteritems(self._chdr_ifaces)
+            for iface_name, iface_info in iteritems(self._chdr_ifaces)
         ]
         return xport_info