TechEmpower.FrameworkBenchmarks/frameworks/CSharp/beetlex/PlatformBenchmarks/HttpToken.cs

//using BeetleX;
//using BeetleX.Buffers;
//using BeetleX.Dispatchs;
//using System;
//using System.Collections.Concurrent;
//using System.Text;
//using System.Text.Json;

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

//        public RawDb Db { get; set; }

//        public HttpToken()
//        {

//        }

//        public SingleThreadDispatcher<HttpToken> ThreadDispatcher { get; set; }

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

//        public Utf8JsonWriter Utf8JsonWriter { get; set; }

//        public ISession Session { get; set; }

//        public RequestData CurrentRequest { get; set; }

//        private HtmlBufferWriter mHtmlBufferWriter = null;

//        public HtmlBufferWriter GetHtmlBufferWriter()
//        {
//            if (mHtmlBufferWriter == null)
//                mHtmlBufferWriter = new HtmlBufferWriter(2048);
//            return mHtmlBufferWriter;
//        }

//        public byte[] GetLengthBuffer(string length)
//        {
//            Encoding.ASCII.GetBytes(length, 0, length.Length, mLengthBuffer, 0);
//            for (int i = length.Length; i < mLengthBuffer.Length; i++)
//            {
//                mLengthBuffer[i] = 32;
//            }
//            mLengthBuffer[6] = (byte)'\r';
//            mLengthBuffer[7] = (byte)'\n';
//            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;
//        }

//    }
//}