pim: igmp: igmp-proxy: T2744: Add check to prevent pimd and igmp-proxy conflict

3 files changed, 64 insertions, 12 deletions

diff --git a/src/conf_mode/igmp_proxy.py b/src/conf_mode/igmp_proxy.py
index 754f46566..d7d8ffd5e 100755
--- a/src/conf_mode/igmp_proxy.py
+++ b/src/conf_mode/igmp_proxy.py
@@ -33,6 +33,8 @@ config_file = r'/etc/igmpproxy.conf'
 default_config_data = {
     'disable': False,
     'disable_quickleave': False,
+    'igmp_conf': False,
+    'pim_conf': False,
     'interfaces': [],
 }
 
@@ -42,6 +44,13 @@ def get_config(config=None):
         conf = config
     else:
         conf = Config()
+
+    if conf.exists('protocols igmp'):
+        igmp_proxy['igmp_conf'] = True
+
+    if conf.exists('protocols pim'):
+        igmp_proxy['pim_conf'] = True
+
     base = ['protocols', 'igmp-proxy']
     if not conf.exists(base):
         return None
@@ -125,11 +134,14 @@ def generate(igmp_proxy):
 
 def apply(igmp_proxy):
     if igmp_proxy is None or igmp_proxy['disable']:
-         # IGMP Proxy support is removed in the commit
-         call('systemctl stop igmpproxy.service')
-         if os.path.exists(config_file):
-             os.unlink(config_file)
+        # IGMP Proxy support is removed in the commit
+        call('systemctl stop igmpproxy.service')
+        if os.path.exists(config_file):
+            os.unlink(config_file)
     else:
+        if igmp_proxy['igmp_conf'] or igmp_proxy['pim_conf']:
+            raise ConfigError('IGMP proxy and PIM cannot be both configured at the same time')
+
         call('systemctl restart igmpproxy.service')
 
     return None
diff --git a/src/conf_mode/protocols_igmp.py b/src/conf_mode/protocols_igmp.py
index 6f4fc784d..8606e7364 100755
--- a/src/conf_mode/protocols_igmp.py
+++ b/src/conf_mode/protocols_igmp.py
@@ -21,8 +21,9 @@ from sys import exit
 
 from vyos import ConfigError
 from vyos.config import Config
-from vyos.util import call
+from vyos.util import call, process_named_running
 from vyos.template import render
+from signal import SIGTERM
 
 from vyos import airbag
 airbag.enable()
@@ -36,12 +37,20 @@ def get_config(config=None):
         conf = Config()
     igmp_conf = {
         'igmp_conf' : False,
+        'pim_conf'  : False,
+        'igmp_proxy_conf' : False,
         'old_ifaces'    : {},
         'ifaces'    : {}
     }
     if not (conf.exists('protocols igmp') or conf.exists_effective('protocols igmp')):
         return None
 
+    if conf.exists('protocols igmp-proxy'):
+        igmp_conf['igmp_proxy_conf'] = True
+
+    if conf.exists('protocols pim'):
+        igmp_conf['pim_conf'] = True
+
     if conf.exists('protocols igmp'):
         igmp_conf['igmp_conf'] = True
 
@@ -79,6 +88,10 @@ def verify(igmp):
         return None
 
     if igmp['igmp_conf']:
+        # Check conflict with IGMP-Proxy
+        if igmp['igmp_proxy_conf']:
+            raise ConfigError(f"IGMP proxy and PIM cannot be both configured at the same time")
+
         # Check interfaces
         if not igmp['ifaces']:
             raise ConfigError(f"IGMP require defined interfaces!")
@@ -99,9 +112,16 @@ def apply(igmp):
     if igmp is None:
         return None
 
-    if os.path.exists(config_file):
-        call(f'vtysh -d pimd -f {config_file}')
-        os.remove(config_file)
+    pim_pid = process_named_running('pimd')
+    if igmp['igmp_conf'] or igmp['pim_conf']:
+        if not pim_pid:
+            call(f'pimd -d -F traditional --daemon -A 127.0.0.1')
+
+        if os.path.exists(config_file):
+            call(f'vtysh -d pimd -f {config_file}')
+            os.remove(config_file)
+    elif pim_pid:
+        os.kill(int(pim_pid), SIGTERM)
 
     return None
 
diff --git a/src/conf_mode/protocols_pim.py b/src/conf_mode/protocols_pim.py
index 6d333e19a..8a9f034d5 100755
--- a/src/conf_mode/protocols_pim.py
+++ b/src/conf_mode/protocols_pim.py
@@ -21,8 +21,9 @@ from sys import exit
 
 from vyos.config import Config
 from vyos import ConfigError
-from vyos.util import call
+from vyos.util import call, process_named_running
 from vyos.template import render
+from signal import SIGTERM
 
 from vyos import airbag
 airbag.enable()
@@ -36,6 +37,8 @@ def get_config(config=None):
         conf = Config()
     pim_conf = {
         'pim_conf' : False,
+        'igmp_conf' : False,
+        'igmp_proxy_conf' : False,
         'old_pim' : {
             'ifaces' : {},
             'rp'     : {}
@@ -48,6 +51,12 @@ def get_config(config=None):
     if not (conf.exists('protocols pim') or conf.exists_effective('protocols pim')):
         return None
 
+    if conf.exists('protocols igmp-proxy'):
+        pim_conf['igmp_proxy_conf'] = True
+
+    if conf.exists('protocols igmp'):
+        pim_conf['igmp_conf'] = True
+
     if conf.exists('protocols pim'):
         pim_conf['pim_conf'] = True
 
@@ -92,6 +101,10 @@ def verify(pim):
         return None
 
     if pim['pim_conf']:
+        # Check conflict with IGMP-Proxy
+        if pim['igmp_proxy_conf']:
+            raise ConfigError(f"IGMP proxy and PIM cannot be both configured at the same time")
+
         # Check interfaces
         if not pim['pim']['ifaces']:
             raise ConfigError(f"PIM require defined interfaces!")
@@ -126,9 +139,16 @@ def apply(pim):
     if pim is None:
         return None
 
-    if os.path.exists(config_file):
-        call("vtysh -d pimd -f " + config_file)
-        os.remove(config_file)
+    pim_pid = process_named_running('pimd')
+    if pim['igmp_conf'] or pim['pim_conf']:
+        if not pim_pid:
+            call(f'pimd -d -F traditional --daemon -A 127.0.0.1')
+
+        if os.path.exists(config_file):
+            call("vtysh -d pimd -f " + config_file)
+            os.remove(config_file)
+    elif pim_pid:
+        os.kill(int(pim_pid), SIGTERM)
 
     return None