Ensure min publish requests is always greater than 1

Azure · Apr 16, 2024 · ff60685 · ff60685
1 parent 8a15273
commit ff60685
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/src/Azure.IIoT.OpcUa.Publisher/src/Stack/Services/OpcUaClient.cs b/src/Azure.IIoT.OpcUa.Publisher/src/Stack/Services/OpcUaClient.cs
@@ -1056,10 +1056,24 @@ private void EnsureMinimumNumberOfPublishRequestsQueued()
             {
                 desiredRequests = _maxPublishRequests.Value;
             }
+            if (desiredRequests <= 0)
+            {
+                desiredRequests = 1;
+            }
             session.MinPublishRequestCount = desiredRequests;
 
+            var additionalRequests = desiredRequests - GoodPublishRequestCount;
+            if (additionalRequests <= 0)
+            {
+                return;
+            }
+
+            _logger.LogDebug(
+                "Ensuring publish request count {Count} is {Desired} requests.",
+                GoodPublishRequestCount, desiredRequests);
+
             // Queue requests
-            for (var i = GoodPublishRequestCount; i < desiredRequests; i++)
+            for (var i = 0; i < additionalRequests; i++)
             {
                 session.BeginPublish(session.OperationTimeout);
             }