using BeetleX.Buffers;
using System;
using System.Collections.Concurrent;
using System.Text;

namespace PlatformBenchmarks
{
    public class HttpToken
    {
        private byte[] mLengthBuffer = new byte[10];

        public RawDb Db { get; set; }

        public HttpToken()
        {

        }

        public ConcurrentQueue<RequestData> Requests { get; set; } = new ConcurrentQueue<RequestData>();

        public RequestData CurrentRequest { get; set; }

        public byte[] GetLengthBuffer(string length)
        {
            Encoding.ASCII.GetBytes(length, 0, length.Length, mLengthBuffer, 0);
            for (int i = length.Length; i < 10; i++)
            {
                mLengthBuffer[i] = 32;
            }
            return mLengthBuffer;
        }

        public int ContentPostion { get; set; }

        public MemoryBlockCollection ContentLength { get; set; }

        public void FullLength(string length)
        {
            var item = GetLengthBuffer(length);
            ContentLength.Full(item);
        }

        private int mProcessStatus = 0;

        public void CompletedProcess()
        {
            System.Threading.Interlocked.Exchange(ref mProcessStatus, 0);
        }

        public bool EnterProcess()
        {
            return System.Threading.Interlocked.CompareExchange(ref mProcessStatus, 1, 0) == 0;
        }

    }
}