+/*
+ * Copyright (c) 2024 Samsung Electronics Co., Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
#include <iostream>
#include <memory>
#include <string>
using grpc::ServerBuilder;
using grpc::ServerContext;
using grpc::Status;
-using grpcbench::Greeter;
-using grpcbench::HelloReply;
-using grpcbench::HelloRequest;
-
-class GreeterServiceImpl final : public Greeter::Service {
- Status SayHello(ServerContext* context, const HelloRequest* request,
- HelloReply* reply) override {
- reply->set_message(0);
+using grpcbench::Benchmark;
+using grpcbench::TestReply;
+using grpcbench::TestRequest;
+
+class BenchmarkServiceImpl final : public Benchmark::Service {
+ Status Test(ServerContext* context, const TestRequest* request,
+ TestReply* reply) override {
+ reply->set_ret(0);
return Status::OK;
}
};
int main(int argc, char** argv) {
std::string server_address("unix:///tmp/test.socket");
- GreeterServiceImpl service;
-
+ BenchmarkServiceImpl service;
ServerBuilder builder;
+
builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
builder.RegisterService(&service);
std::unique_ptr<Server> server(builder.BuildAndStart());
server->Wait();
return 0;
-}
\ No newline at end of file
+}
std::string target_str("unix:///tmp/test.socket");
channel_ = grpc::CreateChannel(target_str,
grpc::InsecureChannelCredentials());
- stub_ = grpcbench::Greeter::NewStub(channel_);
+ stub_ = grpcbench::Benchmark::NewStub(channel_);
}
int GrpcProxy::Test(std::string data) const {
- grpcbench::HelloRequest request;
- request.set_name(data);
+ grpcbench::TestRequest request;
+ request.set_data(data);
grpc::ClientContext context;
- grpcbench::HelloReply response;
+ grpcbench::TestReply response;
- grpc::Status status = stub_->SayHello(&context, request, &response);
+ grpc::Status status = stub_->Test(&context, request, &response);
if (status.ok()) {
- int ret = response.message();
+ int ret = response.ret();
return ret;
}