feat: test ReducingCapacity head before tail Own

Author: Vyacheslav

Src/StackMemoryCollections/GeneratePrimitiveQueue.cs

@@ -361,19 +361,22 @@ public void ReducingCapacity(in nuint reducingCount)
                         _head -= reducingCount;{incrementVersion}
                     }}
                     else
-                    if ((_head < _tail && Capacity - _tail + 1 < reducingCount) ||
-                       (_head == _tail && Capacity - _tail + 1 < reducingCount)
-                       )
+                    if (_head <= _tail)
                     {{
-                        var freeCountToEnd = Capacity - (_head + 1);
-                        if(freeCountToEnd != 0 && freeCountToEnd <= reducingCount)
+                        if(Size == 1)
                         {{
-                            //do nothing
+                            *(_start) = *(_start + _tail);
+                            _tail = 0;
+                            _head = 0;
                         }}
                         else
                         {{
-                            _stackMemoryS->ShiftLeft((byte*)(_start + _head), (byte*)(_start + (_tail + 1)), (long)((Capacity - freeCountToEnd - ((_tail + 1) - _head)) * {sizeOf}));
-                            _tail = 0;{incrementVersion}
+                            var freeCountToEnd = Capacity - (_tail + 1);
+                            if(freeCountToEnd == 0 || freeCountToEnd < reducingCount)
+                            {{
+                                _stackMemoryS->ShiftLeft((byte*)(_start + _head), (byte*)(_start + (_tail + 1)), (long)((Capacity - freeCountToEnd - ((_tail + 1) - _head)) * {sizeOf}));
+                                _head = 0;{incrementVersion}
+                            }}
                         }}
                     }}
                     
@@ -398,19 +401,22 @@ public void ReducingCapacity(in nuint reducingCount)
                         _head -= reducingCount;{incrementVersion}
                     }}
                     else
-                    if ((_head < _tail && Capacity - _tail + 1 < reducingCount) ||
-                       (_head == _tail && Capacity - _tail + 1 < reducingCount)
-                       )
+                    if (_head <= _tail)
                     {{
-                        var freeCountToEnd = Capacity - (_head + 1);
-                        if(freeCountToEnd != 0 && freeCountToEnd <= reducingCount)
+                        if(Size == 1)
                         {{
-                            //do nothing
+                            *(_start) = *(_start + _tail);
+                            _tail = 0;
+                            _head = 0;
                         }}
                         else
                         {{
-                            _stackMemoryC.ShiftLeft((byte*)(_start + _head), (byte*)(_start + (_tail + 1)), (long)((Capacity - freeCountToEnd - ((_tail + 1) - _head)) * {sizeOf}));
-                            _tail = 0;{incrementVersion}
+                            var freeCountToEnd = Capacity - (_tail + 1);
+                            if(freeCountToEnd == 0 || freeCountToEnd < reducingCount)
+                            {{
+                                _stackMemoryC.ShiftLeft((byte*)(_start + _head), (byte*)(_start + (_tail + 1)), (long)((Capacity - freeCountToEnd - ((_tail + 1) - _head)) * {sizeOf}));
+                                _head = 0;{incrementVersion}
+                            }}
                         }}
                     }}                    
 

Src/TestGenerator/GenerateQueuePrimitiveTest.cs

@@ -291,6 +291,7 @@ in Func<T, string> toStr
             QueuePrimitiveReducingCapacity(in values, in builder, in queueNamespace);
             QueuePrimitiveReducingCapacityHeadAfterTail(in values, in builder, in queueNamespace, in toStr);
             QueuePrimitiveReducingCapacityHeadAfterTailOwn(in values, in builder, in queueNamespace, in toStr);
+            QueuePrimitiveReducingCapacityHeadBeforeTail(in values, in builder, in queueNamespace, in toStr);
 
             QueuePrimitiveSize(in values, in builder, in queueNamespace, in toStr);
             QueuePrimitiveCapacity(in values, in builder, in queueNamespace, in toStr);
@@ -1089,7 +1090,7 @@ public void ExpandCapacityHeadAfterTailTest()
             builder.Append($@"
                     Assert.That(queue.Front(), Is.EqualTo({toStr(values[values.Count - 1])}));
                     queue.Pop();
-
+                    Assert.That(queue.Size, Is.EqualTo((nuint)0));
                 }}
             }}
         }}
@@ -1162,6 +1163,7 @@ public void ExpandCapacityHeadAfterTailOwnTest()
 ");
             }
                 builder.Append($@"
+                Assert.That(queue.Size, Is.EqualTo((nuint)0));
             }}
         }}
 ");
@@ -1209,7 +1211,7 @@ public void ExpandCapacityHeadBeforeTailTest()
             builder.Append($@"
                     Assert.That(queue.Front(), Is.EqualTo({toStr(values[values.Count - 1])}));
                     queue.Pop();
-
+                    Assert.That(queue.Size, Is.EqualTo((nuint)0));
                 }}
             }}
         }}
@@ -1264,6 +1266,7 @@ public void ExpandCapacityHeadBeforeTailOwnTest()
 ");
             }
             builder.Append($@"
+                Assert.That(queue.Size, Is.EqualTo((nuint)0));
             }}
         }}
 ");
@@ -1364,6 +1367,7 @@ public void ReducingCapacityHeadAfterTailTest()
             builder.Append($@"
                     Assert.That(queue.Front(), Is.EqualTo({toStr(values[values.Count - 1])}));
                     queue.Pop();
+                    Assert.That(queue.Size, Is.EqualTo((nuint)0));
                 }}
             }}
         }}
@@ -1427,6 +1431,55 @@ public void ReducingCapacityHeadAfterTailOwnTest()
 ");
             }
             builder.Append($@"
+                Assert.That(queue.Size, Is.EqualTo((nuint)0));
+            }}
+        }}
+");
+        }
+
+        private void QueuePrimitiveReducingCapacityHeadBeforeTail<T>(
+            in List<T> values,
+            in StringBuilder builder,
+            in string queueNamespace,
+            in Func<T, string> toStr
+            ) where T : unmanaged
+        {
+            if (values.Count < 5)
+            {
+                throw new ArgumentException($"{nameof(values)} Must have minimum 5 values to generate tests");
+            }
+
+            builder.Append($@"
+        [Test]
+        public void ReducingCapacityHeadBeforeTailTest()
+        {{
+            unsafe
+            {{
+                using (var memory = new StackMemoryCollections.Struct.StackMemory(sizeof({typeof(T).Name}) * {values.Count}))
+                {{
+                    var queue = new StackMemoryCollections.{queueNamespace}.QueueOf{typeof(T).Name}({values.Count}, &memory);
+");
+            for (int i = 0; i < values.Count - 1; i++)
+            {
+                builder.Append($@"
+                    queue.Push({toStr(values[i])});
+");
+            }
+
+            builder.Append($@"
+                    queue.Pop();
+                    queue.ReducingCapacity(2);
+");
+            for (int i = 1; i < values.Count - 1; i++)
+            {
+                builder.Append($@"
+                    Assert.That(queue.Front(), Is.EqualTo({toStr(values[i])}));
+                    queue.Pop();
+");
+            }
+            builder.Append($@"
+                    Assert.That(queue.Size, Is.EqualTo((nuint)0));
+                }}
             }}
         }}
 ");