adapted most languages to the new protobuf file

Author: Trisfald

cpp_asio_grpc_bench/main.cpp

@@ -49,7 +49,7 @@ void spawn_accept_loop(
         return;
       }
       helloworld::HelloReply response;
-      response.set_message(context->request.name());
+      *response.mutable_response() = context->request.request();
       auto &writer = context->writer;
       agrpc::finish(writer, response, grpc::Status::OK,
                     boost::asio::bind_executor(
@@ -92,4 +92,4 @@ int main() {
   }
 
   server->Shutdown();
-}
+}

cpp_grpc_mt_bench/main.cpp

@@ -109,7 +109,7 @@ class ServerImpl final {
         new CallData(service_, cq_);
 
         // The actual processing.
-        reply_.set_message(request_.name());
+        *reply_.mutable_response() = request_.request();
 
         // And we are done! Let the gRPC runtime know we've finished, using the
         // memory address of this instance as the uniquely identifying tag for

cpp_grpc_st_bench/main.cpp

@@ -101,7 +101,7 @@ class ServerImpl final {
         new CallData(service_, cq_);
 
         // The actual processing.
-        reply_.set_message(request_.name());
+        *reply_.mutable_response() = request_.request();
 
         // And we are done! Let the gRPC runtime know we've finished, using the
         // memory address of this instance as the uniquely identifying tag for

crystal_grpc_bench/src/server.cr

@@ -6,7 +6,7 @@ require "./protobufs/helloworld.pb"
 
 class HelloWorldHandler < Helloworld::Greeter
   def say_hello(request : Helloworld::HelloRequest) : Helloworld::HelloReply
-    Helloworld::HelloReply.new(message: request.name)
+    Helloworld::HelloReply.new(response: request.request)
   end
 end
 

csharp_grpc_bench/GreeterServer/Program.cs

@@ -24,7 +24,7 @@ class GreeterImpl : Greeter.GreeterBase
         // Server side handler of the SayHello RPC
         public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
         {
-            return Task.FromResult(new HelloReply { Message = request.Name });
+            return Task.FromResult(new HelloReply { Response = request.Request });
         }
     }
 

dotnet_grpc_bench/GreeterServer/Services/GreeterService.cs

@@ -23,7 +23,7 @@ public class GreeterService : Greeter.GreeterBase
         // Server side handler of the SayHello RPC
         public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
         {
-            return Task.FromResult(new HelloReply { Message = request.Name });
+            return Task.FromResult(new HelloReply { Response = request.Request });
         }
     }
 }

elixir_grpc_bench/lib/server.ex

@@ -4,6 +4,6 @@ defmodule Helloworld.Greeter.Server do
   @spec say_hello(Helloworld.HelloRequest.t(), GRPC.Server.Stream.t()) ::
           Helloworld.HelloReply.t()
   def say_hello(request, _stream) do
-    Helloworld.HelloReply.new(message: "#{request.name}")
+    Helloworld.HelloReply.new(response: request.request)
   end
 end

erlang_grpcbox_bench/src/egb_handler.erl

@@ -9,6 +9,6 @@
 -spec say_hello(ctx:ctx(), helloworld_pb:hello_request()) ->
           {ok, helloworld_pb:hello_reply(), ctx:ctx()} | grpcbox_stream:grpc_error_response().
 
