1b33c96954667ba382fa595baf7b31290bfdd517vboxsync//
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync// � Copyright Henrik Ravn 2004
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync//
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync// Use, modification and distribution are subject to the Boost Software License, Version 1.0.
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync// (See accompanying file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync//
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsyncusing System;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsyncusing System.Diagnostics;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsyncnamespace DotZLib
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync{
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync /// <summary>
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync /// This class implements a circular buffer
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync /// </summary>
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync internal class CircularBuffer
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync {
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync #region Private data
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync private int _capacity;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync private int _head;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync private int _tail;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync private int _size;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync private byte[] _buffer;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync #endregion
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync public CircularBuffer(int capacity)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync {
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync Debug.Assert( capacity > 0 );
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _buffer = new byte[capacity];
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _capacity = capacity;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _head = 0;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _tail = 0;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _size = 0;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync public int Size { get { return _size; } }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync public int Put(byte[] source, int offset, int count)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync {
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync Debug.Assert( count > 0 );
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync int trueCount = Math.Min(count, _capacity - Size);
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync for (int i = 0; i < trueCount; ++i)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _buffer[(_tail+i) % _capacity] = source[offset+i];
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _tail += trueCount;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _tail %= _capacity;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _size += trueCount;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync return trueCount;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync public bool Put(byte b)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync {
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync if (Size == _capacity) // no room
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync return false;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _buffer[_tail++] = b;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _tail %= _capacity;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync ++_size;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync return true;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync public int Get(byte[] destination, int offset, int count)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync {
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync int trueCount = Math.Min(count,Size);
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync for (int i = 0; i < trueCount; ++i)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync destination[offset + i] = _buffer[(_head+i) % _capacity];
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _head += trueCount;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _head %= _capacity;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync _size -= trueCount;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync return trueCount;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync public int Get()
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync {
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync if (Size == 0)
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync return -1;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync int result = (int)_buffer[_head++ % _capacity];
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync --_size;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync return result;
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync }
1b33c96954667ba382fa595baf7b31290bfdd517vboxsync}