From e967037e1834a408254b5bf8c447637a90d12707 Mon Sep 17 00:00:00 2001
From: Suresh Kumar Anaparti <sureshkumar.anaparti@gmail.com>
Date: Tue, 19 May 2026 23:05:31 +0530
Subject: [PATCH 1/2] Ensure VM IP is removed from VR DHCP records in
 dnsmasq.leases after expunge VM

This also reverts the PR #10183 changes (for #10182), in turn resulting in #11877.
---
 systemvm/debian/opt/cloud/bin/cs/CsDhcp.py | 71 +++++++++++++++++++++-
 1 file changed, 70 insertions(+), 1 deletion(-)

diff --git a/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py b/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py
index 574a352b5f3f..26747840e039 100755
--- a/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py
+++ b/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py
@@ -20,6 +20,10 @@
 from netaddr import *
 from random import randint
 import json
+import fcntl
+import shutil
+import tempfile
+import signal
 from .CsGuestNetwork import CsGuestNetwork
 from cs.CsDatabag import CsDataBag
 from cs.CsFile import CsFile
@@ -139,7 +143,8 @@ def configure_server(self):
             # Listen Address
             if self.cl.is_redundant():
                 listen_address.append(gateway)
-            listen_address.append(ip)
+            else:
+                listen_address.append(ip)
             # Add localized "data-server" records in /etc/hosts for VPC routers
             if self.config.is_vpc() or self.config.is_router():
                 self.add_host(gateway, "%s data-server" % CsHelper.get_hostname())
@@ -165,15 +170,79 @@ def delete_leases(self):
                 mac = lease[1]
                 ip = lease[2]
                 if mac not in macs_dhcphosts:
+                    logging.info("Releasing DHCP lease for IP: %s, mac: %s", ip, mac)
                     cmd = "dhcp_release $(ip route get %s | grep eth | head -1 | awk '{print $3}') %s %s" % (ip, ip, mac)
                     logging.info(cmd)
                     CsHelper.execute(cmd)
+                    if self.ensure_lease_removed(ip):
+                        logging.info("Lease for %s still existed after dhcp_release; removed manually", ip)
                     removed = removed + 1
                     self.del_host(ip)
             logging.info("Deleted %s entries from dnsmasq.leases file" % str(removed))
         except Exception as e:
             logging.error("Caught error while trying to delete entries from dnsmasq.leases file: %s" % e)
 
+    def lease_exists(self, ip):
+        if not os.path.exists(LEASES):
+            return False
+
+        with open(LEASES, "r") as fp:
+            for line in fp:
+                fields = line.split()
+                if len(fields) >= 3 and fields[2] == ip:
+                    return True
+
+        return False
+
+    def remove_lease(self, ip):
+        if not os.path.exists(LEASES):
+            return False
+
+        removed = False
+
+        with open(LEASES, "r+") as fp:
+            fcntl.flock(fp.fileno(), fcntl.LOCK_EX)
+            lines = fp.readlines()
+
+            fd, tmp_path = tempfile.mkstemp(
+                prefix="dnsmasq.leases.",
+                dir=os.path.dirname(LEASES)
+            )
+
+            try:
+                with os.fdopen(fd, "w") as tmp:
+                    for line in lines:
+                        fields = line.split()
+
+                        if len(fields) >= 3 and fields[2] == ip:
+                            removed = True
+                            continue
+
+                        tmp.write(line)
+
+                if removed:
+                    shutil.move(tmp_path, LEASES)
+
+                    # reload dnsmasq
+                    try:
+                        with open("/var/run/dnsmasq.pid") as pidf:
+                            os.kill(int(pidf.read().strip()), signal.SIGHUP)
+                    except Exception:
+                        pass
+
+                    os.system("ip neigh flush all")
+                else:
+                    os.remove(tmp_path)
+            finally:
+                fcntl.flock(fp.fileno(), fcntl.LOCK_UN)
+
+        return removed
+
+    def ensure_lease_removed(self, ip):
+        if self.lease_exists(ip):
+            return self.remove_lease(ip)
+        return False
+
     def preseed(self):
         self.add_host("127.0.0.1", "localhost")
         self.add_host("127.0.1.1", "%s" % CsHelper.get_hostname())

From 7742a9ca60b5d21e520363311cf787ce3e7ac640 Mon Sep 17 00:00:00 2001
From: Suresh Kumar Anaparti <sureshkumar.anaparti@gmail.com>
Date: Thu, 21 May 2026 17:55:37 +0530
Subject: [PATCH 2/2] review changes

---
 systemvm/debian/opt/cloud/bin/cs/CsDhcp.py | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py b/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py
index 26747840e039..c067fd349e88 100755
--- a/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py
+++ b/systemvm/debian/opt/cloud/bin/cs/CsDhcp.py
@@ -23,7 +23,6 @@
 import fcntl
 import shutil
 import tempfile
-import signal
 from .CsGuestNetwork import CsGuestNetwork
 from cs.CsDatabag import CsDataBag
 from cs.CsFile import CsFile
@@ -225,12 +224,9 @@ def remove_lease(self, ip):
 
                     # reload dnsmasq
                     try:
-                        with open("/var/run/dnsmasq.pid") as pidf:
-                            os.kill(int(pidf.read().strip()), signal.SIGHUP)
+                        CsHelper.service("dnsmasq", "reload")
                     except Exception:
                         pass
-
-                    os.system("ip neigh flush all")
                 else:
                     os.remove(tmp_path)
             finally: