The C based gRPC (C++, Python, Ruby, Objective-C, PHP, C#) https://grpc.io/
 
 
 
 
 
 

103 lines
3.5 KiB

//
// Copyright 2020 gRPC authors.
//
// 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 "test/cpp/end2end/rls_server.h"
#include <gmock/gmock.h>
#include "src/proto/grpc/lookup/v1/rls.grpc.pb.h"
#include "src/proto/grpc/lookup/v1/rls.pb.h"
#include "test/core/util/test_config.h"
using ::grpc::lookup::v1::RouteLookupRequest;
using ::grpc::lookup::v1::RouteLookupResponse;
namespace grpc {
namespace testing {
::grpc::Status RlsServiceImpl::RouteLookup(grpc::ServerContext* context,
const RouteLookupRequest* request,
RouteLookupResponse* response) {
gpr_log(GPR_INFO, "RLS: Received request: %s",
request->DebugString().c_str());
if (context_proc_ != nullptr) {
context_proc_(context);
}
IncreaseRequestCount();
EXPECT_EQ(request->target_type(), "grpc");
// See if we have a configured response for this request.
ResponseData res;
{
grpc::internal::MutexLock lock(&mu_);
auto it = responses_.find(*request);
if (it == responses_.end()) {
gpr_log(GPR_INFO, "RLS: no matching request, returning INTERNAL");
unmatched_requests_.push_back(*request);
return Status(StatusCode::INTERNAL, "no response entry");
}
res = it->second;
}
// Configured response found, so use it.
if (res.response_delay > grpc_core::Duration::Zero()) {
gpr_sleep_until(
grpc_timeout_milliseconds_to_deadline(res.response_delay.millis()));
}
IncreaseResponseCount();
*response = res.response;
gpr_log(GPR_INFO, "RLS: returning configured response: %s",
response->DebugString().c_str());
return Status::OK;
}
void RlsServiceImpl::SetResponse(RouteLookupRequest request,
RouteLookupResponse response,
grpc_core::Duration response_delay) {
grpc::internal::MutexLock lock(&mu_);
responses_[std::move(request)] = {std::move(response), response_delay};
}
void RlsServiceImpl::RemoveResponse(const RouteLookupRequest& request) {
grpc::internal::MutexLock lock(&mu_);
responses_.erase(request);
}
std::vector<RouteLookupRequest> RlsServiceImpl::GetUnmatchedRequests() {
grpc::internal::MutexLock lock(&mu_);
return std::move(unmatched_requests_);
}
grpc::lookup::v1::RouteLookupRequest BuildRlsRequest(
std::map<std::string, std::string> key,
grpc::lookup::v1::RouteLookupRequest::Reason reason,
const char* stale_header_data) {
grpc::lookup::v1::RouteLookupRequest request;
request.set_target_type("grpc");
request.mutable_key_map()->insert(key.begin(), key.end());
request.set_reason(reason);
request.set_stale_header_data(stale_header_data);
return request;
}
grpc::lookup::v1::RouteLookupResponse BuildRlsResponse(
std::vector<std::string> targets, const char* header_data) {
grpc::lookup::v1::RouteLookupResponse response;
response.mutable_targets()->Add(targets.begin(), targets.end());
response.set_header_data(header_data);
return response;
}
} // namespace testing
} // namespace grpc