move back to stack in buffer manager

fix error from putting licenses in
thirkcircus · Sep 20, 2012 · 548b2e7 · 548b2e7
1 parent b3b7f3f
commit 548b2e7
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 10 deletions.
diff --git a/src/EventStore/EventStore.BufferManagement/BufferManager.cs b/src/EventStore/EventStore.BufferManagement/BufferManager.cs
@@ -32,9 +32,9 @@ public class BufferManager
         private readonly bool _allowedToCreateMemory;
 
 #if __MonoCS__
-        private readonly Common.ConcurrentCollections.ConcurrentQueue<ArraySegment<byte>> _buffers = new Common.ConcurrentCollections.ConcurrentQueue<ArraySegment<byte>>();
+        private readonly Common.ConcurrentCollections.ConcurrentStack<ArraySegment<byte>> _buffers = new Common.ConcurrentCollections.ConcurrentStack<ArraySegment<byte>>();
 #else
-        private readonly System.Collections.Concurrent.ConcurrentQueue<ArraySegment<byte>> _buffers = new System.Collections.Concurrent.ConcurrentQueue<ArraySegment<byte>>();
+        private readonly System.Collections.Concurrent.ConcurrentStack<ArraySegment<byte>> _buffers = new System.Collections.Concurrent.ConcurrentStack<ArraySegment<byte>>();
 #endif
 
         private readonly List<byte[]> _segments;
@@ -157,7 +157,7 @@ private void CreateNewSegment(bool forceCreation)
                 for (int i = 0; i < _segmentChunks; i++)
                 {
                     var chunk = new ArraySegment<byte>(bytes, i * _chunkSize, _chunkSize);
-                    _buffers.Enqueue(chunk);
+                    _buffers.Push(chunk);
                 }
 
                 Log.Info("Segments count: {0}, buffers count: {1}, should be when full: {2}",
@@ -181,7 +181,7 @@ public ArraySegment<byte> CheckOut()
             while (trial < TrialsCount)
             {
                 ArraySegment<byte> result;
-                if (_buffers.TryDequeue(out result))
+                if (_buffers.TryPop(out result))
                     return result;
                 CreateNewSegment(false);
                 trial++;
@@ -208,7 +208,7 @@ public IEnumerable<ArraySegment<byte>> CheckOut(int toGet)
                 ArraySegment<byte> piece;
                 while (totalReceived < toGet)
                 {
-                    if (!_buffers.TryDequeue(out piece))
+                    if (!_buffers.TryPop(out piece))
                         break;
                     result[totalReceived] = piece;
                     ++totalReceived;
@@ -232,7 +232,7 @@ public IEnumerable<ArraySegment<byte>> CheckOut(int toGet)
         public void CheckIn(ArraySegment<byte> buffer)
         {
            CheckBuffer(buffer);
-           _buffers.Enqueue(buffer);
+           _buffers.Push(buffer);
         }
 
         /// <summary>
@@ -251,7 +251,7 @@ public void CheckIn(IEnumerable<ArraySegment<byte>> buffersToReturn)
             foreach (var buf in buffersToReturn)
             {
                 CheckBuffer(buf);
-                _buffers.Enqueue(buf);
+                _buffers.Push(buf);
             }
         }
 

diff --git a/src/EventStore/EventStore.ClientAPI/Common/ConcurrentCollections/ConcurrentQueue.cs b/src/EventStore/EventStore.ClientAPI/Common/ConcurrentCollections/ConcurrentQueue.cs
@@ -24,7 +24,7 @@
 // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-//  using System;
+using System;
 using System.Collections;
 using System.Collections.Concurrent;
 using System.Collections.Generic;

diff --git a/src/EventStore/EventStore.Common/ConcurrentCollections/ConcurrentQueue.cs b/src/EventStore/EventStore.Common/ConcurrentCollections/ConcurrentQueue.cs
@@ -24,7 +24,8 @@
 // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-//  using System;
+
+using System;
 using System.Collections;
 using System.Collections.Concurrent;
 using System.Collections.Generic;

diff --git a/src/EventStore/EventStore.Common/ConcurrentCollections/ConcurrentStack.cs b/src/EventStore/EventStore.Common/ConcurrentCollections/ConcurrentStack.cs
@@ -24,7 +24,7 @@
 // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-//  using System;
+using System;
 using System.Collections;
 using System.Collections.Concurrent;
 using System.Collections.Generic;