aspnetcore/src/SignalR/perf/Microbenchmarks/HandshakeProtocolBenchmark.cs

// Copyright (c) .NET Foundation. All rights reserved.
// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.

using System;
using System.Buffers;
using System.Text;
using BenchmarkDotNet.Attributes;
using Microsoft.AspNetCore.Internal;
using Microsoft.AspNetCore.SignalR.Protocol;

namespace Microsoft.AspNetCore.SignalR.Microbenchmarks
{
    public class HandshakeProtocolBenchmark
    {
        ReadOnlySequence<byte> _requestMessage1;
        ReadOnlySequence<byte> _requestMessage2;
        ReadOnlySequence<byte> _requestMessage3;
        ReadOnlySequence<byte> _requestMessage4;
        ReadOnlySequence<byte> _requestMessage5;

        ReadOnlySequence<byte> _responseMessage1;
        ReadOnlySequence<byte> _responseMessage2;
        ReadOnlySequence<byte> _responseMessage3;
        ReadOnlySequence<byte> _responseMessage4;
        ReadOnlySequence<byte> _responseMessage5;
        ReadOnlySequence<byte> _responseMessage6;

        [GlobalSetup]
        public void GlobalSetup()
        {
            _requestMessage1 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"protocol\":\"dummy\",\"version\":1}\u001e"));
            _requestMessage2 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"protocol\":\"\",\"version\":10}\u001e"));
            _requestMessage3 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"protocol\":\"\",\"version\":10,\"unknown\":null}\u001e"));
            _requestMessage4 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("42"));
            _requestMessage5 = ReadOnlySequenceFactory.CreateSegments(Encoding.UTF8.GetBytes("{\"protocol\":\"dummy\",\"ver"), Encoding.UTF8.GetBytes("sion\":1}\u001e"));

            _responseMessage1 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"error\":\"dummy\"}\u001e"));
            _responseMessage2 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"error\":\"\"}\u001e"));
            _responseMessage3 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{}\u001e"));
            _responseMessage4 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"unknown\":null}\u001e"));
            _responseMessage5 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"error\":\"\",\"minorVersion\":34}\u001e"));
            _responseMessage6 = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"error\":\"flump flump flump\",\"minorVersion\":112}\u001e"));
        }

        [Benchmark]
        public void HandShakeWriteResponseEmpty_MemoryBufferWriter()
        {
            var writer = MemoryBufferWriter.Get();
            try
            {
                HandshakeProtocol.WriteResponseMessage(HandshakeResponseMessage.Empty, writer);
            }
            finally
            {
                MemoryBufferWriter.Return(writer);
            }
        }

        [Benchmark]
        public void HandShakeWriteResponse_MemoryBufferWriter()
        {
            ReadOnlyMemory<byte> result;
            var memoryBufferWriter = MemoryBufferWriter.Get();
            try
            {
                HandshakeProtocol.WriteResponseMessage(HandshakeResponseMessage.Empty, memoryBufferWriter);
                result = memoryBufferWriter.ToArray();
            }
            finally
            {
                MemoryBufferWriter.Return(memoryBufferWriter);
            }
        }

        [Benchmark]
        public void HandShakeWriteRequest_MemoryBufferWriter()
        {
            var memoryBufferWriter = MemoryBufferWriter.Get();
            try
            {
                HandshakeProtocol.WriteRequestMessage(new HandshakeRequestMessage("json", 1), memoryBufferWriter);
            }
            finally
            {
                MemoryBufferWriter.Return(memoryBufferWriter);
            }
        }

        [Benchmark]
        public void ParsingHandshakeRequestMessage_ValidMessage1() {
            var message = _requestMessage1;
            if (!HandshakeProtocol.TryParseRequestMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeRequestMessage_ValidMessage2()
        {
            var message = _requestMessage2;
            if (!HandshakeProtocol.TryParseRequestMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeRequestMessage_ValidMessage3()
        {
            var message = _requestMessage3;
            if (!HandshakeProtocol.TryParseRequestMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeRequestMessage_NotComplete1()
        {
            var message = _requestMessage4;
            if (!HandshakeProtocol.TryParseRequestMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeRequestMessage_ValidMessageSegments()
        {
            var message = _requestMessage5;
            if (!HandshakeProtocol.TryParseRequestMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeResponseMessage_ValidMessages1()
        {
            var message = _responseMessage1;
            if (!HandshakeProtocol.TryParseResponseMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeResponseMessage_ValidMessages2()
        {
            var message = _responseMessage2;
            if (!HandshakeProtocol.TryParseResponseMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeResponseMessage_ValidMessages3()
        {
            var message = _responseMessage3;
            if (!HandshakeProtocol.TryParseResponseMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeResponseMessage_ValidMessages4() 
        {
            var message = _responseMessage4;
            if (!HandshakeProtocol.TryParseResponseMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeResponseMessage_GivesMinorVersion1()
        {
            var message = _responseMessage5;
            if (!HandshakeProtocol.TryParseResponseMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }

        [Benchmark]
        public void ParsingHandshakeResponseMessage_GivesMinorVersion2()
        {
            var message = _responseMessage6;
            if (!HandshakeProtocol.TryParseResponseMessage(ref message, out var deserializedMessage))
            {
                throw new Exception();
            }
        }
    }
}