lock cache row to prevent concurrent updates

threefoldtech · Aug 31, 2024 · a2a8080 · a2a8080
1 parent d8b6bca
commit a2a8080
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/grid-proxy/internal/explorer/db/setup.sql b/grid-proxy/internal/explorer/db/setup.sql
@@ -408,6 +408,12 @@ $$
 BEGIN
     IF (TG_OP = 'UPDATE' AND NEW.state = 'Deleted') THEN
         BEGIN
+            -- lock cache row to prevent concurrent updates
+            PERFORM 1
+            FROM resources_cache 
+            WHERE node_id = NEW.node_id
+            FOR UPDATE;
+
             UPDATE resources_cache
             SET 
                 used_cru = resources_cache.used_cru - contract_resources.cru,
@@ -621,7 +627,7 @@ BEGIN
 
             total_ips = total_ips + (
                 CASE 
-                WHEN TG_OP = 'INSERT' 
+                WHEN TG_OP = 'INSERT'
                     THEN 1 
                 WHEn TG_OP = 'DELETE'
                     THEN -1