-say_hello(Ctx, #{name := Name}) ->
-    Rep = #{message => Name},
+say_hello(Ctx, #{request := Request}) ->
+    Rep = #{response => Request},
     {ok, Rep, Ctx}.

go_grpc_bench/example/main.go

@@ -39,7 +39,7 @@ type server struct {
 
 // SayHello implements helloworld.GreeterServer
 func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
-	return &pb.HelloReply{Message: in.GetName()}, nil
+	return &pb.HelloReply{Response: in.GetRequest()}, nil
 }
 
 func main() {

haskell_mu_bench/.gitignore renamed to haskell_mu_onhold/.gitignore

@@ -34,7 +34,7 @@ var hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld;
  * Implements the SayHello RPC method.
  */
 function sayHello(call, callback) {
-  callback(null, {message: call.request.name});
+  callback(null, {response: call.request.request});
 }
 
 /**

haskell_mu_bench/Dockerfile renamed to haskell_mu_onhold/Dockerfile

@@ -13,6 +13,6 @@ class HelloworldService implements GreeterInterface
     public function SayHello(ContextInterface $ctx, HelloRequest $in): HelloReply
     {
         $out = new HelloReply();
-        return $out->setMessage($in->getName());
+        return $out->setResponse($in->getRequest());
     }
 }

haskell_mu_bench/app/Main.hs renamed to haskell_mu_onhold/app/Main.hs

@@ -1,4 +1,4 @@
-FROM phpswoole/swoole:php8.1-alpine
+FROM phpswoole/swoole:php8.0-alpine
 
 WORKDIR /app
 

haskell_mu_bench/haskell-mu-bench.cabal renamed to haskell_mu_onhold/haskell-mu-bench.cabal

@@ -8,7 +8,7 @@
 
 $http = new Swoole\Http\Server('0.0.0.0', 50051, SWOOLE_BASE);
 $http->set([
-    'worker_num' => swoole_cpu_num(),
+    'trace_flags' => 0,
     'log_file' => '/dev/null',
     'log_level' => 5,
     'open_http2_protocol' => true
@@ -18,10 +18,9 @@
 
     try {
         $request_message = new HelloRequest;
-        $request_message->mergeFromString(Parser::unpack($request->rawContent()));
 
         $response_message = new HelloReply();
-        $response_message->setMessage($request_message->getName());
+        $response_message->setResponse($request_message->getRequest());
 
         $response->header('content-type', 'application/grpc');
         $response->header('trailer', 'grpc-status, grpc-message');
@@ -36,4 +35,4 @@
     }
 });
 
-$http->start();
+$http->start();

haskell_mu_bench/helloworld.proto renamed to haskell_mu_onhold/helloworld.proto

@@ -25,7 +25,7 @@ class Greeter(helloworld_pb2_grpc.GreeterServicer):
     async def SayHello(
             self, request: helloworld_pb2.HelloRequest,
             context: grpc.aio.ServicerContext) -> helloworld_pb2.HelloReply:
-        return helloworld_pb2.HelloReply(message=request.name)
+        return helloworld_pb2.HelloReply(response=request.request)
 
 
 async def serve() -> None:

haskell_mu_bench/run.sh renamed to haskell_mu_onhold/run.sh

@@ -24,7 +24,7 @@
 class Greeter(helloworld_pb2_grpc.GreeterServicer):
 
     def SayHello(self, request, context):
-        return helloworld_pb2.HelloReply(message=request.name)
+        return helloworld_pb2.HelloReply(response=request.request)
 
 
 def serve():

node_grpcjs_st_bench/greeter_server.js

@@ -29,7 +29,7 @@
 class GreeterServer < Helloworld::Greeter::Service
   # say_hello implements the SayHello rpc method.
   def say_hello(hello_req, _unused_call)
-    Helloworld::HelloReply.new(message: hello_req.name)
+    Helloworld::HelloReply.new(response: hello_req.request)
   end
 end
 
@@ -40,7 +40,7 @@ def main
   s.add_http2_port('0.0.0.0:50051', :this_port_is_insecure)
   puts 'Listening on 50051'
   s.handle(GreeterServer)
-  # Runs the server with SIGHUP, SIGINT and SIGQUIT signal handlers to 
+  # Runs the server with SIGHUP, SIGINT and SIGQUIT signal handlers to
   #   gracefully shutdown.
   # User could also choose to run server via call to run_till_terminated
   s.run_till_terminated_or_interrupted([1, 'int', 'SIGQUIT'])