Browse Source

beetlex core cases change (#4905)

* docker add COMPlus_ReadyToRun variable
update beetlex

* update beetlex, enabled thread queue

* beetlex framework add db and queries cases

* add db code

* change result json data

* update query url

* beetlex framework add fortunes cases

* change Content-Type

* add beetlex core cases

* fix queries cases

* update config

* change try readline
Henry 6 years ago
parent
commit
b65d792023
1 changed files with 4 additions and 2 deletions
  1. 4 2
      frameworks/CSharp/beetlex/PlatformBenchmarks/HttpHandler.cs

+ 4 - 2
frameworks/CSharp/beetlex/PlatformBenchmarks/HttpHandler.cs

@@ -81,11 +81,13 @@ namespace PlatformBenchmarks
             base.SessionReceive(server, e);
             base.SessionReceive(server, e);
             PipeStream pipeStream = e.Session.Stream.ToPipeStream();
             PipeStream pipeStream = e.Session.Stream.ToPipeStream();
             HttpToken token = (HttpToken)e.Session.Tag;
             HttpToken token = (HttpToken)e.Session.Tag;
-            int len = pipeStream.IndexOf(_line.Data, token.Buffer);
-            if (len <= 0)
+            var result = pipeStream.IndexOf(_line.Data);
+            if(result.End ==null)
             {
             {
                 return;
                 return;
             }
             }
+            int len = result.Length;
+            pipeStream.Read(token.Buffer, 0, len);
             ReadOnlySpan<byte> line = new Span<byte>(token.Buffer, 0, len);
             ReadOnlySpan<byte> line = new Span<byte>(token.Buffer, 0, len);
             ReadOnlySpan<byte> http = line;
             ReadOnlySpan<byte> http = line;
             ReadOnlySpan<byte> method = line;
             ReadOnlySpan<byte> method = line;