Update benchmark apps to use optimized way to create ByteString (#1261)

grpc · Apr 7, 2021 · 2844af7 · 2844af7
1 parent 7f34166
commit 2844af7
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/perf/benchmarkapps/GrpcClient/Program.cs b/perf/benchmarkapps/GrpcClient/Program.cs
@@ -475,7 +475,7 @@ private static SimpleRequest CreateSimpleRequest()
         {
             return new SimpleRequest
             {
-                Payload = new Payload { Body = ByteString.CopyFrom(new byte[_options.RequestSize]) },
+                Payload = new Payload { Body = UnsafeByteOperations.UnsafeWrap(new byte[_options.RequestSize]) },
                 ResponseSize = _options.ResponseSize
             };
         }

diff --git a/perf/benchmarkapps/Shared/BenchmarkServiceImpl.cs b/perf/benchmarkapps/Shared/BenchmarkServiceImpl.cs
@@ -69,7 +69,7 @@ public override async Task StreamingBothWays(IAsyncStreamReader<SimpleRequest> r
     {
         var response = new SimpleResponse
         {
-            Payload = new Payload { Body = ByteString.CopyFrom(new byte[100]) }
+            Payload = new Payload { Body = UnsafeByteOperations.UnsafeWrap(new byte[100]) }
         };
         var clientComplete = false;
 
@@ -94,7 +94,7 @@ public override async Task StreamingBothWays(IAsyncStreamReader<SimpleRequest> r
 
     public static SimpleResponse CreateResponse(SimpleRequest request)
     {
-        var body = ByteString.CopyFrom(new byte[request.ResponseSize]);
+        var body = UnsafeByteOperations.UnsafeWrap(new byte[request.ResponseSize]);
 
         var payload = new Payload { Body = body };
         return new SimpleResponse { Payload = payload };

diff --git a/testassets/BenchmarkWorkerWebsite/BenchmarkServiceImpl.cs b/testassets/BenchmarkWorkerWebsite/BenchmarkServiceImpl.cs
@@ -47,7 +47,7 @@ await requestStream.ForEachAsync(async request =>
 
         private static Payload CreateZerosPayload(int size)
         {
-            return new Payload { Body = ByteString.CopyFrom(new byte[size]) };
+            return new Payload { Body = UnsafeByteOperations.UnsafeWrap(new byte[size]) };
         }
     }
 }