Iptables wait option (#289)

Azure · Jul 7, 2023 · f90eb41 · f90eb41
1 parent f55a535
commit f90eb41
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/common/IP/IPManager.cs b/src/common/IP/IPManager.cs
@@ -205,8 +205,9 @@ private void AddRoutingRules(IEnumerable<EndpointInfo> endpoints, CancellationTo
                     {
                         foreach (var portPair in endpoint.Ports)
                         {
-                            rules.Add($"--table nat --append PREROUTING -p tcp --dst {endpoint.LocalIP} --dport {portPair.RemotePort} --jump DNAT --to-destination {endpoint.LocalIP}:{portPair.LocalPort}");
-                            rules.Add($"--table nat --append OUTPUT -p tcp --dst {endpoint.LocalIP} --dport {portPair.RemotePort} --jump DNAT --to-destination {endpoint.LocalIP}:{portPair.LocalPort}");
+                            // --wait        -w [seconds]    maximum wait to acquire xtables lock before give up
+                            rules.Add($"--table nat --append PREROUTING -p tcp --dst {endpoint.LocalIP} --dport {portPair.RemotePort} --jump DNAT --to-destination {endpoint.LocalIP}:{portPair.LocalPort} --wait 30");
+                            rules.Add($"--table nat --append OUTPUT -p tcp --dst {endpoint.LocalIP} --dport {portPair.RemotePort} --jump DNAT --to-destination {endpoint.LocalIP}:{portPair.LocalPort} --wait 30");
                         }
                     }
 
@@ -297,7 +298,7 @@ private void RemoveRoutingRules(CancellationToken cancellationToken, IPAddress[]
                 command: args,
                 logCallback: (line) => _log.Info(line),
                 envVariables: null,
-                timeout: TimeSpan.FromSeconds(10),
+                timeout: TimeSpan.FromSeconds(60), // increasing the timeout to match with iptables --wait time.
                 cancellationToken: cancellationToken,
                 out string output);